iS$ddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z m Z ddl mZmZmZmZmZmZmZmZddlmZddlmZddlmZdd lmZdd lmZm Z m!Z!dd l"m#Z#dd l$m%Z%dd l&m'Z'm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.ddl/m0Z0ddl1m2Z2ddl3m4Z4ddl5m6Z6m7Z7ddl8m9Z9ddl:m;Z;ddl:mm?Z?ddl@mAZAmBZBddlCmDZDmEZEmFZFmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTmUZUddlVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^ddl_m`Z`ddlambZbddlcmdZdmeZemfZfddlgmhZhdd limjZjdd!lkmlZldd"lmmnZndd#lompZpdd$lqmrZrmsZsdd%ltmuZudd&lvmwZwmxZxmyZydd'lzm{Z{m|Z|dd(l}m~Z~Gd)d*ZGd+d,ZdS)-N)Executor)ThreadPoolExecutor)SimpleHTTPRequestHandler HTTPServer)ListUnionPatternCallableDictOptionalSequenceAny) SlackApiError)InstallationStore) WebClient)AuthorizeResult) AuthorizeInstallationStoreAuthorizeCallableAuthorize)AssistantThreadContextStore)AssistantUtilities) BoltErrorBoltUnhandledRequestError)ThreadLazyListenerRunner)TokenRevocationListeners)CustomListener)Listener)DefaultListenerStartHandler) DefaultListenerCompletionHandler)DefaultListenerErrorHandlerCustomListenerErrorHandler)ThreadListenerRunner)CustomListenerMatcher)builtins)ListenerMatcher)get_bolt_app_loggerget_bolt_logger)&error_oauth_flow_or_authorize_required,warning_client_prioritized_and_token_skippedwarning_token_skippederror_auth_test_failureerror_token_requiredwarning_unhandled_requestdebug_checking_listenerdebug_applying_middlewaredebug_running_listener$error_unexpected_listener_middlewareerror_client_invalid_typeerror_authorize_conflictswarning_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) MiddlewareSslCheckRequestVerificationSingleTeamAuthorizationMultiTeamsAuthorizationIgnoringSelfEventsCustomMiddlewareAttachingFunctionToken) Assistant)MessageListenerMatches)DefaultMiddlewareErrorHandlerCustomMiddlewareErrorHandlerMiddlewareErrorHandler)UrlVerification) OAuthFlow)$select_consistent_installation_store) OAuthSettings) BoltRequest)is_assistant_eventto_event) BoltResponse)create_web_clientget_boot_messageget_name_for_callable) WorkflowStepWorkflowStepMiddleware)WorkflowStepBuilderc2eZdZddddddddddddddddddddddddddeejdeededed eed eed ed eed ee e e de ffdee de fdeedeedeedededededededeedeedeedeedeef0dZ ddd edededededededeefdZed efd!Zed eefd"Zed ejfd#Zed efd$Zed eefd%Zed efd&Zed efd'Z ded*ed+ed,ed dfd-Zd.e d e!fd/Z"d.e d0e!d e!fd1Z#d ee fd2Z$d ee fd3Z%d4e&d ee fd5Z' dfd6e ee(e)e*fd7ee e dee!fe+e,e fd8ee e dee!fe+e,e fd9ee e dee!fe+e,e ffd:Z-d;e dee!fd e dee!ffd<Z. dgd=e ee(e/eee ee,ee ee(ffffd>ee,e defd?ee,e e e fd e dee dee!fffd@Z0 dhdBe ee(fd>ee,e defd?ee,e e e fd e dee dee!fffdCZ1 did6e ee(fd>ee,e defd?ee,e e e fdEedFed e dee dee!fff dGZ2 dgdHe ee(fd>ee,e defd?ee,e e e fd e dee dee!fffdIZ3 dgdJe ee(e/ee ee(fffd>ee,e defd?ee,e e e fd e dee dee!fffdKZ4 dgd6e ee(fd>ee,e defd?ee,e e e fd e dee dee!fffdLZ5 dgd6e ee(fd>ee,e defd?ee,e e e fd e dee dee!fffdMZ6 dgdJe ee(e/ee ee(fffd>ee,e defd?ee,e e e fd e dee dee!fffdNZ7 dgdJe ee(e/ee ee(fffd>ee,e defd?ee,e e e fd e dee dee!fffdOZ8 dgd6e ee(fd>ee,e defd?ee,e e e fd e dee dee!fffdPZ9 dgd6e ee(fd>ee,e defd?ee,e e e fd e dee dee!fffdQZ: dgd6e ee(fd>ee,e defd?ee,e e e fd e dee dee!fffdRZ; dgdJe ee(e/ee ee(fffd>ee,e defd?ee,e e e fd e dee dee!fffdSZ< dgdJe ee(fd>ee,e defd?ee,e e e fd e dee dee!fffdTZ= dgdJe ee(fd>ee,e defd?ee,e e e fd e dee dee!fffdUZ> dgdJe ee(e/ee ee(fffd>ee,e defd?ee,e e e fd e dee dee!fffdVZ? dgdWe ee(fd>ee,e defd?ee,e e e fd e dee dee!fffdXZ@ dgd6e ee(fd>ee,e defd?ee,e e e fd e dee dee!fffdYZAd e dee!ffdZZBd e dee!ffd[ZCdjd\ZDd.e fd]ZEeFd^eGd ee,e dee!ffd_ZH dkd`e,e dee!fdaeId>ee,e defd?ee,e e e fdbedFed ee dee!ffdcZJdS)lAppNFT)loggernameprocess_before_response!raise_error_for_unhandled_requestsigning_secrettokentoken_verification_enabledclientbefore_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_tokenlistener_executorassistant_thread_context_storerWrXrYrZr[r\r]r^r_.r`rarbrcrdrerfrgrhrirjrkrlrmrnc  | 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|||_)t[|j)j&|j#|j)j$j.|j} | |_#| | |j)j$_.|j)j|j|j)_|j|j)j$j/|_n|t[|j&|j#|j.|j} | |_#| | |_.ta|j1|j2||_)|j|j)j$j/|_|j3|j_3|j#|j4|j-d|_|jti| e|j)^| pd }|j)j$j5}||krC|j2tm||j)j$_5||j_7d|_8|j#ts|j#|_8g|_:g|_;|tyd}||_=||_>t|j|t|jt|jt|j|t|j||_Dt|j|_Fd |_G|H|||||||| dS)aBolt App that provides functionalities to register middleware/listeners. import os from slack_bolt import App # Initializes your app with your bot token and signing secret app = App( 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") def message_hello(message, say): # say() sends a message to the channel where the event was triggered 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/building-an-app 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. token_verification_enabled: Verifies the validity of the given token if True. client: The singleton `slack_sdk.WebClient` 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 `InstallationStore#find_bot()` if True (Default: False) request_verification_enabled: False if you would like to disable the built-in middleware (Default: True). `RequestVerification` 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). `IgnoringSelfEvents` 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). `UrlVerification` is a built-in middleware that handles url_verification requests that verify the endpoint for Events API in HTTP Mode requests. attaching_function_token_enabled: False if you would like to disable the built-in middleware (Default: True). `AttachingFunctionToken` is a built-in middleware that injects the just-in-time workflow-execution tokens when your app receives `function_executed` or interactivity events scoped to a custom step. ssl_check_enabled: bool = False if you would like to disable the built-in middleware (Default: True). `SslCheck` is a built-in middleware that handles ssl_check requests from Slack. oauth_settings: The settings related to Slack app installation flow (OAuth flow) oauth_flow: Instantiated `slack_bolt.oauth.OAuthFlow`. This is always prioritized over oauth_settings. verification_token: Deprecated verification mechanism. This can be used only for ssl_check requests. listener_executor: Custom executor to run background tasks. If absent, the default `ThreadPoolExecutor` will be used. 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_loggerrWrxF authed_user)rb client_id client_secretrWbot_onlyr^user_token_resolutionSLACK_CLIENT_IDSLACK_CLIENT_SECRET)r| app_storeoauth_flow_storerW)r^rWsettings) max_workers)rW)rWexecutor)rWrYlistener_error_handlerlistener_start_handlerlistener_completion_handlerrmlazy_listener_runner)r]rdrerfrgrhrira)Iosenvirongetinspectstackfilenamesplitpathsep_name_signing_secret_verification_token _base_loggerr'rV_framework_logger"_raise_error_for_unhandled_request_token isinstancerrr2_clientr\warningr)rO_before_authorizecallabler@r: _authorizerr3r_installation_storerrr|r}r _oauth_flowrJinfor6rIrbr`rHr^rW!token_rotation_expiration_minutesr*rcr4r~_tokens_revocation_listenersr_middleware_list _listenersr_assistant_thread_context_store_process_before_responser"r rrr_listener_runnerrD_middleware_error_handler_init_middleware_list_done_init_middleware_list)selfrWrXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrirjrkrlrmrnr app_bot_onlyoauth_flow_bot_onlys M/root/projects/butler/venv/lib/python3.11/site-packages/slack_bolt/app/app.py__init__z App.__init__esb  !Z^^,BBGGN:(9::T'-//!"4"="C"CBGK"P"PQS"T $22D2x WqswHxHx #"(!??3+?+?2S/%*  fi00 = 9 ; ;<<<!DL ,DK &../[/]/]^^^,-DL8<  '()) :)9!Z) $ 6***&& ,j99 :)9&/3  )Y// c#,!-1G$$=$?$?@@@"34;QXa"b"b"b@R  # /DO4K.8.Dz**.H8#'#;080D(,,$8@8Lh44RV-4=|IQI]x'E'EcpDO15  " 011= 455A+__N!&8&@&++,N,P,PQQQ  !)D !E*42!%!1!:!M- """  (:D $!-?Q )<'/+/< (&"&"2";"E  '!E(22!/!B- """  (:D $!-4F1( DKZhiiiD &"&"2";"E@N@pDO =  $ 0DO4OUYU`UlDK  " * *+@+B+B C C C ' 2t7G7S6?%L"&"2";"W 222 ##$>$@$@AAAHT )E+7(PT)  # /0HIa0b0bD - 35*,  $ 2q A A A /M,(?% 4)$;#>dF\#]#]#]#>dF\#]#]#](HPTPf(g(g(g/!9-*""" ! ! ! B_)B B B &+0' ""'A)E)E;i/%=-M0S # c |jrdS|dur3|jt|j|j|dur3|jt |j|j|j|j|j|j |j d} |r |j |j } |jt| |j|n#t$r&} tt!| jd} ~ wwxYw|j5|jt'|j|j|ntt)|jE|jt'|j|j|j jj|ntt/|dur.|jt1|j||dur-|jt3|j|dur&|jt5d|_dS) NT)rlryry)r\)auth_test_resultryra)r`ryra)r`ryrra)ryrf)rrappendr;rrr<rrrrr auth_testr=rrr+responserr>r,rrr(r?rGrA) rr]rdrerfrgrhrirarerrs rrzApp._init_middleware_lists  *  F  $ $  ! ( ('+'? $ 1    (4 / /  ! ( ()$r:} tdd}|j | |||cYd} ~ Sd} ~ wwxYw)zApplies all middleware and dispatches an incoming request from Slack to the right code path. Args: req: An incoming request from Slack Returns: The response generated by this Bolt app rq)statusbody next_calledFcdd<dS)NTr)middleware_statesrmiddleware_nextz%App.dispatch..middleware_next+s.2 ] + + +r)rrespnextNerrorzno next() calls in middlewareT)requestcurrent_responselast_global_middleware_name)rrr)rr)rr listener_namelistenerzunhandled request)rri)!time _init_contextrNrrlevelloggingDEBUGdebugr/rXprocessrrrrhandlerr8rrQ ack_functionr.matchesrun_middlewarer5rrr0run_handle_unmatched_requests Exceptionr)rr starting_timerr middlewareerrmiddleware_respnext_was_not_called debug_messagelistener_responserrs @rdispatchz App.dispatchsy  3'33R'H'H'H)51 3 3 3 3 3X "3  27 /)/7=@@*001J:?1[1[\\\!))c?)SS' 6 | ,3gGf=ghhhBdJJ "&?,/59@J'"'"'"!" $=""" $ 5 L S S*+,/-1!T!"!"!"!"!"!"!"!"" $(KKK.667]^h^mor7s7sttt# KKK+ .!O" 1" 1 5h6K L L &,,-D]-S-STTT##$#771;C;R;Rd> 3 #)-1)@GG #!%H  223== =   s444D  * 1 1 2    KKKKKK sBLC00 D&:"D!L!D&&L-0LL"CL2AL L#J44 K*>"K% L%K**L/L M /M>M M rcT|jt||SN)rrr-)rrrs rrzApp._handle_unmatched_requestss' &&'@'E'EFFF rc|j|S)zRegisters a new global middleware to this app. This method can be used as either a decorator or a method. Refer to `App#middleware()` method's docstring for details.r)rargss rusezApp.usest%%rct|dkr|d}t|trE|}|j|t|t r|j |j|_net|r6|jt|j ||j |Stdt|ddS)aRegisters 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 def middleware_func(logger, body, next): logger.info(f"request body: {body}") next() # Pass a function to this method app.middleware(middleware_func) Refer to https://docs.slack.dev/tools/bolt-python/concepts/global-middleware for details. To learn available arguments for middleware/listeners, see `slack_bolt.kwargs_injection.args`'s API document. Args: *args: A function that works as a global middleware. rNrvz"Unexpected type for a middleware ())lenrr:rrrBthread_context_storerrr@rXrrtype)rrmiddleware_or_callablers rrzApp.middlewares( t99q==%)!W "0*== f)? %,,Z888j)44[9X9d;E;ZD8011 f%,,$!%3$($5.- dTJ`EaEa d d deeetr assistantc,||Srr)rrs rrz App.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 `WorkflowStepBuilder`'s methods. # Create a new WorkflowStep instance from slack_bolt.workflows.step import WorkflowStep ws = WorkflowStep( 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.args`'s API document. For further information about WorkflowStep specific function arguments such as `configure`, `update`, `complete`, and `fail`, refer to `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)rrrr ryrzInvalid step object (rN)warningswarnDeprecationWarningrstrr rRrrTbuildrrrrS)rrrrr steps rrzApp.stepsT  Y(      kC> 2 2 C' - DD1 2 2 C::$*;:<! :tada: You can introduce yourself in this channel." 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.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|}tjj}t||dS)NrT)_to_listener_functionslistbuiltin_matchersrr_register_listener)rkwargs functionsprimary_matcherrrrrs r__call__zApp.event..__call__Msc?EU33F;;;4PT::I.4UHYZZZO**4 ??OXWacghh hrr)rrrrrs```` rrz App.event)s>H i i i i i i i i rrqkeywordcjrtngrtngfd}|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:") def say_hello(message, say): user = message['user'] 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.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|j}dt t||dS)Nmessage)N bot_messagethread_broadcast file_share)rsubtype)r constraintsryrT)rrr message_eventrinsertrCr) rrrr'rrrrrs rrzApp.message..__call__ts?EU33F;;;4PT::I! K /<[dFWO   a!7!@!@ A A A**4 ??OXWacghh hr)r)rrrrrs```` rr"z App.messageTsj:&.54>>>2)3;T*%%%  i i i i i i i i0rauto_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") def reverse_string(ack: Ack, inputs: dict, complete: Complete, fail: Fail): try: ack() string_to_reverse = inputs["stringToReverse"] complete(outputs={"reverseString": string_to_reverse[::-1]}) except Exception as e: 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.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 j} ||S)N)rry)rrrfunction_executedrr) rrrrr,r+rrrrs rrzApp.function..__call__sa?EU33F;;;4PT::I.@[fjfwxxxO**9oxQ[]moz{{ {r)rrr9r)rrrrr+r,rs`````` rfunctionz App.functionsF t # #a&../PQ\^i/j/jkkk%-54>>>2)3;T*%%%  | | | | | | | | | | rcommandcfd}|S)a9Registers 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") def repeat_text(ack, say, command): # Acknowledge command request ack() 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.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|}tjj}t||SNr)rrrr1rr)rrrrr1rrrs rrzApp.command..__call__s`?EU33F;;;4PT::I.6wDL]^^^O**4 ??OXWabb brr)rr1rrrs```` rr1z App.commands=> c c c c c c c c rr'cfd}|S)aLRegisters 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") def open_modal(ack, body, client): # Acknowledge the command request ack() # Call views_open with the built-in client 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.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|}tjj}t||Sr4)rrrshortcutrrrrrrr'rrrs rrzApp.shortcut..__call__sa?EU33F;;;4PT::I.7 QUQbcccO**4 ??OXWabb brrrr'rrrs```` rr7z App.shortcuts>J c c c c c c c c rcfd}|S)z)Registers a new global shortcut listener.c|r|nt|}tjj}t||Sr4)rrrglobal_shortcutrrrrrrrrrrs rrz%App.global_shortcut..__call__a?EU33F;;;4PT::I.>{X\XijjjO**4 ??OXWabb brrrrrrrs```` rr<zApp.global_shortcut= c c c c c c c c rcfd}|S)z*Registers a new message shortcut listener.c|r|nt|}tjj}t||Sr4)rrrmessage_shortcutrrr=s rrz&App.message_shortcut..__call__.sa?EU33F;;;4PT::I.? Y]YjkkkO**4 ??OXWabb brrr?s```` rrCzApp.message_shortcut&r@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") def update_message(ack): 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.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|}tjj}t||Sr4)rrractionrrr8s rrzApp.action..__call__Vs`?EU33F;;;4PT::I.5ktO`aaaO**4 ??OXWabb brrr9s```` rrFz App.action8s=< 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|}tjj}t||Sr4)rrr block_actionrrr8s rrz"App.block_action..__call__gsa?EU33F;;;4PT::I.;KUYUfgggO**4 ??OXWabb brrr9s```` rrIzApp.block_action]s= 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|}tjj}t||Sr4)rrrattachment_actionrrr=s rrz'App.attachment_action..__call__wa?EU33F;;;4PT::I.@Z^ZklllO**4 ??OXWabb brrr?s```` rrLzApp.attachment_actionn= c c c c c c c c rcfd}|S)zyRegisters a new `dialog_submission` listener. Refer to https://docs.slack.dev/legacy/legacy-dialogs/ for details.c|r|nt|}tjj}t||Sr4)rrrdialog_submissionrrr=s rrz'App.dialog_submission..__call__rMrrr?s```` rrQzApp.dialog_submission~rNrcfd}|S)z{Registers a new `dialog_cancellation` listener. Refer to https://docs.slack.dev/legacy/legacy-dialogs/ for details.c|r|nt|}tjj}t||Sr4)rrrdialog_cancellationrrr=s rrz)App.dialog_cancellation..__call__sa?EU33F;;;4PT::I.B;\`\mnnnO**4 ??OXWabb brrr?s```` rrTzApp.dialog_cancellationrNrcfd}|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") 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: ack(response_action="errors", errors=errors) return # Acknowledge the view_submission event and close the modal 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.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|}tjj}t||Sr4)rrrviewrrr8s rrzApp.view..__call__s`?EU33F;;;4PT::I.3KTM^___O**4 ??OXWabb brrr9s```` rrWzApp.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|}tjj}t||Sr4)rrrview_submissionrrr8s rrz%App.view_submission..__call__r>rrr9s```` rr[zApp.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|}tjj}t||Sr4)rrr view_closedrrr8s rrz!App.view_closed..__call__sa?EU33F;;;4PT::I.:;TXTefffO**4 ??OXWabb brrr9s```` rr^zApp.view_closedrNrcfd}|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") 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", }, ] 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.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|}tjj}t||Sr4)rrroptionsrrr8s rrzApp.options..__call__sa?EU33F;;;4PT::I.6{PTPabbbO**4 ??OXWabb brrr9s```` rraz App.optionsrXr action_idcfd}|S)z,Registers a new `block_suggestion` listener.c|r|nt|}tjj}t||Sr4)rrrblock_suggestionrr)rrrrrbrrrs rrz&App.block_suggestion..__call__.sa?EU33F;;;4PT::I.? W[WhiiiO**4 ??OXWabb brr)rrbrrrs```` rrezApp.block_suggestion&r@rcfd}|S)zyRegisters a new `dialog_suggestion` listener. Refer to https://docs.slack.dev/legacy/legacy-dialogs/ for details.c|r|nt|}tjj}t||Sr4)rrrdialog_suggestionrrr=s rrz'App.dialog_suggestion..__call__>rMrrr?s```` rrhzApp.dialog_suggestion5rNrc^|jtt|jjSr)rrr7handle_tokens_revoked_eventsrs r%default_tokens_revoked_event_listenerz)App.default_tokens_revoked_event_listenerHs.  , 4SUUVV V0MMrc^|jtt|jjSr)rrr7handle_app_uninstalled_eventsrs r&default_app_uninstalled_event_listenerz*App.default_app_uninstalled_event_listenerOs.  , 4SUUVV V0NNrc|d||d|dS)Ntokens_revokedapp_uninstalled)rrkrnrs r!enable_token_revocation_listenersz%App.enable_token_revocation_listenersVsZ$ #$$T%O%O%Q%QRRR% $%%d&Q&Q&S&STTTTTrc t|j|j|jd<|j|jd<t |j|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)rwryrWr\) r\base_urltimeoutsslproxyheadersteam_idrWretry_handlersr^r)payloadcontextrsay set_status set_titleset_suggested_promptsget_thread_contextsave_thread_context)r&rXrr|rrrrtrurvrwrxryrWrzcopyrrLrrrMrr}r~rrrr)rrclient_per_requestrs rrzApp._init_context\sx 3TYTXTe f f f H#{ G)2+\*L(  ,$L(K'<&AEA\Ah4<6;;===nr ) ) ) !3 H*.)= %& ch ' ' O* ** %)%II "+CK (1(z*App._register_listener..s;4 4 4 ab !491$J[ \ \ \4 4 4 rrv)rwrlazy_functionsrrrr,ry)rrrr)r:rrr@rXr ValueErrorr1rrrpop) rrrrrrr,value_to_returnlistener_matcherslistener_middlewarems ` rrzApp._register_listeners)T** (YI y>>Q  (lO4 4 4 4 gogusu4 4 4    O444 !r P PA!Z(( P#**1----! P#**+;TYUVdhdu+v+v+vwwww !Ed1gg!N!NOOO  &]]1--(*.%9' -    r)TTTTTTTN)rrT)NNN)NN)rqNN)NNTr*rN)Fr*)K__name__ __module__ __qualname__r rLoggerrboolrrr:r rrrrJrHrrrrpropertyrXrkrWr^rbr"rrYintrrKrNrrrrrBrr rRrTrr rrr rr"r0r1r7r<rCrFrIrLrQrTrWr[r^rarerhrkrnrrr staticmethoddictrr%rrrrrVrVds,0"(-27(,#+/&*LP>B=A:>6:-1-1?C"&)-1526*.,004PTM_ _ _ (_ sm _ "&_ ,0_ ! _ }_ %)_ #_ "#5Xc3h5G)G#HI#_ $HS/%9:;%_ &.6c]'_ (%%67)_ ,&.d^-_ 0'+1_ 2'+3_ 49=5_ 6 7_ 8#'9_ :+/;_ >!/?_ @Y'A_ D%SME_ H$H-I_ L)11L(MM_ _ _ _ F ,0-1-1?C"&)-15=AL/L/$(L/'+L/'+ L/ 9= L/  L/#'L/+/L/.6c]L/L/L/L/bcX HY/   X &&&&X& X(H->$?(((X(%!5%%%X%6666X6#+/ ))))%) )  ))))@jKjLjjjjXkR^&HX.&&&& &8H#5&&&&V*9*(1C****fjeihl ?/?/37JJK?/uXc8L+A&ABHhW_N``ab?/uXc8L+A&ABHhW_N``ab ?/ %h|.D)D ExQYZbQc cde ?/?/?/?/H(3(>#>?HSRZ[gRhMhDiL=AFJ))   huS(8E#w,Slack App Development Server This is a thin wrapper of http.server.HTTPServer and is good enough for your local development or prototyping. However, as mentioned in Python official documents, using http.server module in production is not recommended. Please consider using an adapter (refer to slack_bolt.adapter.*) along with a production-grade server when running the app for end users. https://docs.python.org/3/library/http.server.html#http.server.HTTPServer Args: port: the port number path: the path to receive incoming requests app: the `App` instance to execute oauth_flow: the `OAuthFlow` instance to use for OAuth flow http_server_logger_enabled: The flag to turn on/off http.server's logging c eZdZdededdffd ZfdZfdZdefd Z dd e d e ee efd e eeffdZxZS);SlackAppDevelopmentServer.__init__..SlackAppHandlerformatrrNcHdurtj|g|RdSdSNT)super log_message)rrr __class___http_server_logger_enableds rrzGSlackAppDevelopmentServer.__init__..SlackAppHandler.log_messages;.$66'EGG'666666676rcr|jd\}}}|jkrCtd||j}|}||dS|jkrCtd||j}|}||dS| didS| didS)N?rqrqueryrxrrx) r partition install_pathrKrxhandle_installation_send_bolt_responseredirect_uri_pathhandle_callback_send_response)r request_path_rbolt_req bolt_resp_bolt_oauth_flows rdo_GETzBSlackAppDevelopmentServer.__init__..SlackAppHandler.do_GETs#9-1Y-@-@-E-E*L!U#'7'DDD#.!#"'$(L $$$ %5$H$H$R$R 00;;;;;%)9)KKK#.!#"'$(L $$$ %5$D$DX$N$N 00;;;;;++C+<<<<<''R'88888rc|jd\}}} |kr|didS|jdpd}|jt|d}t|||j} |}| |dS)NrrrContent-Lengthrutf-8r) rrrrxrrfilereadrdecoderKrr) rrrr len_header request_bodyrr _bolt_app_bolt_endpoint_paths rdo_POSTzCSlackAppDevelopmentServer.__init__..SlackAppHandler.do_POSTs)-)<)??D1 #zs:??FFwOO &% L  +4*<*.SlackAppHandler._send_bolt_responses:##$+%-"$rrqrrxrc||t|tr|ntj|}|d}|D] \}}|D]}|||!|dtt|| |j |dS)Nrr) send_responserrjsondumpsencodeitems send_headerr end_headerswfilewrite) rrrxr response_body body_byteskvsvs rrzJSlackAppDevelopmentServer.__init__..SlackAppHandler._send_responses ""6***(24(=(= S4:dCSCS *11':: $]]__//EAr//((A..../  !13s:3G3GHHH  """   ,,,,,r)rq)rrrrrrrrrNrrr r rrr __classcell__)rrrrrs@rSlackAppHandlerrs 7# 7c 7d 7 7 7 7 7 7 7 9 9 9 9 94 4 4 4 4 4 4" \    *,  - - -c8C=01 -CI&  - - - - - - - -rrz0.0.0.0N)_portrrrrrr_server) rrrrrkrrrrrrrs @@@@rrz"SlackAppDevelopmentServer.__init__s2 (, !5?+E(Z#'#; 040E&*&F#G -G -G -G -G -G -G -G -G -G -6G -G -G -R"9dj"9?KK rrc~|jjjtjkrt t dn-|jjt d |j d|j dS#|j wxYw)z Starts a new web server process.T)development_serverg?N) rrWrrINFOprintrPrr serve_forever server_closers rrzSlackAppDevelopmentServer.start3s > & 5 5 "d;;; < < < < N ! & &'74'P'P'P Q Q Q ( L & &t , , , L % % ' ' ' ' 'DL % % ' ' ' 's ,B!!B<rr) rrrrrrVr rHrrrrrrrrs +/+/ nLnLnLnL nL Y' nL %) nLnLnLnL` ( ( ( ( ( (rr)rrrrrr concurrent.futuresrconcurrent.futures.threadr http.serverrrtypingrrr r r r r rslack_sdk.errorsr"slack_sdk.oauth.installation_storer slack_sdk.webrslack_bolt.authorizationr"slack_bolt.authorization.authorizerrr7slack_bolt.context.assistant.thread_context_store.storer0slack_bolt.context.assistant.assistant_utilitiesrslack_bolt.errorrr&slack_bolt.lazy_listener.thread_runnerrslack_bolt.listener.builtinsr#slack_bolt.listener.custom_listenerrslack_bolt.listener.listenerr*slack_bolt.listener.listener_start_handlerr/slack_bolt.listener.listener_completion_handlerr*slack_bolt.listener.listener_error_handlerr r!!slack_bolt.listener.thread_runnerr"slack_bolt.listener_matcherr#r$r,slack_bolt.listener_matcher.listener_matcherr%slack_bolt.loggerr&r'slack_bolt.logger.messagesr(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9slack_bolt.middlewarer:r;r<r=r>r?r@rAslack_bolt.middleware.assistantrB.slack_bolt.middleware.message_listener_matchesrC.slack_bolt.middleware.middleware_error_handlerrDrErF&slack_bolt.middleware.url_verificationrGslack_bolt.oauthrHslack_bolt.oauth.internalsrIslack_bolt.oauth.oauth_settingsrJslack_bolt.requestrK slack_bolt.request.payload_utilsrLrMslack_bolt.responserNslack_bolt.util.utilsrOrPrQslack_bolt.workflows.steprRrSslack_bolt.workflows.step.steprTrVrrrrrsX  ''''''888888<<<<<<<<PPPPPPPPPPPPPPPPPPPP******@@@@@@######444444 `_____OOOOOOAAAAAAAAKKKKKKAAAAAA>>>>>>111111RRRRRRCBBBBB======DDDDDDHHHHHHBBBBBBBB(                    655555QQQQQQ CBBBBB&&&&&&KKKKKK999999******-,,,,, KJJJJJJJ>>>>>>XXXXXXXX|*{({({({({({({({({({(r