Contents

# frozen_string_literal: true

require_relative 'step_registry'

module Nocode
  # Class that knows how to execute a series of steps given a context.
  class StepsExecutor
    extend Forwardable

    NAME_KEY    = 'name'
    OPTIONS_KEY = 'options'
    TYPE_KEY    = 'type'

    attr_reader :context, :steps

    def_delegators :context, :log_line, :log

    def initialize(context:, steps:)
      @context = context
      @steps   = steps

      freeze
    end

    def execute
      steps.each do |step|
        step_instance = make_step(step)

        execute_step(step_instance)
      end
    end

    private

    def make_step(step)
      evaluated_step = Util::ObjectTemplate.new(step).evaluate(context.to_h)
      type           = evaluated_step[TYPE_KEY].to_s
      name           = evaluated_step[NAME_KEY].to_s
      step_class     = StepRegistry.constant!(type)

      options =
        if step_class.skip_options_evaluation?
          step[OPTIONS_KEY]
        else
          evaluated_step[OPTIONS_KEY]
        end

      step_class.new(
        options: Util::Dictionary.new(options),
        context: context,
        name: name,
        type: type
      )
    end

    def execute_step(step)
      log(step.name) unless step.name.empty?
      log("Step:  #{step.type}")
      log("Class: #{step.class}")

      time_in_seconds = Benchmark.measure { step.perform }.real

      log("Completed in #{time_in_seconds.round(3)} second(s)")

      log_line
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
nocode-0.0.9	lib/nocode/steps_executor.rb
nocode-0.0.8	lib/nocode/steps_executor.rb
nocode-0.0.7	lib/nocode/steps_executor.rb