Google Chat MCP Server

#!/usr/bin/env node import { Server } from "@modelcontextprotocol/sdk/server/index.js"; import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js"; import { CallToolRequestSchema, ListToolsRequestSchema, McpError, ErrorCode, } from "@modelcontextprotocol/sdk/types.js"; import fetch from "node-fetch"; import * as dotenv from "dotenv"; import { join } from "path"; import { buildTodoCard } from "./todoBuilder.js"; import { summaryBuilder } from "./summaryBuilder.js"; dotenv.config({ path: join(process.cwd(), ".env") }); // Load environment variables from .env file class GoogleChatServer { server; spaceId; apiKey; apiToken; constructor() { this.server = new Server({ name: "google-chat-server", version: "0.1.0" }, { capabilities: { tools: {} } }); this.spaceId = process.env.GOOGLE_CHAT_SPACE_ID; this.apiKey = process.env.GOOGLE_CHAT_API_KEY; this.apiToken = process.env.GOOGLE_CHAT_TOKEN; if (!this.spaceId || !this.apiKey || !this.apiToken) { console.error("Error: GOOGLE_CHAT_SPACE_ID, GOOGLE_CHAT_API_KEY, and GOOGLE_CHAT_TOKEN must be set in .env"); process.exit(1); } this.setupToolHandlers(); this.server.onerror = (error) => console.error("[MCP Error]", error); process.on("SIGINT", async () => { await this.server.close(); process.exit(0); }); } setupToolHandlers() { this.server.setRequestHandler(ListToolsRequestSchema, async () => ({ tools: [ { name: "post_text_message", description: "Post a text message to a Google Chat space.", inputSchema: { type: "object", properties: { text: { type: "string", description: "The text content of the message to be posted.", }, }, required: ["text"], }, }, { name: "send_todo", description: "Send a formatted todo message to Google Chat space", inputSchema: { type: "object", properties: { todoList: { type: "string", description: "The list of todo events", }, }, required: ["todoList"], }, }, { name: "send_summary", description: "Send a summary link and title in a card to a Google Chat space.", inputSchema: { type: "object", properties: { link: { type: "string", description: "The link to be sent in the summary card", }, title: { type: "string", description: "The title of the card", } }, required: ["link", "title"], }, }, ], })); this.server.setRequestHandler(CallToolRequestSchema, async (request) => { const toolName = request.params.name; const args = request.params.arguments; switch (toolName) { case "post_text_message": return await this.handlePostTextMessage(args); case "send_todo": return await this.handleSendTodo(args); case "send_summary": return await this.handleSendSummary(args); default: throw new McpError(ErrorCode.MethodNotFound, `Unknown tool: ${toolName}`); } }); } async handleSendSummary(args) { try { const { link, title } = args; const card = summaryBuilder(link, title); const response = await fetch(`https://chat.googleapis.com/v1/spaces/${this.spaceId}/messages?key=${this.apiKey}&token=${this.apiToken}`, { method: "POST", headers: { "Content-Type": "application/json" }, body: JSON.stringify(card), }); if (!response.ok) { const errorText = await response.text(); throw new Error(`HTTP ${response.status}: ${errorText}`); } const responseData = await response.json(); return { content: [ { type: "text", text: `Todo posted successfully. Response: ${JSON.stringify(responseData)}`, }, ], }; } catch (error) { return { content: [ { type: "text", text: `Error posting summary: ${error.message}`, }, ], isError: true, }; } } async handleSendTodo(args) { try { const { todoList } = args; const card = buildTodoCard(todoList); const response = await fetch(`https://chat.googleapis.com/v1/spaces/${this.spaceId}/messages?key=${this.apiKey}&token=${this.apiToken}`, { method: "POST", headers: { "Content-Type": "application/json" }, body: JSON.stringify(card), }); if (!response.ok) { const errorText = await response.text(); throw new Error(`HTTP ${response.status}: ${errorText}`); } const responseData = await response.json(); return { content: [ { type: "text", text: `Todo posted successfully. Response: ${JSON.stringify(responseData)}`, }, ], }; } catch (error) { return { content: [ { type: "text", text: `Error posting todo: ${error.message}`, }, ], isError: true, }; } } async handlePostTextMessage(args) { try { const { text } = args; const payload = { text }; console.log("space_id:", this.spaceId); console.log("key:", this.apiKey); console.log("token:", this.apiToken); console.log("text:", text); const response = await fetch(`https://chat.googleapis.com/v1/spaces/${this.spaceId}/messages?key=${this.apiKey}&token=${this.apiToken}`, { method: "POST", headers: { "Content-Type": "application/json" }, body: JSON.stringify(payload), }); if (!response.ok) { const errorText = await response.text(); throw new Error(`HTTP ${response.status}: ${errorText}`); } const responseData = await response.json(); return { content: [ { type: "text", text: `Message posted successfully. Response: ${JSON.stringify(responseData)}`, }, ], }; } catch (error) { return { content: [ { type: "text", text: `Error posting message: ${error.message}`, }, ], isError: true, }; } } async run() { const transport = new StdioServerTransport(); await this.server.connect(transport); console.error("Google Chat MCP server running on stdio"); } } const server = new GoogleChatServer(); server.run().catch(console.error);