Contents

class Trailblazer::Circuit
  module Task
    module_function
    # Convenience functions for tasks. Totally optional.

    # Task::Binary aka "step"
    # Step is binary task: true=> Right, false=>Left.
    # Step call proc.(options, flow_options)
    # Step is supposed to run Option::KW, so `step` should be Option::KW.
    #
    # Returns task to call the proc with (options, flow_options), omitting `direction`.
    # When called, the task always returns a direction signal.
    def Binary(step, on_true=Right, on_false=Left)
      ->(direction, *args) do # Activity/Task interface.
        [ step.(direction, *args) ? on_true : on_false, *args ] # <=> Activity/Task interface
      end
    end

    module Args
      module_function
      # :private:
      # Return task to call the proc with keyword arguments. Ruby >= 2.0.
      # This is used by `Operation::step` to wrap the argument and make it
      # callable in the circuit.
      def KW(proc)
        if proc.is_a? Symbol
          ->(*args) { meth!(proc, *args) } # Activity interface
        else
          ->(*args) { call!(proc, *args) } # Activity interface
        end
      end

      # DISCUSS: standardize tmp_options.
      # Calls `proc` with a step interface.
      def call!(proc, direction, options, flow_options, tmp_options={})
        # proc.(options, **options.to_hash(tmp_options))
        proc.(options, **options.to_hash)
      end

      # Make the context's instance method a "lambda" and reuse #call!.
      # TODO: should we make :context a kwarg?
      def meth!(proc, direction, options, flow_options, *args)
        call!(flow_options[:context].method(proc), direction, options, flow_options, *args)
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
trailblazer-circuit-0.0.3	lib/trailblazer/circuit/task.rb
trailblazer-circuit-0.0.2	lib/trailblazer/circuit/task.rb
trailblazer-circuit-0.0.1	lib/trailblazer/circuit/task.rb