$j1UdZddlmZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z mZddlmZmZe rdd lmZdd lmZdd lmZejeZd;dZe ddGddZdd!Z"d?d#Z#d@d$Z$d;d%Z%dAd&Z&d@d'Z'dBd*Z(iZ)d+e d,<dCd0Z*dDd2Z+eZ,d3e d4<d5Z-dEd8Z.dFd:Z/dS)Ga%Task context and scoping for background task execution. Determines authorization scope (``get_task_scope``), manages the context snapshot that is captured at task submission and restored in workers (``TaskContextSnapshot``), and maintains in-process registries for live sessions and servers. ) annotationsN) OrderedDict) ContextVar) dataclass) TYPE_CHECKINGAny)parse_task_keytask_redis_prefix)Docket) ServerSession)FastMCPreturn str | Nonecddlm}|}|dS|jr|jdnd}|r |jd|S|jS)uTGet the authorization scope for task isolation. Returns the raw scope identifier for the current access token, or ``None`` when no auth context is present (anonymous tasks). The scope is composed as ``client_id|sub`` when the token carries a ``sub`` claim — necessary for fixed-OAuth servers where ``client_id`` is shared across all users — and falls back to ``client_id`` alone for DCR/CIMD flows where the client identity is already per-user. Encoding for Redis/Docket keys happens at the boundary in ``keys.py``; this function returns the raw value. r)get_access_tokenNsub|)fastmcp.server.dependenciesrclaimsget client_id)rtokenrs d/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/fastmcp/server/tasks/context.pyget_task_scopersu=<<<<<    E }t%*\ ;%,  5 ! ! !tC */))C))) ?T)frozenslotsc*eZdZUdZded< ded<dS)TaskContextInfozInformation about the current background task context. Returned by ``get_task_context()`` when running inside a Docket worker. Contains identifiers needed to communicate with the MCP session. strtask_idr task_scopeN)__name__ __module__ __qualname____doc____annotations__rrrr7s6 LLL2PPrrTaskContextInfo | Nonecddlm}|sdSddlm} |}t |j}t|d|dS#t$rYdSttf$rYdSwxYw)aJGet the current task context if running inside a background task worker. This function extracts task information from the Docket execution context. Returns None if not running in a task context (e.g., foreground execution). Returns: TaskContextInfo with task_id and task_scope, or None if not in a task. r)is_docket_availableN)current_executionclient_task_idr")r!r") rr+docket.dependenciesr,rr keyr LookupError ValueErrorKeyError)r+r, execution key_partss rget_task_contextr5Fs@?????   t555555 %))++ "9=11 ./ .     tt  !ttsAA B,B?BceZdZUdZdZded<dZded<dZded<dZded<e dd Z e dd Z ddZ ddZ dS)TaskContextSnapshotzAll context data snapshotted at task-submission time. Stored as a single Redis key per task, restored once in the worker. Nraccess_token_jsonzdict[str, str] | None http_headersorigin_request_id session_idrcddlm}m}m}|}|}|j} |j}n#t $rd}YnwxYw||r|nd|dpd|t|j nd|S)z6Capture current context for background task execution.r)r get_contextget_http_headersNT) include_allr8r9r:r;) rrr=r>request_contextr; RuntimeErrormodel_dump_jsonr request_id)clsrr=r> access_tokenctxrAr;s rcapturezTaskContextSnapshot.captureos          (')) kmm- JJ   JJJ s2>H ,,...D))d;;;Ct3B3NO.///TX!    s / >>raw str | bytesct|tr|}tj|}|d}t|t rd|D}||d||d|dS)z&Deserialize from JSON stored in Redis.r9cri|]4\}}t|t|5Sr()r lower).0kvs r z1TaskContextSnapshot.from_json..s2JJJ$!Qs1vv||~~s1vvJJJrr8r:r;r@) isinstancebytesdecodejsonloadsrdictitems)rErIparsedheaderss r from_jsonzTaskContextSnapshot.from_jsons c5 ! ! **,,CC**^,, gt $ $ KJJ'--//JJJGs$jj)<== $jj)<==zz,//     rr c\tj|j|j|j|jdS)z$Serialize to JSON for Redis storage.r@)rUdumpsr8r9r:r;)selfs rto_jsonzTaskContextSnapshot.to_jsons7z%)%; $ 1%)%;"o      rdocketr r"r! ttl_secondsintNonec.K|t||}|4d{V}||||d{Vdddd{VdS#1d{VswxYwYdS)z*Store this snapshot as a single Redis key.N)ex)r/_snapshot_redis_keyredissetr_)r^r`r"r!rar/rgs rsavezTaskContextSnapshot.savesDjj,ZAABB<<>> A A A A A A AU))CK)@@ @ @ @ @ @ @ @ A A A A A A A A A A A A A A A A A A A A A A A A A A A A A As1B BB)rr7)rIrJrr7)rr ) r`r r"rr!r rarbrrc)r#r$r%r&r8r'r9r:r; classmethodrHr[r_rir(rrr7r7cs %)((((*.L....$(((((!J!!!!   [ 4    [        A A A A A Arr7 task_snapshot)defaultz2ContextVar[tuple[str, TaskContextSnapshot] | None]_task_snapshotr!r snapshotrcc>t||fdS)z"Cache a snapshot keyed by task_id.N)rmrh)r!rns r_set_cached_snapshotrps!*+++++rTaskContextSnapshot | NonecVt}| |\}}||kr|SdS)z/Get cached snapshot if it belongs to this task.N)rmr)r!cachedcached_task_idrns r_get_cached_snapshotrus8    ! !F #)  W $ $O 4rr"c,t|d|dS)z/Build the Redis key suffix for a task snapshot.:z :snapshot)r )r"r!s rrfrfs! ++ @ @g @ @ @@rc Kt|}||Sddlm}m} |j}n#t $rd}YnwxYw||}|dS |4d{V}||t||d{V}dddd{Vn#1d{VswxYwY|dSt |}t|||S#ttjt t"f$r"t$d||dYdSwxYw)uLoad task context snapshot from Redis (async) and cache it. Idempotent — returns the cached value if already loaded for this task. Nr)_current_docket get_serverz&Failed to load task snapshot for %s:%sTexc_info)rurryrz_docketrBrrgr/rfr7r[rpOSErrorrUJSONDecodeErrorr2r1_loggerwarning) r"r!rsryrzr`rgrIrns r_load_task_snapshot_asyncrs5"' * *F  GGGGGGGG%  ~ $$&& ~t<<>> X X X X X X XU &**-@W-U-U"V"VWWWWWWWWC X X X X X X X X X X X X X X X X X X X X X X X X X X X ;4&0055Wh/// T)8Z @ 4      ttsI/ >>D6=C3D CDCD+DAE  E c4t}|r|jndS)aGet the session_id for the current background task, if available. Loads the task snapshot (from cache or Redis) and returns the session_id that was captured at task submission time. Returns None if not in a task context or if the snapshot isn't available. N)_get_task_snapshot_syncr;)rns rget_task_session_idrs"'((H"* 48  4rct}|dSt|j}||St|j|jS)zGet the task snapshot using only sync operations. Fallback chain: 1. ContextVar cache (keyed by task_id, set by async or sync loaders) 2. Sync Redis GET (works for both memory:// and real Redis) N)r5rur!_load_task_snapshot_syncr") task_inforss rrrsK!""It !)"3 4 4F  #I$8):K L LLrc ddlm}|}n#ttf$rYdSwxYw|dS t |j}||t||}|dSt |}t|||S#ttjtt tf$r"t"d||dYdSwxYw)zLoad snapshot via sync Redis. For memory:// backends (fakeredis), shares the same FakeServer instance that Docket uses so data is accessible. For real Redis, creates a standard sync connection. r)current_docketNz5Failed to load task snapshot via sync Redis for %s:%sTr{)r.rrr0 ImportError_get_sync_redisurlr/rfr7r[rpr~rUrr2r1rr)r"r! _docket_cvr` sync_redisrIrns rrrs"DDDDDD!!  %tt ~t$VZ00 nnVZZ(;J(P(PQQRR ;4&0055Wh/// T)8Z M C      tts%22A B4+B44AC>=C>rrcddlm}||}|ddlm}||Sddlm}||S)aGet a sync Redis client that shares the same backend as Docket. For memory:// URLs, connects to the same fakeredis FakeServer instance so data written by the async Docket client is visible. For real Redis URLs, creates a standard sync connection. r)get_memory_serverN) FakeRedis)server)Redis) docket._redisr fakeredisrrgrfrom_url)rrrrrs rrr6su0/////  s # #F ''''''y'''' >>#  rz%dict[str, weakref.ref[ServerSession]]_task_sessionsr;sessionr c>tj|t|<dS)zRegister a session for in-process background task access. Called automatically when a task is submitted to Docket. The session is stored as a weakref so it doesn't prevent garbage collection when the client disconnects. N)weakrefrefr)r;rs rregister_task_sessionrUs")W!5!5N:rServerSession | Nonect|}|dS|}|t|d|S)uGet a registered session by ID if still alive. Returns None in distributed workers where the session lives in another process — callers must handle this gracefully. N)rrpop)r;rrs rget_task_sessionr_sL   Z ( (C {tceeG:t,,, Nrz&OrderedDict[str, weakref.ref[FastMCP]]_task_server_mapi'rr ctj|t|<tttkr:tdtttk8dSdS)zRegister the server for a background task. Called at task-submission time so that background workers can resolve the correct (child) server for mounted tasks. F)lastN)rrrlen_TASK_SERVER_MAP_MAX_SIZEpopitem)r!rs rregister_task_serverrrsh !( F 3 3W   "; ; ;  e ,,,   "; ; ; ; ; ; ;rFastMCP | Nonect|}|dS|}|t|d|S)z@Get the registered server for a background task, if still alive.N)rrr)r!rrs rget_task_serverr}sJ   w ' 'C {t SUUF ~Wd+++ Mr)rr)rr))r!r rnr7rrc)r!r rrq)r"rr!r rr )r"rr!r rrq)rrq)rr rr)r;r rr rrc)r;r rr)r!r rr rrc)r!r rr)0r& __future__rrUloggingr collectionsr contextvarsr dataclassesrtypingrrfastmcp.server.tasks.keysr r r`r mcp.server.sessionr fastmcp.server.serverr getLoggerr#rrrr5r7rmr'rprurfrrrrrrrrrrrrr(rrrs0#""""" ######""""""!!!!!!%%%%%%%%GGGGGGGG.000000------ ' H % %2 $d### Q Q Q Q Q Q Q$# Q: $d###KAKAKAKAKAKAKA$#KA`FPZTFFF ,,,, AAAA %%%%P5555MMMM$!!!!H89;::::6666