LINE MCPサーバー：Model Context ProtocolでAIエージェントをLINEに接続

AIエージェント（Claude、Gemini、GPTなど）
       |
       v
  MCPクライアント（AIエージェントに内蔵）
       |
       v
  MCPプロトコル（標準化されたJSON-RPC）
       |
       v
  MCPサーバー（LINE Bot MCPサーバー）
       |
       v
  LINE Messaging API
       |
       v
  LINE公式アカウント --> ユーザー

// 従来のアプローチ：カスタムWebhook + APIコード
import { Client } from "@line/bot-sdk";

const client = new Client({
  channelAccessToken: process.env.LINE_CHANNEL_ACCESS_TOKEN!,
});

app.post("/webhook", async (req, res) => {
  const events = req.body.events;
  for (const event of events) {
    if (event.type === "message" && event.message.type === "text") {
      await client.replyMessage(event.replyToken, {
        type: "text",
        text: "こんにちは！",
      });
    }
  }
  res.sendStatus(200);
});

// MCPアプローチ：AIエージェントがLINEを直接制御
// Claudeに自然言語で指示するだけ：

「ユーザーU1234567890にLINEでウェルカムメッセージを送信してください。
'当店へようこそ！新しい春コレクションを
今週20%オフでご覧ください。'」

// AIエージェントがMCP経由でpush_text_messageを自動呼び出し

# インストール不要 -- 直接実行
npx @line/line-bot-mcp-server

# 公式イメージを取得
docker pull ghcr.io/line/line-bot-mcp-server:latest

# 環境変数で実行
docker run -it --rm \
  -e CHANNEL_ACCESS_TOKEN=your_channel_access_token \
  -e DESTINATION=your_user_id \
  ghcr.io/line/line-bot-mcp-server:latest

{
  "mcpServers": {
    "line-bot": {
      "command": "npx",
      "args": ["-y", "@line/line-bot-mcp-server"],
      "env": {
        "CHANNEL_ACCESS_TOKEN": "your_channel_access_token_here",
        "DESTINATION": "your_default_user_id_here"
      }
    }
  }
}

{
  "mcpServers": {
    "line-bot": {
      "command": "docker",
      "args": [
        "run", "-i", "--rm",
        "-e", "CHANNEL_ACCESS_TOKEN",
        "-e", "DESTINATION",
        "ghcr.io/line/line-bot-mcp-server:latest"
      ],
      "env": {
        "CHANNEL_ACCESS_TOKEN": "your_channel_access_token_here",
        "DESTINATION": "your_default_user_id_here"
      }
    }
  }
}

あなた：「LINEにテストメッセージを送信して、AIからこんにちは」

Claude：LINEアカウントにメッセージを送信します。
[push_text_messageを呼び出し「AIからこんにちは」]
メッセージ送信成功！

プロンプト：「ユーザーU1234567890にメッセージを送信：
ご注文ありがとうございます！追跡番号はTH20260402001です。
配送予定日：2026年4月5日」

プロンプト：「春のセール用のFlex Messageを作成してください：
- ヒーロー画像バナー
- タイトル：Spring Collection 2026
- 20%割引バッジ
- 'Shop Now'ボタン（https://shop.example.com）
ユーザーU1234567890に送信」

// app/api/webhooks/line/route.ts
import { NextRequest, NextResponse } from "next/server";
import crypto from "crypto";

const CHANNEL_SECRET = process.env.LINE_CHANNEL_SECRET!;

function verifySignature(body: string, signature: string): boolean {
  const hash = crypto
    .createHmac("SHA256", CHANNEL_SECRET)
    .update(body)
    .digest("base64");
  return hash === signature;
}

export async function POST(req: NextRequest) {
  const body = await req.text();
  const signature = req.headers.get("x-line-signature") || "";

  if (!verifySignature(body, signature)) {
    return NextResponse.json({ error: "無効な署名" }, { status: 401 });
  }

  const { events } = JSON.parse(body);
  for (const event of events) {
    if (event.type === "message" && event.message.type === "text") {
      await forwardToAIAgent(event);
    }
  }

  return NextResponse.json({ status: "ok" });
}

顧客がLINEでメッセージ送信
       |
       v
  Webhookハンドラー（受信）
       |
       v
  AIルーターエージェント
       |
       +---> セールスエージェント（商品問い合わせ）
       |        |---> MCP: push_flex_message
       |
       +---> サポートエージェント（問題解決）
       |        |---> MCP: push_text_message
       |
       +---> マーケティングエージェント（キャンペーン管理）
                |---> MCP: broadcast_flex_message

import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
import { z } from "zod";

const server = new McpServer({
  name: "custom-line-tools",
  version: "1.0.0",
});

server.tool(
  "send_order_status",
  "注文ステータスの更新と追跡情報をLINEユーザーに送信",
  {
    user_id: z.string().describe("LINE user ID"),
    order_id: z.string().describe("Order ID"),
    status: z.enum(["confirmed", "shipped", "delivered"]),
    tracking_number: z.string().optional(),
  },
  async ({ user_id, order_id, status, tracking_number }) => {
    const flexMessage = buildOrderStatusFlex(order_id, status, tracking_number);
    await lineClient.pushMessage(user_id, flexMessage);
    return { content: [{ type: "text", text: `ステータス送信完了` }] };
  }
);