debugigng the simulation loop

assets/config/tikslop.yaml

@@ -1,6 +1,6 @@
 ui:
   product_name: "#tikslop"
-  showChatInVideoView: false
+  showChatInVideoView: true
 
 render_queue:
   # how many clips should be stored in advance
@@ -21,9 +21,12 @@ advertising:
       link: https://huggingface.co/docs/smolagents/index
 
 simulation:
+  # whether to enable simulation loop to evolve descriptions over time
+  enable_sim_loop: true
+  
   # how often the description should evolve (in seconds)
   # setting to 0 disables description evolution
-  sim_loop_frequency_in_sec: 10
+  sim_loop_frequency_in_sec: 8
 
 # it's OK to use high values here,
 # because some of those values are limited by the backend config,

build/web/assets/assets/config/tikslop.yaml

@@ -1,6 +1,6 @@
 ui:
   product_name: "#tikslop"
-  showChatInVideoView: false
+  showChatInVideoView: true
 
 render_queue:
   # how many clips should be stored in advance
@@ -21,9 +21,12 @@ advertising:
       link: https://huggingface.co/docs/smolagents/index
 
 simulation:
+  # whether to enable simulation loop to evolve descriptions over time
+  enable_sim_loop: true
+  
   # how often the description should evolve (in seconds)
   # setting to 0 disables description evolution
-  sim_loop_frequency_in_sec: 10
+  sim_loop_frequency_in_sec: 8
 
 # it's OK to use high values here,
 # because some of those values are limited by the backend config,

build/web/flutter_bootstrap.js

