'jLddlmZddlmZddlmZmZmZmZm Z m Z m Z ddl m Z ddlmZddlmZmZddlmZmZmZddlmZdd lmZd d lmZd d lmZd d lm Z d dl!m"Z"d dl#m$Z$ddl%m&Z&ddl'm(Z(m)Z)ddl*m+Z+GddZ,GddZ- dde.deede+fdZ/ ddeede+fdZ0 ddeede+fdZ1dS) )wraps)Logger)CallableUnionOptional AwaitableSequenceListPattern)AsyncWebClient)AsyncBoltContext) AsyncListenerAsyncCustomListener)workflow_step_editworkflow_step_saveworkflow_step_execute)AsyncCustomMiddleware) BoltResponse)_is_used_without_argument) AsyncCompleteAsyncConfigure) AsyncFail AsyncUpdate) BoltError)AsyncListenerMatcherAsyncCustomListenerMatcher)AsyncMiddlewarec 8eZdZUdZeeefed<ee ed<ee ed<ee ed<ee ed< ddeeefdeed ee fd Z dddd d eee d e efefdeee efdeee d e dffdZdddd d eee d e efefdeee efdeee d e dffdZdddd d eee d e efefdeee efdeee d e dffdZdd ee ddfdZ ddedee e ee fd eee d e efefdeee efde f dZeded eeee d e efefdeefdZededeeee efdeefdZdS)AsyncWorkflowStepBuilderzdSteps from apps Refer to https://docs.slack.dev/legacy/legacy-steps-from-apps/ for details. callback_id _base_logger_edit_save_executeNapp_name base_loggerch||_|pt|_||_d|_d|_d|_dS)a) Deprecated: Steps from apps for legacy workflows are now deprecated. Use new custom steps: https://docs.slack.dev/workflows/workflow-steps/ This builder is supposed to be used as decorator. my_step = AsyncWorkflowStep.builder("my_step") @my_step.edit async def edit_my_step(ack, configure): pass @my_step.save async def save_my_step(ack, step, update): pass @my_step.execute async def execute_my_step(step, complete, fail): pass app.step(my_step) 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 the workflow app_name: The application name mainly for logging base_logger: The base logger N)r$__name__r)r%r&r'r()selfr$r)r*s e/usr/local/lib/hermes-agent/venv/lib/python3.11/site-packages/slack_bolt/workflows/step/async_step.py__init__z!AsyncWorkflowStepBuilder.__init__)s:D' ,H '   )matchers middlewarelazyr1.r2r3ct|r'|d}d|_|Sfd}|S)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 edit listener with details. You can use this method as decorator as well. @my_step.edit def edit_my_step(ack, configure): pass It's also possible to add additional listener matchers and/or middleware @my_step.edit(matchers=[is_valid], middleware=[update_context]) def edit_my_step(ack, configure): pass 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: *args: This method can behave as either decorator or a method matchers: Listener matchers middleware: Listener middleware lazy: Lazy listeners reditcgngz}d|_tfd}|S)Nr5c$K|i|d{VSNargskwargsfuncs r._wrapperz?AsyncWorkflowStepBuilder.edit.._inner.._wrapper.!T426222222222r0) _to_listenerr&rr= functionsr>r3r1r2r-s` r._innerz-AsyncWorkflowStepBuilder.edit.._inner{d$*:$$CI**69h SSDJ 4[[ 3 3 3 3[ 3Or0)rr@r&r-r1r2r3r;r=rCs```` r.r5zAsyncWorkflowStepBuilder.editRqH %T * * 7D**64:NNDJK         r0ct|r'|d}d|_|Sfd}|S)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 save listener with details. You can use this method as decorator as well. @my_step.save def save_my_step(ack, step, update): pass It's also possible to add additional listener matchers and/or middleware @my_step.save(matchers=[is_valid], middleware=[update_context]) def save_my_step(ack, step, update): pass 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: *args: This method can behave as either decorator or a method matchers: Listener matchers middleware: Listener middleware lazy: Lazy listeners rsavecgngz}d|_tfd}|S)NrHc$K|i|d{VSr8r9r:s r.r>z?AsyncWorkflowStepBuilder.save.._inner.._wrapperr?r0)r@r'rrAs` r.rCz-AsyncWorkflowStepBuilder.save.._innerrDr0)rr@r'rEs```` r.rHzAsyncWorkflowStepBuilder.saverFr0ct|r'|d}d|_|Sfd}|S)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 execute listener with details. You can use this method as decorator as well. @my_step.execute def execute_my_step(step, complete, fail): pass It's also possible to add additional listener matchers and/or middleware @my_step.save(matchers=[is_valid], middleware=[update_context]) def execute_my_step(step, complete, fail): pass 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: *args: This method can behave as either decorator or a method matchers: Listener matchers middleware: Listener middleware lazy: Lazy listeners rexecutecgngz}d|_tfd}|S)NrLc$K|i|d{VSr8r9r:s r.r>zBAsyncWorkflowStepBuilder.execute.._inner.._wrapperr?r0)r@r(rrAs` r.rCz0AsyncWorkflowStepBuilder.execute.._innersd$*:$$CI --iHjYYDM 4[[ 3 3 3 3[ 3Or0)rr@r(rEs```` r.rLz AsyncWorkflowStepBuilder.executesqH %T * * 7D --ixTTDMK         r0returnAsyncWorkflowStepc|jtd|jtd|jtdt |j|j|j|j|j|S)a Deprecated: Steps from apps for legacy workflows are now deprecated. Use new custom steps: https://docs.slack.dev/workflows/workflow-steps/ Constructs a WorkflowStep object. This method may raise an exception if the builder doesn't have enough configurations to build the object. Returns: An `AsyncWorkflowStep` object Nzedit listener is not registeredzsave listener is not registeredz"execute listener is not registered)r$r5rHrLr)r*)r&rr'r(rPr$r))r-r*s r.buildzAsyncWorkflowStepBuilder.builds} : =>> > : =>> > = @AA A (M]#     r0namelistener_or_functionsc t|j|j||||j|||j||jS)N)r$r)rTrSr1r2r*)rPbuild_listenerr$r)to_listener_matchersto_listener_middlewarer%)r-rSrTr1r2s r.r@z%AsyncWorkflowStepBuilder._to_listenersb!//(]"7..t}hGG224=*MM)0   r0cg}||D]}t|tr||-t|tr%|t ||gt dt ||S)Nr)r=zInvalid matcher: ) isinstancerappendrr ValueErrortype)r)r1 _matchersms r.rWz-AsyncWorkflowStepBuilder.to_listener_matchers s    D Da!566D$$Q''''8,,D$$%?XY%Z%Z%Z[[[[$%Ba%B%BCCCr0cg}||D]}t|tr||-t|tr%|t ||gt dt ||S)NrZzInvalid middleware: )r[r!r\rrr]r^)r)r2 _middlewarer`s r.rXz/AsyncWorkflowStepBuilder.to_listener_middleware0s  ! G Ga11G&&q))))8,,G&&'!?AU!UVW3U8_#<=> 3 tHS)D/%9:;< 3333p[_AE?C 3335#y*>!?AU!UVW3U8_#<=> 3 tHS)D/%9:;< 3333p[_AE?C 3335#y*>!?AU!UVW3U8_#<=> 3 tHS)D/%9:;< 3333j  &!1 =P    D[_AE     %]Hd8n%LM 5#y*>!?AU!UVW  U8_#<=>       "  4hsIdO/C&DFZ&Z [\]  " #   \   #+Dx7P1Q,R#S  o    \   r0r#ceZdZUeeefed< eed< eed< eed< ddddeeefdeede e fee efdeede e fee efdeede e fee efde ed e e f d Ze ddeeefd e e d efd Ze ddeeefded eeeeefdede eede eed e e fdZe ddeded e e d efdZe ddeded e e d efdZdS)rPr$r5rHrLN)r)r*.r)r*c||_|pt}||||d||_||||d||_||||d||_dS)aE Deprecated: Steps from apps for legacy workflows are now deprecated. Use new custom steps: https://docs.slack.dev/workflows/workflow-steps/ Args: callback_id: The callback_id for this step from app edit: Either a single function or a list of functions for opening a modal in the builder UI When it's a list, the first one is responsible for ack() while the rest are lazy listeners. save: Either a single function or a list of functions for handling modal interactions in the builder UI When it's a list, the first one is responsible for ack() while the rest are lazy listeners. execute: Either a single function or a list of functions for handling steps from apps executions When it's a list, the first one is responsible for ack() while the rest are lazy listeners. app_name: The app name that can be mainly used for logging base_logger: The logger instance that can be used as a template when creating this step's logger r5)r$r)rTrSr*rHrLN)r$r,rVr5rHrL)r-r$r5rHrLr)r*s r.r/zAsyncWorkflowStep.__init__Js4''x''#"&# (   ''#"&# (   **#")# +   r0rOc$t||S)z Deprecated: Steps from apps for legacy workflows are now deprecated. Use new custom steps: https://docs.slack.dev/workflows/workflow-steps/ )r*)r#)clsr$r*s r.builderzAsyncWorkflowStep.builder|s( MMMMr0rTrSr1r2c *|t|d|dt|tr|g}t|tr|St|tr|r|ng}|d|||||r|ng}|d|||||}|d} t|||| ||dk|Std|dt|d|d) Nz$ listener is required (callback_id: )rrL)r)r1r2 ack_functionlazy_functionsauto_acknowledgementr*zInvalid z listener: z detected (callback_id: ) rr[rrlistinsert_build_primary_matcher_build_single_middlewarepoprr^) rmr$r)rTrSr1r2r*rBrqs r.rVz AsyncWorkflowStep.build_listeners[ ! (tWWWWWXX X +X 6 6 <%:$; ! +] ; ; }( ( -t 4 4 }#+3xxH OOAs99$ [YY Z Z Z'19rJ   a!=!=dKQ\!]!] ^ ^ ^-I$==++L&!!%)(%)Y%6' {t{{=R8S8S{{mx{{{|| |r0c|dkrt|d|S|dkrt|d|S|dkrt|d|Std|)Nr5T)asyncior*rHrL Invalid name )rrrr]rmrSr$r*s r.rvz(AsyncWorkflowStep._build_primary_matchersx 6>>%k4[YYY Y V^^%k4[YYY Y Y  (dP[\\\ \3T3344 4r0c|dkrt||S|dkrt|S|dkrt|Std|)Nr5rHrLr{)_build_edit_listener_middleware_build_save_listener_middleware"_build_execute_listener_middlewarer]r|s r.rwz*AsyncWorkflowStep._build_single_middlewaresd 6>>2; LL L V^^2;?? ? Y  5kBB B3T3344 4r0r8)NNN)r,rcrdrrfr rgrrrrr rrr/ classmethodr#rnr rr!rVrvrwr9r0r.rPrP@ssG|$$$$. E _ I#'(,0 0 0 3<(0 HS)L"99:M8T\K]]^ 0 HS)L"99:M8T\K]]^ 0 xY|%< <=}hW_N``a 0 3-0 f%0 0 0 0 d)- N N3<( Nf% N " N N N[ N:>6:(,#}#}3<(#}#} %]Hd8n%LM #}  #} 4 456 #}T/23#}f%#}#}#}[#}J )- 5 5 5 5f% 5  5 5 5[ 5 )- 5 5 5 5f% 5  5 5 5[ 5 5 5r0rPNr$r*rOc dtdtdtdtgtt fffd }t t||S)NcontextclientbodynextcRKt|||d<|d{VS)N)r$rr configurer)rrrrr$s r.edit_listener_middlewarezA_build_edit_listener_middleware..edit_listener_middlewaresE .#     TVV||||||r0r)r=r*r r dictrrrrr,)r$r*rs` r.r~r~sv !   r9\223       ! %   r0c dtdtdtdtgtt ffd}t t||S)NrrrrcNKt|||d<|d{VS)Nrrupdaterrrrrs r.save_listener_middlewarezA_build_save_listener_middleware..save_listener_middlewaresA (   TVV||||||r0rr)r*rs r.rrsk !   r9\223     ! %   r0c dtdtdtdtgtt ffd}t t||S)NrrrrcvKt|||d<t|||d<|d{VS)Nrcompletefail)rrrs r.execute_listener_middlewarezG_build_execute_listener_middleware..execute_listener_middlewaresa ,    $   TVV||||||r0rr)r*rs r.rr sk!r9\223  ! (   r0r8)2 functoolsrloggingrtypingrrrrr r r slack_sdk.web.async_clientr slack_bolt.context.async_contextr "slack_bolt.listener.async_listenerrr$slack_bolt.listener_matcher.builtinsrrr-slack_bolt.middleware.async_custom_middlewarerslack_bolt.responser internalsrutilities.async_completerutilities.async_configurerutilities.async_failrutilities.async_updatererrorr'listener_matcher.async_listener_matcherrr middleware.async_middlewarer!r#rPrfr~rrr9r0r.rsPPPPPPPPPPPPPPPPPP555555======QQQQQQQQ POOOOO,,,,,,000000333333555555++++++//////;:::::________D M5M5M5M5M5M5M5M5n%)&!<%)&!8%)&!r0