Context Router

-- Query across PostgreSQL and MongoDB
SELECT c.name, c.industry, s.sentiment_score, s.trend
FROM postgres.companies c
JOIN mongo.social_sentiment s ON c.id = s.company_id
WHERE c.stage = 'Series B' 
  AND s.sentiment_score > 0.7
ORDER BY s.trend DESC
LIMIT 10;

-- Agent writes SQL
SELECT name, description FROM projects WHERE status = 'active';

-- Router translates to MongoDB
db.projects.find(
  { status: "active" },
  { name: 1, description: 1, _id: 0 }
)

# Slack integration
result = context_router.call_tool("slack_search", {
    "query": "Q4 roadmap",
    "channel": "engineering",
    "date_range": "last_30_days"
})

# Gmail integration
emails = context_router.call_tool("gmail_search", {
    "query": "from:customer@example.com subject:invoice",
    "max_results": 10
})

# Combined query across tools
SELECT 
    slack.message_text,
    gmail.subject,
    postgres.customer_name
FROM slack_messages slack
JOIN gmail_threads gmail ON slack.user_id = gmail.sender_id
JOIN postgres.customers postgres ON gmail.sender_id = postgres.email
WHERE slack.channel = 'support' 
  AND gmail.received_date > NOW() - INTERVAL '7 days';

caching:
  query_cache:
    enabled: true
    ttl_seconds: 300
    max_size_mb: 1024
  
  tool_cache:
    enabled: true
    ttl_seconds: 600
    per_tool_limits:
      slack: 50_requests_per_minute
      gmail: 100_requests_per_minute
  
  semantic_cache:
    enabled: true
    similarity_threshold: 0.85

-- Agent attempts query
SELECT * FROM employees WHERE department = 'Engineering';

-- Security layer applies policies
SELECT id, name, department, '***' as salary
FROM employees 
WHERE department = 'Engineering' 
  AND manager_id = 123  -- User's access scope
  AND region = 'US';     -- Data residency policy

{
  "timestamp": "2025-10-16T14:23:45Z",
  "agent_id": "voice_support_agent",
  "user_id": "customer_123",
  "query_type": "sql",
  "query": "SELECT * FROM support_tickets WHERE customer_id = 123",
  "data_sources": ["postgres.support_tickets"],
  "tools_called": ["slack_notify"],
  "cache_hit": false,
  "execution_time_ms": 45,
  "rows_returned": 12
}

-- Retrieve customer context during call
SELECT 
    c.name, c.account_tier, c.lifetime_value,
    COUNT(t.id) as open_tickets,
    MAX(t.created_at) as last_ticket_date
FROM customers c
LEFT JOIN support_tickets t ON c.id = t.customer_id
WHERE c.phone_number = '+1234567890'
  AND t.status IN ('open', 'pending')
GROUP BY c.id;

-- Access patient records with HIPAA compliance
SELECT 
    p.patient_id, p.name, p.date_of_birth,
    m.medication_name, m.dosage, m.frequency,
    a.appointment_date, a.provider_name
FROM patients p
JOIN medications m ON p.id = m.patient_id
JOIN appointments a ON p.id = a.patient_id
WHERE p.patient_id = 'P123456'
  AND a.appointment_date >= CURRENT_DATE
ORDER BY a.appointment_date;

-- Retrieve deal context during prospect call
SELECT 
    o.company_name, o.deal_stage, o.amount_usd,
    c.contact_name, c.title, c.last_interaction_date,
    e.email_subject, e.sent_date
FROM opportunities o
JOIN contacts c ON o.id = c.opportunity_id
LEFT JOIN gmail_threads e ON c.email = e.recipient
WHERE o.id = 'OPP-789'
  AND e.sent_date > NOW() - INTERVAL '30 days'
ORDER BY e.sent_date DESC;

-- Unified view across multiple data sources
SELECT 
    crm.customer_name,
    support.ticket_count,
    analytics.engagement_score,
    slack.last_message_date
FROM postgres.crm_customers crm
LEFT JOIN postgres.support_tickets support ON crm.id = support.customer_id
LEFT JOIN clickhouse.user_analytics analytics ON crm.id = analytics.user_id
LEFT JOIN slack_messages slack ON crm.slack_user_id = slack.user_id
WHERE crm.account_tier = 'enterprise'
ORDER BY analytics.engagement_score DESC;

# Query data and trigger tool call
result = context_router.execute("""
    SELECT id, severity, description 
    FROM incidents 
    WHERE status = 'critical' 
      AND created_at > NOW() - INTERVAL '5 minutes'
""")

# Automatically notify via Slack
if result.rows:
    context_router.call_tool("slack_send", {
        "channel": "#incidents",
        "message": f"🚨 {len(result.rows)} critical incidents detected"
    })