+ ll4t7]PA4R?R@l4t8]PA4RARBl4t9]PA4RCRDl4t:]PA4RERFl4t;]PA4RGRHl4t<]PA4RIRJl4t=]PA4RKRLl4t>]PA4R~RMRNll4t?]PA4RRORPll4t@]PA4RRQRRll4tA]PA4R}RSRTll4tB]PA4RRURVll4tC]PA4RWRXl4tD]PA4RRYRZll4tE]PA4RR[R\ll4tF]PA4RR]R^ll4tG]PA4R}R_R`ll4tH]PA4RaRbl4tI]PA4RcRdl4tJ]PA4RReRfll4tK]PA4RzRgRhll4tL]PA4RiRjl4tM]PA4R{RkRlll4tN]PA4RRmRnll4tO]PA4RRoRpll4tP]P4tR]PtS]Rq4tTRrRsltURtRultV!RvRw4tWRxRyltXR#)uShared jarvis-tools MCP endpoint (streamable-HTTP) for Railway. Mirrors the memory service's proven pattern so the SAME claude.ai custom connector setup works. Two doors, one handler, auth enforced BEFORE the MCP handler runs: • POST /mcp — Authorization: Bearer $JARVIS_TOOLS_KEY (Claude Code --header) • POST /mcp/ — token = first 32 hex of sha256(JARVIS_TOOLS_KEY) (path-secret door for claude.ai custom connectors, whose UI can't send custom headers; OAuth is overkill here). If JARVIS_TOOLS_KEY is empty, BOTH doors are open. Tools = the shared Google Drive folder (list/read/write/delete). Smartlead and the Ultron DB can be added here later as more @mcp.tool()s on the same connector. ) annotationsN)asynccontextmanager)FastMCP)TransportSecuritySettings)RouteJARVIS_TOOLS_KEYzBearer :N Nz jarvis-toolsTF)enable_dns_rebinding_protectionuAhmed's shared Jarvis storage — one Google Drive folder ('Jarvis Drive') any Claude on any device can read and write. drive_list to see what's there, drive_read to read a file (e.g. an Apollo CSV), drive_write to save one, drive_delete to remove one. It ONLY sees this one shared folder, never Ahmed's personal Drive. The asana_* tools are Ahmed's project management — everything he could do in the Asana web app: list/create/update/archive projects, invite people to them (asana_project_members) and post status updates; read a task in full (asana_task), list, create, update, move between projects/columns, complete, delete (recoverable 30 days) and break tasks into subtasks; set assignees, followers and tags; post and READ comment threads; and search. asana_api is the escape hatch for anything else in Asana's REST API. Prefer archiving a project over deleting it — archive is reversible.)stateless_http json_responsetransport_security instructionscV^8dQhRR/#returnstr)formats" mcp_server.py __annotate__rEs<<#<cx"\PP\P4GRjxL #L5i)z1List the files in the shared Jarvis Drive folder.N)anyio to_threadrun_syncdrive list_filesrrr drive_listrD())%*:*:; ;; ; 1:8:c V^8dQhRRRR/#rfilerrr)rs"rrrKsII3I3Ircfa"\PPV3Rl4GRjxL #L5i)zFRead a text/csv/json file from the shared folder. `file` = name or id.c0<\P!S4#N)r read_filer$srdrive_read..Ms%//$2GrNrrrr)sfr drive_readr-Js$))*GH HH H '1/1c$V^8dQhRRRRRR/#rnamercontentrr)rs"rrrQs&SSCS#S#Srcjaa"\PPVV3Rl4GRjxL #L5i)zHCreate or overwrite a text file in the shared folder from given content.c2<\P!SS4#r')r write_filer2r1srr*drive_write..Ss%2B2B42QrNr,r1r2sffr drive_writer9Ps$))*QR RR R (313c V^8dQhRRRR/#r#r)rs"rrrWsKKSKSKrcfa"\PPV3Rl4GRjxL #L5i)zBRemove (trash) a file from the shared folder. `file` = name or id.c0<\P!S4#r')r delete_filer)srr*drive_delete..Y%2C2CD2IrNr,r)sfr drive_deleterAVs$))*IJ JJ Jr.cV^8dQhRR/#rr)rs"rrr^s??3?rcx"\PP\P4GRjxL #L5i)z=List Ahmed's Smartlead cold-email campaigns and their status.N)rrr smartlead campaignsrrrsmartlead_campaignsrF]s()))*=*=> >> >r!c V^8dQhRRRR/#)rcampaignrrr)rs"rrrdsVVSVSVrcfa"\PPV3Rl4GRjxL #L5i)zMAnalytics for one campaign (sent/open/reply/bounce). `campaign` = id or name.c0<\P!S4#r')rDcampaign_statsrHsrr**smartlead_campaign_stats..fs)2J2J82TrNr,rLsfrsmartlead_campaign_statsrNcs$))*TU UU Ur.cV^8dQhRR/#rr)rs"rrrjs===rcx"\PP\P4GRjxL #L5i)zCList sender inboxes and their warmup reputation / daily send limit.N)rrrrDsendersrrrsmartlead_sendersrRis()))*;*;< << .rs)2K2KD2QrNr,rXsfrsmartlead_create_campaignrZos$))*QR RR Rr.c$V^8dQhRRRRRR/#)rrHr sequence_jsonrr)rs"rrrvs&AA3AsAsArcjaa"\PPVV3Rl4GRjxL #L5i)zSet a campaign's email sequence. sequence_json = JSON array of steps {seq_number, seq_delay_details:{delay_in_days}, subject, email_body}.c2<\P!SS4#r')rD set_sequencerHr\srr*(smartlead_set_sequence..zs &&x?rNr,r`sffrsmartlead_set_sequencerbus0))?A AA Ar:c$V^8dQhRRRRRR/#)rrHr leads_jsonrr)rs"rrr~s!;;;;;rcjaa"\PPVV3Rl4GRjxL #L5i)zxAdd leads to a campaign. leads_json = JSON array of {email, first_name, last_name, company_name, ...}. Max 100 per call.c2<\P!SS4#r')rD add_leadsrHrdsrr*%smartlead_add_leads..s ##Hj9rNr,rhsffrsmartlead_add_leadsrj}s,))9; ;; ;r:c$V^8dQhRRRRRR/#)rrHractionrr)rs"rrrs!>>s>C>C>rcjaa"\PPVV3Rl4GRjxL #L5i)zEStart / pause / stop a campaign. action = 'start' | 'pause' | 'stop'.c2<\P!SS4#r')rDcampaign_control)rlrHsrr*,smartlead_campaign_control..s **8V >> >r:c(V^8dQhRRRRRRRR/#)rmethodrpath body_jsonrr)rs"rrrs(88838388rcnaaa"\PPVVV3Rl4GRjxL #L5i)uEscape hatch — call ANY Smartlead REST endpoint. method=GET/POST/DELETE, path after /api/v1 (api_key added for you), body_json = JSON body for writes.c4<\P!SSS4#r')rDraw)rursrtsrr*smartlead_api..s fdI6rNr,)rsrtrusfffr smartlead_apirzs,))68 88 8 )535c$V^8dQhRRRRRR/#)rsqlrconfirmrr)rs"rrrs&QQCQ#QsQrcjaa"\PPVV3Rl4GRjxL #L5i)uRun SQL against the Ultron master DB (18k+ leads + CRM: clients, contacts, users…). SELECT to read/aggregate, INSERT/UPDATE to write. Irreversible statements (drop/truncate, WHERE-less delete/update) need confirm='yes'.c2<\P!SS4#r') ultron_dbquery)r~r}srr*ultron_query..s)//#w2OrNr,)r}r~sffr ultron_queryrs$ ))*OP PP Pr:c V^8dQhRRRR/#)rtablerrr)rs"rrrsKKsKCKrcfa"\PPV3Rl4GRjxL #L5i)utInspect the DB: no table → all tables with row counts; with a table → its columns. Use before composing a query.c0<\P!S4#r')rschemarsrr*ultron_schema..s)2B2B52IrNr,rsfr ultron_schemar$))*IJ JJ Jr.c V^8dQhRRRR/#)rrrrr)rs"rrrsOOsOsOrcfa"\PPV3Rl4GRjxL #L5i)zSearch EVERYWHERE Ahmed keeps people/leads (memory graph, Ultron leads DB, Jarvis Drive sheets) by phone number or name. Use whenever Ahmed asks who someone is or gives an unknown number.c0<\P!S4#r')lookup person_lookuprsrr*person_lookup..s&2F2Fu2MrNr,rsfrrrs$ ))*MN NN Nr.c ,V^8dQhRRRRRRRRRR/#rtorsubjectbodyccrr)rs"rrrs/666s6#6366rcraaaa"\PPVVVV3Rl4GRjxL #L5i)zSend an email from Ahmed's business mailbox (ahmad@revalstudio.com). `to` and `cc` are comma-separated; cc optional. Namecheap takes ~15-30s to deliver.c6<\P!SSSS4#r')emailboxsendrrrrsrr*email_send..s b'44rNr,rrrrsffffr email_sendrs,))46 66 6 *757c$V^8dQhRRRRRR/#rrrlimitintrr)rs"rrrs&QQcQ#QsQrcjaa"\PPVV3Rl4GRjxL #L5i)z{Search the business inbox by phrase (sender+subject; empty = latest). Returns a list with a UID per message for email_read.c2<\P!SS4#r')rsearchrrsrr*email_search..s(//%2OrNr,rrsffr email_searchrs$))*OP PP Pr:c V^8dQhRRRR/#)ruidrrr)rs"rrrsFF#F#Frcfa"\PPV3Rl4GRjxL #L5i)z.s(--2DrNr,rsfr email_readr$))*DE EE Er.c ,V^8dQhRRRRRRRRRR/#rr)rs"rrrs/>>>s>#>3>>rcraaaa"\PPVVVV3Rl4GRjxL #L5i)zHSend an email from Ahmed's WORK Gmail (alrugaib). to/cc comma-separated.c6<\P!SSSS4#r') gworkspace gmail_sendrsrr*gmail_send..s %%b'4 >> >rc$V^8dQhRRRRRR/#rr)rs"rrrs!77c7#7s7rcjaa"\PPVV3Rl4GRjxL #L5i)zqSearch the WORK Gmail inbox (Gmail query syntax; empty = latest). Returns a message id per result for gmail_read.c2<\P!SS4#r')r gmail_searchrsrr*gmail_search..s ''u5rNr,rsffrrrs,))57 77 7r:c V^8dQhRRRR/#)r message_idrrr)rs"rrrsUUUUrcfa"\PPV3Rl4GRjxL #L5i)z7Read the full body of one WORK Gmail message by its id.c0<\P!S4#r')r gmail_readrsrr*gmail_read..s*2G2G 2SrNr,rsfrrrs$))*ST TT Tr.c V^8dQhRRRR/#)rdaysrrrr)rs"rrrsRRcR#Rrcfa"\PPV3Rl4GRjxL #L5i)zBList Ahmed's WORK calendar events for the next N days (default 7).c0<\P!S4#r')r calendar_listrsrr*calendar_list..s*2J2J42PrNr,rsfrrrs$))*PQ QQ Qr.c4V^8dQhRRRRRRRRRRRRRR/#) rtitlerstartend attendees descriptionadd_meetrr)rs"rrrsJBBsB3BSB+.BBEB*-B7:Brczaaaaaa"\PPVVVVVV3Rl4GRjxL #L5i)zCreate a WORK calendar event. start/end = ISO datetime with timezone (2026-07-15T14:00:00+03:00). attendees = comma-separated emails (invited). add_meet='yes' attaches a Google Meet link.c:<\P!SSSSSS4#r')rcalendar_create_event)rrrrrrsrr*'calendar_create_event..s 00 5#y+xArNr,)rrrrrrsffffffrrrs9)) A AB BB B ,;9;c$V^8dQhRRRRRR/#)rspreadsheet_idra1_rangerr)rs"rrrs&BBcBSBSBrcjaa"\PPVV3Rl4GRjxL #L5i)zORead a range from a Google Sheet (work account). a1_range e.g. 'Sheet1!A1:D20'.c2<\P!SS4#r')r sheets_read)rrsrr*sheets_read..s &&~x@rNr,)rrsffrrrs0))@B BB Br:c(V^8dQhRRRRRRRR/#)rrrr values_jsonrr)rs"rrrs0PPsPcP$'P,/Prcnaaa"\PPVVV3Rl4GRjxL #L5i)zkWrite to a Google Sheet range (work account). values_json = JSON array of rows, e.g. [["a","b"],["c","d"]].c4<\P!SSS4#r')r sheets_write)rrrsrr*sheets_write..s ''+NrNr,)rrrsfffrrrs0 ))NP PP Pr{c$V^8dQhRRRRRR/#r0r)rs"rrrs&PPcPCPCPrcjaa"\PPVV3Rl4GRjxL #L5i)zSave a text file to the shared writable storage (syncs across all devices). `name` = file name/path (e.g. 'crm/riyadh.csv'), `content` = the full text. This is where Jarvis/AIs put files for each other (drive_* is read-only).c2<\P!SS4#r')storagewriter6srr*storage_write..s'--g2NrNr,r8sffr storage_writers$ ))*NO OO Or:c V^8dQhRRRR/#rTr)rs"rrrsFFSFSFrcfa"\PPV3Rl4GRjxL #L5i)z?Read a file back from the shared writable storage by name/path.c0<\P!S4#r')rrrXsrr*storage_read..s',,t2DrNr,rXsfr storage_readrrr.cV^8dQhRR/#rr)rs"rrr s>>C>rcx"\PP\P4GRjxL #L5i)z.List the files in the shared writable storage.N)rrrrrrrr storage_listr s())'*<*<= == =r!c V^8dQhRRRR/#rTr)rs"rrrsHHsHsHrcfa"\PPV3Rl4GRjxL #L5i)z.s'..2FrNr,rXsfrstorage_deleters$))*FG GG Gr.cV^8dQhRR/#rr)rs"rrrs<<.#s%..2QrNr,)rrsffrasana_projectsr s$))*QR RR Rr:c 0V^8dQhRRRRRRRRRRRR/#)rr1rteamnotesdue_onprivacyrr)rs"rrr'sAJJSJJJ'*J:=JGJJrcvaaaaa"\PPVVVVV3Rl4GRjxL #L5i)zCreate an Asana project. `team` is required only if the workspace is an ORGANIZATION (the tool says so, and names the teams, if it is). `privacy` = public_to_workspace | private_to_team | private.c8<\P!SSSSS4#r')rproject_create)rr1rrr srr*&asana_project_create..-s$$T4HrNr,)r1r rrrsfffffrasana_project_creater&s3 ))HHJ JJ J +979c4V^8dQhRRRRRRRRRRRRR R/#) rprojectrr1rrownerarchive bool | Nonerr)rs"rrr1sJTTT3TCT'*T8;T(3T?BTrczaaaaaa"\PPVVVVVV3Rl4GRjxL #L5i)uChange a project (`project` = name or id): rename, notes, due_on, owner, or archive=True to ARCHIVE it (reversible, keeps everything — this is how you retire a project; deleting one is not offered here because it can't be undone, use asana_api if you truly mean DELETE).c:<\P!SSSSSS4#r')rproject_update)rrr1rrrsrr*&asana_project_update..9s$$WdE65'RrNr,)rr1rrrrsffffffrasana_project_updater 0s3))RRT TT Trc ,V^8dQhRRRRRRRRRR/#)rrraddremove access_levelrr)rs"rrr=s8KKK3KSK.1K;>Krcraaaa"\PPVVVV3Rl4GRjxL #L5i)aJWho's on a project, and invite/remove them. `add`/`remove` = comma-separated emails, names or ids ('me' works). `access_level` = admin|editor|commenter|viewer. No add/remove = list them. This shares a project with someone already in the workspace; inviting a NEW person to Asana itself is asana_api POST /workspaces/{gid}/addUser.c6<\P!SSSS4#r')rproject_members)r$r"rr#srr*'asana_project_members..Es%%gsFLIrNr,)rr"r#r$sffffrasana_project_membersr)<s0))IK KK Krc ,V^8dQhRRRRRRRRRR/#)rrrtext status_typerrr)rs"rrrIs9III3I,/I&)I36Ircraaaa"\PPVVVV3Rl4GRjxL #L5i)z`Post a project status update. status_type = on_track | at_risk | off_track | on_hold | complete.c6<\P!SSSS4#r')rproject_status)rr,r+rsrr*&asana_project_status..Os$$WdKGrNr,)rr+r,rsffffrasana_project_statusr1Hs0 ))GI II Irc V^8dQhRRRR/#rtaskrrr)rs"rrrSsDD3D3Drcfa"\PPV3Rl4GRjxL #L5i)zFULL detail of ONE task (`task` = name or id): notes, assignee, due date, project, section, tags, followers, subtasks and the latest comments.c0<\P!S4#r')rr4r4srr*asana_task..Vs%**T2BrNr,r7sfr asana_taskr9Rs$))*BC CC Cr.c 0V^8dQhRRRRRRRRRRR R/#) rrrminersection completedrrrr)rs"rrrZsAGGsGtGSG!%G69GCFGrcvaaaaa"\PPVVVVV3Rl4GRjxL #L5i)zList Asana tasks. `project` (name or id) = that project's; add `section` for one board column; empty project with mine=True = 'what's on my plate'. Open tasks only unless completed=True.c8<\P!SSSSS4#r')rtasks)r=rr;rr<srr*asana_tasks..`s GT7IuErNr,)rr;r<r=rsfffffr asana_tasksrBYs3 ))EEG GG Grc8V^8dQhRRRRRRRRRRRRRRR R/#) rr1rrrassigneerr<parentrr)rs"rrrdsI44#4c44&)4:=4%(47:4DG4rc ~aaaaaaa"\PPVVVVVVV3Rl4GRjxL #L5i)zCreate an Asana task. `project` = project name or id (optional), `section` = a board column in it, `parent` = another task to make this a SUBTASK of, `due_on` = YYYY-MM-DD, `assignee` = 'me' or a user id/email/name.c <<\P!SSSSSSS4#r')r task_create)rDrr1rrErr<srr*#asana_task_create..ks!!$w&")63rNr,)r1rrrDrr<rEsfffffffrasana_task_createrJcs3)) 3 34 44 4 -=;=c8V^8dQhRRRRRRRRRRRRRR R R/#) rr4rr1rrstart_onrDcompleterrr)rs"rrrpsN - -# -S -c -$' -8; -&) -'2 ->A -rc ~aaaaaaa"\PPVVVVVVV3Rl4GRjxL #L5i)zChange a task (`task` = name or id): rename, edit notes, set due_on (YYYY-MM-DD), reassign, or set complete true/false. `start_on` needs a due date too AND a paid Asana plan (it 402s on a free workspace).c <<\P!SSSSSSS4#r')r task_update)rDrNrr1rrMr4srr*#asana_task_update..xs!!$eVXx"*,rNr,)r4r1rrrMrDrNsfffffffrasana_task_updaterSos3)) , ,- -- -rKc ,V^8dQhRRRRRRRRRR/#)rr4rrr< remove_fromrr)rs"rrr}s8FFFcFF'*F47Frcraaaa"\PPVVVV3Rl4GRjxL #L5i)zMove a task to another `project` and/or `section`. A REAL move: it is removed from the project it was in (Asana's addProject alone would leave it in both). `section` alone moves it between columns of its current project.c6<\P!SSSS4#r')r task_move)rrUr<r4srr*!asana_task_move..sgw DrNr,)r4rr<rUsffffrasana_task_moverZ|s0 ))DF FF Frc V^8dQhRRRR/#r3r)rs"rrrsMMCMCMrcfa"\PPV3Rl4GRjxL #L5i)z1Mark an Asana task done. `task` = its name or id.c0<\P!S4#r')r task_completer7srr*%asana_task_complete..s%2E2Ed2KrNr,r7sfrasana_task_completer`s$))*KL LL Lr.c V^8dQhRRRR/#r3r)rs"rrrsKK#K#Krcfa"\PPV3Rl4GRjxL #L5i)uDelete an Asana task. It goes to Deleted Items and is recoverable for 30 days. Only when he means DELETE — 'it's done' is asana_task_complete.c0<\P!S4#r')r task_deleter7srr*#asana_task_delete..r@rNr,r7sfrasana_task_deleterfrr.c4V^8dQhRRRRRRRRRRRRRR/#) rr4rrD add_followersremove_followersadd_tag remove_tagrr)rs"rrrsB88#88+.8GJ8%(8;>8HK8rczaaaaaa"\PPVVVVVV3Rl4GRjxL #L5i)zWho/what is on a task: set the assignee, add/remove followers (comma-separated names, emails or 'me'), add/remove tags (a new tag is created if needed). With no changes it just reports.c:<\P!SSSSSS4#r')r task_people)rhrjrDrirkr4srr*#asana_task_people..s!!$-AQ"):7rNr,)r4rDrhrirjrksffffffrasana_task_peoplerps3)) 7 78 88 8rc$V^8dQhRRRRRR/#)rr4rr"rr)rs"rrrs&MMsMMcMrcjaa"\PPVV3Rl4GRjxL #L5i)zNList a task's subtasks, or create them: `add` = comma-separated subtask names.c2<\P!SS4#r')rsubtasks)r"r4srr* asana_subtasks..s%..s2KrNr,)r4r"sffrasana_subtasksrv$))*KL LL Lr:c$V^8dQhRRRRRR/#)rr4rr+rr)rs"rrrs&MMcMMMrcjaa"\PPVV3Rl4GRjxL #L5i)uOPost a comment on an Asana task (`task` = name or id) — e.g. a status update.c2<\P!SS4#r')rcommentr4r+srr*asana_comment..s%--d2KrNr,r|sffr asana_commentr~rwr:c$V^8dQhRRRRRR/#)rr4rrrrr)rs"rrrs&OOsO3OOrcjaa"\PPVV3Rl4GRjxL #L5i)zdREAD a task's comment thread (system events skipped). `limit` = how many of the latest (default 10).c2<\P!SS4#r')rcomments)rr4srr* asana_comments..s%..u2MrNr,)r4rsffrasana_commentsrs$))*MN NN Nr:c4V^8dQhRRRRRRRRRRRRR R/#) rrrrrD due_before due_afterr=rrr)rs"rrrsA ) )c ) )S )#& )8; )"- )9< )rczaaaaaa"\PPVVVVVV3Rl4GRjxL #L5i)u6Find tasks by phrase, with optional filters (project, assignee='me' or a name, due_before/due_after as YYYY-MM-DD, completed). Uses Asana's premium search when the plan has it, else name-matching typeahead. The search index lags up to a minute — for a task just created, use asana_task / asana_tasks instead.c:<\P!SSSSSS4#r')rr)rDr=rrrrsrr*asana_search..s UGXz9&(rNr,)rrrDrrr=sffffffr asana_searchrs3)) ( () )) )rc ,V^8dQhRRRRRRRRRR/#)rrsrrtru params_jsonrr)rs"rrrs8AACAsAsA!$A.1Arcraaaa"\PPVVVV3Rl4GRjxL #L5i)uEscape hatch — call ANY Asana REST endpoint (base https://app.asana.com/api/1.0) for what the curated asana_* tools don't cover: sections, tags, teams, attachments, dependencies, templates, goals, portfolios, custom fields, webhooks, batch, inviting a NEW person to the workspace, deleting a project. method = GET/POST/PUT/DELETE. path = everything after /api/1.0, e.g. '/projects/12345/sections'. ENVELOPE: do NOT wrap body_json in {"data": ...} — that's added for you. Just pass the inner object: {"name": "Q3 launch", "workspace": "12345"}. The response is unwrapped from `data` for you too. OPT_FIELDS (important): Asana returns ONLY gid/resource_type/name by default. To get real fields, pass them in params_json: params_json = {"opt_fields": "name,due_on,completed,assignee.name", "limit": 50} Dot-notation reaches into related objects (assignee.name, projects.name). Returns raw JSON.c6<\P!SSSS4#r')rrx)rursrrtsrr*asana_api..s &$ ;?rNr,)rsrtrursffffr asana_apirs0())?A AA Arc"\P4;_uu_4GRjxL R5xRRR4GRjxL R#LL +GRjxL 'giR#;i5i)zIEnter from the FastAPI lifespan so the session manager's task group runs.N)session_managerrunrrrlifespanrs0""$$$ %$$$$$sF!A ?A A A AA A A A  A A  A c V^8dQhRRRR/#)rtokenz str | Nonerrr)rs"rrrsJJjJTJrc^\'gR#Ve\P!V\4#VP R.4UUu/uF2wr#VP 4P 4VP 4bK4 ppp\P!VP RR4\4#uuppi)Theaders authorizationr)API_KEYhmaccompare_digest PATH_TOKENgetdecodelower_BEARER)scoperkvrs&& r _authorizedrs 7 ""5*55 99Y35341xxz!188:-3 5   w{{?B? II5s8B)cV^8dQhRR/#rrNoner)rs"rrrsTT4Trcl"V!RRRRRR ./4GRjxL V!RRRR/4GRjxL R#LL5i) typezhttp.response.startstatusirNzhttp.response.bodyrs{"error":"unauthorized"})s content-typesapplication/jsonr)rs&r_rejectrsT -xBCE FFF ,f6QR SSSFSs404244c,]tRtRtRtRRltRtRtR#)_DoorizHASGI gate in front of the shared MCP handler. mode: 'header' or 'token'.cV^8dQhRR/#)rmoderr)rs"rr_Door.__annotate__sSrc WnR#r'r)selfrs&&r__init___Door.__init__s rc P"VR,R8wd\V4GRjxL R#VPR8Xd"VPR/4PR4MRp\W4'g\V4GRjxL R#\P WV4GRjxL R#LL(L 5i)rhttpNr path_params)rrrrrhandle_request)rrreceiverrs&&&& r__call___Door.__call__s =F "$-   II(="-11':.2 5(($-   ,,UTBBB Bs4B&B AB&9B":B&B$B&"B&$B&rN)__name__ __module__ __qualname____firstlineno____doc__rr__static_attributes__rrrrrsR CrrcV^8dQhRR/#rr)rs"rrrsDD$DrcVPPP\R\ R444VPPP\R\ R444R#)z=Attach both MCP doors to an existing FastAPI / Starlette app.z/mcpheaderz /mcp/{token}rN)routerroutesappendrr)apps&rmountrsHJJU65?;<JJU>5>BCr)r) ))rrr)rF)rrrr)rrrrN)on_trackr)rTrF2)rrmerrr)rrrrrN)rrrrr)rr)Yr __future__rhashlibros contextlibrrmcp.server.fastmcprmcp.server.transport_securityrstarlette.routingrrrrrrrDrrenvironrrrsha256encode hexdigestrmcptoolrr-r9rArFrNrRrZrbrjrqrzrrrrrrrrrrrrrrrrrrr rr r)r1r9rBrJrSrZr`rfrprvr~rrrstreamable_http_app_rrrrrrrrrrs  # * &C#   **..+R 0 G9 CJW^^GNN, - 7 7 9# >r  1(-/ Q2< < I I S S K K ? ? V V = = S S A A; ;> > 8 8Q QK KO O6 6Q Q F F > > 7 7U U R R B BB B P PP PF F > > H H< < S S J JT TK KI ID D G G4 4 -  -F FM M K K 8 8M M M M O O  )  )A A.%% JT CC$Dr