Add reply message tools

README.ja.md

@@ -23,37 +23,49 @@ LINE公式アカウントとAI Agentを接続するために、LINE Messaging AP
      - `message.altText` (string): フレックスメッセージが表示できない場合に表示される代替テキスト。
      - `message.contents` (any): フレックスメッセージの内容。メッセージのレイアウトとコンポーネントを定義するJSONオブジェクト。
      - `message.contents.type` (enum): コンテナのタイプ。'bubble'は単一コンテナ、'carousel'は複数のスワイプ可能なバブルを示す。
-3. **broadcast_text_message**
+3. **reply_text_message**
+   - LINEでユーザーにシンプルなテキストメッセージで返信する。書式なしのプレーンテキストメッセージの送信に使用する。
+   - **入力:**
+     - `message.text` (string): ユーザーに返信するテキスト。
+     - `replyToken` (string): 返信トークン。
+4. **reply_flex_message**
+   - LINEでユーザーに高度にカスタマイズ可能なフレックスメッセージで返信する。バブル（単一コンテナ）とカルーセル（複数のスワイプ可能なバブル）の両方のレイアウトをサポート。
+   - **入力:**
+     - `message.altText` (string): フレックスメッセージが表示できない場合に表示される代替テキスト。
+     - `message.contents` (any): フレックスメッセージの内容。メッセージのレイアウトとコンポーネントを定義するJSONオブジェクト。
+     - `message.contents.type` (enum): コンテナのタイプ。'bubble'は単一コンテナ、'carousel'は複数のスワイプ可能なバブルを示す。
+     - `replyToken` (string): 返信トークン。
+5. **broadcast_text_message**
    - LINE公式アカウントと友だちになっているすべてのユーザーに、LINEでシンプルなテキストメッセージを送信する。
    - **入力:**
      - `message.text` (string): ユーザーに送信するテキスト。
-4. **broadcast_flex_message**
+6. **broadcast_flex_message**
    - LINE公式アカウントと友だちになっているすべてのユーザーに、LINEで高度にカスタマイズ可能なフレックスメッセージを送信する。
    - **入力:**
      - `message.altText` (string): フレックスメッセージが表示できない場合に表示される代替テキスト。
      - `message.contents` (any): フレックスメッセージの内容。メッセージのレイアウトとコンポーネントを定義するJSONオブジェクト。
      - `message.contents.type` (enum): コンテナのタイプ。'bubble'は単一コンテナ、'carousel'は複数のスワイプ可能なバブルを示す。
-5. **get_profile**
+7. **get_profile**
    - LINEユーザーの詳細なプロフィール情報を取得する。表示名、プロフィール画像URL、ステータスメッセージ、言語を取得できる。
    - **入力:**
       - `userId` (string?): プロフィールを取得したいユーザーのユーザーID。デフォルトはDESTINATION_USER_ID。`user_id`または`DESTINATION_USER_ID`のどちらか一方は必ず設定する必要があります。
-6. **get_message_quota**
+8. **get_message_quota**
    - LINE公式アカウントのメッセージ容量と消費量を取得します。月間メッセージ制限と現在の使用量が表示されます。
    - **入力:**
      - なし
-7. **get_rich_menu_list**
+9. **get_rich_menu_list**
    - LINE公式アカウントに登録されているリッチメニューの一覧を取得する。
    - **入力:**
      - なし
-8. **delete_rich_menu**
-   - LINE公式アカウントからリッチメニューを削除する。
-   - **入力:**
-     - `richMenuId` (string): 削除するリッチメニューのID。
-9. **set_rich_menu_default**
+10. **delete_rich_menu**
+    - LINE公式アカウントからリッチメニューを削除する。
+    - **入力:**
+      - `richMenuId` (string): 削除するリッチメニューのID。
+11. **set_rich_menu_default**
     - リッチメニューをデフォルトとして設定する。
     - **入力:**
       - `richMenuId` (string): デフォルトとして設定するリッチメニューのID。
-10. **cancel_rich_menu_default**
+12. **cancel_rich_menu_default**
     - デフォルトのリッチメニューを解除する。
     - **入力:**
       - なし

