LINE公式アカウントにAI自動応答を導入する方法
Webhook×Claude API実践ガイド

// server.js — Webhookサーバー

const express = require('express');
const crypto = require('crypto');
const { handleMessage } = require('./handler');
require('dotenv').config();

const app = express();
const PORT = process.env.PORT || 3000;

// LINE署名検証ミドルウェア
function validateSignature(req, res, buf) {
  const signature = req.headers['x-line-signature'];
  if (!signature) return;

  const hash = crypto
    .createHmac('SHA256', process.env.LINE_CHANNEL_SECRET)
    .update(buf)
    .digest('base64');

  if (hash !== signature) {
    throw new Error('Invalid signature');
  }
}

app.use(express.json({
  verify: validateSignature,
}));

// Webhook エンドポイント
app.post('/webhook', async (req, res) => {
  // LINEからの接続確認（空イベント）
  if (!req.body.events || req.body.events.length === 0) {
    return res.status(200).json({ ok: true });
  }

  // 各イベントを処理
  const results = await Promise.all(
    req.body.events
      .filter(event => event.type === 'message'
                    && event.message.type === 'text')
      .map(event => handleMessage(event))
  );

  res.status(200).json({ results });
});

// ヘルスチェック
app.get('/', (req, res) => {
  res.json({ status: 'LINE AI Bot is running' });
});

app.listen(PORT, () => {
  console.log('Server running on port ' + PORT);
});

// handler.js — メッセージ処理+AI応答

const Anthropic = require('@anthropic-ai/sdk');
require('dotenv').config();

const anthropic = new Anthropic();

// 会話履歴（メモリ内保持。本番ではRedis等を推奨）
const conversationHistory = new Map();
const MAX_HISTORY = 10; // 直近10往復まで保持

// 業種に合わせてカスタマイズするシステムプロンプト
const SYSTEM_PROMPT = `あなたは親切なカスタマーサポートAIです。
LINE公式アカウントでお客様の質問に答えます。

ルール:
- 丁寧語で、でも堅すぎないフレンドリーなトーン
- 回答は簡潔に（LINEなので3-5行以内）
- わからないことは「担当者に確認いたします」と返す
- 予約や見積もりの具体的な金額は提示しない
- 営業時間やアクセスなどの基本情報は即答
- 緊急性が高い内容は「お急ぎの場合はお電話ください」と案内

お店の情報:
- 営業時間: 10:00-19:00（土日祝休み）
- 電話: 03-XXXX-XXXX
- 住所: 東京都○○区○○
※ 上記は例です。実際のお店の情報に置き換えてください。`;

async function handleMessage(event) {
  const userId = event.source.userId;
  const userMessage = event.message.text;
  const replyToken = event.replyToken;

  // 会話履歴を取得（なければ新規作成）
  if (!conversationHistory.has(userId)) {
    conversationHistory.set(userId, []);
  }
  const history = conversationHistory.get(userId);

  // ユーザーメッセージを履歴に追加
  history.push({ role: 'user', content: userMessage });

  // 履歴が長すぎたら古いものを削除
  while (history.length > MAX_HISTORY * 2) {
    history.shift();
  }

  try {
    // Claude APIでAI応答を生成
    const response = await anthropic.messages.create({
      model: 'claude-sonnet-4-20250514',
      max_tokens: 300,
      system: SYSTEM_PROMPT,
      messages: history,
    });

    const aiReply = response.content[0].text;

    // AI応答を履歴に追加
    history.push({ role: 'assistant', content: aiReply });

    // LINE Reply APIで返信
    await replyToLine(replyToken, aiReply);

    return { success: true };
  } catch (error) {
    console.error('AI response error:', error);

    // エラー時はフォールバックメッセージ
    await replyToLine(
      replyToken,
      'ご返信ありがとうございます。'
      + '担当者より改めてご連絡いたします。'
      + '少々お待ちくださいませ。'
    );

    return { success: false, error: error.message };
  }
}

async function replyToLine(replyToken, text) {
  const url = 'https://api.line.me/v2/bot/message/reply';

  const res = await fetch(url, {
    method: 'POST',
    headers: {
      'Content-Type': 'application/json',
      'Authorization':
        'Bearer ' + process.env.LINE_CHANNEL_ACCESS_TOKEN,
    },
    body: JSON.stringify({
      replyToken,
      messages: [{ type: 'text', text }],
    }),
  });

  if (!res.ok) {
    const err = await res.text();
    console.error('LINE Reply error:', err);
    throw new Error(err);
  }
}

module.exports = { handleMessage };

// エスカレーション判定をプロンプトに組み込む

// システムプロンプトに追加:
// 「以下のケースでは必ず
//   "担当者にお繋ぎいたします"と回答:
//   - クレーム、不満、怒りの表現
//   - 具体的な金額の交渉
//   - 医療・法律に関する相談
//   - "人間と話したい"という要望
//   - 3回以上同じ質問が繰り返された場合」