`gjedZddlmZddlZddlmZddlmZddlm Z ddl m Z m Z ddl mZejeZd d Zdd Zdd Zdd Zy)z=Gateway runtime wiring for the Teams meeting pipeline plugin.) annotationsN)Any)Platform)TeamsMeetingPipeline)TeamsPipelineStore!resolve_teams_pipeline_store_path)build_graph_clientc0t|jdxs(|jdxs|jdxsdjj}|dk(r-t |jdxs|jdS|dk(r|jdxs|jd}|jdxs|jd}|jd xs|jd }t |xs|xr|Sy ) Nmode delivery_modeincoming_webhookincoming_webhook_urlgraphchat_idteam_id channel_idF)strgetstriplowerbool) teams_extrateams_deliveryr rrrs Q/root/.hermes/venv/lib/python3.12/site-packages/plugins/teams_pipeline/runtime.py_teams_delivery_is_configuredrs6"    o .  ??? +     egeeg **   5 6 756   $$Y/M;??93M $$Y/M;??93M#'' 5V9V G7 6J88 c|jjtd}t|r|jxsini}t|jdxsi}|r|j rt|jdxsi}t |jdxsdj}|r||d<dD]}|j|}|dvs|||<|rt|||d <||d<|S) zBuild pipeline config from gateway platform config. Pipeline-specific knobs live under ``teams.extra.meeting_pipeline`` while Teams delivery continues to source its target details from the existing Teams platform config. teamsmeeting_pipelinerr r r )r access_tokenrrr>Nr enabled) platformsrrdictextrar"rrr)gateway_config teams_configrpipeline_configrr keyvalues rbuild_pipeline_runtime_configr+&s"++//0ABL\ **0brJK;??+=>D"EO ,,o112BCIrJKOOO<BCIIK %2N6 " ,C OOC(EJ&&+s# , (EkSa(bN9 %0>O, - rcd}|jjjtd}t |j}t |jdxsi}|r-|j r!|jdr ddlm}||}tttt||S#t$rtjdYHwxYw) Nrrr"r)TeamsSummaryWriter)platform_configzlTeamsSummaryWriter unavailable; Teams outbound delivery remains disabled until the adapter layer is present.) graph_clientstoreconfig teams_sender)r1r#rrr+r$r"plugins.platforms.teams.adapterr- ImportErrorloggerdebugrr rr)gatewayr2r'r(rr-s rbuild_pipeline_runtimer8KsL>>++//0ABL3GNNCO/--.>?E2FN ,,1C1CI1N L J .lKL ') !B!DE!    LL~  sB;;CCc|jjtj}|yt |ddy t |dfd }|j||_ d|_y#t $rG}t|}||_tjd|dd}|j|Yd}~yd}~wwxYw) zAAttach the Teams pipeline runtime to the msgraph webhook adapter.NF_teams_pipeline_runtimeTzTeams pipeline runtime unavailable: %s. Installing a drop-scheduler so Graph notifications ack cleanly without piling up unbound.cvKtjd|jd|jdyw)NzMDropping Graph notification because runtime is unavailable: id=%s resource=%sidresource)r5r6r) notificationevents r_dropz#bind_gateway_runtime.._dropws1 LL_  &  , s79cDKj|d{y7w)N)run_notification)r>r?runtimes r _schedulez'bind_gateway_runtime.._schedules&&|444s   )r>dict[str, Any]r?rreturnNone) adaptersrrMSGRAPH_WEBHOOKgetattrr8 Exceptionr_teams_pipeline_runtime_errorr5warningset_notification_schedulerr:)r7adapterexc error_messager@rDrCs @rbind_gateway_runtimerRbs""8#;#;7=B99B>)rrErrErFr)r&rrFrE)r7rrFr)r7rrFr)__doc__ __future__rloggingtypingrgateway.configrplugins.teams_pipeline.pipelinerplugins.teams_pipeline.storerr$plugins.teams_pipeline.subscriptionsr getLogger__name__r5rr+r8rRrrr^sDC"#@^C   8 $,"J.%r