import { Gork } from "@gork/sdk"

const gork = new Gork({ apiKey: process.env.GORK_API_KEY })

export async function handleWebhook(req: Request) {
  const signature = req.headers.get("X-Gork-Signature")
  const rawBody = await req.text()

  // 1. Verify webhook authenticity (HMAC-SHA256)
  // Ensure signature verification matches the payload
  const event = JSON.parse(rawBody)

  if (event.event === "email.received") {
    const { from, subject, text, threadId, inboxId } = event.data

    // 2. Feed sanitized text to your LLM agent
    const aiResponse = await generateAgentReply({
      prompt: `Prospect: ${from}\nSubject: ${subject}\nBody: ${text}`,
    })

    // 3. Send threaded reply
    await client.messages.send({
      inboxId,
      to: [from],
      subject: `Re: ${subject}`,
      text: aiResponse,
      inReplyTo: threadId,
    })
  }

  return new Response("OK", { status: 200 })
}