Function handleQuery

website/api/v1/query.ts:94–297

(req: any, res: any)

}

async function handleQuery(req: any, res: any) {
  const method = req.method;
  const params = method === "POST" ? (req.body || {}) : (req.query || {});
  const { repo, query_type, target, cypher_query, branch, commit } = params;

  if (!query_type || typeof query_type !== "string") {
    return res.status(400).json({
      error: "Missing required parameter 'query_type'. Expected: 'definitions', 'callers', 'callees', 'file_structure', or 'cypher'."
    });
  }

  const isGlobalTool = query_type === "list_indexed_repositories" || query_type === "search_registry_bundles";

  if (!isGlobalTool) {
    if (!repo || typeof repo !== "string") {
      return res.status(400).json({ error: "Missing required parameter 'repo' (owner/repo)." });
    }
  }

  const supabaseUrl = process.env.VITE_SUPABASE_URL || process.env.SUPABASE_URL;
  const supabaseAnonKey = process.env.VITE_SUPABASE_ANON_KEY || process.env.SUPABASE_ANON_KEY;

  if (!supabaseUrl || !supabaseAnonKey) {
    return res.status(500).json({
      error: "Server configuration error: Supabase credentials are not configured on Vercel."
    });
  }

  const supabase = createClient(supabaseUrl, supabaseAnonKey);

  const wasmQueries = ["definitions", "callers", "callees", "file_structure", "search", "cypher"];
  const isWasmQuery = wasmQueries.includes(query_type);

  const sessionToken = extractSessionToken(params);

  if (!sessionToken) {
    // MUST be 200 — ChatGPT maps non-2xx responses to ClientResponseError and drops the body
    return res.status(200).json({
      ...MISSING_SESSION_PAYLOAD,
      ...offlineResponse(typeof query_type === "string" ? query_type : "unknown"),
    });
  }

  const channelName = `cgc-tunnel-${sessionToken}`;

  const channel = supabase.channel(channelName);
  const requestId = Math.random().toString(36).substring(2, 15);
  let hasResponded = false;

  // Cleanup helper
  const cleanup = () => {
    try { supabase.removeChannel(channel); } catch (err) {}
  };

  try {
    if (isWasmQuery) {
      // ── WASM Query Path (definitions, callers, callees, file_structure, search, cypher) ──
      let wasmResponse: any = null;