Contents

# frozen_string_literal: true

module Micro
  module Service
    class Pipeline
      INVALID_COLLECTION =
        'argument must be a collection of `Micro::Service::Base` classes'.freeze

      def self.[](*services)
        new(services)
      end

      def initialize(services)
        @services = validate!(services)
      end

      def call(arg={})
        @services.reduce(initial_result(arg)) do |result, service|
          break result if result.failure?
          service.call(result.value)
        end
      end

      private

        def validate!(services)
          Array(services).tap do |collection|
            if collection.any? { |klass| !(klass < ::Micro::Service::Base) }
              raise ArgumentError, INVALID_COLLECTION
            end
          end
        end

        def initial_result(arg)
          return arg if arg.is_a?(Micro::Service::Result)
          Micro::Service::Result::Success(value: arg)
        end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
u-service-0.6.0	lib/micro/service/pipeline.rb
u-service-0.5.0	lib/micro/service/pipeline.rb