1 import Base 2 import ../change_tick.bend as Tick 3 import ../ordinary_app_execution_recipe.bend as Exec 4 import ../ordinary_app_execution_run.bend as ExecuteRun 5 import ../ordinary_app_registration_run.bend as Transport 6 import ../execution_context.bend as Ctx 7 import ../schedule_provision.bend as SP 8 import ../captured_schedule_composition.bend as Choice 9 import ../ordinary_app_composer.bend as Build 10 import ../ordinary_app_registration_fields.bend as Records 11 import ../ordinary_app_records.bend as Leaf 12 import ../ordinary_app_recipe.bend as Tree 13 import ../ordinary_app_observation.bend as Leaves 14 import ../world.bend as W 15 import ../system.bend as Sys 16 import ../transaction.bend as T 17 import ../ordinary_system.bend as System 18 import ../compose.bend as Q 19 import ../inspector.bend as I 20 import ../inspector_query.bend as IQ 21 import ../ordinary_query_observable.bend as O 22 import ../ordinary_app_observation_data.bend as DTO 23 def extracted(~S:Data,~C:Type,~R:Type,~E:Data,~Owners:Type,~Rows:Data,~observe:W.World -> W.World & DTO.Observation,~fold:Owners -> Owners & List<&2,Records.Fields>,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~render:Value -> String,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,~Output:Type,done:Build.Registered,Owners & Leaf.Record,Q.Error,List<&2,Out>,runner>>>,DTO.Product>>>,Tree.observe_pair(~W.World,~Rows,~DTO.Product>>,~observe,~Leaves.component_observe(~S,~C,~R,~E,~Ops,~Value,~query,~render)),Leaf.fold_pair(~S,~Owners,~Leaf.Record,Q.Error,List<&2,Out>,runner>>>,~fold,~Leaf.observed(~S,~Records.Token,Q.Error,List<&2,Out>,runner>>))> -> Output,failed:Build.Registered,Owners,Rows,observe,fold> -> Output,worl 24 match result: 25 case (token,fields):done(Build.appended(~S,~W.World,~Owners,~Rows,~observe,~fold,~Leaf.Record,Q.Error,List<&2,Out>,runner>>>,~DTO.Product>>,~Leaves.component_observe(~S,~C,~R,~E,~Ops,~Value,~query,~render),~Leaf.observed(~S,~Records.Token,Q.Error,List<&2,Out>,runner>>),world,owners,Leaf.Record{token,fields},debug)) 26 def defined(~S:Data,~C:Type,~R:Type,~E:Data,~Owners:Type,~Rows:Data,~observe:W.World -> W.World & DTO.Observation,~fold:Owners -> Owners & List<&2,Records.Fields>,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~render:Value -> String,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,~Output:Type,done:Build.Registered,Owners & Leaf.Record,Q.Error,List<&2,Out>,runner>>>,DTO.Product>>>,Tree.observe_pair(~W.World,~Rows,~DTO.Product>>,~observe,~Leaves.component_observe(~S,~C,~R,~E,~Ops,~Value,~query,~render)),Leaf.fold_pair(~S,~Owners,~Leaf.Record,Q.Error,List<&2,Out>,runner>>>,~fold,~Leaf.observed(~S,~Records.Token,Q.Error,List<&2,Out>,runner>>))> -> Output,failed:Build.Registered,Owners,Rows,observe,fold> -> Output,owners 27 match result: 28 case System.Rejected{world}:failed(Build.Registered{world,owners,recipe,debug}) 29 case System.Defined{world,owner}:extracted(~S,~C,~R,~E,~Owners,~Rows,~observe,~fold,~Ops,~Args,~Error,~Out,~Value,~query,~render,~body,~runner,~define_runner,~execute_runner,~ExecError,~callback_failure,~registration_refused,~Output,done,failed,world,owners,debug,Records.component(~S,~C,~R,~E,~(Args & Maybe<&2,Tick.Tick>),~Q.Error,~List<&2,Out>,~runner,owner)) 30 def register(~S:Data,~C:Type,~R:Type,~E:Data,~Owners:Type,~Rows:Data,~observe:W.World -> W.World & DTO.Observation,~fold:Owners -> Owners & List<&2,Records.Fields>,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~render:Value -> String,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,~Output:Type,done:Build.Registered,Owners & Leaf.Record,Q.Error,List<&2,Out>,runner>>>,DTO.Product>>>,Tree.observe_pair(~W.World,~Rows,~DTO.Product>>,~observe,~Leaves.component_observe(~S,~C,~R,~E,~Ops,~Value,~query,~render)),Leaf.fold_pair(~S,~Owners,~Leaf.Record,Q.Error,List<&2,Out>,runner>>>,~fold,~Leaf.observed(~S,~Records.Token,Q.Error,List<&2,Out>,runner>>))> -> Output,failed:Build.Registered,Owners,Rows,observe,fold> -> Output,app:B 31 match app: 32 case Build.Registered{world,owners,recipe,debug}:defined(~S,~C,~R,~E,~Owners,~Rows,~observe,~fold,~Ops,~Args,~Error,~Out,~Value,~query,~render,~body,~runner,~define_runner,~execute_runner,~ExecError,~callback_failure,~registration_refused,~Output,done,failed,owners,recipe,debug,define_runner(world,name,slot)) 33 34 def execution_returned(~S:Data,~C:Type,~R:Type,~E:Data,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,+args:Args,result:Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>) -> Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out> & Sys.Outcome>,ExecError,Unit>: 35 match result: 36 case Transport.Completed{token,fields,Sys.Succeeded{world,outputs}}:(Exec.Invocation{Leaf.Record{token,fields},args,outputs},Sys.Succeeded{world,Unit{}}) 37 case Transport.Completed{token,fields,Sys.Failed{world,error}}:(Exec.Invocation{Leaf.Record{token,fields},args,[]},Sys.Failed{world,callback_failure(error)}) 38 case Transport.RegistrationRejected{token,fields,world,_}:(Exec.Invocation{Leaf.Record{token,fields},args,[]},Sys.Failed{world,registration_refused}) 39 def execution_allowed(~S:Data,~C:Type,~R:Type,~E:Data,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,allowed:Bool,owner:Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out>,world:Ctx.Context>,id:U32) -> Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out> & Sys.Outcome>,ExecError,Unit>: 40 match allowed owner: 41 case False{} owner:(owner,Sys.Failed{world,registration_refused}) 42 case True{} Exec.Invocation{Leaf.Record{token,fields},+args,_}:execution_returned(~S,~C,~R,~E,~Ops,~Args,~Error,~Out,~Value,~query,~body,~runner,~define_runner,~execute_runner,~ExecError,~callback_failure,~registration_refused,args,execute_runner(token,fields,world,args)) 43 def execution_run(~S:Data,~C:Type,~R:Type,~E:Data,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,owner:Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out>,world:Ctx.Context>,id:U32) -> Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out> & Sys.Outcome>,ExecError,Unit>: 44 match owner: 45 case Exec.Invocation{Leaf.Record{token,+fields},args,outputs}: 46 +selected=id 47 execution_allowed(~S,~C,~R,~E,~Ops,~Args,~Error,~Out,~Value,~query,~body,~runner,~define_runner,~execute_runner,~ExecError,~callback_failure,~registration_refused,U32.is_eq(selected,Exec.registration_id(~S,fields)),Exec.Invocation{Leaf.Record{token,fields},args,outputs},world,selected) 48 def Application(~S:Data,~C:Type,~R:Type,~E:Data,~Owners:Type,~Rows:Data,~observe:W.World -> W.World & DTO.Observation,~fold:Owners -> Owners & List<&2,Records.Fields>,~PriorError:Data,~priorPlan:Owners -> Owners & SP.Plan,~priorDispatch:Owners -> Ctx.Context> -> U32 -> Owners & Sys.Outcome>,PriorError,Unit>,~priorProvide:W.World -> W.World & List<&2,SP.Requirement>,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,~render:Value -> String) -> Type: 49 Exec.Registered,Owners & Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out>,DTO.Product>>>,Tree.observe_pair(~W.World,~Rows,~DTO.Product>>,~observe,~Leaves.component_observe(~S,~C,~R,~E,~Ops,~Value,~query,~render)),Leaf.fold_pair(~S,~Owners,~Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out>,~fold,~Exec.invocation_fields(~S,~Records.Token,Q.Error,List<&2,Out>,runner>>,~Args,~Out)),Choice.Choice,Exec.plan_pair(~S,~Owners,~Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out>,~priorPlan,~Exec.invocation_plan(~S,~Records.Token,Q.Error,List<&2,Out>,runner>>,~Args,~Out)),Exec.dispatch_pair(~S,~W.World,~Owners,~Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out>,~PriorError,~ExecError,~fold,~priorDispatch,~execution_run(~S,~C,~R,~E,~Ops,~Args,~Error,~Out,~Value,~query,~body,~runner,~define_runner,~execute_runner,~ExecError,~callback_failure,~registration_refused)),Exec.provision_pair(~S,~W.World,~priorProvide,~Exec.empty_provide(~S,~W.World))> 50 def execution_added(~S:Data,~C:Type,~R:Type,~E:Data,~Owners:Type,~Rows:Data,~observe:W.World -> W.World & DTO.Observation,~fold:Owners -> Owners & List<&2,Records.Fields>,~PriorError:Data,~priorPlan:Owners -> Owners & SP.Plan,~priorDispatch:Owners -> Ctx.Context> -> U32 -> Owners & Sys.Outcome>,PriorError,Unit>,~priorProvide:W.World -> W.World & List<&2,SP.Requirement>,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,~render:Value -> String,~Output:Type,args:Args,done:Application(~S,~C,~R,~E,~Owners,~Rows,~observe,~fold,~PriorError,~priorPlan,~priorDispatch,~priorProvide,~Ops,~Args,~Error,~Out,~Value,~query,~body,~runner,~define_runner,~execute_runner,~ExecError,~callback_failure,~registration_refused,~render) -> Output,result:Build.Registered,Owners & Leaf.Record,Q.Error,List<&2,Out>,runner>>>,DTO.Product -> W.World & DTO.Observation,~fold:Owners -> Owners & List<&2,Records.Fields>,~PriorError:Data,~priorPlan:Owners -> Owners & SP.Plan,~priorDispatch:Owners -> Ctx.Context> -> U32 -> Owners & Sys.Outcome>,PriorError,Unit>,~priorProvide:W.World -> W.World & List<&2,SP.Requirement>,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,~render:Value -> String,~Output:Type,failed:Exec.Registered,Owners,Rows,observe,fold,PriorError,priorPlan,priorDispatch,priorProvide> -> Output,result:Build.Registered,Owners,Rows,observe,fold>) -> Output: 54 failed(Exec.Registered{result,Exec.Recipe{}}) 55 def add(~S:Data,~C:Type,~R:Type,~E:Data,~Owners:Type,~Rows:Data,~observe:W.World -> W.World & DTO.Observation,~fold:Owners -> Owners & List<&2,Records.Fields>,~PriorError:Data,~priorPlan:Owners -> Owners & SP.Plan,~priorDispatch:Owners -> Ctx.Context> -> U32 -> Owners & Sys.Outcome>,PriorError,Unit>,~priorProvide:W.World -> W.World & List<&2,SP.Requirement>,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,~render:Value -> String,~Output:Type,done:Application(~S,~C,~R,~E,~Owners,~Rows,~observe,~fold,~PriorError,~priorPlan,~priorDispatch,~priorProvide,~Ops,~Args,~Error,~Out,~Value,~query,~body,~runner,~define_runner,~execute_runner,~ExecError,~callback_failure,~registration_refused,~render) -> Output,failed:Exec.Registered,Owners,Rows,observe,fold,PriorError,priorPlan,priorDispatch,priorProvide> -> Output,value:Exec.Registered,Owners,Rows,observe,fold,PriorError,priorPlan,priorDispatch,priorProvide 56 match value: 57 case Exec.Registered{app,_}:register(~S,~C,~R,~E,~Owners,~Rows,~observe,~fold,~Ops,~Args,~Error,~Out,~Value,~query,~render,~body,~runner,~define_runner,~execute_runner,~ExecError,~callback_failure,~registration_refused,~Output,execution_added(~S,~C,~R,~E,~Owners,~Rows,~observe,~fold,~PriorError,~priorPlan,~priorDispatch,~priorProvide,~Ops,~Args,~Error,~Out,~Value,~query,~body,~runner,~define_runner,~execute_runner,~ExecError,~callback_failure,~registration_refused,~render,~Output,args,done),execution_rejected(~S,~C,~R,~E,~Owners,~Rows,~observe,~fold,~PriorError,~priorPlan,~priorDispatch,~priorProvide,~Ops,~Args,~Error,~Out,~Value,~query,~body,~runner,~define_runner,~execute_runner,~ExecError,~callback_failure,~registration_refused,~render,~Output,failed),app,name,slot) 58 def execution_owners(~S:Data,~C:Type,~R:Type,~E:Data,~Owners:Type,~Rows:Data,~observe:W.World -> W.World & DTO.Observation,~fold:Owners -> Owners & List<&2,Records.Fields>,~PriorError:Data,~priorPlan:Owners -> Owners & SP.Plan,~priorDispatch:Owners -> Ctx.Context> -> U32 -> Owners & Sys.Outcome>,PriorError,Unit>,~priorProvide:W.World -> W.World & List<&2,SP.Requirement>,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,~render:Value -> String) -> Type: 59 Owners & Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out> 60 def execution_rows(~S:Data,~C:Type,~R:Type,~E:Data,~Owners:Type,~Rows:Data,~observe:W.World -> W.World & DTO.Observation,~fold:Owners -> Owners & List<&2,Records.Fields>,~PriorError:Data,~priorPlan:Owners -> Owners & SP.Plan,~priorDispatch:Owners -> Ctx.Context> -> U32 -> Owners & Sys.Outcome>,PriorError,Unit>,~priorProvide:W.World -> W.World & List<&2,SP.Requirement>,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,~render:Value -> String) -> Data: 61 DTO.Product>>> 62 def execution_observe(~S:Data,~C:Type,~R:Type,~E:Data,~Owners:Type,~Rows:Data,~observe:W.World -> W.World & DTO.Observation,~fold:Owners -> Owners & List<&2,Records.Fields>,~PriorError:Data,~priorPlan:Owners -> Owners & SP.Plan,~priorDispatch:Owners -> Ctx.Context> -> U32 -> Owners & Sys.Outcome>,PriorError,Unit>,~priorProvide:W.World -> W.World & List<&2,SP.Requirement>,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,~render:Value -> String) -> W.World -> W.World & DTO.Observation>>>>: 63 Tree.observe_pair(~W.World,~Rows,~DTO.Product>>,~observe,~Leaves.component_observe(~S,~C,~R,~E,~Ops,~Value,~query,~render)) 64 def execution_fold(~S:Data,~C:Type,~R:Type,~E:Data,~Owners:Type,~Rows:Data,~observe:W.World -> W.World & DTO.Observation,~fold:Owners -> Owners & List<&2,Records.Fields>,~PriorError:Data,~priorPlan:Owners -> Owners & SP.Plan,~priorDispatch:Owners -> Ctx.Context> -> U32 -> Owners & Sys.Outcome>,PriorError,Unit>,~priorProvide:W.World -> W.World & List<&2,SP.Requirement>,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,~render:Value -> String) -> (Owners & Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out>) -> (Owners & Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out>) & List<&2,Records.Fields>: 65 Leaf.fold_pair(~S,~Owners,~Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out>,~fold,~Exec.invocation_fields(~S,~Records.Token,Q.Error,List<&2,Out>,runner>>,~Args,~Out)) 66 def execution_plan(~S:Data,~C:Type,~R:Type,~E:Data,~Owners:Type,~Rows:Data,~observe:W.World -> W.World & DTO.Observation,~fold:Owners -> Owners & List<&2,Records.Fields>,~PriorError:Data,~priorPlan:Owners -> Owners & SP.Plan,~priorDispatch:Owners -> Ctx.Context> -> U32 -> Owners & Sys.Outcome>,PriorError,Unit>,~priorProvide:W.World -> W.World & List<&2,SP.Requirement>,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,~render:Value -> String) -> (Owners & Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out>) -> (Owners & Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out>) & SP.Plan: 67 Exec.plan_pair(~S,~Owners,~Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out>,~priorPlan,~Exec.invocation_plan(~S,~Records.Token,Q.Error,List<&2,Out>,runner>>,~Args,~Out)) 68 def execution_dispatch(~S:Data,~C:Type,~R:Type,~E:Data,~Owners:Type,~Rows:Data,~observe:W.World -> W.World & DTO.Observation,~fold:Owners -> Owners & List<&2,Records.Fields>,~PriorError:Data,~priorPlan:Owners -> Owners & SP.Plan,~priorDispatch:Owners -> Ctx.Context> -> U32 -> Owners & Sys.Outcome>,PriorError,Unit>,~priorProvide:W.World -> W.World & List<&2,SP.Requirement>,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,~render:Value -> String) -> (Owners & Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out>) -> Ctx.Context> -> U32 -> (Owners & Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out>) & Sys.Outcome>,Choice.Choice,Unit>: 69 Exec.dispatch_pair(~S,~W.World,~Owners,~Exec.Invocation,Q.Error,List<&2,Out>,runner>>,Args,Out>,~PriorError,~ExecError,~fold,~priorDispatch,~execution_run(~S,~C,~R,~E,~Ops,~Args,~Error,~Out,~Value,~query,~body,~runner,~define_runner,~execute_runner,~ExecError,~callback_failure,~registration_refused)) 70 def execution_provide(~S:Data,~C:Type,~R:Type,~E:Data,~Owners:Type,~Rows:Data,~observe:W.World -> W.World & DTO.Observation,~fold:Owners -> Owners & List<&2,Records.Fields>,~PriorError:Data,~priorPlan:Owners -> Owners & SP.Plan,~priorDispatch:Owners -> Ctx.Context> -> U32 -> Owners & Sys.Outcome>,PriorError,Unit>,~priorProvide:W.World -> W.World & List<&2,SP.Requirement>,~Ops:Type -> Type,~Args:Data,~Error:Data,~Out:Data,~Value:Data,~query:O.Declaration,Ops(Q.Frame),I.Frame,Value>,~body:@-H:Type -> @-caps:Ops(H) -> Args -> H -> H & (T.Outcome & Out),~runner:W.World -> (Args & Maybe<&2,Tick.Tick>) -> Sys.Outcome,Q.Error,List<&2,Out>>,~define_runner:W.World -> String -> String -> System.Defined,Sys.Registry,Q.Error,List<&2,Out>,runner>>,~execute_runner:Records.Token,Q.Error,List<&2,Out>,runner>> -> Records.Fields -> Ctx.Context> -> Args -> Transport.TransportResult>,Args & Maybe<&2,Tick.Tick>,Q.Error,List<&2,Out>,Records.Token,Q.Error,List<&2,Out>,runner>>>,~ExecError:Data,~callback_failure:Q.Error -> ExecError,~registration_refused:ExecError,~render:Value -> String) -> W.World -> W.World & List<&2,SP.Requirement>: 71 Exec.provision_pair(~S,~W.World,~priorProvide,~Exec.empty_provide(~S,~W.World))