"""
Working Event Handler with proper message spacing
Waits for Claude to respond before sending next message
"""
from ultra_fast_sender import send_to_claude
import time
import threading
import queue
from datetime import datetime
class WorkingEventHandler:
def __init__(self):
self.event_queue = queue.Queue()
self.running = False
# Adjust this based on typical Claude response time
self.response_wait_time = 5 # seconds to wait for Claude to respond
def add_event(self, event_type, message):
"""Add event to queue"""
self.event_queue.put({
'type': event_type,
'message': message,
'time': datetime.now()
})
print(f"š„ Queued: {event_type} - {message}")
def process_events(self):
"""Process events with proper spacing"""
while self.running:
try:
event = self.event_queue.get(timeout=1)
# Format message
msg = f"[MAID_EVENT] {event['type']}: {event['message']}"
# Send using ultra fast sender
start = time.time()
if send_to_claude(msg):
elapsed = (time.time() - start) * 1000
print(f"ā
Sent in {elapsed:.0f}ms: {msg}")
else:
print(f"ā Failed: {msg}")
# IMPORTANT: Wait for Claude to process and respond
print(f"ā³ Waiting {self.response_wait_time}s for Claude to respond...")
time.sleep(self.response_wait_time)
except queue.Empty:
continue
def start(self):
"""Start processing"""
self.running = True
self.thread = threading.Thread(target=self.process_events, daemon=True)
self.thread.start()
print(f"š Event handler started! (Response wait: {self.response_wait_time}s)")
def stop(self):
"""Stop processing"""
self.running = False
print("š Event handler stopped")
def set_response_time(self, seconds):
"""Adjust wait time based on Claude's response speed"""
self.response_wait_time = seconds
print(f"ā±ļø Response wait time set to {seconds}s")
# Demo
if __name__ == "__main__":
handler = WorkingEventHandler()
handler.start()
print("\nš® Event Handler Demo")
print("Events will be spaced out to allow Claude to respond")
print("-" * 50)
while True:
print("\n1. Send test event")
print("2. Send multiple events (queued)")
print("3. Adjust response wait time")
print("4. Show queue size")
print("5. Exit")
choice = input("\nChoice: ")
if choice == '1':
handler.add_event("test", "Single test event")
elif choice == '2':
print("Adding 3 events to queue...")
handler.add_event("voice", "Hey Mimi, how are you?")
handler.add_event("system", "Battery at 25%")
handler.add_event("app", "User opened VS Code")
print(f"Events will be sent with {handler.response_wait_time}s spacing")
elif choice == '3':
seconds = input("Enter wait time in seconds (current: {}): ".format(handler.response_wait_time))
try:
handler.set_response_time(float(seconds))
except:
print("Invalid number")
elif choice == '4':
print(f"š Queue size: {handler.event_queue.qsize()} events waiting")
elif choice == '5':
handler.stop()
break
