Documentation

import requests

MOBIUS = "https://acme.mobiusops.ai/v1"
HEADERS = {"Authorization": "Bearer mobius_sk_..."}

# Agent checks its pipeline every morning
prospects = requests.get(f"{MOBIUS}/entities", headers=HEADERS, params={
    "type": "company",
    "attr.stage": "prospect",
    "expand": "relationships,recent_events",
    "sort": "-updated_at"
}).json()["data"]

for company in prospects:
    # Check recent activity
    last_event = company["recent_events"][0] if company["recent_events"] else None

    if not last_event or days_since(last_event["created_at"]) > 7:
        # No activity in a week — draft a follow-up
        draft = generate_followup(company)

        # Log the outreach attempt
        requests.post(f"{MOBIUS}/events", headers=HEADERS, json={
            "entity_id": company["id"],
            "type": "outreach_sent",
            "content": f"Follow-up email sent: {draft['subject']}"
        })

        # Update the entity
        requests.patch(f"{MOBIUS}/entities/{company['id']}", headers=HEADERS, json={
            "attributes": {
                **company["attributes"],
                "last_outreach": datetime.now().isoformat()
            }
        })

# Support agent receives a new ticket via job queue
job = requests.post(f"{MOBIUS}/jobs/claim", headers=HEADERS, json={
    "queue": "support-tickets",
    "timeout": 30
}).json()["data"]

ticket = job["input"]

# Look up the customer in the knowledge graph
customers = requests.get(f"{MOBIUS}/search", headers=HEADERS, params={
    "q": ticket["customer_email"]
}).json()["data"]

customer = customers[0] if customers else None

if customer:
    # Get full context: relationships, recent events
    context = requests.get(
        f"{MOBIUS}/entities/{customer['id']}",
        headers=HEADERS,
        params={"expand": "relationships,recent_events"}
    ).json()["data"]

    # Check for related open issues
    related = requests.get(f"{MOBIUS}/entities", headers=HEADERS, params={
        "type": "issue",
        "attr.customer_id": customer["id"],
        "attr.status": "open"
    }).json()["data"]

    # Draft response with full context
    response = draft_support_response(
        ticket=ticket,
        customer_history=context["recent_events"],
        open_issues=related
    )

# Log the interaction
if customer and response:
    requests.post(f"{MOBIUS}/events", headers=HEADERS, json={
        "entity_id": customer["id"],
        "type": "support_ticket",
        "content": f"Ticket: {ticket['subject']}\nResponse: {response['summary']}"
    })

# Complete the job
requests.post(f"{MOBIUS}/jobs/{job['id']}/complete", headers=HEADERS, json={
    "result": {"response_sent": customer is not None, "ticket_id": ticket["id"]}
})

# Research agent discovers a new competitor
competitor = requests.post(f"{MOBIUS}/entities", headers=HEADERS, json={
    "type": "competitor",
    "name": "RivalCo",
    "summary": "Series B competitor in the SMB segment",
    "path": "/research/competitors",
    "attributes": {
        "funding": "25M",
        "headcount": 80,
        "key_features": ["workflow automation", "integrations"],
        "threat_level": "medium"
    }
}).json()["data"]

# Link it to the market we're tracking
requests.post(f"{MOBIUS}/relationships", headers=HEADERS, json={
    "from_entity_id": competitor["id"],
    "to_entity_id": "ent_market_smb",
    "type": "competes_in",
    "attributes": {"position": "challenger"}
})

# Log the research finding
requests.post(f"{MOBIUS}/events", headers=HEADERS, json={
    "entity_id": competitor["id"],
    "type": "research_finding",
    "content": "RivalCo launched a new API product targeting our ICP. \
                Pricing is 30% below ours for comparable features."
})

# Notify the strategy agent
requests.post(f"{MOBIUS}/messages", headers=HEADERS, json={
    "channel": "competitive-intel",
    "from_user_id": "agent_researcher",
    "recipient_id": "agent_strategy",
    "content": "New competitor identified: RivalCo. See /research/competitors",
    "priority": "high"
})