Form Filling Webhook Handler

import express from "express";

const app = express();
app.use(express.json());

app.post("/webhooks/suki", async (req, res) => {
  // 1. Verify signature (required in production)
  // verifySukiSignature(req.headers, req.body);

  const { status, session_id: sessionId, encounter_id: encounterId } = req.body;

  if (!sessionId) {
    res.status(400).json({ error: "Missing session_id" });
    return;
  }

  if (status === "success") {
    const { structured_data: structured } = await fetchFormFillingStructuredData(sessionId);

    await saveFormsToEhr({
      encounterId,
      sessionId,
      forms: structured.generated_values,
    });
  }

  if (status === "failure") {
    console.error("Form filling session failed", req.body.error_code, req.body.error_detail);
  }

  res.status(200).json({ received: true });
});

async function fetchFormFillingStructuredData(ambientSessionId) {
  const res = await fetch(
    `https://sdp.suki-stage.com/api/v1/form-filling/session/${ambientSessionId}/structured-data`,
    {
      headers: {
        sdp_suki_token: process.env.SUKI_SERVICE_TOKEN,
        sdp_provider_id: process.env.SUKI_PROVIDER_ID,
      },
    }
  );
  if (!res.ok) throw new Error(`structured-data fetch failed: ${res.status}`);
  return res.json();
}