npm create cloudflare@latest -- linebot-claude
cd linebot-claude

npx wrangler dev

npx wrangler secret put LINE_CHANNEL_SECRET
npx wrangler secret put LINE_CHANNEL_ACCESS_TOKEN
npx wrangler secret put ANTHROPIC_API_KEY

LINE_CHANNEL_SECRET="ここにChannel Secret"
LINE_CHANNEL_ACCESS_TOKEN="ここにChannel Access Token"
ANTHROPIC_API_KEY="ここにClaude APIキー"

// =============================================
// アプリケーション全体の設定値（定数）
// =============================================
const APP_CONFIG = {
  anthropicApiUrl: "https://api.anthropic.com/v1/messages",
  lineReplyApiUrl: "https://api.line.me/v2/bot/message/reply",
  claudeModel: "claude-sonnet-4-6",
  maxClaudeTokens: 300,
  maxReplyLength: 1000,
};

// =============================================
// ServicePolicy：サービス情報・プロンプト管理クラス
// ここを書き換えることで、業種ごとに対応を変えられる
// =============================================
class ServicePolicy {
  static buildSystemPrompt() {
    return `
あなたは個人事業主向けのLINE問い合わせBotです。
以下のルールで回答してください。

- 日本語で、丁寧なです・ます調で返答する
- わからないことは断定しない
- 料金・納期・FAQなどの定型質問に強く答える
- 個別見積もり・クレーム・判断が難しい相談は、人間対応に案内する
- 回答はできるだけ短く、要点を絞る

サービス情報の例:
- 料金: 初回相談 5,000円、通常プラン 30,000円〜
- 納期: 通常 5〜7営業日、混雑時は 10営業日前後
- 対応内容: 企画相談、文章作成支援、LINE運用相談
- 対応不可: 法務判断、税務判断、緊急クレーム処理
`;
  }
}

// =============================================
// LineSignatureVerifier：LINE Webhookの署名検証クラス
// リクエストが本当にLINEから来たものか確認する
// =============================================
class LineSignatureVerifier {
  constructor(channelSecret) {
    this.channelSecret = channelSecret;
  }

  /**
   * HMAC-SHA256で署名を生成し、LINEから届いた署名と照合する
   * @param {string} rawBody - リクエストの生のボディ文字列
   * @param {string} signature - x-line-signatureヘッダーの値
   * @returns {Promise<boolean>} 署名が一致すれば true
   */
  async verify(rawBody, signature) {
    const encoder = new TextEncoder();

    const key = await crypto.subtle.importKey(
      "raw",
      encoder.encode(this.channelSecret),
      { name: "HMAC", hash: "SHA-256" },
      false,
      ["sign"]
    );

    const signedBuffer = await crypto.subtle.sign(
      "HMAC",
      key,
      encoder.encode(rawBody)
    );

    const generatedSignature = this.toBase64(signedBuffer);
    return generatedSignature === signature;
  }

  /** ArrayBufferをBase64文字列に変換する */
  toBase64(buffer) {
    const bytes = new Uint8Array(buffer);
    let binary = "";

    for (let index = 0; index < bytes.byteLength; index += 1) {
      binary += String.fromCharCode(bytes[index]);
    }

    return btoa(binary);
  }
}

// =============================================
// ClaudeClient：Claude APIとの通信クラス
// ユーザーメッセージを受け取り、返答テキストを返す
// =============================================
class ClaudeClient {
  constructor(apiKey) {
    this.apiKey = apiKey;
  }

  /**
   * ユーザーメッセージをClaudeに送り、返答テキストを取得する
   * @param {string} userMessage - LINEで受信したテキスト
   * @returns {Promise<string>} Claudeの返答テキスト
   */
  async generateReply(userMessage) {
    const requestBody = {
      model: APP_CONFIG.claudeModel,
      max_tokens: APP_CONFIG.maxClaudeTokens,
      system: ServicePolicy.buildSystemPrompt(),
      messages: [
        {
          role: "user",
          content: userMessage,
        },
      ],
    };

    const response = await fetch(APP_CONFIG.anthropicApiUrl, {
      method: "POST",
      headers: {
        "content-type": "application/json",
        "x-api-key": this.apiKey,
        "anthropic-version": "2023-06-01",
      },
      body: JSON.stringify(requestBody),
    });

    // API呼び出しが失敗した場合はフォールバックメッセージを返す
    if (!response.ok) {
      return "現在混み合っているため、後ほど担当者よりご案内します。";
    }

    const data = await response.json();
    const text = data?.content?.[0]?.text?.trim();

    if (!text) {
      return "内容を確認のうえ、後ほど担当者よりご案内します。";
    }

    // LINEの文字数制限に合わせてトリミング
    return text.slice(0, APP_CONFIG.maxReplyLength);
  }
}

