FIx: State Management Issues

Make Visuals Smoother

Author: spicyneutrino

main_complete_integration.py

@@ -279,7 +279,7 @@ def broadcast_state(scenario_status):
     )
 
     # Start automatic monitoring
-    scenario_controller.start_auto_monitoring()
+    # scenario_controller.start_auto_monitoring() # DISABLED: Controlled by simulation_loop now
 
     # Add API endpoints
     integrate_scenario_controller(app, scenario_controller, load_model)
@@ -385,6 +385,10 @@ def simulation_loop():
     print(f"V2G State Update:       {V2G_UPDATE}s (V2G session rate)")
     print("="*70 + "\n")
 
+    # BROADCAST OPTIMIZATION
+    BROADCAST_INTERVAL = 5  # Send 1 update per 5 physics steps
+    step_counter = 0
+
     while system_state['running']:
         try:
             step_start = time_module.perf_counter()
@@ -411,6 +415,15 @@ def simulation_loop():
                 sumo_time = (time_module.perf_counter() - sumo_start) * 1000
                 perf_stats['sumo_step'].append(sumo_time)
 
+                # SOCKET BROADCAST: Frame Skipping Logic
+                step_counter += 1
+                if step_counter % BROADCAST_INTERVAL == 0:
+                    try:
+                        status = scenario_controller.get_system_status() if scenario_controller else {"status": "Running"}
+                        broadcast_state(status)
+                    except Exception as e:
+                        print(f"Broadcast loop error: {e}")
+
                 # ASYNC VEHICLE SPAWNING: Process spawn queue in batches (max 5 per tick)
                 # This prevents UI freezing when bulk spawning vehicles
                 global vehicle_spawn_queue

manhattan_sumo_manager.py

@@ -570,8 +570,9 @@ def spawn_vehicles(self, count: int = 10, ev_percentage: float = 0.3, battery_mi
                         else:
                             continue
 
-                    # Try to find route
-                    route_result = traci.simulation.findRoute(origin, destination)
+                    # CRITICAL FIX: Use findRoute with vType to validate departure edge permissions
+                    # This checks if the vehicle TYPE can actually depart from the origin edge
+                    route_result = traci.simulation.findRoute(origin, destination, vType=vtype)
 
                     if route_result and route_result.edges and len(route_result.edges) > 0:
                         # Valid route found!
@@ -580,13 +581,20 @@ def spawn_vehicles(self, count: int = 10, ev_percentage: float = 0.3, battery_mi
                         # Add route
                         traci.route.add(route_id, route_result.edges)
 
-                        # Add vehicle
-                        traci.vehicle.add(
-                            vehicle_id,
-                            route_id,
-                            typeID=vtype,
-                            depart="now"
-                        )
+                        # Add vehicle with explicit departure checking
+                        try:
+                            traci.vehicle.add(
+                                vehicle_id,
+                                route_id,
+                                typeID=vtype,
+                                depart="now"
+                            )
+                        except Exception as e:
+                            # If departure fails, remove the edge from valid_edges
+                            if origin in valid_edges:
+                                valid_edges.remove(origin)
+                            print(f"  Departure failed on edge {origin}: {str(e)}, removed from valid edges")
+                            continue
 
                         # Set REALISTIC Manhattan speeds and COLLISION PREVENTION
                         traci.vehicle.setMaxSpeed(vehicle_id, 13.9)  # 50 km/h (31 mph) - realistic city speed