Contents

module God
  
  class Logger < ::Logger
    attr_accessor :logs
    
    def initialize
      super($stdout)
      self.logs = {}
      @mutex = Mutex.new
      @capture = nil
    end
    
    def start_capture
      @mutex.synchronize do
        @capture = StringIO.new
      end
    end
    
    def finish_capture
      @mutex.synchronize do
        cap = @capture.string
        @capture = nil
        cap
      end
    end
    
    def log(watch, level, text)
      # initialize watch log if necessary
      self.logs[watch.name] ||= Timeline.new(God::LOG_BUFFER_SIZE_DEFAULT) if watch
      
      # push onto capture and timeline for the given watch
      buf = StringIO.new
      templog = ::Logger.new(buf)
      templog.level = Logger::INFO
      templog.send(level, text)
      @mutex.synchronize do
        @capture.puts(buf.string) if @capture
        self.logs[watch.name] << [Time.now, buf.string] if watch
      end
      templog.close
      
      # send to regular logger
      self.send(level, text)
    end
    
    def watch_log_since(watch_name, since)
      # initialize watch log if necessary
      self.logs[watch_name] ||= Timeline.new(God::LOG_BUFFER_SIZE_DEFAULT)
      
      # get and join lines since given time
      @mutex.synchronize do
        self.logs[watch_name].select do |x|
          x.first > since
        end.map do |x|
          x[1]
        end.join
      end
    end
  end
  
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
god-0.5.0	lib/god/logger.rb