XMTP MCP Server

Instructions

Implementation Reference

• src/index.ts:339-380 (handler)

  The main handler function that implements the get_messages tool logic: creates a DM conversation with the given address, syncs, fetches up to 'limit' messages, formats them as JSON, and returns as text content.

  private async getMessages(args: any) {
    if (!this.state.client) {
      throw new Error("XMTP client not connected. Use connect_xmtp tool first.");
    }
  
    const { address, limit = 50 } = args;
  
    try {
      // Create conversation with proper identifier (back to original method)
      const addressIdentifier = {
        identifier: address,
        identifierKind: 0, // IdentifierKind.Ethereum
      };
      const conversation = await this.state.client.conversations.newDmWithIdentifier(addressIdentifier);
      
      // Sync conversations to ensure we get latest messages
      await this.state.client.conversations.syncAll();
      
      // Add brief delay after sync
      await new Promise(resolve => setTimeout(resolve, 500));
      
      const messages = await conversation.messages({ limit });
  
      const messageList = messages.map((msg: DecodedMessage<any>) => ({
        id: msg.id,
        sender: msg.senderInboxId,
        content: msg.content,
        timestamp: msg.sentAt?.toISOString(),
      }));
  
      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(messageList, null, 2),
          },
        ],
      };
    } catch (error) {
      throw new Error(`Failed to get messages: ${error}`);
    }
  }

• src/index.ts:220-221 (registration)

  Tool dispatch/registration in the CallToolRequestSchema handler switch statement, which calls the getMessages method when 'get_messages' is requested.

  case "get_messages":
    return await this.getMessages(args);

• src/index.ts:150-168 (schema)

  Tool definition including name, description, and input schema (address required, limit optional default 50) in the ListToolsRequestSchema response.

  {
    name: "get_messages",
    description: "Get messages from a conversation with an address",
    inputSchema: {
      type: "object",
      properties: {
        address: {
          type: "string",
          description: "Wallet address to get conversation with",
        },
        limit: {
          type: "number",
          description: "Maximum number of messages to retrieve",
          default: 50,
        },
      },
      required: ["address"],
    },
  },