Contents

require_relative 'string'

module RTALogger
  # base log repository class
  class LogRepository
    def initialize
      @semaphore = Mutex.new
      @log_records = []
      @enable = true
      @formatter = RTALogger::LogFactory.log_formatter_default
    end

    # @@sub_classes = {}

    # def self.create type
    #   requested_class = @@sub_classes[type]
    #   if requested_class
    #     requested_class.new
    #   else
    #     raise "Bad log repository type: #{type}"
    #   end
    # end
    #
    # def self.register repository_name
    #   @@sub_classes[repository_name] = self
    # end

    attr_accessor :enable
    attr_accessor :formatter

    def add_log_records(items)
      return 0 unless @enable
      @semaphore.synchronize do
        items.each { |item| @log_records.push(item.dup) }
      end
      flush_and_clear
    end

    def load_config(config_json)
      @enable = config_json['enable'].nil? ? true : config_json['enable']

      formatter_config = config_json['formatter']
      if formatter_config && formatter_config['type']
        @formatter = LogFactory.create_formatter(formatter_config['type'], formatter_config)
      end
    end

    def to_builder
      jb = Jbuilder.new do |json|
        json.type self.class.to_s.split('::').last.underscore.sub('log_repository_', '')
        json.enable enable
        json.formatter @formatter.to_builder.attributes!
      end

      jb
    end

    def reveal_config
      to_builder.target!
    end

    protected

    def flush_and_clear
      @semaphore.synchronize { @log_records.clear }
    end

    attr_reader :log_records
    attr_reader :semaphore
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
RTALogger-1.1.1	lib/log_repository.rb
RTALogger-1.1.0	lib/log_repository.rb