import os
import json
import time
import redis  # uses the same 'redis' package you already installed

REDIS_URL = os.environ.get("REDIS_URL", "redis://default:eK2XVEAWB7G7oWAsTTJPYDOqX6Y8lPa2@redis-14639.c241.us-east-1-4.ec2.cloud.redislabs.com:14639")
SRC_STREAM = "ctx_events"

r = redis.from_url(REDIS_URL)

user_id = "demo_user"

print(f"Connecting to Redis at {REDIS_URL}...")
print("Sending fake SCREENSHOT events to stream:", SRC_STREAM)

while True:
    # This simulates a 30-second chunk of BROWSER_DISTRACT activity
    event = {
        "user_id": user_id,
        "type": "SCREENSHOT",
        "context_label": "BROWSER_DISTRACT",  # matches your off_task_browser rule
        "payload": {
            "elapsed": 30  # seconds
        }
    }

    r.xadd(SRC_STREAM, {"data": json.dumps(event)})
    print("Sent event:", event)

    # wait 30 seconds before the next event
    time.sleep(30)