README.md

@@ -25,37 +25,49 @@
      - `message.altText` (string): Alternative text shown when flex message cannot be displayed.
      - `message.contents` (any): The contents of the flex message. This is a JSON object that defines the layout and components of the message.
      - `message.contents.type` (enum): Type of the container. 'bubble' for single container, 'carousel' for multiple swipeable bubbles.
-3. **broadcast_text_message**
+3. **reply_text_message**
+   - Reply with a simple text message to a user via LINE. Use this for sending plain text messages without formatting.
+   - **Inputs:**
+     - `message.text` (string): The plain text content to reply to the user.
+     - `replyToken` (string): Reply token.
+4. **reply_flex_message**
+   - Reply with a highly customizable flex message to a user via LINE. Supports both bubble (single container) and carousel (multiple swipeable bubbles) layouts.
+   - **Inputs:**
+     - `message.altText` (string): Alternative text shown when flex message cannot be displayed.
+     - `message.contents` (any): The contents of the flex message. This is a JSON object that defines the layout and components of the message.
+     - `message.contents.type` (enum): Type of the container. 'bubble' for single container, 'carousel' for multiple swipeable bubbles.
+     - `replyToken` (string): Reply token.
+5. **broadcast_text_message**
    - Broadcast a simple text message via LINE to all users who have followed your LINE Official Account.
    - **Inputs:**
      - `message.text` (string): The plain text content to send to the users.
-4. **broadcast_flex_message**
+6. **broadcast_flex_message**
    - Broadcast a highly customizable flex message via LINE to all users who have added your LINE Official Account.
    - **Inputs:**
      - `message.altText` (string): Alternative text shown when flex message cannot be displayed.
      - `message.contents` (any): The contents of the flex message. This is a JSON object that defines the layout and components of the message.
      - `message.contents.type` (enum): Type of the container. 'bubble' for single container, 'carousel' for multiple swipeable bubbles.
-5. **get_profile**
+7. **get_profile**
    - Get detailed profile information of a LINE user including display name, profile picture URL, status message and language.
    - **Inputs:**
      - `userId` (string?): The ID of the user whose profile you want to retrieve. Defaults to DESTINATION_USER_ID.
-6. **get_message_quota**
+8. **get_message_quota**
    - Get the message quota and consumption of the LINE Official Account. This shows the monthly message limit and current usage.
    - **Inputs:**
      - None
-7. **get_rich_menu_list**
+9. **get_rich_menu_list**
    - Get the list of rich menus associated with your LINE Official Account.
    - **Inputs:**
      - None
-8. **delete_rich_menu**
-   - Delete a rich menu from your LINE Official Account.
-   - **Inputs:**
-     - `richMenuId` (string): The ID of the rich menu to delete.
-9. **set_rich_menu_default**
+10. **delete_rich_menu**
+    - Delete a rich menu from your LINE Official Account.
+    - **Inputs:**
+      - `richMenuId` (string): The ID of the rich menu to delete.
+11. **set_rich_menu_default**
     - Set a rich menu as the default rich menu.
     - **Inputs:**
       - `richMenuId` (string): The ID of the rich menu to set as default.
-10. **cancel_rich_menu_default**
+12. **cancel_rich_menu_default**
     - Cancel the default rich menu.
     - **Inputs:**
       - None

src/common/schema/constants.ts

@@ -1,2 +1,5 @@
 export const NO_USER_ID_ERROR =
   "Error: Specify the userId or set the DESTINATION_USER_ID in the environment variables of this MCP Server.";
+
+export const NO_REPLY_TOKEN_ERROR =
+  "Error: Reply token is required to send a reply message.";

src/index.ts

@@ -23,6 +23,8 @@ import { LINE_BOT_MCP_SERVER_VERSION, USER_AGENT } from "./version.js";
 import CancelRichMenuDefault from "./tools/cancelRichMenuDefault.js";
 import PushTextMessage from "./tools/pushTextMessage.js";
 import PushFlexMessage from "./tools/pushFlexMessage.js";
