iddlZddlZddlZddlZddlmZmZmZmZm Z m Z m Z m Z m Z ddlZddlmZddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lm Z dd l!m"Z"m#Z#m$Z$dd l%m&Z&ddl'm(Z(ddl)m*Z*m+Z+ddl,m-Z-m.Z.ddl/m0Z0m1Z1ddl2m3Z3ddl4m5Z5ddl6m7Z7ddl8m9Z9ddl:m;Z;mm?Z?m@Z@ddlAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTddlUmVZVddlWmXZXmYZYddlZm[Z[m\Z\ddl]m^Z_ddl`maZambZbddlcmdZdmeZeddlfmgZgmhZhmiZimjZjmkZkdd llmmZmmnZndd!lompZpdd"lqmrZrdd#lsmtZtdd$lumvZvdd%lwmxZxdd&lymzZzdd'l{m|Z|Gd(d)Z}dS)*N) OptionalListUnionCallablePatternDict AwaitableSequenceAny)webAsyncSlackAppServer)AsyncAssistantUtilities) AsyncAssistantThreadContextStore)AsyncTokenRevocationListeners) AsyncDefaultListenerStartHandler)%AsyncDefaultListenerCompletionHandler)AsyncioListenerRunner)AsyncAssistant)!AsyncCustomMiddlewareErrorHandler"AsyncDefaultMiddlewareErrorHandlerAsyncMiddlewareErrorHandler)AsyncMessageListenerMatches)$select_consistent_installation_store)is_assistant_eventto_event)get_name_for_callableis_callable_coroutine)AsyncWorkflowStepAsyncWorkflowStepBuilder)AsyncWorkflowStepMiddleware)AsyncInstallationStore)AsyncWebClient)AuthorizeResult)AsyncAuthorizeAsyncCallableAuthorizeAsyncInstallationStoreAuthorize) BoltErrorBoltUnhandledRequestError)&error_oauth_flow_or_authorize_required,warning_client_prioritized_and_token_skippedwarning_token_skippederror_token_requiredwarning_unhandled_requestdebug_checking_listenerdebug_running_listener$error_unexpected_listener_middleware)error_listener_function_must_be_coro_funcerror_client_invalid_type_asyncerror_authorize_conflicts'error_oauth_settings_invalid_type_async#error_oauth_flow_invalid_type_asyncwarning_bot_only_conflicts)debug_return_listener_middleware_response"info_default_oauth_settings_loaded7error_installation_store_required_for_builtin_listeners&warning_unhandled_by_global_middleware!warning_ack_timeout_has_no_effect)AsyncioLazyListenerRunner) AsyncListenerAsyncCustomListener) AsyncDefaultListenerErrorHandlerAsyncCustomListenerErrorHandler)builtins)AsyncListenerMatcherAsyncCustomListenerMatcher)get_bolt_loggerget_bolt_app_logger) AsyncSslCheckAsyncRequestVerificationAsyncIgnoringSelfEventsAsyncUrlVerificationAsyncAttachingFunctionToken)AsyncMiddlewareAsyncCustomMiddleware)AsyncMultiTeamsAuthorization)AsyncSingleTeamAuthorization)AsyncOAuthFlow)AsyncOAuthSettings)AsyncBoltRequest) BoltResponse)create_async_web_clientc.ZeZdZddddddddddddddddddddddddeejdeededed eed eed eed ee e e d e e ffdee d e efdeedeedeedededededededeedeedeedeef,dZ dfdededededededeefdZedefdZedeefd Zedefd!Zedejfd"Zedeefd#Zedefd$Zedefd%Zd&d'lmZ dgd*e d+ed,eedefd-Z!dhd+ed*e de"j#fd.Z$dgd*e d+ed,eeddfd/Z%d0e&de'fd1Z(d0e&d2e'de'fd3Z)dee fd4Z*dee fd5Z+d6e,dee fd7Z- did8e ee.e/e0fd9ee e d ee'fe1e2e fd:ee e d ee'fe1e2e fd;ee e d ee'fe1e2e ffd<Z3d=e d e ee'fde d e ee'ffd>Z4 djd?e ee.e5eee ee2ee ee.ffffd@ee2e d e efdAee2e e e fde d ee d e ee'fffdBZ6 dkdDe ee.fd@ee2e d e efdAee2e e e fde d ee d e ee'fffdEZ7 dld8e ee.fd@ee2e d e efdAee2e e e fdGedHe de d ee d e e'fff dIZ8 djdJe ee.fd@ee2e d e efdAee2e e e fde d ee d e ee'fffdKZ9 djdLe ee.e5ee ee.fffd@ee2e d e efdAee2e e e fde d ee d e ee'fffdMZ: djd8e ee.fd@ee2e d e efdAee2e e e fde d ee d e ee'fffdNZ; djd8e ee.fd@ee2e d e efdAee2e e e fde d ee d e ee'fffdOZ< djdLe ee.e5ee ee.fffd@ee2e d e efdAee2e e e fde d ee d e ee'fffdPZ= djdLe ee.e5ee ee.fffd@ee2e d e efdAee2e e e fde d ee d e ee'fffdQZ> djd8e ee.fd@ee2e d e efdAee2e e e fde d ee d e ee'fffdRZ? djd8e ee.fd@ee2e d e efdAee2e e e fde d ee d e ee'fffdSZ@ djd8e ee.fd@ee2e d e efdAee2e e e fde d ee d e ee'fffdTZA djdLe ee.e5ee ee.fffd@ee2e d e efdAee2e e e fde d ee d e ee'fffdUZB djdLe ee.fd@ee2e d e efdAee2e e e fde d ee d e ee'fffdVZC djdLe ee.fd@ee2e d e efdAee2e e e fde d ee d e ee'fffdWZD djdLe ee.e5ee ee.fffd@ee2e d e efdAee2e e e fde d ee d e ee'fffdXZE djdYe ee.fd@ee2e d e efdAee2e e e fde d ee d e ee'fffdZZF djd8e ee.fd@ee2e d e efdAee2e e e fde d ee d e ee'fffd[ZGde d e ee'ffd\ZHde d e ee'ffd]ZIdmd^ZJd0e&fd_ZKeLd`eMdee2e d e ee'ffdaZN dndbe2e d e ee'fdceOd@ee2e d e efdAee2e e e fddedHe dee d e ee'ffdeZPdS)oAsyncAppNFT)loggernameprocess_before_response!raise_error_for_unhandled_requestsigning_secrettokenclientbefore_authorize authorize#user_facing_authorize_error_messageinstallation_storeinstallation_store_bot_onlyrequest_verification_enabledignoring_self_events_enabled.ignoring_self_assistant_message_events_enabledssl_check_enabledurl_verification_enabled attaching_function_token_enabledoauth_settings oauth_flowverification_tokenassistant_thread_context_storerWrXrYrZr[r\r]r^.r_r`rarbrcrdrerfrgrhrirjrkrlc Z | tjdd}|ptjd}|pEtjdjtjjd|_ ||_ |ptjdd|_ ||_ |ptt|_||_||_|lt%|t&st)t+||_|j|_|&|jt3nt5||j|_d|_|Mt9|r"t;|j ||j |_nt%|t<r||_d|_| Wt%| t@r| |_n:||t)tCtE|j| |_| |_#|j#Y|jR||j$n|}tK|j#||j&nd||j'nd|j| pd |j||j(nd |_d|_)|vtjdWtjd8tU}|(| &|j+tY|rt%|tZst)t]||_)t_|j)j&|j#|j)j$j0|j} | |_#| | |j)j$_0|j)j|j|j)_|j|j)j$j1|_n|t%|tTst)tet_|j&|j#|j0|j} | |_#| | |_0t[|j|j3||_)|j|j)j$j1|_|j4|j_4|j#|j4|j-d|_|jtk| e|j)^| pd }|j)j$j6}||krC|j3to||j)j$_6||j_8d|_9|j#tu|j#|_9g|_;g|_<||_=||_>t|j|t|jt|jt|jt|j|_Dt|j|_Fd |_G|H| |||||| d|_IdS)a"Bolt App that provides functionalities to register middleware/listeners. import os from slack_bolt.async_app import AsyncApp # Initializes your app with your bot token and signing secret app = AsyncApp( token=os.environ.get("SLACK_BOT_TOKEN"), signing_secret=os.environ.get("SLACK_SIGNING_SECRET") ) # Listens to incoming messages that contain "hello" @app.message("hello") async def message_hello(message, say): # async function # say() sends a message to the channel where the event was triggered await say(f"Hey there <@{message['user']}>!") # Start your app if __name__ == "__main__": app.start(port=int(os.environ.get("PORT", 3000))) Refer to https://docs.slack.dev/tools/bolt-python/concepts/async for details. If you would like to build an OAuth app for enabling the app to run with multiple workspaces, refer to https://docs.slack.dev/tools/bolt-python/concepts/authenticating-oauth to learn how to configure the app. Args: logger: The custom logger that can be used in this app. name: The application name that will be used in logging. If absent, the source file name will be used. process_before_response: True if this app runs on Function as a Service. (Default: False) raise_error_for_unhandled_request: True if you want to raise exceptions for unhandled requests and use @app.error listeners instead of the built-in handler, which pints warning logs and returns 404 to Slack (Default: False) signing_secret: The Signing Secret value used for verifying requests from Slack. token: The bot/user access token required only for single-workspace app. client: The singleton `slack_sdk.web.async_client.AsyncWebClient` instance for this app. before_authorize: A global middleware that can be executed right before authorize function authorize: The function to authorize an incoming request from Slack by checking if there is a team/user in the installation data. user_facing_authorize_error_message: The user-facing error message to display when the app is installed but the installation is not managed by this app's installation store installation_store: The module offering save/find operations of installation data installation_store_bot_only: Use `AsyncInstallationStore#async_find_bot()` if True (Default: False) request_verification_enabled: False if you would like to disable the built-in middleware (Default: True). `AsyncRequestVerification` is a built-in middleware that verifies the signature in HTTP Mode requests. Make sure if it's safe enough when you turn a built-in middleware off. We strongly recommend using RequestVerification for better security. If you have a proxy that verifies request signature in front of the Bolt app, it's totally fine to disable RequestVerification to avoid duplication of work. Don't turn it off just for easiness of development. ignoring_self_events_enabled: False if you would like to disable the built-in middleware (Default: True). `AsyncIgnoringSelfEvents` is a built-in middleware that enables Bolt apps to easily skip the events generated by this app's bot user (this is useful for avoiding code error causing an infinite loop). ignoring_self_assistant_message_events_enabled: False if you would like to disable the built-in middleware. `IgnoringSelfEvents` for this app's bot user message events within an assistant thread This is useful for avoiding code error causing an infinite loop; Default: True url_verification_enabled: False if you would like to disable the built-in middleware (Default: True). `AsyncUrlVerification` is a built-in middleware that handles url_verification requests that verify the endpoint for Events API in HTTP Mode requests. ssl_check_enabled: bool = False if you would like to disable the built-in middleware (Default: True). `AsyncSslCheck` is a built-in middleware that handles ssl_check requests from Slack. attaching_function_token_enabled: False if you would like to disable the built-in middleware (Default: True). `AsyncAttachingFunctionToken` is a built-in middleware that injects the just-in-time workflow-execution token when your app receives `function_executed` or interactivity events scoped to a custom step. oauth_settings: The settings related to Slack app installation flow (OAuth flow) oauth_flow: Instantiated `slack_bolt.oauth.AsyncOAuthFlow`. This is always prioritized over oauth_settings. verification_token: Deprecated verification mechanism. This can be used only for ssl_check requests. assistant_thread_context_store: Custom AssistantThreadContext store (Default: the built-in implementation, which uses a parent message's metadata to store the latest context) NSLACK_SIGNING_SECRETSLACK_BOT_TOKENSLACK_VERIFICATION_TOKEN)r\rWapp_namefunc base_loggerrWrvF authed_user)ra client_id client_secretrWbot_onlyr]user_token_resolutionSLACK_CLIENT_IDSLACK_CLIENT_SECRET)rz app_storeoauth_flow_storerW)r]rWsettings)rW)rWrYlistener_error_handlerlistener_start_handlerlistener_completion_handlerlazy_listener_runner)rcrdrerfrgrhr`)Josenvirongetinspectstackfilenamesplitpathsep_name_signing_secret_verification_token _base_loggerrErV_framework_logger"_raise_error_for_unhandled_request_token isinstancer#r(r3 _async_clientr\warningr+rT_async_before_authorizecallablerMrL_async_authorizer%r4r&_async_installation_storerr'rzr{r}_async_oauth_flowrQinfor9rPr6rrar_r5rW!token_rotation_expiration_minutesr,rbr7r|"_async_tokens_revocation_listenersr_async_middleware_list_async_listeners_assistant_thread_context_store_process_before_responserr@rrr=_async_listener_runnerr_async_middleware_error_handler_init_middleware_list_done_init_async_middleware_list_server)selfrWrXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrirjrkrlr app_bot_onlyoauth_flow_bot_onlys S/root/projects/butler/venv/lib/python3.11/site-packages/slack_bolt/app/async_app.py__init__zAsyncApp.__init__nsfV  !Z^^,BBGGN:(9::T'-//!"4"="C"CBGK"P"PQS"T $22D2x WqswHxHx #"(!D?8+D+D2S/%*  fn55 C ? A ABBB!'D  ,DK &../[/]/]^^^!8-"""D CG$  '()) @/D!Z) $ 6000,, ,o>> @/?,:>  )^44 n)2%%!-1G$$=$?$?@@@(>dF\cl(m(m(m%K]&  ) 5$:O:W.8.Dz**.H$C#'#A080D(,,$8@8Lh44RV-4=)IQI]x'E'Ecp%%%D !<@  " 011= 455A011N!&8&@&++,N,P,PQQQ $ wj.99 G C E EFFF%/D "!E0:8!%!7!@!S- """  .@D *!-EW&/B%3;7;7I&4$,(,(>(G(Q%  'n.@AA K G I IJJJ!E(28!/!B- """  .@D *!-4F1%34;MVZValz%{%{%{D "$,(,(>(G(Q%FTFvD ! C  * 6$:O:[aealaxDK  " * *+@+B+B C C C ' 2t7M7Y6?%L"&"8"A"] 222 ##$>$@$@AAANZ&/K1=%.[_/  ) 56STXTr6s6sD 3 >@#57/M,(?%&;)$;#C4Ka#b#b#b#C4Ka#b#b#b(MUYUk(l(l(l!:-""" ' ' ' #Mo)M M M ,+0' (()E)E;i/%=-M0S )   7; c^|jrdS|dur3|jt|j|j|dur3|jt |j|j|j|j|j|j |j r/|jt|j|n|j 5|jt|j |j|ntt|j E|jt|j |j|j jj|ntt%|dur.|jt'|j||dur-|jt)|j|dur&|jt+d|_dS)NT)rkrwrw)rwr`)r_rwr`)r_rwr}r`)rwre)rrappendrGrrrHrrrrrOrrNr(r-rr}r*rIrJrK)rrcrdrerfrgrhr`s rrz$AsyncApp._init_async_middleware_lists  *  F  $ $  ' . .'+'? $ 1    (4 / /  ' . ./GH\jnj{/|/|/| } } }  ' 3  ' . .t/K L L L  ! ){ 8+220$($5<_ &2+220"&"7$($5<_ 4 6 6777  " .  ' . .,"3 $ 1*.*@*I*_8[     BDDEE E '4 / /  ' . .' $ 1Cq    $t + +  ' . ./CPTPa/b/b/b c c c +t 3 3  ' . ./J/L/L M M M*.'''rreturnc|jS)z,The name of this app (default: the filename))rrs rrXz AsyncApp.names zrc|jS)z(Configured `OAuthFlow` object if exists.)rrs rrjzAsyncApp.oauth_flow %%rc|jS)zOThe singleton `slack_sdk.web.async_client.AsyncWebClient` instance in this app.)rrs rr]zAsyncApp.clients !!rc|jS)zThe logger this app uses.)rrs rrWzAsyncApp.loggerrrc|jS)z\The `slack_sdk.oauth.AsyncInstallationStore` that can be used in the `authorize` middleware.)rrs rrazAsyncApp.installation_stores --rc|jS)z@The asyncio-based executor for asynchronously running listeners.)rrs rlistener_runnerzAsyncApp.listener_runners **rc|jpdS)NF)rrs rrYz AsyncApp.process_before_responses,55rrqr /slack/eventsportrhostc|j |jj|ks|jj|krt|||||_|jS)aaConfigure a web server using AIOHTTP. Refer to https://docs.aiohttp.org/ for more details about AIOHTTP. Args: port: The port to listen on (Default: 3000) path: The path to handle request from Slack (Default: `/slack/events`) host: The hostname to serve the web endpoints. (Default: 0.0.0.0) N)rrappr)rrrrrrrrs rserverzAsyncApp.serversW < 4<#4#<#< @QUY@Y@Y. DL |rc:|||jS)acReturns a `web.Application` instance for aiohttp-devtools users. from slack_bolt.async_app import AsyncApp app = AsyncApp() @app.event("app_mention") async def event_test(body, say, logger): logger.info(body) await say("What's up?") def app_factory(): return app.web_app() # adev runserver --port 3000 --app-factory app_factory async_app.py Args: path: The path to receive incoming requests from Slack port: The port to listen on (Default: 3000) )rr)rweb_app)rrrs rrzAsyncApp.web_apps({{4{0088rcZ||||dS)a]Start a web server using AIOHTTP. Refer to https://docs.aiohttp.org/ for more details about AIOHTTP. Args: port: The port to listen on (Default: 3000) path: The path to handle request from Slack (Default: `/slack/events`) host: The hostname to serve the web endpoints. (Default: 0.0.0.0) )rrrN)rstartrs rrzAsyncApp.start's. Dt 44::<<<<.async_middleware_nextDs.2 ] + + +rz Applying )rrespnextNierrorzno next() calls in middlewareT)requestcurrent_responselast_global_middleware_name)rrresponse)rr)rr listener_namelistenerzunhandled request)rri) time _init_contextrSrrlevelloggingDEBUGdebugrX async_processrr)rrhandlerr;rr ack_functionr/ async_matchesrun_async_middlewarer8rrr0run_handle_unmatched_requests Exceptionr)rr starting_timerr middlewareerrmiddleware_respnext_was_not_called debug_messagelistener_responserrs @rasync_dispatchzAsyncApp.async_dispatch5sW  3'33R'H'H'H)51 3 3 3 3 3[ "9  27 /)/7=@@*001NZ_1N1NOOO'55$-B6( 6 | ,3gGf=ghhhBdJJ "&?,/59@J'"'"'"!" $="""&*&A&X&_&_*+,/-1'`'"'"!"!"!"!"!"!"!"!"!"!"!"!"" $(KKK.667]^h^mor7s7sttt# KKK+ .!1" 1" 1 5h6K L L &,,-D]-S-STTT!//Cd/CCCCCCCC1CKC`C`dDaDD>>>>>>:_&9+ !*6#5;w}LL0Y$1$3$:$3$8$1 1"1" !% 6 < <] K K K#2222!&2.*001G 1V1VWWWFJFaFeFe #!%&3!) GfGGAAAAAA% )40000|#3g?R5STTT6$>> 3 #)-15LSS #!%T  223== =   s444D6==>        KKKKKK sBL!C.. D*8(D% L!%D**L!10L!"L!&CL!AL! L!9K L(L<L!LL! L!! M++5M& M+&M+rcT|jt||SN)rrr.)rrrs rrz#AsyncApp._handle_unmatched_requestss' &&'@'E'EFFF rc|j|S)z@Refer to `AsyncApp#middleware()` method's docstring for details.r)rargss rusez AsyncApp.usest%%rct|dkr|d}t|trE|}|j|t|t r|j |j|_net|r6|jt|j ||j |Stdt|ddS)aqRegisters a new middleware to this app. This method can be used as either a decorator or a method. # Use this method as a decorator @app.middleware async def middleware_func(logger, body, next): logger.info(f"request body: {body}") await next() # Pass a function to this method app.middleware(middleware_func) To learn available arguments for middleware/listeners, see `slack_bolt.kwargs_injection.async_args`'s API document. Args: *args: A function that works as a global middleware. rNrtz"Unexpected type for a middleware ())lenrrLrrrthread_context_storerrrMrXrr(type)rrmiddleware_or_callablers rrzAsyncApp.middlewares$ t99q==%)!W "0/BB f.D +22:>>>j.99[j>]>i;E;ZD8011 f+22)!%3$($5.- dTJ`EaEa d d deeetr assistantc,||Srr)rrs rrzAsyncApp.assistantsy)))r callback_ideditsaveexecutectjdt|}t|tt frt |||||j}nft|tr| |j}n5t|t s tdt|d| t|dS)a Deprecated: Steps from apps for legacy workflows are now deprecated. Use new custom steps: https://docs.slack.dev/workflows/workflow-steps/ Registers a new step from app listener. Unlike others, this method doesn't behave as a decorator. If you want to register a step from app by a decorator, use `AsyncWorkflowStepBuilder`'s methods. # Create a new WorkflowStep instance from slack_bolt.workflows.async_step import AsyncWorkflowStep ws = AsyncWorkflowStep( callback_id="add_task", edit=edit, save=save, execute=execute, ) # Pass Step to set up listeners app.step(ws) Refer to https://docs.slack.dev/legacy/legacy-steps-from-apps/ for details of steps from apps. To learn available arguments for middleware/listeners, see `slack_bolt.kwargs_injection.async_args`'s API document. For further information about AsyncWorkflowStep specific function arguments such as `configure`, `update`, `complete`, and `fail`, refer to the `async` prefixed ones in `slack_bolt.workflows.step.utilities` API documents. Args: callback_id: The Callback ID for this step from app edit: The function for displaying a modal in the Workflow Builder save: The function for handling configuration in the Workflow Builder execute: The function for handling the step execution zSteps from apps for legacy workflows are now deprecated. Use new custom steps: https://docs.slack.dev/workflows/workflow-steps/)category)rrrrrwrzInvalid step object (rN)warningswarnDeprecationWarningrstrrrrr buildr(rrr!)rrrrrsteps rr z AsyncApp.stepsR  Y(      kC> 2 2 C$' - DD6 7 7 C::$*;:< > > #:0Q)0 0 0 , reventmatchersrcfd}|S)aRegisters a new event listener. This method can be used as either a decorator or a method. # Use this method as a decorator @app.event("team_join") async def ask_for_introduction(event, say): welcome_channel_id = "C12345" user_id = event["user"] text = f"Welcome to the team, <@{user_id}>! :tada: You can introduce yourself in this channel." await say(text=text, channel=welcome_channel_id) # Pass a function to this method app.event("team_join")(ask_for_introduction) Refer to https://docs.slack.dev/apis/events-api/ for details of Events API. To learn available arguments for middleware/listeners, see `slack_bolt.kwargs_injection.async_args`'s API document. Args: event: The conditions that match a request payload. If you pass a dict for this, you can have type, subtype in the constraint. matchers: A list of listener matcher functions. Only when all the matchers return True, the listener function can be invoked. middleware: A list of lister middleware functions. Only when all the middleware call `next()` method, the listener function can be invoked. c|r|nt|}tjdj}t||dS)NTr)_to_listener_functionslistbuiltin_matchersrr_register_listener)rkwargs functionsprimary_matcherrrrrs r__call__z AsyncApp.event..__call__fse?EU33F;;;4PT::I.4UDdN_```O**4 ??OXWacghh hrr)rrrrrs```` rrzAsyncApp.eventBs>H i i i i i i i i rrokeywordcjrtngrtngfd}|S)a:Registers a new message event listener. This method can be used as either a decorator or a method. Check the `App#event` method's docstring for details. # Use this method as a decorator @app.message(":wave:") async def say_hello(message, say): user = message['user'] await say(f"Hi there, <@{user}>!") # Pass a function to this method app.message(":wave:")(say_hello) Refer to https://docs.slack.dev/reference/events/message/ for details of `message` events. To learn available arguments for middleware/listeners, see `slack_bolt.kwargs_injection.async_args`'s API document. Args: keyword: The keyword to match matchers: A list of listener matcher functions. Only when all the matchers return True, the listener function can be invoked. middleware: A list of lister middleware functions. Only when all the middleware call `next()` method, the listener function can be invoked. c&|r|nt|}ddd}tj|dj}dt t||dS)Nmessage)N bot_messagethread_broadcast file_share)rsubtypeT) constraintsrasynciorwr)rrr message_eventrinsertrr) rrrr#rrrrrs rrz"AsyncApp.message..__call__s?EU33F;;;4PT::I! K /<' - O   a!>>2)3;T*%%%  i i i i i i i i6rauto_acknowledge ack_timeoutcdur.dkr(jtrtngrtngfd}|S)aRegisters a new Function listener. This method can be used as either a decorator or a method. # Use this method as a decorator @app.function("reverse") async def reverse_string(ack: AsyncAck, inputs: dict, complete: AsyncComplete, fail: AsyncFail): try: await ack() string_to_reverse = inputs["stringToReverse"] await complete({"reverseString": string_to_reverse[::-1]}) except Exception as e: await fail(f"Cannot reverse string (error: {e})") raise e # Pass a function to this method app.function("reverse")(reverse_string) To learn available arguments for middleware/listeners, see `slack_bolt.kwargs_injection.async_args`'s API document. Args: callback_id: The callback id to identify the function matchers: A list of listener matcher functions. Only when all the matchers return True, the listener function can be invoked. middleware: A list of lister middleware functions. Only when all the middleware call `next()` method, the listener function can be invoked. Tr'c|r |nt|}tj jd} ||S)NT)rrwr$)rrrfunction_executedrr) rrrrr)r(rrrrs rrz#AsyncApp.function..__call__sl?EU33F;;;4PT::I.@'T5FPTO**9oxQ[]moz{{ {r)rrr<r)rrrrr(r)rs`````` rfunctionzAsyncApp.functionsD t # #a&../PQ\^i/j/jkkk%-54>>>2)3;T*%%%  | | | | | | | | | |rcommandcfd}|S)aQRegisters a new slash command listener. This method can be used as either a decorator or a method. # Use this method as a decorator @app.command("/echo") async def repeat_text(ack, say, command): # Acknowledge command request await ack() await say(f"{command['text']}") # Pass a function to this method app.command("/echo")(repeat_text) Refer to https://docs.slack.dev/interactivity/implementing-slash-commands/ for details of Slash Commands. To learn available arguments for middleware/listeners, see `slack_bolt.kwargs_injection.async_args`'s API document. Args: command: The conditions that match a request payload matchers: A list of listener matcher functions. Only when all the matchers return True, the listener function can be invoked. middleware: A list of lister middleware functions. Only when all the middleware call `next()` method, the listener function can be invoked. c|r|nt|}tjdj}t||SNT)r$rw)rrrr.rr)rrrrr.rrrs rrz"AsyncApp.command..__call__sc?EU33F;;;4PT::I.6wZ^ZklllO**4 ??OXWabb brr)rr.rrrs```` rr.zAsyncApp.commands=> c c c c c c c c rr#cfd}|S)adRegisters a new shortcut listener. This method can be used as either a decorator or a method. # Use this method as a decorator @app.shortcut("open_modal") async def open_modal(ack, body, client): # Acknowledge the command request await ack() # Call views_open with the built-in client await client.views_open( # Pass a valid trigger_id within 3 seconds of receiving it trigger_id=body["trigger_id"], # View payload view={ ... } ) # Pass a function to this method app.shortcut("open_modal")(open_modal) Refer to https://docs.slack.dev/interactivity/implementing-shortcuts/ for details about Shortcuts. To learn available arguments for middleware/listeners, see `slack_bolt.kwargs_injection.async_args`'s API document. Args: constraints: The conditions that match a request payload. matchers: A list of listener matcher functions. Only when all the matchers return True, the listener function can be invoked. middleware: A list of lister middleware functions. Only when all the middleware call `next()` method, the listener function can be invoked. c|r|nt|}tjdj}t||Sr1)rrrshortcutrrrrrrr#rrrs rrz#AsyncApp.shortcut..__call__-sc?EU33F;;;4PT::I.7 T_c_pqqqO**4 ??OXWabb brrrr#rrrs```` rr4zAsyncApp.shortcuts>J c c c c c c c c rcfd}|S)z)Registers a new global shortcut listener.c|r|nt|}tjdj}t||Sr1)rrrglobal_shortcutrrrrrrrrrrs rrz*AsyncApp.global_shortcut..__call__<d?EU33F;;;4PT::I.>{TXfjfwxxxO**4 ??OXWabb brrrrrrrs```` rr9zAsyncApp.global_shortcut4= c c c c c c c c rcfd}|S)z*Registers a new message shortcut listener.c|r|nt|}tjdj}t||Sr1)rrrmessage_shortcutrrr:s rrz+AsyncApp.message_shortcut..__call__Ksd?EU33F;;;4PT::I.? UYgkgxyyyO**4 ??OXWabb brrr<s```` rr@zAsyncApp.message_shortcutCr=rcfd}|S)aRegisters a new action listener. This method can be used as either a decorator or a method. # Use this method as a decorator @app.action("approve_button") async def update_message(ack): await ack() # Pass a function to this method app.action("approve_button")(update_message) * Refer to https://docs.slack.dev/reference/interaction-payloads/block_actions-payload/ for actions in `blocks`. * Refer to https://docs.slack.dev/legacy/legacy-messaging/legacy-message-buttons/ for actions in `attachments`. * Refer to https://docs.slack.dev/legacy/legacy-dialogs/ for actions in dialogs. To learn available arguments for middleware/listeners, see `slack_bolt.kwargs_injection.async_args`'s API document. Args: constraints: The conditions that match a request payload matchers: A list of listener matcher functions. Only when all the matchers return True, the listener function can be invoked. middleware: A list of lister middleware functions. Only when all the middleware call `next()` method, the listener function can be invoked. c|r|nt|}tjdj}t||Sr1)rrractionrrr5s rrz!AsyncApp.action..__call__ssc?EU33F;;;4PT::I.5k4]a]noooO**4 ??OXWabb brrr6s```` rrCzAsyncApp.actionUs=< c c c c c c c c rcfd}|S)zRegisters a new `block_actions` action listener. Refer to https://docs.slack.dev/reference/interaction-payloads/block_actions-payload/ for details. c|r|nt|}tjdj}t||Sr1)rrr block_actionrrr5s rrz'AsyncApp.block_action..__call__sd?EU33F;;;4PT::I.;KQUcgctuuuO**4 ??OXWabb brrr6s```` rrFzAsyncApp.block_actionzs= c c c c c c c c rcfd}|S)zRegisters a new `interactive_message` action listener. Refer to https://docs.slack.dev/legacy/legacy-messaging/legacy-message-buttons/ for details.c|r|nt|}tjdj}t||Sr1)rrrattachment_actionrrr:s rrz,AsyncApp.attachment_action..__call__d?EU33F;;;4PT::I.@VZhlhyzzzO**4 ??OXWabb brrr<s```` rrIzAsyncApp.attachment_action= c c c c c c c c rcfd}|S)yRegisters a new `dialog_submission` listener. Refer to https://docs.slack.dev/legacy/legacy-dialogs/ for details.c|r|nt|}tjdj}t||Sr1)rrrdialog_submissionrrr:s rrz,AsyncApp.dialog_submission..__call__rJrrr<s```` rrOzAsyncApp.dialog_submissionrKrcfd}|S)rMc|r|nt|}tjdj}t||Sr1)rrrdialog_cancellationrrr:s rrz.AsyncApp.dialog_cancellation..__call__sd?EU33F;;;4PT::I.B;X\jnj{|||O**4 ??OXWabb brrr<s```` rrRzAsyncApp.dialog_cancellationrKrcfd}|S)aRegisters a new `view_submission`/`view_closed` event listener. This method can be used as either a decorator or a method. # Use this method as a decorator @app.view("view_1") async def handle_submission(ack, body, client, view): # Assume there's an input block with `block_c` as the block_id and `dreamy_input` hopes_and_dreams = view["state"]["values"]["block_c"]["dreamy_input"] user = body["user"]["id"] # Validate the inputs errors = {} if hopes_and_dreams is not None and len(hopes_and_dreams) <= 5: errors["block_c"] = "The value must be longer than 5 characters" if len(errors) > 0: await ack(response_action="errors", errors=errors) return # Acknowledge the view_submission event and close the modal await ack() # Do whatever you want with the input data - here we're saving it to a DB # Pass a function to this method app.view("view_1")(handle_submission) Refer to https://docs.slack.dev/reference/interaction-payloads/view-interactions-payload for details of payloads. To learn available arguments for middleware/listeners, see `slack_bolt.kwargs_injection.async_args`'s API document. Args: constraints: The conditions that match a request payload matchers: A list of listener matcher functions. Only when all the matchers return True, the listener function can be invoked. middleware: A list of lister middleware functions. Only when all the middleware call `next()` method, the listener function can be invoked. c|r|nt|}tjdj}t||Sr1)rrrviewrrr5s rrzAsyncApp.view..__call__sc?EU33F;;;4PT::I.3K[_[lmmmO**4 ??OXWabb brrr6s```` rrUz AsyncApp.view>R c c c c c c c c rcfd}|S)zRegisters a new `view_submission` listener. Refer to https://docs.slack.dev/reference/interaction-payloads/view-interactions-payload/#view_submission for details. c|r|nt|}tjdj}t||Sr1)rrrview_submissionrrr5s rrz*AsyncApp.view_submission..__call__r;rrr6s```` rrYzAsyncApp.view_submissions= c c c c c c c c rcfd}|S)zRegisters a new `view_closed` listener. Refer to https://docs.slack.dev/reference/interaction-payloads/view-interactions-payload/#view_closed for details.c|r|nt|}tjdj}t||Sr1)rrr view_closedrrr5s rrz&AsyncApp.view_closed..__call__ sd?EU33F;;;4PT::I.:;PTbfbstttO**4 ??OXWabb brrr6s```` rr\zAsyncApp.view_closedrKrcfd}|S)aRegisters a new options listener. This method can be used as either a decorator or a method. # Use this method as a decorator @app.options("menu_selection") async def show_menu_options(ack): options = [ { "text": {"type": "plain_text", "text": "Option 1"}, "value": "1-1", }, { "text": {"type": "plain_text", "text": "Option 2"}, "value": "1-2", }, ] await ack(options=options) # Pass a function to this method app.options("menu_selection")(show_menu_options) Refer to the following documents for details: * https://docs.slack.dev/reference/block-kit/block-elements/select-menu-element#external_select * https://docs.slack.dev/reference/block-kit/block-elements/multi-select-menu-element#external_multi_select To learn available arguments for middleware/listeners, see `slack_bolt.kwargs_injection.async_args`'s API document. Args: matchers: A list of listener matcher functions. Only when all the matchers return True, the listener function can be invoked. middleware: A list of lister middleware functions. Only when all the middleware call `next()` method, the listener function can be invoked. c|r|nt|}tjdj}t||Sr1)rrroptionsrrr5s rrz"AsyncApp.options..__call__<sc?EU33F;;;4PT::I.6{D^b^opppO**4 ??OXWabb brrr6s```` rr_zAsyncApp.optionsrVr action_idcfd}|S)z,Registers a new `block_suggestion` listener.c|r|nt|}tjdj}t||Sr1)rrrblock_suggestionrr)rrrrr`rrrs rrz+AsyncApp.block_suggestion..__call__Ksd?EU33F;;;4PT::I.? SWeievwwwO**4 ??OXWabb brr)rr`rrrs```` rrczAsyncApp.block_suggestionCr=rcfd}|S)zyRegisters a new `dialog_suggestion` listener. Refer to https://docs.slack.dev/legacy/legacy-dialogs/ for details.c|r|nt|}tjdj}t||Sr1)rrrdialog_suggestionrrr:s rrz,AsyncApp.dialog_suggestion..__call__[rJrrr<s```` rrfzAsyncApp.dialog_suggestionRrKrc^|jtt|jjSr)rr(r:handle_tokens_revoked_eventsrs r%default_tokens_revoked_event_listenerz.AsyncApp.default_tokens_revoked_event_listeneres.  2 :SUUVV V6SSrc^|jtt|jjSr)rr(r:handle_app_uninstalled_eventsrs r&default_app_uninstalled_event_listenerz/AsyncApp.default_app_uninstalled_event_listenerls.  2 :SUUVV V6TTrc|d||d|dS)Ntokens_revokedapp_uninstalled)rrirlrs r!enable_token_revocation_listenersz*AsyncApp.enable_token_revocation_listenersssZ$ #$$T%O%O%Q%QRRR% $%%d&Q&Q&S&STTTTTrct|j|j|jd<|j|jd<t |j|jj|jj|jj |jj |jj |jj |jj |jj|jj|jj|jjnd }||jd<|j|jd<t'|jrt+t-|j|j|j}|j|jd<|j|jd <|j|jd <|j|jd <|j|jd <|j|jd <dSdS)N)rurwrWr\) r\base_urltimeoutsslproxysessiontrust_env_in_sessionheadersteam_idrWretry_handlersr]r)payloadcontextrsay set_status set_titleset_suggested_promptsget_thread_contextsave_thread_context)rFrXrr|rr#rrrrsrtrurvrwrxryrWrzcopyrrrrrrr}r~rrrr)rrclient_per_requestrs rrzAsyncApp._init_contextys 3TYTXTe f f f H#{ G.<+'0&."&$*&.!%!3!H&.K'%,<@z/AsyncApp._register_listener..s;9 9 9 fg & tO` a a a9 9 9 rrt)rurlazy_functionsrrrr)rw)rrrrrr(r2r&rLrrrMrXr ValueErrorr1rrr?pop) rrrrrrr)value_to_returnrvrXlistener_matcherslistener_middlewarems ` rrzAsyncApp._register_listeners)T** (YI y>>Q  (lO Q QD(.. Q,T22 I$ O OPPP Q9 9 9 9 ltlzxz9 9 9    O444 !r P PA!_-- P#**1----! P!6q!9!9 P#**+@$)Z[imiz+{+{+{|||| !Ed1gg!N!NOOO $$ &]]1--(*.%9' -    r)TTTTTTN)rrN)rr)NNN)NN)roNN)NNTr')rN)Fr')Q__name__ __module__ __qualname__rrLoggerr boolr#rrLrr r r$r"rQrPrrrpropertyrXrjr]rWrarrrY async_serverrintrr ApplicationrrrRrSrrrrrrrrr r>r r rrrrr-r.r4r9r@rCrFrIrOrRrUrYr\r_rcrfrirlrpr staticmethoddictrrCrrrrrVrVms,0"(-27(,#+/\`IM=A?C6:-1-1?C"&)-157;/3,0UYG[;[;[;([; sm [;"&[;,0[;! [;}[;([; #5(3 RUCV:W)W#XY![;"HS)O*D%DEF#[;$.6c]%[;&%%;<'[;*&.d^+[;.'+/[;0'+1[;29=3[;4 5[;6#'7[;8+/9[;<!!34=[;>^,?[;B%SMC[;F)11Q(RG[;[;[;[;~.2-1?C"&)-15=AC/C/&*C/'+C/9= C/  C/ #' C/+/C/.6c]C/C/C/C/PcX&H^4&&&X&""""X"&&&&X&.H-C$D...X.+!6+++X+6666X6 211111#" sm   .99C999999, = =# =C =RU =bf = = = =m(8m\mmmm^.>lWc&HX.&&&&$8H#5$$$$L*>*hx6H****kojnmq >4>43):4uXc8L+A&ABMS[\dSeefg>4uXc8L+A&ABMS[\dSeefg >4 %h|.D)D E}V^_gVh hij >4>4>4>4FS)H\,B"CCD #y,!788 9VHLKO))   huS(8E#w,r?0slack_bolt.listener.async_listener_error_handlerr@rAslack_bolt.listener_matcherrBr2slack_bolt.listener_matcher.async_listener_matcherrCrDslack_bolt.loggerrErF$slack_bolt.middleware.async_builtinsrGrHrIrJrK-slack_bolt.middleware.async_custom_middlewarerLrMCslack_bolt.middleware.authorization.async_multi_teams_authorizationrNCslack_bolt.middleware.authorization.async_single_team_authorizationrO!slack_bolt.oauth.async_oauth_flowrP%slack_bolt.oauth.async_oauth_settingsrQ slack_bolt.request.async_requestrRslack_bolt.responserSslack_bolt.util.async_utilsrTrVrrrrsd [[[[[[[[[[[[[[[[[[[[[[;;;;;;ZZZZZZMLLLLLEDDDDDJJJJJJ RQQQQQIIIIIIIINNNNNNNNXWWWWW655555444444 BAAAAAAA*NMMMMMQQQQQQQQEDDDDDCBBBBBBB=<<<<<DDDDDD======,,,,,,??????vvvvvvvvvvr