Contents

module Pageflow
  module Panorama
    class JobStatusAttributes < Struct.new(:record, :stage_name)
      def self.handle(record, options = {}, &block)
        new(record, options[:stage]).call(&block)
      end

      def call(&block)
        update_progress(0)

        with_error_message_handling do
          block.call do |percent|
            update_progress(percent)
          end
        end
      end

      private

      def update_progress(percent)
        record.update(stage_attribute_name(:progress) => percent,
                      stage_attribute_name(:error_message) => nil)
      end

      def with_error_message_handling
        yield
      rescue StandardError => e
        if e.respond_to?(:message_i18n_key)
          record[stage_attribute_name(:error_message)] = e.message_i18n_key
        end

        raise
      end

      def stage_attribute_name(suffix)
        [stage_name, suffix].compact.join('_')
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
pageflow-panorama-0.3.0	lib/pageflow/panorama/job_status_attributes.rb
pageflow-panorama-0.2.0	lib/pageflow/panorama/job_status_attributes.rb
pageflow-panorama-0.1.0	lib/pageflow/panorama/job_status_attributes.rb