jKjC#^dZddlmZddlmZmZddlmZmZddlm Z ddl m Z ddl m Z mZmZdd lmZdd lmZdd lmZmZmZdd lmZmZdd lmZddlmZmZddl m!Z!ddl"m#Z#ddl$m%Z%m&Z&m'Z'm(Z(m)Z)ddl*m+Z+gdZ,GddZ-Gdde-Z.ddZ/ddZ0ddZ1 d d!dZ2y)"ucPostHog MCP analytics SDK — product analytics for Model Context Protocol servers. Wrap a Python MCP server (``FastMCP`` or low-level ``mcp.server.Server``) so every tool call, agent intent, and failure is captured to PostHog as a ``$mcp_*`` event:: from posthog import Posthog from posthog.mcp import instrument from mcp.server.fastmcp import FastMCP posthog = Posthog("phc_...", host="https://us.i.posthog.com") server = FastMCP("my-server") analytics = instrument(server, posthog) Install is just ``pip install posthog``. ``instrument()`` needs the MCP SDK at runtime, but anyone wrapping a server already has it (you built the server with it), so it's treated as a peer dependency — imported lazily and version-checked inside ``instrument()`` rather than bundled. ``PostHogMCP`` for custom dispatchers needs nothing beyond posthog. ) annotations)datetimetimezone)AnyOptional)Client) capture_event)POSTHOG_MCP_ANALYTICS_SOURCEPostHogMCPAnalyticsEventPostHogMCPAnalyticsProperty)MCPAnalyticsEventType drain_pending)MCPAnalyticsDataget_server_tracking_dataset_server_tracking_data)log set_logger) PostHogMCP)"derive_session_id_from_mcp_sessionnew_session_id) McpEventSink)get_more_tools_result)CaptureEventDataMCPAnalyticsContextOptionsMCPAnalyticsOptionsPreparedToolCall UserIdentity) __version__) instrument McpAnalyticsrrrrrrrrrr r r r c*eZdZdZddZdddZd dZy) r"zHandle returned by :func:`instrument`. Use it to capture custom events for the instrumented server without passing the server object around.c||_yN)_key)selfkeys e/Users/ahmed/devFolder/Ultron/claude-voice/.venv/lib/python3.12/site-packages/posthog/mcp/__init__.py__init__zMcpAnalytics.__init__Qs  Nc *Kt|tr|s tdt|j}|yt ||j tj|tjtj|d}| |d{yy7w)zCapture a custom event for this server. ``event`` is sent verbatim (a customer-defined event, so it is not ``$``-prefixed).zTcapture() requires an event name, e.g. await analytics.capture("feedback_submitted")N) session_id event_type event_name timestamp properties) isinstancestr ValueErrorrr&r r-rCUSTOMrnowrutc)r'eventr1datacoros r)capturezMcpAnalytics.captureTs%%Uf ( 2 <  "oo3::#%\\(,,7(      JJ  sBB B Bc4Ktd{y7w)zAwait in-flight auto-captured events scheduled on the current event loop. Call this before ``posthog.shutdown()`` on exit so trailing tool-call events aren't dropped. (Then call ``posthog.flush()``/``shutdown()`` to send them.)Nr)r's r)flushzMcpAnalytics.flushksos )r(rreturnNoner%r8r3r1zOptional[dict]r>r?r>r?)__name__ __module__ __qualname____doc__r*r;r=r+r)r"r"MsI.r+r"c*eZdZdfd ZdddZxZS)_NoopAnalyticsc$t|dyr%)superr*)r' __class__s r)r*z_NoopAnalytics.__init__ss r+c Kywr%rF)r'r8r1s r)r;z_NoopAnalytics.capturevs srAr%r@)rBrCrDr*r; __classcell__)rKs@r)rHrHrsr+rHcD||S ddlm}|S#t$rYywxYw)Nr)setup)posthogrO Exception)posthog_clientrOs r)_resolve_clientrSzs/!!w s  c ddlm}|d}d|jdddD\}}||fdks|dk\rt d |d yy#t$rYywxYw) aAThe adapters hook private MCP SDK seams (``_tool_manager``, ``_mcp_server``, ``request_handlers``) tested against ``mcp>=1.26,<2``. Since ``mcp`` is a peer dependency we don't pin, advise at runtime when the installed version is outside that range rather than failing hard (older/newer may still mostly work).r)versionmcpc32K|]}t|ywr%)int).0ps r) z3_warn_if_unsupported_mcp_version..sA(@1A(@s.N)r zEWarning: PostHog MCP analytics is tested against mcp>=1.26,<2; found zJ. Instrumentation hooks private SDK internals and may behave unexpectedly.)importlib.metadatarUsplitrQr)rU installedmajorminors r) _warn_if_unsupported_mcp_versionrds| .EN A (=1.26'. (PostHogMCP for custom dispatchers works without it.)r ) is_fastmcp is_fastmcp_v2is_low_level_server)instrument_fastmcp)instrument_fastmcp_v2instrument_low_levelzBWarning: no PostHog client available; MCP events will not be sent.zCinstrument() - server already instrumented, skipping initialization)optionssinkr-zUnsupported server type: zU. Pass a FastMCP (official or jlowin's fastmcp 2.0) or a low-level mcp.server.Server.z'Warning: failed to instrument server - )rloggerrrV ImportErrorModuleNotFoundErrorrd_compatibilityrlrmrn_instrument_fastmcpro_instrument_lowlevelrprqrjrSrrr"rrrr TypeErrortyperQrH)rhrRrroptsrVrlrmrnrorprqr(clientrsr9errors r)r!r!sm&  +)+D {{4;;   %&NN7Q F #C  0 > T U #C ( 4 U V$ $'-'9|F#t4NDTU d+ f  vt , 6 " !&$ /  (  .+DL+; s0D&#8D>B D>&D;> E)E$E)$E))rROptional[Client]r>rrA)rhrr>r)NN)rhrrRrrrzOptional[MCPAnalyticsOptions]r>r")3rE __future__rrrtypingrrposthog.clientr_capturer constantsr r r _event_typesr_instrumentationr _internalrrrrtrr posthog_mcprsessionrr_sinkrtoolsrtypesrrrrrrUr __all__r"rHrSrdrjr!rFr+r)rs &#' !# 0+ $#G(! &""J\ &:(,-1H H $H +H  H r+