Sha256: 6667eb28176a35359873b40563971a75d035897ff653705cc12b3b1041c40c80

Contents?: true

Size: 1.45 KB

Versions: 1

Compression:

Stored size: 1.45 KB

Contents

require 'forwardable'

module Fasten
  module UI
    class Console
      extend Forwardable

      def_delegators :executor, :worker_list, :task_list, :task_done_list, :task_error_list, :task_running_list, :task_waiting_list, :worker_list
      def_delegators :executor, :name, :workers, :workers=, :state, :state=, :hformat

      attr_accessor :executor

      def initialize(executor:)
        @executor = executor
        @old = {
          task_done_list: [],
          task_error_list: []
        }
      end

      def setup
        puts <<~FIN

          = == === ==== ===== ====== ======= ======== ========= ==========
          Fasten your seatbelts! #{'💺' * workers}

          #{name}
        FIN

        $stdout.sync = true
        @setup_done = true
      end

      def update
        setup unless @setup_done
        display_task_message(task_done_list, @old[:task_done_list], 'Done in')
        display_task_message(task_error_list, @old[:task_error_list], 'Fail in')
      end

      def cleanup
        puts '========== ========= ======== ======= ====== ===== ==== === == ='
        @setup_done = false
      end

      def force_clear; end

      protected

      def display_task_message(orig, old, message)
        return unless old.count != orig.count

        (orig - old).each do |task|
          puts "Time: #{hformat Time.new - executor.ini} #{message} #{hformat task.dif} Task #{task}"
          old << task
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
fasten-0.5.4 lib/fasten/ui/console.rb