+import ReplyFlexMessage from "./tools/replyFlexMessage.js";
+import ReplyTextMessage from "./tools/replyTextMessage.js";
 import BroadcastTextMessage from "./tools/broadcastTextMessage.js";
 import BroadcastFlexMessage from "./tools/broadcastFlexMessage.js";
 import GetProfile from "./tools/getProfile.js";
@@ -48,6 +50,8 @@ const messagingApiClient = new line.messagingApi.MessagingApiClient({
 
 new PushTextMessage(messagingApiClient, destinationId).register(server);
 new PushFlexMessage(messagingApiClient, destinationId).register(server);
+new ReplyTextMessage(messagingApiClient).register(server);
+new ReplyFlexMessage(messagingApiClient).register(server);
 new BroadcastTextMessage(messagingApiClient).register(server);
 new BroadcastFlexMessage(messagingApiClient).register(server);
 new GetProfile(messagingApiClient, destinationId).register(server);

src/tools/replyFlexMessage.ts

@@ -0,0 +1,48 @@
+import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
+import { messagingApi } from "@line/bot-sdk";
+import { z } from "zod";
+import {
+  createErrorResponse,
+  createSuccessResponse,
+} from "../common/response.js";
+import { AbstractTool } from "./AbstractTool.js";
+import { NO_REPLY_TOKEN_ERROR } from "../common/schema/constants.js";
+import { flexMessageSchema } from "../common/schema/flexMessage.js";
+
+export default class PushFlexMessage extends AbstractTool {
+  private client: messagingApi.MessagingApiClient;
+
+  constructor(client: messagingApi.MessagingApiClient) {
+    super();
+    this.client = client;
+  }
+
+  register(server: McpServer) {
+    server.tool(
+      "reply_flex_message",
+      "Push a highly customizable flex message to a user via LINE. Supports both bubble (single container) and carousel " +
+        "(multiple swipeable bubbles) layouts.",
+      {
+        message: flexMessageSchema,
+        replyToken: z.string().describe("Reply token."),
+      },
+      async ({ message, replyToken }) => {
+        if (!replyToken) {
+          return createErrorResponse(NO_REPLY_TOKEN_ERROR);
+        }
+
+        try {
+          const response = await this.client.replyMessage({
+            messages: [message as unknown as messagingApi.Message],
+            replyToken: replyToken,
+          });
+          return createSuccessResponse(response);
+        } catch (error) {
+          return createErrorResponse(
+            `Failed to reply flex message: ${error.message}`,
+          );
+        }
+      },
+    );
+  }
+}

src/tools/replyTextMessage.ts

@@ -0,0 +1,47 @@
+import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
+import { messagingApi } from "@line/bot-sdk";
+import { z } from "zod";
+import {
+  createErrorResponse,
+  createSuccessResponse,
+} from "../common/response.js";
+import { AbstractTool } from "./AbstractTool.js";
+import { NO_REPLY_TOKEN_ERROR } from "../common/schema/constants.js";
+import { textMessageSchema } from "../common/schema/textMessage.js";
+
+export default class PushTextMessage extends AbstractTool {
+  private client: messagingApi.MessagingApiClient;
+
+  constructor(client: messagingApi.MessagingApiClient) {
+    super();
+    this.client = client;
+  }
+
+  register(server: McpServer) {
+    server.tool(
+      "reply_text_message",
+      "Push a simple text message to a user via LINE. Use this for sending plain text messages without formatting.",
+      {
+        message: textMessageSchema,
+        replyToken: z.string().describe("Reply token."),
+      },
+      async ({ message, replyToken }) => {
+        if (!replyToken) {
+          return createErrorResponse(NO_REPLY_TOKEN_ERROR);
+        }
+
+        try {
+          const response = await this.client.replyMessage({
+            messages: [message as unknown as messagingApi.Message],
+            replyToken: replyToken,
+          });
+          return createSuccessResponse(response);
+        } catch (error) {
+          return createErrorResponse(
+            `Failed to reply message: ${error.message}`,
+          );
+        }
+      },
+    );
+  }
+}