Contents

require_relative "dsl"

module Linepipe
  class Process
    include DSL
    attr_reader :output, :steps

    def initialize(io=STDOUT)
      @data         = []
      @steps        = []
      @setup        = nil
      @output       = nil
      @expectations = []
      @io           = io
    end

    def [](name)
      steps.detect { |s| s.name == name }
    end

    def run
      run_setup
      @output = steps.reduce(initial_data) { |d, step| step.apply(d) }
    end

    def develop
      run_setup
      @output = steps.to_enum.with_index.reduce(initial_data) { |d, (step, idx)|
        log "Stage #{idx}", step.name
        log "\tInput", d
        step.apply(d).tap do |result|
          log "\tOutput", result
          step.verify_expectations(result).each do |expectation|
            log "\t\t#{expectation.name}: #{expectation.status}"
          end
        end
      }

      if expectations.all? { |exp| exp.successful?(output) }
        log "Expect", "SUCCESS"
      end
    end

    def benchmark(iterations)
      require 'benchmark'
      require 'stringio'

      run_setup

      label_length = steps.map(&:name).map(&:length).max

      out = $stdout
      $stdout = stringio = StringIO.new

      Benchmark.bmbm(label_length) do |x|
        @output = steps.reduce(initial_data) { |d, step|
          result = step.apply(d)
          x.report(step.name) { iterations.times { step.apply(d) } }
          result
        }
      end

      io.puts stringio.string
    ensure
      $stdout = out
    end


    private
    attr_reader :expectations, :io

    def log(topic, msg = "")
      io.puts "\n[Linepipe] #{topic} #{msg}\n"
    end

    def run_setup
      @setup.call if @setup
    end

    def initial_data
      @data.call.tap do |data|
        if data.nil?
          log("Warn", "You need to specify an initial data set")
        end
      end
    end

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
linepipe-0.2.0	lib/linepipe/process.rb