// =============================================
// LineBotClient：LINE Messaging APIとの通信クラス
// replyTokenを使ってメッセージを返信する
// =============================================
class LineBotClient {
  constructor(channelAccessToken) {
    this.channelAccessToken = channelAccessToken;
  }

  /**
   * LINEの応答メッセージAPIを使ってテキストを送信する
   * @param {string} replyToken - イベントから取得したreplyToken
   * @param {string} text - 送信するテキスト
   */
  async reply(replyToken, text) {
    await fetch(APP_CONFIG.lineReplyApiUrl, {
      method: "POST",
      headers: {
        "content-type": "application/json",
        Authorization: `Bearer ${this.channelAccessToken}`,
      },
      body: JSON.stringify({
        replyToken,
        messages: [
          {
            type: "text",
            text,
          },
        ],
      }),
    });
  }
}

// =============================================
// WebhookEventReader：LINEイベント解析クラス
// テキストメッセージのイベントだけを抽出する
// =============================================
class WebhookEventReader {
  /**
   * Webhookボディからテキストメッセージイベントを抽出する
   * @param {object} parsedBody - JSON.parseで解析済みのボディ
   * @returns {Array} テキストメッセージイベントの配列
   */
  static getTextMessageEvents(parsedBody) {
    const events = parsedBody?.events ?? [];

    return events.filter((event) => {
      return (
        event.type === "message" &&
        event.message?.type === "text" &&
        typeof event.message?.text === "string" &&
        typeof event.replyToken === "string"
      );
    });
  }
}

// =============================================
// LineBotApplication：アプリケーション本体クラス
// 各クライアントを組み合わせてWebhookを処理する
// =============================================
class LineBotApplication {
  /**
   * 環境変数からクライアントを初期化する
   * @param {object} env - Cloudflare WorkersのEnvオブジェクト
   */
  constructor(env) {
    this.signatureVerifier = new LineSignatureVerifier(env.LINE_CHANNEL_SECRET);
    this.claudeClient = new ClaudeClient(env.ANTHROPIC_API_KEY);
    this.lineBotClient = new LineBotClient(env.LINE_CHANNEL_ACCESS_TOKEN);
  }

  /**
   * HTTPリクエストを振り分けるルーターメソッド
   * @param {Request} request - Fetch APIのRequestオブジェクト
   */
  async handle(request) {
    if (request.method === "GET") {
      return new Response("ok", { status: 200 });
    }

    if (request.method !== "POST") {
      return new Response("Method Not Allowed", { status: 405 });
    }

    return this.handleWebhook(request);
  }

  /**
   * LINEからのWebhookリクエストを処理する
   * 署名検証 → テキストイベント取得 → Claude呼び出し → LINE返信
   * @param {Request} request - Fetch APIのRequestオブジェクト
   */
  async handleWebhook(request) {
    // 署名ヘッダーの存在確認
    const signature = request.headers.get("x-line-signature");

    if (!signature) {
      return new Response("Missing signature", { status: 400 });
    }

    // 署名検証はJSON.parseの前に必ず生のボディ文字列で行う
    const rawBody = await request.text();

    const isValid = await this.signatureVerifier.verify(rawBody, signature);

    if (!isValid) {
      return new Response("Invalid signature", { status: 401 });
    }

    // 検証完了後にパースしてテキストイベントを処理
    const parsedBody = JSON.parse(rawBody);
    const textEvents = WebhookEventReader.getTextMessageEvents(parsedBody);

    for (const event of textEvents) {
      const replyText = await this.claudeClient.generateReply(event.message.text);
      await this.lineBotClient.reply(event.replyToken, replyText);
    }

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

// =============================================
// Cloudflare Workers エントリーポイント
// fetchイベントをLineBotApplicationに委譲する
// =============================================
export default {
  async fetch(request, env) {
    const application = new LineBotApplication(env);
    return application.handle(request);
  },
};

npx wrangler deploy

https://linebot-claude.your-subdomain.workers.dev