Webhook の中で動く LangChain エージェント。

タイミングの問題

エージェントを動かす。送信元への応答は AnyHook が引き受ける。

既存の Next.js や Fastify のルートはそのままです。送信元の署名の代わりに AnyHook-Signature を検証し、タイムアウトを気にせずエージェントを実行するだけです。

import { verifyWebhook } from "anyhook-verify";
import { AgentExecutor } from "langchain/agents";

export async function POST(req: Request) {
  const ok = await verifyWebhook(req, process.env.ANYHOOK_SIGNING_SECRET!);
  if (!ok) return new Response("invalid", { status: 401 });

  const event = await req.json();

  // Stripe / GitHub / Shopify already saw a 200 from AnyHook.
  // You have up to 5 minutes (Scale plan) to finish.
  const result = await agentExecutor.invoke({
    input: `Process this event: ${JSON.stringify(event)}`,
  });

  await persistToDb(result);
  await maybeNotify(result);

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

よくある質問

AnyHook は LangGraph でも使えますか？

はい。/for/langgraph-webhooks を参照してください。LangGraph のステートフルなワークフローも同じ形をしています。さらにモデル呼び出しを起動する必要がある Webhook コールバックです。

エージェントが途中で失敗したら？

ハンドラーから 5xx を返してください。AnyHook はそれをリトライ対象として扱い、設定されたバックオフのスケジュールを適用します。元のイベントは暗号化して保存されているので、バグを直した後にダッシュボードから再送できます。

Inngest や Trigger.dev と比べてどうですか？

それらは永続実行のプラットフォームで、それぞれの DSL でワークフローを書くと、そのプラットフォームが実行します。AnyHook はその上流にあり、同期的な Webhook を信頼できる非同期の配信に変えるだけです。ワークフローには引き続き Inngest を使えます。AnyHook はトリガーとなるイベントが確実に Inngest に届くようにするだけです。