t28.dev

LINE Messaging API を使って Mastra アプリから LINE でリプライを受け取る

2025/5/17
Tech

Fairy (AI エージェント) を作るメモまとめ > LINE Messaging API を使って Mastra アプリから LINE でリプライを受け取る

我が家の Fairy はまだろくなやり取りが出来ないが、LINE で返事を返すようにして、モチベーションを上げたい。

LINE Messaging API

LINE Messaging API を使って LINE でリプライを受け取る とは具体的には 👇️ をする:

LINE Messaging API については 👇️ を見ればいいと思う。

https://developers.line.biz/ja/docs/messaging-api/overview/

Mastra のカスタム API ルート で Webhook を受信する

LINE からの Webhook を受信するために、 Mastra のカスタム API ルートを作成する。

// 👇️ ヘルパーを使って API ルートを登録する
export default registerApiRoute("/line-webhook", {
  method: "POST",
  handler: async (c) => {
    // 👇️ Request body の型は `@line/bot-sdk` からインポートする
    const json = await c.req.json<WebhookRequestBody>();

    let replyToken: string | null = null;
    for (const event of json.events) {
      if (event.type === "message" && event.message.type === "text") {
        replyToken = event.replyToken;
      }
    }

    // 👇️ replyToken を使って応答する (https://developers.line.biz/ja/docs/messaging-api/sending-messages/#reply-messages)
    if (replyToken) {
      await lineClient.replyMessage({
        replyToken,
        messages: [
          {
            type: "text",
            text: "共に新エリー都を",
          },
        ],
      });
    }

    return new Response("OK");
  },
});

Middleware で署名を検証する

ボットサーバーが受信したHTTP POSTリクエストは、LINEプラットフォームから送信されていない危険なリクエストの可能性があります。必ず署名を検証してから、Webhookイベントオブジェクトを処理してください。

ref: https://developers.line.biz/ja/docs/messaging-api/receiving-messages/#verify-signature

署名検証用の関数は @line/bot-sdk が提供してくれている ので、これを middleware で使うだけ 1。

export const lineSignatureMiddleware: MiddlewareHandler = async (
  c,
  next,
): Promise<Response | void> => {
  const xLineSignature = c.req.header("x-line-signature");
  const body = await c.req.text();

  if (
    !xLineSignature ||
    !validateSignature(body, LINE_CHANNEL_SECRET, xLineSignature)
  ) {
    return c.json({ message: "Unauthorized" }, { status: 401 });
  }

  await next();
};

Mastra の生成を非同期で行う

現在のリクエストが処理されるまで後続のリクエストが待たされるのを防ぐため、Webhookイベントは非同期で処理することを推奨します

ref: https://developers.line.biz/ja/docs/messaging-api/receiving-messages/

export default registerApiRoute("/agents/fairy/line/webhook", {
  method: "POST",
  middleware: [lineSignatureMiddleware],
  handler: async (c) => {
    const fairy = c.get("mastra").getAgent("fairy");
    const json = await c.req.json<WebhookRequestBody>();

    let replyToken: string | null = null;
    const inputTexts: string[] = [];

    // (略)

    // 👇️
    c.executionCtx.waitUntil(
      (async () => {
        const generated = await fairy.generate(inputTexts);

        // (略)

        await lineClient.replyMessage({
          replyToken,
          messages: replyTexts.map((text) => ({
            sender: REPLY_SENDER,
            type: "text",
            text,
          })),
        });
      })(),
    );

    return new Response("OK");
  },
});

Static Assets で画像を配信して、アイコンと表示名のカスタマイズする

https://developers.cloudflare.com/workers/static-assets/

https://developers.line.biz/ja/reference/messaging-api/#icon-nickname-switch

Footnotes

  1. Cloudflare Workers に設置することを考えると依存関係を安易に増やしてよいのか？と思いつつも、@line/bot-sdk の validateSignature() のコードは十分小さい (追加の依存関係も大規模な抽象化もない) ので問題なし。 ↩