orchestrator.py

import json
from pathlib import Path
from motion_id import load_ids

DATA_FILE = Path("data/telemetry.json")

def load_telemetry():
    if DATA_FILE.exists():
        return json.load(open(DATA_FILE))
    return []

def save_telemetry(logs):
    json.dump(logs, open(DATA_FILE, "w"), indent=2)

def route_task(agent_id, task_type, message):
    ids = load_ids()
    if agent_id not in ids:
        return "Invalid Motion ID"

    # Simple routing
    if task_type == "generate":
        from agents.generator import generate
        result = generate(message)
    elif task_type == "summarize":
        from agents.summarizer import summarize
        result = summarize(message)
    else:
        result = "Unknown task"

    # Log telemetry
    logs = load_telemetry()
    logs.append({
        "agent_id": agent_id,
        "task_type": task_type,
        "message": message,
        "result": result
    })
    save_telemetry(logs)

    return result