i+dZddlmZddlZddlZddlmZdZeejvrejjdeddZ y)u; Genesis KB MCP Tools — Module 9 ================================= Registers 3 MCP tools on a FastMCP instance for platform knowledge base operations: search, list, and ingest. Stories implemented: 9.01 — search_platform_kb — Semantic search across the KB bloodstream 9.02 — list_platform_kbs — List platforms with vector + ingestion stats 9.03 — ingest_platform_kb — Trigger full platform ingestion pipeline Usage: from kb_tools import register_kb_tools register_kb_tools(mcp) # adds 3 tools to an existing FastMCP instance ) annotationsN) TYPE_CHECKINGz/mnt/e/genesis-systemc|jddd}|jdd}|jdd d}y) z|Register all 3 KB tools on the given FastMCP instance. Args: mcp: A FastMCP instance to register tools on. c|r|js yddlm}m}|r|jr|jj }|||}|Dcgc]V}|j ddj |k(s/|j ddj j |r|X}}|s |||Sd|d t|d g} t|d D]\} }| jd | d |j ddd|j ddd|j ddd | jd|j ddt|j dddd} | jd| | jddj| S|||Scc}w)aSearch the platform knowledge base for relevant documentation. Performs semantic search across the Genesis bloodstream Qdrant collection using Gemini embeddings. Returns a formatted context string suitable for injection into an LLM prompt. Args: query: Natural language search query. platform: Optional platform filter (e.g. "hubspot", "telnyx", "ghl"). Leave empty to search all platforms. top_k: Number of results to return (default 5). Returns: Formatted context string with the top matching KB entries, or a message indicating no results were found. zPlease provide a non-empty search query to search the platform KB. Example: search_platform_kb('How do I configure a Telnyx AI assistant?')r) rag_context rag_query)questiontop_kplatformsourcez$=== BLOODSTREAM KNOWLEDGE (platform=, z matches) === [z] titlez (score: scorez, type: type)z Source: contentNiz  ) stripcore.rag_queryrrlowerget startswithlen enumerateappendstrjoin) queryr r rrplatresultsrfilteredlinesirs :/mnt/e/genesis-system/mcp-servers/genesis-core/kb_tools.pysearch_platform_kbz-register_kb_tools..search_platform_kb)s$EKKM[  : (>>#))+De.list_platform_kbsas K;J"$ J -/L ')  !#D! **3D$aHG5>$+Ddhh~txx e7TUVKs;/"4)#2. HH_e4EXX.6F LLTF#gYc'#k]#eWCPVxWYZ ' .%((!<  R 8HI 1#i.1ABCyyo L !*')Jt$*    !JJL  sG HG0HH%H G- G((G-0H>HHH HH%HH% H"!H"%I )H:9I : II II cddlm}m}ddlm}||}|&|}d|d|rdj |d Sdd S t j||| }|jdd} |jdd} d} | dkDr2|jdgdd} dj d| D} d| } d|jd|jddd|jddd|jddd|jddd | d!| d"d#| S#t$r}d |cYd}~Sd}~wt$r}d |d |dcYd}~Sd}~wwxYw)$aSTrigger platform KB ingestion and return a progress summary. Runs the full ingestion pipeline: sitemap fetch -> extract -> chunk -> embed -> upsert to Qdrant + PostgreSQL. Args: platform: Platform name (e.g. "hubspot", "telnyx", "ghl"). Must match a registered platform in the registry. max_pages: Maximum number of pages to ingest (default 100, safety limit to prevent runaway ingestions). Returns: Formatted summary with pages, chunks, vectors, errors, and duration. r)r,r+)ingest_platformNzUnknown platform: 'z'. Registered platforms: rz(none)z8 Use list_platform_kbs() to see all available platforms.)r max_pageszIngestion failed: zIngestion error for platform 'z': z Check server logs for details.duration_secondserrorsr error_detailsz; c3jK|]+}|jddd|jdd-yw)step?z: errorN)r).0ds r( z@register_kb_tools..ingest_platform_kb..s;!55$%Rgc(:';<!s13z First errors: zIngestion complete for 'z' Pages fetched: r6z Pages skipped: pages_skippedz" (unchanged) Chunks created: r7z Vectors upserted: vectors_upsertedz Errors: z Duration: z.1fs) r9r,r+core.kb.orchestratorrOr asynciorun ValueErrorr<rr>)r rPr,r+rOrE registeredstatsr@durationrR error_notedetailssnippetss r(ingest_platform_kbz-register_kb_tools..ingest_platform_kbs K8h' >')J%hZ0)BL:)>([\JJ RZ([\JJ  KKYGE99/38Q' A:ii4Ra8Gyy! !H,H:6J'v':':&;<##(99_a#@"AB##(99_a#@"AB##(99-=q#A"BC##(99-?#C"DE##)(+##+C.l  ) .'u- - 0 #cUC11  s0D E(D2,E2 E>E E EN)r )r!rr rr intreturnr)rlr)d)r rrPrkrlr)tool)mcpr)rMris r(register_kb_toolsrp"sT XXZ1818n XXZN N h XXZ> > )rlNone) __doc__ __future__rr`systypingr _PROJECT_ROOTpathinsertrprqr(r{sC # (  HHOOA}%S rq