Contents

# frozen_string_literal: true

module Importeur
  class ETL
    def initialize(extractor:, transformer:, loader:)
      @extractor = extractor
      @transformer = transformer
      @loader = loader
    end

    def call
      extracted = extractor.call
      return if extracted.nil?
      transformed = extracted.lazy.flat_map do |entity|
        transformer.call(entity)
      end
      loader.call(transformed.lazy)
    end

    private

    attr_reader :extractor, :transformer, :loader
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
importeur-0.1.1	lib/importeur/etl.rb
importeur-0.1.0	lib/importeur/etl.rb