import { Gork } from "@gork/sdk"

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

const inbox = await gork.inboxes.create({
  username: "sdr-alex",
  name: "Alex (SDR)",
})

console.log(inbox.address)
// → sdr-alex@try.gork.email

curl -X POST https://api.gork.email/v1/webhooks \
  -H "Authorization: Bearer gork_live_YOUR_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "url": "https://your-agent.com/api/webhooks/gork",
    "subscribedEvents": ["email.received", "email.bounced"]
  }'

export async function POST(req: Request) {
  const rawBody = await req.text()
  if (!verifySignature(rawBody, req.headers.get("X-Gork-Signature"))) {
    return new Response("Unauthorized", { status: 401 })
  }

  const event = JSON.parse(rawBody)
  if (event.event !== "email.received") return new Response("OK")

  // Pull the whole conversation, not just the last message.
  const thread = await gork.threads.get(event.message.threadId)
  const history = (thread.messages ?? []).map((m) => ({
    role: m.direction === "inbound" ? "user" : "assistant",
    content: m.textBody ?? "",
  }))

  const replyText = await draftWithYourModel(history) // your LLM call

  await gork.messages.send({
    inboxId: event.message.inboxId,
    to: [event.message.from.address],
    subject: `Re: ${event.message.subject}`,
    text: replyText,
    inReplyTo: event.message.id, // sets In-Reply-To / References
  })

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