Sha256: ab1c5db0d135afc3ef16f143f54a67a9bf77f74315b9028906829471085039ea
Contents?: true
Size: 1.46 KB
Versions: 10
Compression:
Stored size: 1.46 KB
Contents
module Trailblazer::Macro
module Policy
# Step: This generically `call`s a policy and then pushes its result to `options`.
# You can use any callable object as a policy with this step.
class Eval
def initialize(name: nil, path: nil)
@name = name
@path = path
end
# incoming low-level {Task API}.
# outgoing Task::Binary API.
def call((options, flow_options), **circuit_options)
condition = options[@path] # this allows dependency injection.
result = condition.([options, flow_options], **circuit_options)
options[:"policy.#{@name}"] = result[:policy] # assign the policy as a skill.
options[:"result.policy.#{@name}"] = result
# flow control
signal = result.success? ? Trailblazer::Activity::Right : Trailblazer::Activity::Left # since we & this, it's only executed OnRight and the return boolean decides the direction, input is passed straight through.
return signal, [options, flow_options]
end
end
# Adds the `yield` result to the pipe and treats it like a
# policy-compatible object at runtime.
def self.step(condition, options, &block)
name = options[:name]
path = :"policy.#{name}.eval"
task = Eval.new(name: name, path: path)
injection = Trailblazer::Activity::TaskWrap::Inject::Defaults::Extension(
path => condition
)
{task: task, id: path, extensions: [injection]}
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems