format by deno

Author: light4

index.ts

@@ -10,7 +10,7 @@ import morgan from "morgan";
 import { z } from "zod";
 import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
 import { SSEServerTransport } from "@modelcontextprotocol/sdk/server/sse.js";
-import { Client, estypes, ClientOptions } from "@elastic/elasticsearch";
+import { Client, ClientOptions, estypes } from "@elastic/elasticsearch";
 import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
 import fs from "fs";
 
@@ -74,13 +74,13 @@ const ConfigSchema = z
       message:
         "Either ES_API_KEY or both ES_USERNAME and ES_PASSWORD must be provided, or no auth for local development",
       path: ["username", "password"],
-    }
+    },
   );
 
 type ElasticsearchConfig = z.infer<typeof ConfigSchema>;
 
 export async function createElasticsearchMcpServer(
-  config: ElasticsearchConfig
+  config: ElasticsearchConfig,
 ) {
   const validatedConfig = ConfigSchema.parse(config);
   const { url, apiKey, username, password, caCert } = validatedConfig;
@@ -105,7 +105,7 @@ export async function createElasticsearchMcpServer(
       console.error(
         `Failed to read certificate file: ${
           error instanceof Error ? error.message : String(error)
-        }`
+        }`,
       );
     }
   }
@@ -149,7 +149,7 @@ export async function createElasticsearchMcpServer(
         console.error(
           `Failed to list indices: ${
             error instanceof Error ? error.message : String(error)
-          }`
+          }`,
         );
         return {
           content: [
@@ -162,7 +162,7 @@ export async function createElasticsearchMcpServer(
           ],
         };
       }
-    }
+    },
   );
 
   // Tool 2: Get mappings for an index
@@ -190,19 +190,21 @@ export async function createElasticsearchMcpServer(
             },
             {
               type: "text" as const,
-              text: `Mappings for index ${index}: ${JSON.stringify(
-                mappingResponse[index]?.mappings || {},
-                null,
-                2
-              )}`,
+              text: `Mappings for index ${index}: ${
+                JSON.stringify(
+                  mappingResponse[index]?.mappings || {},
+                  null,
+                  2,
+                )
+              }`,
             },
           ],
         };
       } catch (error) {
         console.error(
           `Failed to get mappings: ${
             error instanceof Error ? error.message : String(error)
-          }`
+          }`,
         );
         return {
           content: [
@@ -215,7 +217,7 @@ export async function createElasticsearchMcpServer(
           ],
         };
       }
-    }
+    },
   );
 
   // Tool 3: Search an index with simplified parameters
@@ -242,10 +244,10 @@ export async function createElasticsearchMcpServer(
           },
           {
             message: "queryBody must be a valid Elasticsearch query DSL object",
-          }
+          },
         )
         .describe(
-          "Complete Elasticsearch query DSL object that can include query, size, from, sort, etc."
+          "Complete Elasticsearch query DSL object that can include query, size, from, sort, etc.",
         ),
     },
     async ({ index, queryBody }) => {
@@ -266,9 +268,11 @@ export async function createElasticsearchMcpServer(
         if (indexMappings.properties) {
           const textFields: Record<string, estypes.SearchHighlightField> = {};
 
-          for (const [fieldName, fieldData] of Object.entries(
-            indexMappings.properties
-          )) {
+          for (
+            const [fieldName, fieldData] of Object.entries(
+              indexMappings.properties,
+            )
+          ) {
             if (fieldData.type === "text" || "dense_vector" in fieldData) {
               textFields[fieldName] = {};
             }
@@ -294,9 +298,11 @@ export async function createElasticsearchMcpServer(
 
           for (const [field, highlights] of Object.entries(highlightedFields)) {
             if (highlights && highlights.length > 0) {
-              content += `${field} (highlighted): ${highlights.join(
-                " ... "
-              )}\n`;
+              content += `${field} (highlighted): ${
+                highlights.join(
+                  " ... ",
+                )
+              }\n`;
             }
           }
 
@@ -328,7 +334,7 @@ export async function createElasticsearchMcpServer(
         console.error(
           `Search failed: ${
             error instanceof Error ? error.message : String(error)
-          }`
+          }`,
         );
         return {
           content: [
@@ -341,7 +347,7 @@ export async function createElasticsearchMcpServer(
           ],
         };
       }
-    }
+    },
   );
 
   // Tool 4: Get shard information
@@ -392,7 +398,7 @@ export async function createElasticsearchMcpServer(
         console.error(
           `Failed to get shard information: ${
             error instanceof Error ? error.message : String(error)
-          }`
+          }`,
         );
         return {
           content: [
@@ -405,7 +411,7 @@ export async function createElasticsearchMcpServer(
           ],
         };
       }
-    }
+    },
   );
 
   return server;
@@ -426,10 +432,10 @@ async function create_sse_server(server: any) {
   // Use morgan to log every request
   app.use(morgan("combined"));
 
-  const transports: {[sessionId: string]: SSEServerTransport} = {};
+  const transports: { [sessionId: string]: SSEServerTransport } = {};
 
   app.get("/sse", async (_: Request, res: Response) => {
-    const transport = new SSEServerTransport('/messages', res);
+    const transport = new SSEServerTransport("/messages", res);
     transports[transport.sessionId] = transport;
     res.on("close", () => {
       delete transports[transport.sessionId];
@@ -443,7 +449,7 @@ async function create_sse_server(server: any) {
     if (transport) {
       await transport.handlePostMessage(req, res);
     } else {
-      res.status(400).send('No transport found for sessionId');
+      res.status(400).send("No transport found for sessionId");
     }
   });
 
@@ -479,7 +485,7 @@ async function main() {
 main().catch((error) => {
   console.error(
     "Server error:",
-    error instanceof Error ? error.message : String(error)
+    error instanceof Error ? error.message : String(error),
   );
   process.exit(1);
 });