Update Consumer.py

Consumer.py

@@ -10,6 +10,20 @@ from FoxDot import *
 API_URL = "https://houseofplaying.com/hop/api.php"
 POLL_INTERVAL = 1  # Seconds
 
+def change_key(amt = 3, scl="minor", duration=4, flag=True):
+    Root.default = ((Root.default+amt) % 14)-5
+    print(f"Key changed to {Root.default}")
+    Scale.default = scl
+    if flag:
+       Clock.future(duration, change_key, args=[amt, scl, duration])
+
+def change_cycle(notes, scales, plen, flag=True):
+    if Clock.now() % plen) == 0:
+       Scale.default = scales[(Clock.now()/plen) % len(notes)]
+       Root.default = notes[(Clock.now()/plen) % len(notes)]
+       if flag:
+           change_cycle(notes, scales, plen)
+
 # Global dictionary to store active tasks and their cancellation tokens (or just the futures)
 active_tasks = {}
 
@@ -30,8 +44,6 @@ def update_server(uid, output, status):
         print(f"Error updating server: {e}")
 
 def stop(uid):
-    #global loop
-    #global active_tasks
     """Stops the execution of the cell with the given uid."""
     if uid in active_tasks:
         print(f"Stopping task {uid}...")
@@ -45,8 +57,6 @@ def stop(uid):
 
 def stopall():
     """Stops all running executions."""
-    #global loop
-    #global active_tasks
     count = 0
     for uid in list(active_tasks.keys()):
         if active_tasks[uid] != asyncio.current_task():
@@ -69,7 +79,7 @@ def stopall():
             print("Starting new event loop...")
             loop=asyncio.run(main())
             loop.run_forever()
-            
+
     except KeyboardInterrupt:
         print("Stopping consumer...")
 
@@ -77,17 +87,17 @@ def stopall():
 
 def execute_code_sync(code, uid):
     # Capture stdout
-    #global loop
-    #global active_tasks
     stdout_capture = i_o.StringIO()
     status = "completed"
     output = ""
     
     # Inject stop functions into locals
     local_scope = locals()
-    #local_scope['stop'] = stop
-    #local_scope['stopall'] = stopall
-
+    local_scope['stop'] = stop
+    local_scope['stopall'] = stopall
+    local_scope['change_key'] = change_key
+    local_scope['change_cycle'] = change_cycle
+    
     try:
         with contextlib.redirect_stdout(stdout_capture):
             # Execute the code
@@ -131,24 +141,24 @@ async def process_task(uid, code):
 
 async def main():
     print(f"Starting FoxDot Consumer (Async)... Polling {API_URL}")
-    
+
     while True:
         # Move polling to thread to avoid blocking loop
         task_data = await asyncio.to_thread(poll_server)
-        
+
         if task_data:
             uid = task_data.get('uid')
             code = task_data.get('code')
             print(f"Received task {uid}")
-            
+
             # Create async task
             task = asyncio.create_task(process_task(uid, code))
             active_tasks[uid] = task
             if uid in active_tasks:
-                active_tasks[uid].cancel() 
+                active_tasks[uid].cancel()
 
         await asyncio.sleep(POLL_INTERVAL)
-
+      
 if __name__ == "__main__":
     try:
         # Check if an event loop is already running
@@ -165,7 +175,7 @@ if __name__ == "__main__":
         else:
             print("Starting new event loop...")
             loop = asyncio.run(main())
-            
-        loop.run_forever()      
+
+        loop.run_forever()
     except KeyboardInterrupt:
         print("Stopping consumer...")