߲jdZddlmZmZmZmZddlmZddl m Z ddl m Z ddl mZmZmZmZddlmZmZddddddd d eeefd eegefd eed eedeedeeeeefgeefdeegefdefdZddddeeddddddidddiddddd gd!d"gid#d$dd%dd&gd'd(Zej4dd)ed*d+d,-y).zConnection lifecycle tool for managed gateway accounts and local MCP servers. Disconnecting accounts remains a portal-only user decision. )AnyCallableDictOptional)config)run_managed_action)run_mcp_operation) ALL_ACTIONS MCP_ACTIONSnormalize_targetsvalidate_action)registry tool_errorN)client_factory mcp_backend session_id tool_call_idconnection_callbackconnectors_availableargsrrrrrrreturnc Xt|jdxsdjj}t |jd\}} } | r t | St ||| } | r t | S|tvrt| |||||St||||||||S)Nactionstatus connectors)backendrrr)rrrrr) strgetstriplowerr rr r r r) rrrrrrrrmanaged mcp_targets target_error action_errors :/home/ubuntu/.hermes/hermes-agent/tools/connectors/tool.pymanage_connectionsr&s(#/x 0 6 6 8 > > @F):488L;Q)R&G[,,''"67K@L,''   3 Ye  %*</FZ r&u Connect the user to apps. Two kinds: a hosted connector account (Gmail, Notion, ...) served through the tool gateway, and a local MCP server from the bundled catalog. Targets go in 'connectors': a bare slug or {"name": "gmail"} is a hosted connector account; {"name": "linear", "mcp": true} is a local MCP server. Many names exist on both sides, so the user's own words decide. Pass "mcp": true only when the user asks for an MCP server, a local server or an install, or when the name exists only as a catalog entry; otherwise the target is hosted. 'connect' and 'reconnect' are hosted actions; 'install', 'enable' and 'authorize' are MCP actions. A target the other side owns is refused with the call that does work. Hosted actions: 'status' lists connectors and whether each is connected; 'connect' starts an authorization for the given connectors; 'reconnect' checks each one and repairs only what is not connected ('force': true restarts even a working one, for an account switch). Pass SEVERAL slugs in one call. In the desktop app, the terminal UI and the interactive CLI the call shows the user a card and blocks until every app is connected, skipped, or the deadline passes; the result lists each target as connected / skipped / not_connected and never carries a link. Where no card exists (a one-shot run, a scheduled job, a messaging platform) the result carries a connect_url per app for the USER to open in a browser (never open it yourself); ask them to say when they are done, then use 'status'. When a hosted connector tool call returns CONNECTION_REQUIRED, use 'connect'. MCP actions (every target must carry "mcp": true): 'install' adds a catalog entry, 'enable' re-enables a disabled configured server, 'authorize' runs its OAuth. They show the user an approval card and block until it settles. Never hand-edit mcp_servers config — always use this tool. After a skip or a timeout, do not re-ask on your own: continue without the app or ask in chat. A later request from the USER for that same app is not a re-ask — run it. A connected server's tools are named in the result and are callable at once through tool_describe/tool_call. Where no card exists an MCP target runs at once and the result says what happened, with a link for the user to open when one is needed. This tool can NOT disconnect, delete, or revoke an account — that is deliberately user-only. When asked, say so and direct the user to the Nous Portal (their org's Connectors page) or the desktop app.objectstringzDefaults to status. connect and reconnect take hosted connector slugs only. install, enable and authorize take mcp:true targets only.)typeenum descriptionarrayanyOfr*booleanzYtrue = a local MCP server from the catalog; absent or false = a hosted connector account.)r*r,)namemcpr0F)r* propertiesrequiredadditionalPropertieszTargets. REQUIRED for every action but status (e.g. ["gmail", {"name": "linear", "mcp": true}]); optional filter for status. A bare slug is a hosted connector, so an MCP server needs the object form with "mcp": true.)r*itemsr,zXreconnect only: restart the authorization even if the app is connected (account switch).)rrforce)r*r2r3)r0r, parameters connectionsc Xt||jdtjS)Nr)rr)r&rgateway_configr)rkws r%r<s"1  -NDgDg r'c*tjS)N)r:rr'r%r<r<s^88:r'u🔗)r0toolsetschemahandlercheck_fnemoji)__doc__typingrrrrtools.connectors.gatewayrr:tools.connectors.managedrtools.connectors.mcpr tools.connectors.targetsr r r r tools.registryrrrboolr&listMANAGE_CONNECTIONS_SCHEMAregisterr>r'r%rOs 10=72aa/ 37!% $"&OS9= sCx.Xb#g./#    3- "(DcN+;Xc]+J"KL#8BH#56 @ ! H@![)P  *$,)/(:,5)N(" +*049*//<"yM* V[.EQh   $  ; r'