testing continuous simulation

api.py

@@ -2,7 +2,7 @@ import asyncio
 import json
 import logging
 import os
-import pathlib
+from pathlib import Path
 import time
 import uuid
 from aiohttp import web, WSMsgType
@@ -233,7 +233,7 @@ async def init_app() -> web.Application:
     
     # Set up static file serving
     # Define the path to the public directory
-    public_path = pathlib.Path(__file__).parent / 'build' / 'web'
+    public_path = Path(__file__).parent / 'build' / 'web'
     if not public_path.exists():
         public_path.mkdir(parents=True, exist_ok=True)
     

api_core.py

@@ -473,7 +473,7 @@ A video can be anything from a tutorial, webcam, trailer, movie, live stream etc
             # Determine if this is the first simulation
             is_first_simulation = evolution_count == 0 or not condensed_history
             
-            logger.info(f"simulate(): is_first_simulation={is_first_simulation}")
+            #logger.info(f"simulate(): is_first_simulation={is_first_simulation}")
                 
             # Create an appropriate prompt based on whether this is the first simulation
             chat_section = ""
@@ -492,15 +492,21 @@ Original description:
 {chat_section}
 
 Instructions:
-1. Imagine the next logical scene or development that would follow this description.
-2. Create a compelling new description (200-300 words) that builds on the original but introduces new elements, developments, or perspectives.
-3. Maintain the original style, tone, and setting.
-4. If viewers have shared messages, consider their input and incorporate relevant suggestions or reactions into your narrative evolution.
-5. Also create a brief "scene history" (50-75 words) that summarizes what has happened so far.
-
-Return your response in this format:
-EVOLVED_DESCRIPTION: [your new evolved description here]
-CONDENSED_HISTORY: [your scene history summary]"""
+1. Imagine the next logical scene or development that would follow the current description.
+2. Consider the video context and recent events
+3. Create a natural progression from previous clips
+4. Take into account user suggestions (chat messages) into the scene
+5. IMPORTANT: viewers have shared messages, consider their input in priority to guide your story, and incorporate relevant suggestions or reactions into your narrative evolution.
+6. Keep visual consistency with previous clips (in most cases you should repeat the same exact description of the location, characters etc but only change a few elements. If this is a webcam scenario, don't touch the camera orientation or focus)
+7. Return ONLY the caption text, no additional formatting or explanation
+8. Write in English, about 200 words.
+9. Keep the visual style consistant, but content as well (repeat the style, character, locations, appearance etc..from the previous description, when it makes sense).
+10. Your caption must describe visual elements of the scene in details, including: camera angle and focus, people's appearance, age, look, costumes, clothes, the location visual characteristics and geometry, lighting, action, objects, weather, textures, lighting.
+11. Please write in the same style as the original description, by keeping things brief etc.
+
+Remember to obey to what users said in the chat history!!
+
+Now, you must write down the new scene description (don't write a long story! write a synthetic description!):"""
             else:
                 prompt = f"""You are tasked with continuing to evolve the narrative for a video titled: "{original_title}"
 
@@ -516,14 +522,20 @@ Current description (most recent scene):
 
 Instructions:
 1. Imagine the next logical scene or development that would follow the current description.
-2. Create a compelling new description (200-300 words) that builds on the narrative but introduces new elements, developments, or perspectives.
-3. Maintain consistency with the previous scenes while advancing the story.
-4. If viewers have shared messages, consider their input and incorporate relevant suggestions or reactions into your narrative evolution.
-5. Also update the condensed history (50-75 words) to include this new development.
+2. Consider the video context and recent events
+3. Create a natural progression from previous clips
+4. Take into account user suggestions (chat messages) into the scene
+5. IMPORTANT: if viewers have shared messages, consider their input in priority to guide your story, and incorporate relevant suggestions or reactions into your narrative evolution.
+6. Keep visual consistency with previous clips (in most cases you should repeat the same exact description of the location, characters etc but only change a few elements. If this is a webcam scenario, don't touch the camera orientation or focus)
+7. Return ONLY the caption text, no additional formatting or explanation
+8. Write in English, about 200 words.
+9. Keep the visual style consistant, but content as well (repeat the style, character, locations, appearance etc..from the previous description, when it makes sense).
+10. Your caption must describe visual elements of the scene in details, including: camera angle and focus, people's appearance, age, look, costumes, clothes, the location visual characteristics and geometry, lighting, action, objects, weather, textures, lighting.
+11. Please write in the same style as the original description, by keeping things brief etc.
+
+Remember to obey to what users said in the chat history!!
 
-Return your response in this format:
-EVOLVED_DESCRIPTION: [your new evolved description here]
-CONDENSED_HISTORY: [your updated scene history summary]"""
+Now, you must write down the new scene description (don't write a long story! write a synthetic description!):"""
 
             # Generate the evolved description
             response = await asyncio.get_event_loop().run_in_executor(
@@ -531,45 +543,32 @@ CONDENSED_HISTORY: [your updated scene history summary]"""
                 lambda: self.inference_client.text_generation(
                     prompt,
                     model=TEXT_MODEL,
-                    max_new_tokens=200,
-                    temperature=0.7
+                    max_new_tokens=280,
+                    temperature=0.68
                 )
             )
+
+            # print("RAW RESPONSE: ", response)
             
-            # Extract the evolved description and condensed history from the response
-            evolved_description = ""
-            new_condensed_history = ""
-            
-            # Parse the response
-            if "EVOLVED_DESCRIPTION:" in response and "CONDENSED_HISTORY:" in response:
-                parts = response.split("CONDENSED_HISTORY:")
-                if len(parts) >= 2:
-                    desc_part = parts[0].strip()
-                    if "EVOLVED_DESCRIPTION:" in desc_part:
-                        evolved_description = desc_part.split("EVOLVED_DESCRIPTION:", 1)[1].strip()
-                    new_condensed_history = parts[1].strip()
+            # Just use the whole response as the evolved description
+            evolved_description = response.strip()
             
-            # If parsing failed, use some fallbacks
+            # If response is empty, use fallback
             if not evolved_description:
                 evolved_description = current_description
-                logger.warning(f"Failed to parse evolved description, using current description as fallback")
-            
-            if not new_condensed_history and condensed_history:
-                new_condensed_history = condensed_history
-                logger.warning(f"Failed to parse condensed history, using current history as fallback")
-            elif not new_condensed_history:
-                new_condensed_history = f"The video begins with {original_title}: {original_description[:100]}..."
+                logger.warning(f"Empty response, using current description as fallback")
             
+            # Pass the condensed history through unchanged
             return {
                 "evolved_description": evolved_description,
-                "condensed_history": new_condensed_history
+                "condensed_history": condensed_history
             }
             
         except Exception as e:
             logger.error(f"Error simulating video: {str(e)}")
             return {
                 "evolved_description": current_description,
-                "condensed_history": condensed_history or f"The video shows {original_title}."
+                "condensed_history": condensed_history
             }
 
 

api_session.py

@@ -286,7 +286,7 @@ class UserSession:
                 evolution_count = data.get('evolution_count', 0)
                 chat_messages = data.get('chat_messages', '')
                 
-                logger.info(f"Processing video simulation for user {self.user_id}, video_id={video_id}, evolution_count={evolution_count}")
+                # logger.info(f"Processing video simulation for user {self.user_id}, video_id={video_id}, evolution_count={evolution_count}")
                 
                 # Validate required parameters
                 if not original_title or not original_description or not current_description:

build/web/flutter_bootstrap.js

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

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": "c711e457cccbe0bcbccc12f740ac44af",
+const RESOURCES = {"flutter_bootstrap.js": "e872c517f2e5a256b7e7e90083844b1e",
 "version.json": "68350cac7987de2728345c72918dd067",
 "tikslop.png": "570e1db759046e2d224fef729983634e",
 "index.html": "3a7029b3672560e7938aab6fa4d30a46",
 "/": "3a7029b3672560e7938aab6fa4d30a46",
-"main.dart.js": "494e091a049a511f985f81a61cedf669",
+"main.dart.js": "2b68b90804df2f31f56c7601f5c5048f",
 "tikslop.svg": "26140ba0d153b213b122bc6ebcc17f6c",
 "flutter.js": "83d881c1dbb6d6bcd6b42e274605b69c",
 "favicon.png": "c8a183c516004e648a7bac7497c89b97",

build/web/index.html

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

docs/for-bots/flutter/flutter-videos/fvp_usage_example__multi_textures.dart

@@ -5,7 +5,7 @@ void main(List<String> args) async {
   runApp(const SinglePlayerMultipleVideoWidget());
 }
 class SinglePlayerMultipleVideoWidget extends StatefulWidget {
-  const SinglePlayerMultipleVideoWidget({Key? key}) : super(key: key);
+  const SinglePlayerMultipleVideoWidget({super.key});
 
   @override
   State<SinglePlayerMultipleVideoWidget> createState() =>

lib/main.dart

@@ -91,7 +91,7 @@ void main() async {
     wsService.statusStream.listen((status) {
       if (status == ConnectionStatus.maintenance) {
         // Force update to maintenance screen if server goes into maintenance mode later
-        runApp(TikSlopApp(home: const MaintenanceScreen(error: null)));
+        runApp(const TikSlopApp(home: MaintenanceScreen(error: null)));
       }
     });
     

lib/screens/home_screen.dart

@@ -30,7 +30,7 @@ class HomeScreen extends StatefulWidget {
 class _HomeScreenState extends State<HomeScreen> {
   final _searchController = TextEditingController();
   final _websocketService = WebSocketApiService();
-  List<VideoResult> _results = [];
+  final List<VideoResult> _results = [];
   bool _isSearching = false;
   String? _currentSearchQuery;
   StreamSubscription? _searchSubscription;

lib/screens/video_screen.dart

@@ -9,7 +9,6 @@ import 'package:tikslop/widgets/web_utils.dart';
 import 'package:flutter/foundation.dart';
 import 'package:flutter/material.dart';
 import 'package:flutter/services.dart';
-import 'package:universal_html/html.dart' if (dart.library.io) 'package:tikslop/services/html_stub.dart' as html;
 import '../config/config.dart';
 import '../models/video_result.dart';
 import '../services/websocket_api_service.dart';

lib/services/chat_service.dart

@@ -20,6 +20,10 @@ class ChatService {
   final _chatController = StreamController<ChatMessage>.broadcast();
   Stream<ChatMessage> get chatStream => _chatController.stream;
   
+  // Store recent messages for each room
+  final Map<String, List<ChatMessage>> _recentMessages = {};
+  static const int _maxRecentMessages = 5;
+  
   final WebSocketApiService _websocketService = WebSocketApiService();
   String? _userId;
   String? _username;
@@ -145,9 +149,43 @@ class ChatService {
     // Only add messages if they're for the current room
     if (message.videoId == _currentRoomId) {
       _chatController.add(message);
+      
+      // Store this message in the recent messages for this room
+      if (!_recentMessages.containsKey(message.videoId)) {
+        _recentMessages[message.videoId] = [];
+      }
+      
+      _recentMessages[message.videoId]!.add(message);
+      
+      // Keep only most recent messages
+      if (_recentMessages[message.videoId]!.length > _maxRecentMessages) {
+        _recentMessages[message.videoId]!.removeAt(0);
+      }
+      
       debugPrint('Received chat message: ${message.id} from ${message.username}');
     }
   }
+  
+  /// Get recent messages for a video room
+  Future<List<ChatMessage>> getRecentMessages(String videoId) async {
+    // Initialize if needed
+    if (!_isInitialized) {
+      await initialize();
+    }
+    
+    // If not in the requested room, try to join it
+    if (_currentRoomId != videoId) {
+      try {
+        await joinRoom(videoId);
+      } catch (e) {
+        debugPrint('Error joining room to get messages: $e');
+        return [];
+      }
+    }
+    
+    // Return the stored messages or an empty list
+    return _recentMessages[videoId] ?? [];
+  }
 
   // This method is only for application shutdown
   // Individual widgets should use leaveRoom instead

lib/services/clip_queue/clip_generation_handler.dart

@@ -1,7 +1,6 @@
 // lib/services/clip_queue/clip_generation_handler.dart
 
 import 'dart:async';
-import 'package:flutter/foundation.dart';
 import 'package:tikslop/config/config.dart';
 import '../websocket_api_service.dart';
 import '../../models/video_result.dart';

lib/services/clip_queue/clip_queue_manager.dart

@@ -104,8 +104,8 @@ class ClipQueueManager {
   void _addChatMessage(ChatMessage message) {
     if (message.videoId == videoId) {
       _recentChatMessages.add(message);
-      // Keep only the 10 most recent messages
-      if (_recentChatMessages.length > 10) {
+      // Keep only the 5 most recent messages
+      if (_recentChatMessages.length > 5) {
         _recentChatMessages.removeAt(0);
       }
       ClipQueueConstants.logEvent('Added chat message: ${message.content.substring(0, min(20, message.content.length))}...');
@@ -172,7 +172,7 @@ class ClipQueueManager {
         if (_isDisposed) return;
         
         final newClip = VideoClip(
-          prompt: "${video.title}\n${video.description}",
+          prompt: "${video.title}\n${video.evolvedDescription.isEmpty ? video.description : video.evolvedDescription}",
           seed: video.useFixedSeed && video.seed > 0 ? video.seed : generateSeed(),
           orientation: _currentOrientation,
         );
@@ -248,7 +248,7 @@ class ClipQueueManager {
     _descriptionEvolutionTimer = Timer.periodic(
       Duration(seconds: checkInterval),
       (timer) async {
-        debugPrint('SIMULATION: Timer check triggered');
+        // debugPrint('SIMULATION: Timer check triggered');
         if (_isDisposed) {
           debugPrint('SIMULATION: Skipping because manager is disposed');
           return;
@@ -256,7 +256,7 @@ class ClipQueueManager {
         
         // Skip if simulation is paused (due to video playback being paused)
         if (_isSimulationPaused) {
-          debugPrint('SIMULATION: Skipping because it is paused');
+          // debugPrint('SIMULATION: Skipping because it is paused');
           ClipQueueConstants.logEvent('Skipping simulation because it is paused');
           return;
         }
@@ -265,7 +265,7 @@ class ClipQueueManager {
         // but since clip generation is constant, we'll now run them in parallel
         final isGenerating = _activeGenerations.isNotEmpty;
         if (isGenerating) {
-          debugPrint('SIMULATION: Continuing with simulation despite active generations');
+          // debugPrint('SIMULATION: Continuing with simulation despite active generations');
           ClipQueueConstants.logEvent('Running simulation in parallel with active generations');
           // We no longer return early here
         }
@@ -273,7 +273,7 @@ class ClipQueueManager {
         // 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)');
+        // 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) {
@@ -282,7 +282,7 @@ class ClipQueueManager {
           await _evolveDescription();
           _lastDescriptionEvolutionTime = now;
         } else {
-          debugPrint('SIMULATION: Not enough time elapsed since last simulation');
+          // debugPrint('SIMULATION: Not enough time elapsed since last simulation');
         }
       },
     );
@@ -315,8 +315,10 @@ class ClipQueueManager {
       try {
         // Format recent chat messages as a string for the simulation prompt
         String chatMessagesString = getChatMessagesString();
+        
         if (chatMessagesString.isNotEmpty) {
           ClipQueueConstants.logEvent('Including ${_recentChatMessages.length} chat messages in simulation');
+          debugPrint('SIMULATION: Including chat messages: $chatMessagesString');
         }
         
         // Use the WebSocketService to simulate the video
@@ -334,8 +336,8 @@ class ClipQueueManager {
         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))}...');
+        // debugPrint('SIMULATION: Received evolved description (${newEvolvedDescription.length} chars)');
+        // debugPrint('SIMULATION: First 100 chars: ${newEvolvedDescription.substring(0, min(100, newEvolvedDescription.length))}...');
         
         video = video.copyWith(
           evolvedDescription: newEvolvedDescription,
@@ -343,11 +345,11 @@ class ClipQueueManager {
         );
         
         _evolutionCounter++;
-        debugPrint('SIMULATION: Video simulated (iteration $_evolutionCounter)');
-        ClipQueueConstants.logEvent('Video simulated (iteration $_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');
+        // debugPrint('SIMULATION: Emitting updated video to stream');
         _videoUpdateController.add(video);
         
         onQueueUpdated?.call();
@@ -368,7 +370,7 @@ class ClipQueueManager {
           
           // If we've been successful before but failed now, we can continue using the last evolved description
           if (_evolutionCounter > 0) {
-            ClipQueueConstants.logEvent('Continuing with previous description');
+            // ClipQueueConstants.logEvent('Continuing with previous description');
           }
         }
       }
@@ -407,16 +409,8 @@ class ClipQueueManager {
 
     // First ensure we have the correct buffer size
     while (_clipBuffer.length < Configuration.instance.renderQueueBufferSize) {
-      // Determine which description to use for the prompt
-      String descriptionToUse = video.description;
-      
-      // If we have an evolved description, use that instead
-      if (video.evolvedDescription.isNotEmpty) {
-        descriptionToUse = video.evolvedDescription;
-      }
-      
       final newClip = VideoClip(
-        prompt: "${video.title}\n${descriptionToUse}",
+        prompt: "${video.title}\n${video.evolvedDescription.isEmpty ? video.description : video.evolvedDescription}",
         seed: video.useFixedSeed && video.seed > 0 ? video.seed : generateSeed(),
         orientation: _currentOrientation,
       );
@@ -435,8 +429,9 @@ class ClipQueueManager {
     for (final clip in failedClips) {
       _clipBuffer.remove(clip);
       final newClip = VideoClip(
-        prompt: "${video.title}\n${video.description}",
+        prompt: "${video.title}\n${video.evolvedDescription.isEmpty ? video.description : video.evolvedDescription}",
         seed: video.useFixedSeed && video.seed > 0 ? video.seed : generateSeed(),
+        orientation: _currentOrientation, // Use the current orientation here too
       );
       _clipBuffer.add(newClip);
     }
@@ -538,18 +533,9 @@ class ClipQueueManager {
       _clipBuffer.remove(clip);
       _clipHistory.add(clip);
       
-      // Determine which description to use for the prompt
-      String descriptionToUse = video.description;
-      
-      // If we have an evolved description, use that instead
-      if (video.evolvedDescription.isNotEmpty) {
-        descriptionToUse = video.evolvedDescription;
-        ClipQueueConstants.logEvent('Using evolved description for new clip (evolution #$_evolutionCounter)');
-      }
-      
       // Add a new pending clip with current orientation
       final newClip = VideoClip(
-        prompt: "${video.title}\n${descriptionToUse}",
+        prompt: "${video.title}\n${video.evolvedDescription.isEmpty ? video.description : video.evolvedDescription}",
         seed: video.useFixedSeed && video.seed > 0 ? video.seed : generateSeed(),
         orientation: _currentOrientation,
       );

lib/services/clip_queue/queue_stats_logger.dart

@@ -1,7 +1,5 @@
 // lib/services/clip_queue/queue_stats_logger.dart
 
-import 'dart:async';
-import 'package:flutter/foundation.dart';
 import 'package:collection/collection.dart';
 import 'video_clip.dart';
 import 'clip_states.dart';

lib/services/clip_queue/video_clip.dart

@@ -2,7 +2,6 @@
 
 import 'dart:async';
 import 'package:uuid/uuid.dart';
-import 'package:flutter/foundation.dart';
 import 'clip_states.dart';
 import '../../models/video_orientation.dart';
 

lib/services/html_stub.dart

@@ -1,5 +1,6 @@
 /// Stub implementation for dart:html when not on web platform
 /// This file is imported when dart.library.html is not available
+library;
 
 class Window {
   final Document document = Document();

lib/services/websocket_api_service.dart

@@ -219,7 +219,7 @@ class WebSocketApiService {
   String get anonLimitMessage => _anonLimitMessage;
   
   // Message to display when device limit is exceeded
-  String _deviceLimitMessage = 'Too many connections from this device. Please close other tabs running TikSlop.';
+  final String _deviceLimitMessage = 'Too many connections from this device. Please close other tabs running TikSlop.';
   String get deviceLimitMessage => _deviceLimitMessage;
   
   // Stream to notify listeners when anonymous limit status changes
@@ -280,7 +280,7 @@ class WebSocketApiService {
       // Check if we're exceeding the limit, but only for non-anonymous users
       // For anonymous users, we rely on the server-side IP check
       if (_userRole != 'anon' && connections.length > _maxDeviceConnections) {
-        debugPrint('Device connection limit exceeded: ${connections.length} connections for ${_userRole} user');
+        debugPrint('Device connection limit exceeded: ${connections.length} connections for $_userRole user');
         return false;
       }
       
@@ -386,18 +386,18 @@ class WebSocketApiService {
     // Prevent multiple simultaneous connection attempts
     return _connectionLock.synchronized(() async {
       if (_status == ConnectionStatus.connected) {
-        debugPrint('WebSocketApiService: Already connected, skipping connection attempt');
+        // debugPrint('WebSocketApiService: Already connected, skipping connection attempt');
         return;
       }
       
       if (_status == ConnectionStatus.connecting) {
-        debugPrint('WebSocketApiService: Connection already in progress, waiting...');
+        // debugPrint('WebSocketApiService: Connection already in progress, waiting...');
         
         // Wait for a short time to see if connection completes
         for (int i = 0; i < 10; i++) {
           await Future.delayed(const Duration(milliseconds: 200));
           if (_status == ConnectionStatus.connected) {
-            debugPrint('WebSocketApiService: Connection completed while waiting');
+            // debugPrint('WebSocketApiService: Connection completed while waiting');
             return;
           }
           if (_status == ConnectionStatus.error || _status == ConnectionStatus.maintenance) {
@@ -412,7 +412,7 @@ class WebSocketApiService {
 
       try {
         _setStatus(ConnectionStatus.connecting);
-        debugPrint('WebSocketApiService: Setting status to CONNECTING');
+        // debugPrint('WebSocketApiService: Setting status to CONNECTING');
         
         // Close existing channel if any
         await _channel?.sink.close();
@@ -632,7 +632,7 @@ class WebSocketApiService {
         }
         
         // Setup stream listener with error handling
-        debugPrint('WebSocketApiService: Setting up stream listeners...');
+        // debugPrint('WebSocketApiService: Setting up stream listeners...');
         _channel!.stream.listen(
           _handleMessage,
           onError: _handleError,
@@ -646,7 +646,7 @@ class WebSocketApiService {
           _startConnectionHeartbeat();
         }
         
-        debugPrint('WebSocketApiService: Setting status to CONNECTED');
+        // debugPrint('WebSocketApiService: Setting status to CONNECTED');
         _setStatus(ConnectionStatus.connected);
         _reconnectAttempts = 0;
         
@@ -678,7 +678,7 @@ class WebSocketApiService {
 
    void addSubscriber(String id) {
     _subscribers[id] = (_subscribers[id] ?? 0) + 1;
-    debugPrint('WebSocket subscriber added: $id (total: ${_subscribers[id]})');
+    // debugPrint('WebSocket subscriber added: $id (total: ${_subscribers[id]})');
   }
 
   void removeSubscriber(String id) {
@@ -687,15 +687,15 @@ class WebSocketApiService {
       if (_subscribers[id]! <= 0) {
         _subscribers.remove(id);
       }
-      debugPrint('WebSocket subscriber removed: $id (remaining: ${_subscribers[id] ?? 0})');
+      // debugPrint('WebSocket subscriber removed: $id (remaining: ${_subscribers[id] ?? 0})');
     }
   }
 
   Future<void> joinChatRoom(String videoId) async {
-    debugPrint('WebSocketApiService: Attempting to join chat room: $videoId');
+   // debugPrint('WebSocketApiService: Attempting to join chat room: $videoId');
     
     if (!isConnected) {
-      debugPrint('WebSocketApiService: Not connected, connecting first...');
+      // debugPrint('WebSocketApiService: Not connected, connecting first...');
       await connect();
     }
     
@@ -708,7 +708,7 @@ class WebSocketApiService {
         timeout: const Duration(seconds: 10),
       );
 
-      debugPrint('WebSocketApiService: Join chat room response received: $response');
+      // debugPrint('WebSocketApiService: Join chat room response received: $response');
 
       if (!response['success']) {
         final error = response['error'] ?? 'Failed to join chat room';
@@ -721,7 +721,7 @@ class WebSocketApiService {
         _handleChatHistory(response);
       }
 
-      debugPrint('WebSocketApiService: Successfully joined chat room: $videoId');
+      // debugPrint('WebSocketApiService: Successfully joined chat room: $videoId');
     } catch (e) {
       debugPrint('WebSocketApiService: Error joining chat room: $e');
       rethrow;
@@ -740,7 +740,7 @@ class WebSocketApiService {
         ),
         timeout: const Duration(seconds: 5),
       );
-      debugPrint('Successfully left chat room: $videoId');
+      // debugPrint('Successfully left chat room: $videoId');
     } catch (e) {
       debugPrint('Failed to leave chat room: $e');
     }
@@ -800,13 +800,13 @@ class WebSocketApiService {
     _activeSearches[query] = false;
     
     if (_disposed) {
-      debugPrint('Search terminated: Service disposed');
+      // debugPrint('Search terminated: Service disposed');
     } else if (failedAttempts >= maxFailedAttempts) {
-      debugPrint('Search terminated: Max failures ($maxFailedAttempts) reached');
+      // debugPrint('Search terminated: Max failures ($maxFailedAttempts) reached');
     } else if ((_currentSearchState?.resultCount ?? 0) >= maxResults) {
-      debugPrint('Search terminated: Max results ($maxResults) reached');
+      // debugPrint('Search terminated: Max results ($maxResults) reached');
     } else {
-      debugPrint('Search terminated: Search cancelled');
+      // debugPrint('Search terminated: Search cancelled');
     }
   }
 
@@ -1182,7 +1182,7 @@ class WebSocketApiService {
         action: 'generate_video',
         params: {
           'title': video.title,
-          'description': video.description,
+          'description': video.evolvedDescription.isEmpty ? video.description : video.evolvedDescription,
           'video_prompt_prefix': settings.videoPromptPrefix,
           'options': {
             'enhance_prompt': enhancePrompt,
@@ -1249,6 +1249,31 @@ class WebSocketApiService {
     debugPrint('WebSocketApiService: Sending simulation request for video $videoId (evolution #$evolutionCount)');
     
     try {
+      // If chat messages are provided directly, use them; otherwise the default empty string is used
+      String formattedChatMessages = chatMessages;
+      
+      // If no chat messages were provided but we have a chat stream, try to get recent messages
+      if (formattedChatMessages.isEmpty) {
+        // Check if we have any active chat messages in our stream
+        try {
+          // Get messages directly from the chatController's history
+          final List<ChatMessage> recentChatMessages = [];
+          // We'd ideally query for recent messages in a real implementation
+          // but to avoid circular dependencies we'll use any messages provided to us
+          
+          if (recentChatMessages.isNotEmpty) {
+            formattedChatMessages = recentChatMessages.map((msg) => 
+              "${msg.username}: ${msg.content}"
+            ).join("\n");
+            debugPrint('WebSocketApiService: Including ${recentChatMessages.length} chat messages in simulation');
+          }
+        } catch (e) {
+          debugPrint('WebSocketApiService: Error getting chat messages: $e');
+        }
+      }
+      
+      debugPrint('WebSocketApiService: Chat messages included: ${formattedChatMessages.isNotEmpty ? 'Yes' : 'No'}');
+      
       final response = await _sendRequest(
         WebSocketRequest(
           action: 'simulate',
@@ -1259,7 +1284,7 @@ class WebSocketApiService {
             'current_description': currentDescription,
             'condensed_history': condensedHistory,
             'evolution_count': evolutionCount,
-            'chat_messages': chatMessages,
+            'chat_messages': formattedChatMessages,
           },
         ),
         timeout: const Duration(seconds: 60),

lib/services/websocket_core_interface.dart

@@ -2,6 +2,8 @@
 
 /// This file provides a subset of WebSocket functionality needed for the nano player
 /// It's a simplified version that avoids exposing the entire WebSocketApiService
+library;
+
 
 /// WebSocketRequest model
 class WebSocketRequest {

lib/widgets/ai_content_disclaimer.dart

@@ -2,7 +2,6 @@
 
 import 'package:flutter/material.dart';
 import 'package:google_fonts/google_fonts.dart';
-import '../theme/colors.dart';
 
 class AiContentDisclaimer extends StatelessWidget {
   final bool isInteractive;

lib/widgets/maintenance_screen.dart

@@ -1,6 +1,5 @@
 // lib/widgets/maintenance_screen.dart
 import 'package:flutter/material.dart';
-import 'package:tikslop/theme/colors.dart';
 
 class MaintenanceScreen extends StatelessWidget {
   final Exception? error;

lib/widgets/video_card.dart

@@ -1,5 +1,4 @@
 import 'package:flutter/material.dart';
-import 'dart:convert';
 import '../theme/colors.dart';
 import '../models/video_result.dart';
 import './video_player/index.dart';

lib/widgets/video_player/buffer_manager.dart

@@ -3,7 +3,6 @@
 import 'dart:async';
 import 'package:flutter/foundation.dart';
 import 'package:tikslop/config/config.dart';
-import 'package:tikslop/services/clip_queue/video_clip.dart';
 import 'package:tikslop/services/clip_queue/clip_queue_manager.dart';
 import 'package:video_player/video_player.dart';
 import 'package:tikslop/models/video_result.dart';

lib/widgets/video_player/nano_clip_manager.dart

@@ -1,7 +1,6 @@
 // lib/widgets/video_player/nano_clip_manager.dart
 
 import 'dart:async';
-import 'dart:convert';
 import 'package:flutter/foundation.dart';
 import 'package:tikslop/models/video_result.dart';
 import 'package:tikslop/services/clip_queue/video_clip.dart';

lib/widgets/video_player/playback_controller.dart

@@ -2,7 +2,6 @@
 
 import 'dart:async';
 import 'package:flutter/foundation.dart';
-import 'package:flutter/material.dart';
 import 'package:video_player/video_player.dart';
 import 'package:tikslop/config/config.dart';
 import 'package:tikslop/services/clip_queue/video_clip.dart';

lib/widgets/video_player/video_player_widget.dart

@@ -302,11 +302,11 @@ class _VideoPlayerWidgetState extends State<VideoPlayerWidget> with WidgetsBindi
       VideoPlayerController? newController;
       
       if (_playbackController.nextController != null) {
-        debugPrint('Using preloaded controller for clip ${clip.seed}');
+        // debugPrint('Using preloaded controller for clip ${clip.seed}');
         newController = _playbackController.nextController;
         _playbackController.nextController = null;
       } else {
-        debugPrint('Creating new controller for clip ${clip.seed}');
+        // debugPrint('Creating new controller for clip ${clip.seed}');
         newController = VideoPlayerController.networkUrl(
           Uri.parse(clip.base64Data!),
         );
@@ -338,7 +338,7 @@ class _VideoPlayerWidgetState extends State<VideoPlayerWidget> with WidgetsBindi
 
       if (widget.autoPlay) {
         await newController.play();
-        debugPrint('Started playback of clip ${clip.seed}');
+        // debugPrint('Started playback of clip ${clip.seed}');
         _playbackController.startPlaybackTimer();
       }
 
@@ -444,10 +444,8 @@ class _VideoPlayerWidgetState extends State<VideoPlayerWidget> with WidgetsBindi
     _isDisposed = true;
     
     // Ensure simulation is paused when widget is disposed
-    if (_bufferManager.queueManager != null) {
-      _bufferManager.queueManager.setSimulationPaused(true);
-    }
-    
+    _bufferManager.queueManager.setSimulationPaused(true);
+      
     // Unregister the observer
     WidgetsBinding.instance.removeObserver(this);
     

lib/widgets/web_utils.dart

@@ -1,4 +1,3 @@
-import 'dart:async';
 import 'package:flutter/foundation.dart';
 
 // Platform-specific imports handling