Auto-reply agent

import crypto from "node:crypto";

const KEY = process.env.SENTFROMAI_API_KEY!;
const SECRET = process.env.SENTFROMAI_WEBHOOK_SECRET!;
const API = "https://api.sentfrom.ai/v1";

// Express-style handler. Use the RAW body for signature verification.
export async function handler(req, res) {
  const sig = req.headers["x-sentfromai-signature"];
  const expected = "sha256=" + crypto.createHmac("sha256", SECRET).update(req.rawBody).digest("hex");
  if (sig !== expected) return res.status(401).end();

  const { event, message } = JSON.parse(req.rawBody);
  if (event !== "message.received") return res.status(200).end();

  // 1. draft a reply with your LLM of choice
  const reply = await draftReply(message.subject, message.body_text);

  // 2. send it in-thread
  await fetch(`${API}/messages/${message.id}/reply`, {
    method: "POST",
    headers: { Authorization: `Bearer ${KEY}`, "Content-Type": "application/json" },
    body: JSON.stringify({ text: reply }),
  });

  res.status(200).end();   // respond fast; do heavy work async
}

import hmac, hashlib, os, requests
from flask import Flask, request

KEY = os.environ["SENTFROMAI_API_KEY"]
SECRET = os.environ["SENTFROMAI_WEBHOOK_SECRET"].encode()
API = "https://api.sentfrom.ai/v1"
app = Flask(__name__)

@app.post("/sentfromai")
def inbound():
    raw = request.get_data()
    expected = "sha256=" + hmac.new(SECRET, raw, hashlib.sha256).hexdigest()
    if request.headers.get("x-sentfromai-signature") != expected:
        return "", 401

    body = request.get_json()
    if body["event"] != "message.received":
        return "", 200
    msg = body["message"]

    reply = draft_reply(msg["subject"], msg.get("body_text", ""))   # your LLM
    requests.post(
        f"{API}/messages/{msg['id']}/reply",
        headers={"Authorization": f"Bearer {KEY}"},
        json={"text": reply},
    )
    return "", 200