Contents

module NxtPipeline
  class Step
    def initialize(type, constructor, index, **opts)
      define_attr_readers(opts)

      @type = type
      @index = index
      @result = nil
      @opts = opts
      @status = nil
      @constructor = constructor
      @error = nil
    end

    attr_reader :type, :result, :status, :error, :opts, :index

    def execute(arg)
      guard_args = [arg, self]
      if_guard_args = guard_args.take(if_guard.arity)
      unless_guard_guard_args = guard_args.take(unless_guard.arity)

      if unless_guard.call(*unless_guard_guard_args) && if_guard.call(*if_guard_args)
        self.result = constructor.call(self, arg)
      end

      set_status
      result
    rescue StandardError => e
      self.status = :failed
      self.error = e
      raise
    end

    def to_s
      "#{opts.merge(type: type)}"
    end

    def type?(potential_type)
      type.to_sym == potential_type.to_sym
    end

    private

    attr_writer :result, :status, :error
    attr_reader :constructor

    def if_guard
      opts.fetch(:if) { no_guard }
    end

    def unless_guard
      opts.fetch(:unless) { no_guard }
    end

    def no_guard
      -> { true }
    end

    def define_attr_readers(opts)
      opts.each do |key, value|
        define_singleton_method key.to_s do
          value
        end
      end
    end

    def set_status
      self.status = result.present? ? :success : :skipped
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
nxt_pipeline-0.2.8	lib/nxt_pipeline/step.rb