0jadZddlZddlZddlZddlZddlmZmZm Z m Z m Z m Z m Z mZmZmZmZddlmZddlmZmZddlmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%ddl&m'Z'ddl&m(Z)dd l*m+Z+dd l,m-Z-m.Z.m/Z/m0Z0erdd l1m2Z2d d l3m4Z4d dl5m6Z6d dl7m8Z8d dl9m:Z:d dl;mZ>d dl?m@Z@d dlAmBZBd dlCmDZDd dlEmFZFmGZGmHZHmIZImJZJmKZKd dlLmMZMmNZNd dlOmPZPmQZQd dlRmSZSmTZTd dlUmVZVmWZWd dlXmYZYmZZZd dl[m\Z\d dl]m^Z^d dl_m`Z`d dlambZbejcdd Zde d!e d"ef#Zee d$e eDegef#Zfeed%&d'edZgejheiZjGd(d)eYZkdS)*z[ Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT License. N) TYPE_CHECKINGAny AwaitableCallableListOptionalTypeVarUnionUnpackcastoverload) providers) find_dotenv load_dotenv)Account ActivityBaseActivityParams ApiClientClientCredentialsConversationAccountConversationReference CredentialsFederatedIdentityCredentialsManagedIdentityCredentialsMessageActivityInput SentActivityTokenCredentials TokenProtocol)PUBLIC) from_name) AdaptiveCard)Client ClientOptions EventEmitter LocalStorage)GraphServiceClient)ActivitySender) EventManager) OauthHandlers)PluginProcessor)ActivityProcessor)TokenValidator) validate_remote_function_request) Container)FunctionContext) ErrorEvent EventType StartEvent StopEventget_event_type_from_signatureis_registered_event)FastAPIAdapter HttpServer) HttpRequest HttpResponse) AppOptionsInternalAppOptions) PluginBasePluginStartEvent)ActivityHandlerMixinActivityRouter)ActivityContext) TokenManager)create_graph_client)to_threaded_conversation_idzmicrosoft-teams-appsF.)boundFCtxT)usecwdzteams.py[apps]/c eZdZdZdeefdZedee fdZ ede e fdZ edefdZedeefdZd/d Zd edefd Zd0d ee dd fdZd/dZdedeezezfdZedededeezezdefdZededeezezdefdZ d1dedeezezdeezezd zdefdZdeeege d fdd fdZ!de"fdZ#dee$fdZ%ede&de&fdZ'ede(e efdee&ge&ffdZ'ed0dd dee&ge&ffdZ' d0de(e&e ed fde(e&ee&ge&fffd Z'd0d!ed"ed#eedd fd$Z)d!ed%edd fd&Z*d0d'e(ee+d fde(e+ee+ge+fffd(Z,d/d)Z-d*Z.d0d+eedee/fd,Z0d0d+eedd-fd.Z1d S)2Appz The main Teams application orchestrator. Manages plugins, tokens, and application lifecycle for Microsoft Teams apps. optionsc  tj|_tjd}jjp|rt |nt_jjp t_ _ tt_t__t'jj_t+_jdt1jjjdt1jjjdt1jfdjdt1jjjj jjt1jfdjjptjd pd d }tA|j !tEj# jj$j _%tMjj'}jj(p tS}tU|jj+_,jdt1jj,d_-d_.t_j !tEj# _0tcjjjjj2j jjj$j0j _3tij_5j5j3_5tmjj5jj3_7j78|_'tsjj2j}:|j;<|j=>|j?d_@jrWtjdrDtjCjjDjjEjjFj_@dSdSdS)NCLOUD) credentialscloudidrN bot_tokencjSN)_get_bot_tokenselfs`/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/microsoft_teams/apps/app.pyzApp.__init__..ks 4K^storagecjSrS) http_clientrUsrWrXzApp.__init__..ms cgcsrY SERVICE_URLz%https://smba.trafficmanager.net/teams/)tokenrO)messaging_endpointr8F)default_connection_name event_emitter client_id)application_id_urirO)Gr<from_typeddictrKosgetenvrOcloud_from_namerrZr%_init_http_clientr\r$r2_eventsr@_router_init_credentialsrNrB_token_managerr/ container set_providerrObjectrPFactory __class____name__ service_urlrstriprcloner#rTapi_client_settingsapilistpluginshttp_server_adapterr7r8raserver_port _initializedr(activity_senderr,rbactivity_processorr) event_managerr+_plugin_processorinitialize_pluginsr*on_signin_token_exchangesign_in_token_exchangeon_signin_verify_statesign_in_verify_stateon_signin_failuresign_in_failureentra_token_validatorhasattrr- for_entrard tenant_idre)rVrKcloud_env_namerur{adapteroauth_handlerss` rW__init__z App.__init__SsZ)8AA 7++\'j~,iON,K,K,Kci |+=|~~ 1133#I.00 %'' 1133*(*    # ##D)*:47*C*CDDD ##M93CDDT3U3UVVV ##K1BC^C^C^C^1_1_``` ##Iy/? /M/MNNN ##D$4$>$GIZ[s[s[s[sItItuuu L $ k -(@(@ kDk &++     " "=t7J#K#K#K L L L ,*    %))=$>$>,2Fn6F6F T\=\]]]  ##L)2B4;2O2OPPP$( ! .d.>.D.D]Y]YlEmEmEm.n.noo#4 L G L L 0     L ,  J # # *$,77040B-!0 ND. d>U" " -@@II '$(L$H,    %%n&KLLL ##N$GHHH ~=>>>?C"   (8+ F F )7)A * *#'<#Bj ***D & & &    rYreturnc|jS)zPort the app is running on.)r~rUs rWportzApp.ports zrYc|jS)z+The event emitter instance used by the app.)rkrUs rWeventsz App.events |rYc|jS)zThe activity router instance.)rlrUs rWrouterz App.routerrrYc,|jsdS|jjS)zThe app's ID from credentials.N)rNrdrUs rWrPzApp.ids  4))rYNc K|jrtddS |jD]Z}|j|t |dr.t|jr|d{V[|j |j _ |j |j |jj|jd|_tddS#t$$rO}td||jdt-|d d i d}~wwxYw) a Initialize the Teams application without starting the HTTP server. This method sets up credentials, token manager, activity sender, and plugins, allowing you to use app.send() for proactive messaging without running a server. zApp is already initializedNon_init)rN skip_authrOTz"Teams app initialized successfullyzFailed to initialize app: errormethod initializecontext)rloggerwarningr{rinjectrcallabler_process_activity_eventr} on_requestrrNrKrrOinfo Exceptionrrkemitr1)rVpluginrs rWrzApp.initializesi    NN7 8 8 8 F , + +&--f55569--+(6>2J2J+ ..*********&*%ADK " K " " ,,0j #    !%D  KK< = = = = =    LL=e== > > > L  gz%(LAY'Z'Z'Z [ [ [  sCC.. E8A EEeventcK|j|d{V|j|j|d{VS)z[Process an activity event through the app pipeline. Used as HttpServer.on_request callback.N)r on_activityrprocess_activityr{)rVrs rWrzApp._process_activity_events\ ,,U333333333,==dlERRRRRRRRRrYrc K|p!ttjdd|_ |js|d{Vg}t |j}|jD]P}t|dot|j }|r(| | |Qt d|jdt!|j| |jj|jt)j|d{VdS#t(jt.f$rt d |d{Vd |_|jd t5YdS#d |_|jd t5wxYwt6$rU}td ||jd t;|d|jd d}~wwxYw)a5 Start the Teams application and begin serving HTTP requests. This method will block and keep the application running until stopped. This is the main entry point for running your Teams app. Args: port: Port to listen on (defaults to PORT env var or 3978) PORT3978N)ron_startzTeams app started successfullystartzTeams app shutting downFstopzFailed to start app: r)rrr)intrgrhr~rrr>r{rrrappendrrrkrr3r}rrasynciogatherCancelledErrorKeyboardInterrupt _stop_plugins_runningr4rrr1)rVrtasksrr is_callablers rWrz App.startsj;S66!:!:;;  $ (oo'''''''''+-E$$*555E, 9 9%fj99Whv>W>W 9LL!7!7888 KK8 9 9 9 L  gztz'B'B'B C C C LL,224:>> ? ? ?.%( ( ( ( ( ( ( ( ( (&(9: 7 7 7 KK1 2 2 2 7((********* %  !!&)++666666!&  !!&)++6666    LL888 9 9 9 L  gz%G]a]gAhAh'i'i'i j j j  s1D#E0IG.I0G>> I AIIc <K |jjd{Vt|jD]B}t |dot |j}|r|d{VCt d|j dtdS#t$rO}td||j dt|ddid}~wwxYw) zStop the Teams application.Non_stopzTeams app stoppedrzFailed to stop app: rrr)r}rrreversedr{rrrrrrkrr4rrr1)rVrrrs rWrzApp.stops4 +%**,, , , , , , , ,#4<00 + +%fi88UXfn=U=U + ..********* KK+ , , , L  fikk 2 2 2 2 2    LL777 8 8 8 L  gz%(FAS'T'T'T U U U  sB> >0 ,47###,@@@     h $ $ +:::HH , / / +--66x@@HHH)..x9IJJJJJJJJJrY message_idc KdSrSrVrrrs rWreplyz App.replyGs srYc KdSrSr)rVrrs rWrz App.replyOs srYcK|Nt|tstd|t |||d{VS|||d{VS)a Send an activity proactively to a conversation, optionally as a threaded reply. **3-arg form** ``reply(conversation_id, message_id, activity)``: Constructs a threaded conversation ID via :func:`to_threaded_conversation_id` and sends to that thread. The service determines whether threading is supported for the given conversation type. **2-arg form** ``reply(conversation_id, activity)``: Sends to the exact conversation ID provided - threaded if it contains ``;messageid=``, flat otherwise. Args: conversation_id: The conversation ID message_id: The thread root message ID (3-arg form) or the activity (2-arg form) activity: The activity to send (only in 3-arg form) Nz5message_id must be a string when activity is provided)rr TypeErrorrrDrs rWrz App.replyVs,  j#.. Y WXXX#>PZ#[#[]effffffff fYY ;;;;;;;;;rY middlewarec>|jd|dS)z(Add middleware to run on all activities.cdS)NTr)_s rWrXzApp.use..us$rYN)r add_handler)rVrs rWusezApp.usess"  ;;;;;rYc(tdti}|jj}t |t r||St |tr"t ||St |S)zInitialize the HTTP client from options or create a default one. Always injects the app's User-Agent header via clone, which merges User-Agent values rather than overwriting them. z User-Agent)headers)r# USER_AGENTrKclientrr"rw)rV ua_options client_opts rWrjzApp._init_http_clientws #L*+EFFF \( j& ) ) 0##J// / j- 0 0 8*%%++J77 7j!!!rYc|jjptjd}|jjptjd}|jjptjd}|jj}|jjptjd}t d||st dnt d|d|r.|r,t d t||| S|r|rt||| S|r|d kr-t d t|d d|S|r3||kr-t dt|d||St d|p|}t||SdS)zCInitialize authentication credentials from options and environment. CLIENT_ID CLIENT_SECRET TENANT_IDMANAGED_IDENTITY_CLIENT_IDzUsing CLIENT_ID: z/TENANT_ID is not set, assuming multi-tenant appzUsing TENANT_ID: z (assuming single-tenant app)zUsing client secret for auth)rd client_secretr)rdrr_systemzJUsing Federated Identity Credentials with system-assigned managed identityN)rdmanaged_identity_typemanaged_identity_client_idrzHUsing Federated Identity Credentials with user-assigned managed identityuserz-Using user-assigned managed identity (direct))rdr)rKrdrgrhrrr_rrdebugrrrrr)rVrdrrr_r mi_client_ids rWrmzApp._init_credentialssL*Dbi .D.D  2Pbi6P6P L*Dbi .D.D  "%)\%L%wPRPYZvPwPw" 444555 W NNL M M M M LLUYUUU V V V  l l LL7 8 8 8$y ajkkk k  [ [#i9TYZZZ Z  )X55 ijjj3'*2/3' * .HI.U.U ghhh3'*0/I'  LLH I I I5BL-&#  trYfunc_or_event_typecdS)zGRegister event handler with auto-detected type from function signature.NrrVrs rWrz App.event  rYcdS)z0Register event handler with explicit event type.Nrrs rWrz App.eventrrYcdS)z&Register event handler (no arguments).Nrrs rWrz App.eventrrYcdtdtffd }tr"tts }||S|S)a Decorator to register event handlers with automatic type inference. Can be used in multiple ways: - @app.event (auto-detect from type hints) - @app.event("activity") Args: func_or_event_type: Either the function to decorate or an event type string event_type: Explicit event type (keyword-only) Returns: Decorated function or decorator Example: ```python @app.event async def handle_activity(event: ActivityEvent): print(f"Activity: {event.activity}") @app.event("error") async def handle_error(event: ErrorEvent): print(f"Error: {event.error}") ``` funcrcHd}ttr}nt|}|std|jdt |st d|dtt|}j |||S)Nz#Could not determine event type for zA. Either provide an explicit event_type or use a typed parameter.z Event type 'z' is not a registered type.) rrr5rrtr6rrr r2rkon)r detected_typerrVs rW decoratorzApp.event..decorators M,c22 D 2 !>d C C    V$-VVV '}55 W U=UUUVVV M::M LOOM4 0 0 0KrY)rErrr)rVrrrs`` rWrz App.eventsu> A !       4 & ' ' # ;Ms0S0S #(D9T?? "rYnamedir_path page_pathcP|jj|pd||dS)a Register a static page to serve at a specific path. Args: name: Unique name for the page dir_path: Directory containing the static files page_path: Optional path to serve the page at (defaults to /pages/{name}) Example: ```python app.page("customform", os.path.join(os.path.dirname(__file__), "views", "customform"), "/tabs/dialog-form") ``` r^N)r}r serve_static)rVrrrs rWpagezApp.pages0 (()@j$jj(KKKKKrYpathc>|||d|ddS)a{ Add/update a static tab. The tab will be hosted at http://localhost:/tabs/ or https:///tabs/ Scopes default to 'personal'. Args: name A unique identifier for the entity which the tab displays. path The path to the directory containing the tab's content (HTML, JS, CSS, etc.) z/tabs/r^)rrN)r)rVrrs rWtabzApp.tabs. $1A$1A1A1A BBBBBrY name_or_funccdtdtffd }tr tts |S|S)a Decorator that registers a function as a remotely callable endpoint. Args: name_or_func: - str: explicit name for the endpoint - Callable: directly decorating the function, endpoint name defaults to the function's name Example: ```python @app.func async def post_to_chat(ctx: FunctionContext[Any]): await ctx.send(ctx.data["message"]) ``` rrc"ttrnjdd}tdj|dt dtffd }jj dd||S) Nr-z-Generated endpoint name for function '%s': %srequestrcKt|djd{V\}}|s|stdd|pdiStd jjj|dd|j}|d{V}td|S) Nridetail unauthorized)statusbodyr)rPryrdatar)r.rr:r0rPryr__dict__)r client_contextrctxresultrrVs rWhandlerz,App.func..decorator..handler8s.NI&(B//))))))%^^'s(ED[^9\]]]]%w$($8   %-  $tCyy#3V<<<.decorator4s,6|S,I,InLLt}OdOdehjmOnOnM LLH$-Yf g g g ={ =| = = = = = = =" K  . .v7X7X7XZa b b bKrY)rGrrr)rVr rs`` rWrzApp.func#sp" D T       2 L ! ! +*\3*G*G +9\** *rYcKt|jD]@}t|dr.t|jr|d{VAdS)Nr)rr{rrr)rVrs rWrzApp._stop_pluginsSsot|,, ' 'Fvy)) 'hv~.F.F 'nn&&&&&&&&& ' 'rYcDK|jd{VSrS)rn get_bot_tokenrUs rWrTzApp._get_bot_tokenXs-(66888888888rYrcFK|j|d{VSrS)rnget_graph_tokenrVrs rW_get_graph_tokenzApp._get_graph_token[s/(88CCCCCCCCCrYr&c:tfdjS)a Get a Microsoft Graph client configured with the app's token. This client can be used for app-only operations that don't require user context. For multi-tenant apps, pass a tenant_id to get a tenant-specific token. Args: tenant_id: Optional tenant ID. If not provided, uses the app's default tenant. Raises: ImportError: If the graph dependencies are not installed. c.SrS)r$r#srWrXz#App.get_app_graph..ls4+@+@+K+KrYr`)rCrOr#s``rW get_app_graphzApp.get_app_graph^s*##K#K#K#K#KSWS]^^^^rY)rNrS)rN)2rt __module__ __qualname____doc__r r;rpropertyrrrr$r2rr@rrrPrrrrrrr!rr rrrrArrrr"rjrrmrErr rrrGrrrTrr$r'rrYrWrJrJLs\ W&"4WWWWrhsmX Y/XX*HSM***X*    DS3S3SSSS ** *****X(K#K~9MP\9\KKKK<&5   X.(<7  X;=?C <<<.(<7<&5< <  <<<<:B??!!YT"9:? q(A36"" #????BLLLL LQULLLL C C3 C4 C C C C..sD$!7.5xY]X^`dXdOeIeCf....`'''' 999DD DR_I`DDDD__x}_@T______rYrJ)lr*rimportlib.metadata importlibloggingrgtypingrrrrrrr r r r r dependency_injectorrdotenvrrmicrosoft_teams.apirrrrrrrrrrrrrr*microsoft_teams.api.auth.cloud_environmentrr rimicrosoft_teams.cardsr!microsoft_teams.commonr"r#r$r%msgraph.graph_service_clientr&rr( app_eventsr) app_oauthr* app_pluginsr+ app_processr,authr-#auth.remote_function_jwt_middlewarer.ror/contexts.function_contextr0rr1r2r3r4r5r6httpr7r8 http.adapterr9r:rKr;r<r{r=r>routingr?r@routing.activity_contextrA token_managerrButilsrC utils.threadrDmetadataversionrErGr getLoggerrtrrJrrYrWrHsZ  rrrrrrrrrrrrrrrrrrrrrrrrrr))))))++++++++ >=====SSSSSS......TTTTTTTTTTTT@??????++++++$$$$$$$$$$$$((((((****** QQQQQQ 666666-,,,,,,,33333333333333331111111199999999555555''''''&&&&&&555555   $ $%; < < GCxS)***wvXs';&