Contents

require "simple_speaker/version"

module SimpleSpeaker
  class Speaker
    def initialize(logger_path = nil, logger_error_path = nil)
      @logger = Logger.new(logger_path) unless logger_path.nil?
      @logger_error = Logger.new(logger_error_path) unless logger_error_path.nil?
      @daemons = []
      @user_input = nil
    end

    def ask_if_needed(question, no_prompt = 0, default = 'y', thread = Thread.current)
      ask_if_needed = default
      if no_prompt.to_i == 0
        self.speak_up(question, 0, thread)
        if Daemon.is_daemon?
          wtime = 0
          while @user_input.nil?
            sleep 1
            ask_if_needed = @user_input
            break if (wtime += 1) > USER_INPUT_TIMEOUT
          end
          @user_input = nil
        else
          ask_if_needed = STDIN.gets.strip
        end
      end
      ask_if_needed
    end

    def daemon_send(str)
      Thread.current[:current_daemon].send_data "#{str}\n" if Thread.current[:current_daemon]
    end

    def email_msg_add(str, in_mail, thread)
      thread[:email_msg] += str + NEW_LINE if thread[:email_msg]
      if in_mail.to_i > 0
        thread[:send_email] = in_mail.to_i if thread[:send_email]
      end
    end

    def speak_up(str, in_mail = 1, thread = Thread.current)
      puts str
      daemon_send(str)
      @logger.info(str) if @logger
      email_msg_add(str, in_mail, thread)
      str
    end

    def log(str)
      @logger.info(str) if @logger
    end

    def tell_error(e, src, in_mail = 1, thread = Thread.current)
      puts "In #{src}"
      daemon_send(src)
      puts e
      daemon_send(e)
      @logger_error.error("ERROR #{Time.now.utc.to_s} #{src}") if @logger_error
      @logger_error.error(e) if @logger_error
      email_msg_add("ERROR #{Time.now.utc.to_s} #{src}" + NEW_LINE, in_mail, thread)
      email_msg_add(e.to_s + NEW_LINE, in_mail, thread)
    end

    def user_input(input)
      @user_input = input
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
simple_speaker-0.2.6	lib/simple_speaker.rb