Contents

module Seam
  class Worker
    def for(step)
      @step = step
    end

    def execute effort
      @current_run = HashWithIndifferentAccess.new( { 
                                                      started_at: Time.now,
                                                      step: @step.to_s, 
                                                      data_before: effort.data,
                                                    } )
      @current_effort = effort
      process
      @current_run[:data_after] = effort.data
      @current_run[:stopped_at] = Time.now
      @current_effort.history << @current_run
      @current_effort.save
    end

    def execute_all
      Seam::Effort.find_all_by_step(@step.to_s).each do |effort|
        execute effort
      end
    end

    def eject
      @current_run[:result] = "eject"
      @current_effort.complete = true
      @current_effort.next_step = nil
      @current_effort.save
    end

    def move_to_next_step
      @current_run[:result] = "move_to_next_step"
      @current_effort.completed_steps << @current_effort.next_step

      steps = @current_effort.flow['steps'].map { |x| x['name'] }

      next_step = steps[@current_effort.completed_steps.count]
      @current_effort.next_step = next_step
      @current_effort.complete  = next_step.nil?
      @current_effort.save
    end

    def try_again_in seconds
      try_again_on = Time.now + seconds

      @current_run[:result] = "try_again_in"
      @current_run[:try_again_on] = try_again_on

      @current_effort.next_execute_at = try_again_on
      @current_effort.save
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
seam-0.0.1	lib/seam/worker.rb