Web3 Research MCP

Implementation Reference

• src/tools/researchTools.ts:409-485 (handler)

  The main handler function for the 'search-source' tool. It takes tokenName, tokenTicker, and source as input, calls the searchSource helper, stores results, fetches content from the top result, saves it as a resource, and returns a formatted text response.
  async ({ tokenName, tokenTicker, source, }: { tokenName: string; tokenTicker: string; source: string; }) => { storage.addLogEntry( `Searching ${source} for ${tokenName} (${tokenTicker})` ); try { const results = await searchSource(tokenName, tokenTicker, source); storage.addToSection("searchResults", { [source]: results, }); let responseText = `Search results for ${source} about ${tokenName} (${tokenTicker}):\n\n`; if (results.results && results.results.length > 0) { const topResults = results.results.slice(0, 5); responseText += JSON.stringify(topResults, null, 2); if (topResults[0] && topResults[0].url) { const url = topResults[0].url; responseText += `\n\nFetching content from top result: ${url}`; try { await sleep(3000); const content = await fetchContent(url, "text"); const resourceId = `${source.toLowerCase()}_${tokenName.toLowerCase()}_${new Date().getTime()}`; storage.addToSection("resources", { [resourceId]: { url, format: "text", content, source, fetchedAt: new Date().toISOString(), }, }); responseText += `\n\nContent has been saved as a resource. Use 'research://resource/${resourceId}' to access it.`; } catch (fetchError) { responseText += `\n\nCould not fetch content from URL: ${fetchError}`; } } } else { responseText += `No results found.`; } return { content: [ { type: "text", text: responseText, }, ], }; } catch (error) { storage.addLogEntry(`Error searching ${source}: ${error}`); return { isError: true, content: [ { type: "text", text: `Error searching ${source}: ${error}`, }, ], }; } } );
• src/tools/researchTools.ts:402-408 (schema)

  Zod input schema for the 'search-source' tool defining parameters tokenName, tokenTicker, and source.
  { tokenName: z.string().describe("Name of the token"), tokenTicker: z.string().describe("Ticker symbol of the token"), source: z .string() .describe("Source to search (e.g., 'Dune', 'IQ Wiki', 'News')"), },
• src/tools/researchTools.ts:400-485 (registration)

  Registration of the 'search-source' tool in registerResearchTools function using McpServer.tool().
  server.tool( "search-source", { tokenName: z.string().describe("Name of the token"), tokenTicker: z.string().describe("Ticker symbol of the token"), source: z .string() .describe("Source to search (e.g., 'Dune', 'IQ Wiki', 'News')"), }, async ({ tokenName, tokenTicker, source, }: { tokenName: string; tokenTicker: string; source: string; }) => { storage.addLogEntry( `Searching ${source} for ${tokenName} (${tokenTicker})` ); try { const results = await searchSource(tokenName, tokenTicker, source); storage.addToSection("searchResults", { [source]: results, }); let responseText = `Search results for ${source} about ${tokenName} (${tokenTicker}):\n\n`; if (results.results && results.results.length > 0) { const topResults = results.results.slice(0, 5); responseText += JSON.stringify(topResults, null, 2); if (topResults[0] && topResults[0].url) { const url = topResults[0].url; responseText += `\n\nFetching content from top result: ${url}`; try { await sleep(3000); const content = await fetchContent(url, "text"); const resourceId = `${source.toLowerCase()}_${tokenName.toLowerCase()}_${new Date().getTime()}`; storage.addToSection("resources", { [resourceId]: { url, format: "text", content, source, fetchedAt: new Date().toISOString(), }, }); responseText += `\n\nContent has been saved as a resource. Use 'research://resource/${resourceId}' to access it.`; } catch (fetchError) { responseText += `\n\nCould not fetch content from URL: ${fetchError}`; } } } else { responseText += `No results found.`; } return { content: [ { type: "text", text: responseText, }, ], }; } catch (error) { storage.addLogEntry(`Error searching ${source}: ${error}`); return { isError: true, content: [ { type: "text", text: `Error searching ${source}: ${error}`, }, ], }; } } );
• src/utils/searchUtils.ts:145-186 (helper)

  Helper function implementing the core search logic for specific sources by adding relevant extra search terms and delegating to performSearch (which uses DuckDuckGo scraper). This is the exact implementation of the search functionality called by the tool handler.
  export async function searchSource( tokenName: string, tokenTicker: string, source: string ): Promise<any> { const extraTerms = ["crypto", "token"]; switch (source.toLowerCase()) { case "coinmarketcap": extraTerms.push("price", "market", "chart"); break; case "docs": extraTerms.push("documentation", "whitepaper", "github"); break; case "vesting": extraTerms.push("tokenomics", "schedule", "unlock"); break; case "raise": extraTerms.push("funding", "investment", "ico", "seed"); break; case "news": extraTerms.push("latest", "announcement", "update"); break; case "crypto token": case "dashboard": case "iq wiki": case "dune": extraTerms.push("dashboard", "crypto", "stats"); break; case "airdrop": break; default: } const query = `${tokenName} ${tokenTicker} ${source} ${extraTerms.join(" ")}`; if (source.toLowerCase() === "news") { return performSearch(query, "news"); } return performSearch(query, "web"); }
• src/tools/index.ts:5-10 (registration)

  Top-level tool registration entrypoint that invokes registerResearchTools, which registers 'search-source' among other tools.
  export function registerAllTools( server: McpServer, storage: ResearchStorage ): void { registerResearchTools(server, storage); }