@@ -39,6 +39,6 @@ _flutter.buildConfig = {"engineRevision":"382be0028d370607f76215a9be322e5514b263
 
 _flutter.loader.load({
   serviceWorkerSettings: {
-    serviceWorkerVersion: "754772620"
+    serviceWorkerVersion: "2278791886"
   }
 });

build/web/flutter_service_worker.js

@@ -3,12 +3,12 @@ const MANIFEST = 'flutter-app-manifest';
 const TEMP = 'flutter-temp-cache';
 const CACHE_NAME = 'flutter-app-cache';
 
-const RESOURCES = {"flutter_bootstrap.js": "04ff3a8576d911a2f01466a30986bd48",
+const RESOURCES = {"flutter_bootstrap.js": "c711e457cccbe0bcbccc12f740ac44af",
 "version.json": "68350cac7987de2728345c72918dd067",
 "tikslop.png": "570e1db759046e2d224fef729983634e",
 "index.html": "3a7029b3672560e7938aab6fa4d30a46",
 "/": "3a7029b3672560e7938aab6fa4d30a46",
-"main.dart.js": "44d4476ea7e6f9159320973c3d29cbc3",
+"main.dart.js": "494e091a049a511f985f81a61cedf669",
 "tikslop.svg": "26140ba0d153b213b122bc6ebcc17f6c",
 "flutter.js": "83d881c1dbb6d6bcd6b42e274605b69c",
 "favicon.png": "c8a183c516004e648a7bac7497c89b97",
@@ -31,7 +31,7 @@ const RESOURCES = {"flutter_bootstrap.js": "04ff3a8576d911a2f01466a30986bd48",
 "assets/assets/config/README.md": "07a87720dd00dd1ca98c9d6884440e31",
 "assets/assets/config/custom.yaml": "52bd30aa4d8b980626a5eb02d0871c01",
 "assets/assets/config/default.yaml": "9ca1d05d06721c2b6f6382a1ba40af48",
-"assets/assets/config/tikslop.yaml": "1165218a000aa0c9841e88b072e40756",
+"assets/assets/config/tikslop.yaml": "45d535b24df6e81ce983bf4f550c9be7",
 "canvaskit/skwasm.js": "ea559890a088fe28b4ddf70e17e60052",
 "canvaskit/skwasm.js.symbols": "9fe690d47b904d72c7d020bd303adf16",
 "canvaskit/canvaskit.js.symbols": "27361387bc24144b46a745f1afe92b50",

build/web/index.html

@@ -156,7 +156,7 @@
   </script>
   
   <!-- Add version parameter for cache busting -->
-  <script src="flutter_bootstrap.js?v=1747155709" async></script>
+  <script src="flutter_bootstrap.js?v=1747395579" async></script>
   
   <!-- Add cache busting script -->
   <script>

lib/config/config.dart

@@ -129,6 +129,9 @@ class Configuration {
       _config['video']['default_negative_prompt'] ?? 'captions, subtitles, logo, text, watermark, low quality, worst quality, gore, sex, blood, nudity, nude, porn, erotic';
       
   // Simulation settings
+  bool get enableSimLoop =>
+      _config['simulation']?['enable_sim_loop'] ?? true;
+      
   int get simLoopFrequencyInSec =>
       _config['simulation']?['sim_loop_frequency_in_sec'] ?? 0;
 

lib/screens/settings_screen.dart

@@ -15,6 +15,8 @@ class _SettingsScreenState extends State<SettingsScreen> {
   final _negativePromptController = TextEditingController();
   final _hfApiKeyController = TextEditingController();
   final _settingsService = SettingsService();
+  bool _showSceneDebugInfo = false;
+  bool _enableSimulation = true;
 
   @override
   void initState() {
@@ -22,6 +24,8 @@ class _SettingsScreenState extends State<SettingsScreen> {
     _promptController.text = _settingsService.videoPromptPrefix;
     _negativePromptController.text = _settingsService.negativeVideoPrompt;
     _hfApiKeyController.text = _settingsService.huggingfaceApiKey;
+    _showSceneDebugInfo = _settingsService.showSceneDebugInfo;
+    _enableSimulation = _settingsService.enableSimulation;
   }
 
   @override
@@ -161,6 +165,49 @@ class _SettingsScreenState extends State<SettingsScreen> {
             ),
           ),
           const SizedBox(height: 16),
+          // Display Options Card
+          Card(
+            child: Padding(
+              padding: const EdgeInsets.all(16),
+              child: Column(
+                crossAxisAlignment: CrossAxisAlignment.start,
+                children: [
+                  const Text(
+                    'Display Options',
+                    style: TextStyle(
+                      color: TikSlopColors.onBackground,
+                      fontSize: 20,
+                      fontWeight: FontWeight.bold,
+                    ),
+                  ),
+                  const SizedBox(height: 16),
+                  SwitchListTile(
+                    title: const Text('Show scene debug information'),
+                    subtitle: const Text('Display initial, current, and last description in video view'),
+                    value: _showSceneDebugInfo,
+                    onChanged: (value) {
+                      setState(() {
+                        _showSceneDebugInfo = value;
+                      });
+                      _settingsService.setShowSceneDebugInfo(value);
+                    },
+                  ),
+                  SwitchListTile(
+                    title: const Text('Enable simulation'),
+                    subtitle: const Text('Allow video descriptions to evolve over time'),
+                    value: _enableSimulation,
+                    onChanged: (value) {
+                      setState(() {
+                        _enableSimulation = value;
+                      });
+                      _settingsService.setEnableSimulation(value);
+                    },
+                  ),
+                ],
+              ),
+            ),
+          ),
+          const SizedBox(height: 16),
           // Custom Video Model Card
           Card(
             child: Padding(

lib/screens/video_screen.dart

@@ -1,5 +1,6 @@
 // lib/screens/video_screen.dart
 import 'dart:async';
+import 'dart:math' as math;
 
 import 'package:tikslop/screens/home_screen.dart';
 import 'package:tikslop/widgets/chat_widget.dart';
@@ -39,6 +40,9 @@ class _VideoScreenState extends State<VideoScreen> {
   // Subscription for limit statuses
   StreamSubscription? _anonLimitSubscription;
   StreamSubscription? _deviceLimitSubscription;
+  
+  // Reference to access video player's buffer manager for simulation updates
+  StreamSubscription? _videoUpdateSubscription;
 
   @override
   void initState() {
@@ -484,6 +488,19 @@ class _VideoScreenState extends State<VideoScreen> {
               video: _videoData,
               initialThumbnailUrl: _videoData.thumbnailUrl,
               autoPlay: true,
+              onVideoUpdated: (updatedVideo) {
+                debugPrint('VIDEO_SCREEN: Received updated video data');
+                if (updatedVideo.evolvedDescription.isNotEmpty) {
+                  debugPrint('VIDEO_SCREEN: Evolved description (${updatedVideo.evolvedDescription.length} chars)');
+                  debugPrint('VIDEO_SCREEN: First 100 chars: ${updatedVideo.evolvedDescription.substring(0, math.min(100, updatedVideo.evolvedDescription.length))}...');
+                } else {
+                  debugPrint('VIDEO_SCREEN: No evolved description received');
+                }
+                
+                setState(() {
+                  _videoData = updatedVideo;
+                });
+              },
             ),
             const SizedBox(height: 16),
 
@@ -496,6 +513,10 @@ class _VideoScreenState extends State<VideoScreen> {
   }
   
   Widget _buildCollapsibleInfoSection() {
+    // Get settings service to check if debug info should be shown
+    final settingsService = SettingsService();
+    final showDebugInfo = settingsService.showSceneDebugInfo;
+    
     return ExpansionTile(
       initiallyExpanded: false,
       tilePadding: EdgeInsets.zero,
@@ -526,16 +547,85 @@ class _VideoScreenState extends State<VideoScreen> {
         Column(
           crossAxisAlignment: CrossAxisAlignment.start,
           children: [
-            // Description Section
-            const SizedBox(height: 8),
-            Text(
-              _videoData.description,
-              style: const TextStyle(
-                color: TikSlopColors.onSurface,
-                height: 1.5,
+            // Regular Description Section
+            if (!showDebugInfo) ...[
+              const SizedBox(height: 8),
+              Text(
+                _videoData.description,
+                style: const TextStyle(
+                  color: TikSlopColors.onSurface,
+                  height: 1.5,
+                ),
               ),
-            ),
-            const SizedBox(height: 8),
+              const SizedBox(height: 8),
+            ],
+            
+            // Debug Information (when enabled)
+            if (showDebugInfo) ...[
+              const SizedBox(height: 16),
+              const Text(
+                'Initial Description:',
+                style: TextStyle(
+                  color: TikSlopColors.primary,
+                  fontWeight: FontWeight.bold,
+                  fontSize: 14,
+                ),
+              ),
+              const SizedBox(height: 4),
+              Text(
+                _videoData.description,
+                style: const TextStyle(
+                  color: TikSlopColors.onSurface,
+                  height: 1.5,
+                  fontSize: 13,
+                ),
+              ),
+              const SizedBox(height: 16),
+              
+              // Current Description (Evolved Description) Section
+              const Text(
+                'Current Description:',
+                style: TextStyle(
+                  color: TikSlopColors.primary,
+                  fontWeight: FontWeight.bold,
+                  fontSize: 14,
+                ),
+              ),
+              const SizedBox(height: 4),
+              Text(
+                _videoData.evolvedDescription.isNotEmpty
+                    ? _videoData.evolvedDescription
+                    : _videoData.description, // If evolved description is empty, show initial
+                style: const TextStyle(
+                  color: TikSlopColors.onSurface,
+                  height: 1.5,
+                  fontSize: 13,
+                ),
+              ),
+              const SizedBox(height: 16),
+              
+              // Condensed History (Last Description) Section
+              const Text(
+                'Last Description:',
+                style: TextStyle(
+                  color: TikSlopColors.primary,
+                  fontWeight: FontWeight.bold,
+                  fontSize: 14,
+                ),
+              ),
+              const SizedBox(height: 4),
+              Text(
+                _videoData.condensedHistory.isNotEmpty
+                    ? _videoData.condensedHistory
+                    : "No history available yet", // Show message if no history
+                style: const TextStyle(
+                  color: TikSlopColors.onSurface,
+                  height: 1.5,
+                  fontSize: 13,
+                ),
+              ),
+              const SizedBox(height: 8),
+            ],
           ],
         ),
       ],

lib/services/clip_queue/clip_queue_manager.dart

@@ -1,7 +1,7 @@
 // lib/services/clip_queue/clip_queue_manager.dart
 
 import 'dart:async';
-import 'dart:math';
+import 'dart:math' show max, min;
 import 'package:tikslop/config/config.dart';
 import 'package:flutter/foundation.dart';
 import 'package:collection/collection.dart';
@@ -10,6 +10,7 @@ import '../../models/video_orientation.dart';
 import '../../models/chat_message.dart';
 import '../websocket_api_service.dart';
 import '../chat_service.dart';
+import '../settings_service.dart';
 import '../../utils/seed.dart';
 import 'clip_states.dart';
 import 'video_clip.dart';
@@ -65,6 +66,12 @@ class ClipQueueManager {
   
   /// Recent chat messages to include in description evolution
   final List<ChatMessage> _recentChatMessages = [];
+  
+  /// Stream controller for video updates (evolved descriptions)
+  final StreamController<VideoResult> _videoUpdateController = StreamController<VideoResult>.broadcast();
+  
+  /// Stream of video updates for subscribers
+  Stream<VideoResult> get videoUpdateStream => _videoUpdateController.stream;
 
   /// Constructor
   ClipQueueManager({
@@ -213,12 +220,25 @@ class ClipQueueManager {
     // Cancel any existing timer
     _descriptionEvolutionTimer?.cancel();
     
-    // Only start if simulation frequency is greater than 0
+    // Check if simulation is enabled globally in config and from user settings
+    final settingsService = SettingsService();
+    final isSimulationEnabled = Configuration.instance.enableSimLoop && settingsService.enableSimulation;
+    
+    // Only start if simulation is enabled and frequency is greater than 0
+    if (!isSimulationEnabled) {
+      debugPrint('SIMULATION: Disabled (enable_sim_loop is false)');
+      ClipQueueConstants.logEvent('Simulation disabled (enable_sim_loop is false)');
+      return;
+    }
+    
     if (Configuration.instance.simLoopFrequencyInSec <= 0) {
+      debugPrint('SIMULATION: Disabled (frequency is 0)');
       ClipQueueConstants.logEvent('Simulation disabled (frequency is 0)');
       return;
     }
     
+    debugPrint('SIMULATION: Starting simulation timer with settings: enableSimLoop=${Configuration.instance.enableSimLoop}, userSetting=${settingsService.enableSimulation}, frequency=${Configuration.instance.simLoopFrequencyInSec}s');
+    
     // Adaptive check interval - less frequent checks to reduce overhead
     final checkInterval = max(3, Configuration.instance.simLoopFrequencyInSec ~/ 3);
     
@@ -228,30 +248,41 @@ class ClipQueueManager {
     _descriptionEvolutionTimer = Timer.periodic(
       Duration(seconds: checkInterval),
       (timer) async {
-        if (_isDisposed) return;
+        debugPrint('SIMULATION: Timer check triggered');
+        if (_isDisposed) {
+          debugPrint('SIMULATION: Skipping because manager is disposed');
+          return;
+        }
         
         // Skip if simulation is paused (due to video playback being paused)
         if (_isSimulationPaused) {
+          debugPrint('SIMULATION: Skipping because it is paused');
           ClipQueueConstants.logEvent('Skipping simulation because it is paused');
           return;
         }
         
-        // Check if we're currently generating a video - if so, delay simulation
+        // We previously delayed simulation if clips were being generated,
+        // but since clip generation is constant, we'll now run them in parallel
         final isGenerating = _activeGenerations.isNotEmpty;
         if (isGenerating) {
-          ClipQueueConstants.logEvent('Delaying simulation due to active generations');
-          return;
+          debugPrint('SIMULATION: Continuing with simulation despite active generations');
+          ClipQueueConstants.logEvent('Running simulation in parallel with active generations');
+          // We no longer return early here
         }
         
         // Calculate time since last simulation
         final now = DateTime.now();
         final duration = now.difference(_lastDescriptionEvolutionTime);
+        debugPrint('SIMULATION: Time since last simulation: ${duration.inSeconds}s (frequency: ${Configuration.instance.simLoopFrequencyInSec}s)');
         
         // If we've waited long enough, simulate the video
         if (duration.inSeconds >= Configuration.instance.simLoopFrequencyInSec) {
+          debugPrint('SIMULATION: Triggering simulation after ${duration.inSeconds} seconds');
           ClipQueueConstants.logEvent('Triggering simulation after ${duration.inSeconds} seconds');
           await _evolveDescription();
           _lastDescriptionEvolutionTime = now;
+        } else {
+          debugPrint('SIMULATION: Not enough time elapsed since last simulation');
         }
       },
     );
@@ -260,13 +291,16 @@ class ClipQueueManager {
   
   /// Simulate the video by evolving the description using the LLM
   Future<void> _evolveDescription() async {
+    debugPrint('SIMULATION: Starting description evolution');
     if (!_websocketService.isConnected) {
+      debugPrint('SIMULATION: Cannot simulate video - websocket not connected');
       ClipQueueConstants.logEvent('Cannot simulate video: websocket not connected');
       return;
     }
     
     int retryCount = 0;
     const maxRetries = 2;
+    debugPrint('SIMULATION: Current video state: title="${video.title}", evolvedDescription length=${video.evolvedDescription.length}, original description length=${video.description.length}');
     
     // Function to get chat message string
     String getChatMessagesString() {
@@ -297,13 +331,25 @@ class ClipQueueManager {
         );
         
         // Update the video with the evolved description
+        final newEvolvedDescription = result['evolved_description'] as String;
+        final newCondensedHistory = result['condensed_history'] as String;
+        
+        debugPrint('SIMULATION: Received evolved description (${newEvolvedDescription.length} chars)');
+        debugPrint('SIMULATION: First 100 chars: ${newEvolvedDescription.substring(0, min(100, newEvolvedDescription.length))}...');
+        
         video = video.copyWith(
-          evolvedDescription: result['evolved_description'],
-          condensedHistory: result['condensed_history'],
+          evolvedDescription: newEvolvedDescription,
+          condensedHistory: newCondensedHistory,
         );
         
         _evolutionCounter++;
+        debugPrint('SIMULATION: Video simulated (iteration $_evolutionCounter)');
         ClipQueueConstants.logEvent('Video simulated (iteration $_evolutionCounter)');
+        
+        // Emit the updated video to the stream for subscribers
+        debugPrint('SIMULATION: Emitting updated video to stream');
+        _videoUpdateController.add(video);
+        
         onQueueUpdated?.call();
         
         // Success, exit retry loop
@@ -658,6 +704,9 @@ class ClipQueueManager {
       _websocketService.cancelRequestsForVideo(videoId);
     }
 
+    // Close stream controller
+    await _videoUpdateController.close();
+
     // Clear all collections
     _clipBuffer.clear();
     _clipHistory.clear();

lib/services/settings_service.dart

@@ -7,6 +7,8 @@ class SettingsService {
   static const String _promptPrefixKey = 'video_prompt_prefix';
   static const String _hfApiKeyKey = 'huggingface_api_key';
   static const String _negativePromptKey = 'negative_video_prompt';
+  static const String _showSceneDebugInfoKey = 'show_scene_debug_info';
+  static const String _enableSimulationKey = 'enable_simulation';
   static final SettingsService _instance = SettingsService._internal();
   
   factory SettingsService() => _instance;
@@ -41,6 +43,20 @@ class SettingsService {
     await _prefs.setString(_hfApiKeyKey, apiKey);
     _settingsController.add(null);
   }
+  
+  bool get showSceneDebugInfo => _prefs.getBool(_showSceneDebugInfoKey) ?? false;
+  
+  Future<void> setShowSceneDebugInfo(bool value) async {
+    await _prefs.setBool(_showSceneDebugInfoKey, value);
+    _settingsController.add(null);
+  }
+  
+  bool get enableSimulation => _prefs.getBool(_enableSimulationKey) ?? Configuration.instance.enableSimLoop;
+  
+  Future<void> setEnableSimulation(bool value) async {
+    await _prefs.setBool(_enableSimulationKey, value);
+    _settingsController.add(null);
+  }
 
   void dispose() {
     _settingsController.close();

lib/services/websocket_api_service.dart

@@ -1246,6 +1246,8 @@ class WebSocketApiService {
       };
     }
 
+    debugPrint('WebSocketApiService: Sending simulation request for video $videoId (evolution #$evolutionCount)');
+    
     try {
       final response = await _sendRequest(
         WebSocketRequest(
@@ -1264,12 +1266,18 @@ class WebSocketApiService {
       );
 
       if (!response['success']) {
+        debugPrint('WebSocketApiService: Simulation API returned error: ${response['error']}');
         throw Exception(response['error'] ?? 'Simulation failed');
       }
 
+      final evolvedDescription = response['evolved_description'] as String? ?? currentDescription;
+      final newHistory = response['condensed_history'] as String? ?? condensedHistory;
+      
+      debugPrint('WebSocketApiService: Simulation successful, received ${evolvedDescription.length} chars for evolved description');
+      
       return {
-        'evolved_description': response['evolved_description'] as String? ?? currentDescription,
-        'condensed_history': response['condensed_history'] as String? ?? condensedHistory
+        'evolved_description': evolvedDescription,
+        'condensed_history': newHistory
       };
     } catch (e) {
       debugPrint('WebSocketApiService: Error simulating video: $e');

lib/widgets/ad_banner.dart

@@ -100,13 +100,13 @@ class _AdBannerState extends State<AdBanner> {
             onTap: () => _launchURL(_currentAd!['link'] ?? ''),
             child: Image.asset(
               _currentAd!['image'] ?? '',
-              height: 64,
+              height: 80,
               fit: BoxFit.contain,
               errorBuilder: (context, error, stackTrace) {
                 // If image fails to load, show a placeholder
                 print('Error loading ad image: $error');
                 return Container(
-                  height: 64,
+                  height: 80,
                   color: Colors.grey.withOpacity(0.1),
                   child: const Center(child: Text('Ad')),
                 );

lib/widgets/video_player/video_player_widget.dart

@@ -2,6 +2,7 @@
 
 import 'dart:async';
 import 'dart:math' as math;
+import 'dart:math' show min;
 import 'dart:io' show Platform;
 import 'package:tikslop/config/config.dart';
 import 'package:flutter/material.dart';
@@ -43,6 +44,9 @@ class VideoPlayerWidget extends StatefulWidget {
   
   /// Callback when video is loaded
   final VoidCallback? onVideoLoaded;
+  
+  /// Callback when video data is updated (for simulation updates)
+  final Function(VideoResult updatedVideo)? onVideoUpdated;
 
   /// Constructor
   const VideoPlayerWidget({
@@ -52,6 +56,7 @@ class VideoPlayerWidget extends StatefulWidget {
     this.autoPlay = true,
     this.borderRadius = 12,
     this.onVideoLoaded,
+    this.onVideoUpdated,
   });
 
   @override
@@ -71,6 +76,9 @@ class _VideoPlayerWidgetState extends State<VideoPlayerWidget> with WidgetsBindi
   /// Whether playback was happening before going to background
   bool _wasPlayingBeforeBackground = false;
   
+  /// Subscription to video update stream
+  StreamSubscription? _videoUpdateSubscription;
+  
   /// Current orientation
   VideoOrientation _currentOrientation = VideoOrientation.LANDSCAPE;
   
@@ -205,6 +213,29 @@ class _VideoPlayerWidgetState extends State<VideoPlayerWidget> with WidgetsBindi
       
       // Update orientation after initialization
       await _bufferManager.updateOrientation(_currentOrientation);
+      
+      // Subscribe to video updates
+      _videoUpdateSubscription = _bufferManager.queueManager.videoUpdateStream.listen((updatedVideo) {
+        if (!_isDisposed && mounted) {
+          // Calling setState to refresh UI with updated video data
+          setState(() {
+            // Since VideoResult is immutable, we need to use the updated copy
+            // that comes from the stream, not create a new one
+            // The parent widget should receive this via the onVideoUpdated callback
+            if (widget.onVideoUpdated != null) {
+              debugPrint('PLAYER: Received video update, evolvedDescription length: ${updatedVideo.evolvedDescription.length}');
+              
+              if (updatedVideo.evolvedDescription.isNotEmpty) {
+                debugPrint('PLAYER: First 100 chars: ${updatedVideo.evolvedDescription.substring(0, min(100, updatedVideo.evolvedDescription.length))}...');
+              }
+              
+              widget.onVideoUpdated!(updatedVideo);
+            } else {
+              debugPrint('PLAYER: No video update callback registered');
+            }
+          });
+        }
+      });
     }
     
     if (!_isDisposed && mounted) {
@@ -420,6 +451,9 @@ class _VideoPlayerWidgetState extends State<VideoPlayerWidget> with WidgetsBindi
     // Unregister the observer
     WidgetsBinding.instance.removeObserver(this);
     
+    // Cancel the video update subscription
+    _videoUpdateSubscription?.cancel();
+    
     // Dispose controllers and timers
     _playbackController.dispose();
     _bufferManager.dispose();