Class: Trailblazer::Macro::Nested::Dynamic

Inherits:
Object
  • Object
show all
Defined in:
lib/trailblazer/macro/nested.rb

Overview

API:

  • private The internals here are considered private and might change in the near future.

Constant Summary collapse

SUCCESS_SEMANTICS =

TODO: make this injectable/or get it from operation.

API:

  • private The internals here are considered private and might change in the near future.

[:success, :pass_fast]

Class Method Summary collapse

Class Method Details

.call_dynamic_nested_activity(ctx, flow_options, runner:, **circuit_options) ⇒ Object

API:

  • private The internals here are considered private and might change in the near future.



86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
 
# File 'lib/trailblazer/macro/nested.rb', line 86

def self.call_dynamic_nested_activity((ctx, flow_options), runner:, **circuit_options)
  nested_activity       = flow_options[:decision]
  original_flow_options = flow_options.slice(*(flow_options.keys - [:decision]))

  host_activity = Dynamic.host_activity_for(activity: nested_activity)

  # TODO: make activity here that has only one step (plus In and Out config) which is {nested_activity}

  return_signal, (ctx, flow_options) = runner.(
    nested_activity,
    [ctx, original_flow_options], # pass {flow_options} without a {:decision}.
    runner:   runner,
    **circuit_options,
    activity: host_activity
  )

  return compute_legacy_return_signal(return_signal), [ctx, flow_options]
end

.compute_legacy_return_signal(return_signal) ⇒ Object

API:

  • private The internals here are considered private and might change in the near future.



105
106
107
108
 
# File 'lib/trailblazer/macro/nested.rb', line 105

def self.compute_legacy_return_signal(return_signal)
  actual_semantic  = return_signal.to_h[:semantic]
  applied_signal   = SUCCESS_SEMANTICS.include?(actual_semantic) ? Activity::Right : Activity::Left # TODO: we could also provide PassFast/FailFast.
end

.host_activity_for(activity:) ⇒ Object

This is used in Nested and Each where some tasks don't have a corresponding, hard-wired activity. This is needed for TaskWrap.invoke and the Debugging API in tracing.

API:

  • private The internals here are considered private and might change in the near future.



113
114
115
116
117
118
 
# File 'lib/trailblazer/macro/nested.rb', line 113

def self.host_activity_for(activity:)
  Activity::TaskWrap.container_activity_for(
    activity,
    id: activity.to_s
  )
end