jarvis/api/endpoints/arc.php

<?php
/**
 * JARVIS Arc Reactor Bridge
 * Proxies job requests to the Arc Reactor daemon at 127.0.0.1:7474
 */

define('ARC_REACTOR_URL', 'http://127.0.0.1:7474');
define('ARC_TIMEOUT', 8);

function arc_request(string $method, string $path, array $body = []): array {
    $url = ARC_REACTOR_URL . $path;
    $ch  = curl_init($url);
    curl_setopt_array($ch, [
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_TIMEOUT        => ARC_TIMEOUT,
        CURLOPT_CONNECTTIMEOUT => 3,
        CURLOPT_HTTPHEADER     => ['Content-Type: application/json'],
    ]);
    if ($method === 'POST') {
        curl_setopt($ch, CURLOPT_POST, true);
        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($body));
    } elseif ($method === 'DELETE') {
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'DELETE');
    }
    $raw  = curl_exec($ch);
    $code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    $err  = curl_error($ch);
    curl_close($ch);

    if ($err || $raw === false) {
        return ['error' => 'Arc Reactor unreachable: ' . $err, 'online' => false];
    }
    $decoded = json_decode($raw, true);
    return $decoded ?? ['error' => 'Invalid response from Arc Reactor', 'raw' => substr($raw, 0, 200)];
}

// ── ROUTING ───────────────────────────────────────────────────────────────────
// arc action comes from query string or POST body (not the URL path segment)
global $data;
$action = $_GET['action'] ?? $data['action'] ?? '';

switch ($action) {

    // GET /api/arc?action=status
    case 'status':
        $result = arc_request('GET', '/status');
        if (!isset($result['online'])) $result['online'] = false;
        echo json_encode($result);
        break;

    // POST /api/arc — create a job
    case 'job_create':
        $type     = $data['type']     ?? '';
        $payload  = $data['payload']  ?? [];
        $priority = (int)($data['priority'] ?? 5);
        if (!$type) { http_response_code(400); echo json_encode(['error' => 'Missing job type']); break; }
        $result = arc_request('POST', '/job', [
            'type'       => $type,
            'payload'    => $payload,
            'priority'   => $priority,
            'created_by' => 'jarvis_ui',
        ]);
        echo json_encode($result);
        break;

    // GET /api/arc?action=job_get&id=123
    case 'job_get':
        $id = (int)($data['id'] ?? $_GET['id'] ?? 0);
        if (!$id) { http_response_code(400); echo json_encode(['error' => 'Missing job id']); break; }
        echo json_encode(arc_request('GET', "/job/{$id}"));
        break;

    // GET /api/arc?action=jobs&status=done&limit=20
    case 'jobs':
        $status = $_GET['status'] ?? $data['status'] ?? '';
        $limit  = (int)($_GET['limit']  ?? $data['limit']  ?? 50);
        $qs     = http_build_query(array_filter(['status' => $status, 'limit' => $limit]));
        echo json_encode(arc_request('GET', '/jobs' . ($qs ? "?{$qs}" : '')));
        break;

    // DELETE /api/arc?action=job_cancel&id=123
    case 'job_cancel':
        $id = (int)($data['id'] ?? $_GET['id'] ?? 0);
        if (!$id) { http_response_code(400); echo json_encode(['error' => 'Missing job id']); break; }
        echo json_encode(arc_request('DELETE', "/job/{$id}"));
        break;

    // DELETE /api/arc?action=purge
    case 'purge':
        echo json_encode(arc_request('DELETE', '/jobs/purge'));
        break;

    // Quick ping test
    case 'ping':
        $result = arc_request('POST', '/job', [
            'type'       => 'ping',
            'payload'    => [],
            'priority'   => 9,
            'created_by' => 'jarvis_ping',
        ]);
        echo json_encode($result);
        break;

    // GET /api/arc?action=triage&limit=50&filter=priority
    // Returns email_triage rows for the COMMS tab
    case 'triage':
        $limit  = min((int)($_GET['limit'] ?? 50), 100);
        $filter = $_GET['filter'] ?? 'priority';

        if ($filter === 'urgent') {
            $sql = "SELECT id, account, from_name, from_email, subject, date_received,
                           category, priority, summary, draft_reply, action_taken, created_at
                    FROM email_triage
                    WHERE action_taken != 'dismissed' AND category = 'urgent'
                    ORDER BY priority DESC, created_at DESC LIMIT ?";
        } elseif ($filter === 'action') {
            $sql = "SELECT id, account, from_name, from_email, subject, date_received,
                           category, priority, summary, draft_reply, action_taken, created_at
                    FROM email_triage
                    WHERE action_taken != 'dismissed' AND category IN ('urgent','action','reply','meeting')
                    ORDER BY priority DESC, created_at DESC LIMIT ?";
        } elseif ($filter === 'priority') {
            $sql = "SELECT id, account, from_name, from_email, subject, date_received,
                           category, priority, summary, draft_reply, action_taken, created_at
                    FROM email_triage
                    WHERE action_taken != 'dismissed' AND category IN ('urgent','action','reply','meeting')
                      AND priority >= 5
                    ORDER BY priority DESC, created_at DESC LIMIT ?";
        } else {
            $sql = "SELECT id, account, from_name, from_email, subject, date_received,
                           category, priority, summary, draft_reply, action_taken, created_at
                    FROM email_triage
                    WHERE action_taken != 'dismissed'
                    ORDER BY priority DESC, created_at DESC LIMIT ?";
        }
        $rows = JarvisDB::query($sql, [$limit]);
        echo json_encode($rows ?: []);
        break;

    // POST /api/arc?action=triage_action&id=123  body: { action: "dismissed"|"replied"|"done" }
    case 'triage_action':
        $id          = (int)($_GET['id'] ?? $data['id'] ?? 0);
        $actionTaken = $data['action'] ?? 'dismissed';
        $allowed     = ['dismissed', 'replied', 'done', 'snoozed'];
        if (!$id || !in_array($actionTaken, $allowed)) {
            http_response_code(400);
            echo json_encode(['error' => 'Invalid id or action']);
            break;
        }
        JarvisDB::execute(
            "UPDATE email_triage SET action_taken = ? WHERE id = ?",
            [$actionTaken, $id]
        );
        echo json_encode(['ok' => true, 'id' => $id, 'action_taken' => $actionTaken]);
        break;

    default:
        http_response_code(404);
        echo json_encode(['error' => "Unknown arc action: {$action}"]);
}