Contents

module Trailblazer
  class Circuit::Activity
    # Find all `direction` connections TO <old_task> and rewire them to new_task,
    # then connect new to old with `direction`.
    def self.Before(activity, old_task, new_task, direction:raise, **kws)
      Rewrite(activity, **kws) do |new_map|
        cfg = new_map.find_all { |act, outputs| outputs[direction]==old_task }
        # rewire old line to new task.
        cfg.each { |(activity, outputs)| outputs[direction] = new_task }
        # connect new_task --> old_task.
        new_map[new_task] = { direction => old_task }
      end
    end

    def self.Connect(activity, from, to, direction:raise)
      Rewrite(activity) do |new_map|
        new_map[from][direction] = to
      end
    end

    # Deep-clones an Activity's circuit and allows to alter its map by yielding it.
    #
    #   activity = Circuit::Activity::Rewrite(activity) do |map, evt|
    #     map[some_task] = { Circuit::Right => evt[:End] }
    #   end
    #
    # You can only add events as they might already be in use in the existing map.
    #
    # :private:
    def self.Rewrite(activity, debug:{}, events:{})
      # decompose Activity and Circuit.
      circuit, original_events = activity.values
      map, end_events, original_debug  = circuit.to_fields

      original_events = original_events.to_h
      events.each { |k, v| original_events[k] = (original_events[k] || {}).merge(v) }

      # events = events.to_h.merge(added_events) # add new events.
      debug  = original_debug.to_h.merge(debug) # add new events.

      new_map = {} # deep-dup.
      map.each { |act, outputs| new_map[act] = outputs.dup }

      # recompose to an Activity.
      # new_map is mutable.
      Circuit::Activity(debug, original_events) { |evts| yield(new_map, evts); new_map }
    end
  end
end

Version data entries

11 entries across 11 versions & 1 rubygems

Version	Path
trailblazer-circuit-0.0.11	lib/trailblazer/circuit/alter.rb
trailblazer-circuit-0.0.10	lib/trailblazer/circuit/alter.rb
trailblazer-circuit-0.0.9	lib/trailblazer/circuit/alter.rb
trailblazer-circuit-0.0.8	lib/trailblazer/circuit/alter.rb
trailblazer-circuit-0.0.7	lib/trailblazer/circuit/alter.rb
trailblazer-circuit-0.0.6	lib/trailblazer/circuit/alter.rb
trailblazer-circuit-0.0.5	lib/trailblazer/circuit/alter.rb
trailblazer-circuit-0.0.4	lib/trailblazer/circuit/alter.rb
trailblazer-circuit-0.0.3	lib/trailblazer/circuit/alter.rb
trailblazer-circuit-0.0.2	lib/trailblazer/circuit/alter.rb
trailblazer-circuit-0.0.1	lib/trailblazer/circuit/alter.rb