Telegram MCP Server

Instructions

Implementation Reference

• mcp-server/mcp-server.py:20-23 (registration)

  Registration of the MCP tool 'get_unread_messages' using @mcp.tool decorator

  @mcp.tool(
      name="get_unread_messages",
      description="get all unread messages from a given entity id",
  )

• mcp-server/mcp-server.py:24-25 (handler)

  Handler function for the 'get_unread_messages' MCP tool, which proxies the request to the HTTP API endpoint to fetch unread messages.

  async def get_unread_messages(id: int = None) -> list[dict]:
      return get(f"{api_endpoint}get_unread_messages/{id}").json()

• http-server/http-api.py:46-56 (handler)

  HTTP API endpoint handler that implements the logic for retrieving unread messages by getting the unread count from chats and fetching that many messages, marking them as read.

  @app.get("/get_unread_messages/{chat_id}")
  async def get_unread_messages(chat_id: int):
      dialogs = await get_chats()
      if chat_id not in dialogs:
          raise HTTPException(status_code=404, detail=f"Entity {chat_id} not found")
  
      dialog = dialogs[chat_id]
      unread_count = dialog["unread_count"]
  
      return await get_messages(chat_id=chat_id, count=unread_count)