class Mettric

# File lib/mettric/mettric.rb, line 5
def self.config
  @config
end

# File lib/mettric/mettric.rb, line 9
def self.config=(config)
  # See if the config is valid
  config_test = Client.new(config)
  config_test.close

  # Set the config
  @config = config

  # Attempt to install sidekiq middleware unless
  # we're told not to
  if config.delete(:sidekiq_middleware) != false
    Mettric::SidekiqMiddleware.install
  end

  @config
end

# File lib/mettric/mettric.rb, line 79
def self.ensure_worker_running
  return if worker_running?
  LOCK.synchronize do
    return if worker_running?
    start_worker
  end
end

# File lib/mettric/mettric.rb, line 39
def self.event(payload)
  payload[:tags] ||= []
  payload[:tags] << :event
  track(payload)
end

# File lib/mettric/mettric.rb, line 34
def self.meter(payload)
  track(payload)
end

# File lib/mettric/mettric.rb, line 91
def self.start_worker
  exception = nil
  worker = Mettric::Worker.new(QUEUE, @config)
  @worker_thread = Thread.new do
    begin
    worker.start
    rescue => e
      exception = e
    end
  end
  sleep 0.5
  return if @worker_thread.alive?
  raise Mettric::CouldNotStartWorkerThread, exception
end

# File lib/mettric/mettric.rb, line 46
def self.time(payload)
  exception = nil
  result = nil
  state = 'success'
  start = Time.now
  begin
    result = yield
  rescue => e
    exception = e
    state = 'failure'
  end

  # Be super conservative, always return the result
  begin
    timing_payload = payload.dup
    timing_payload[:service] = "#{payload[:service]}.duration"
    timing_payload[:metric] = ((Time.now - start) * 1000).to_i
    timing_payload[:description] = [payload[:description], "(ms)"].compact.join(' ')
    timing_payload[:tags] = (payload[:tags] || []) + [:timing]
    track(timing_payload)
  rescue
    result
  end

  if exception
    event(service: "#{payload[:service]}.failure", tags: payload[:tags], description: exception.to_s) rescue nil
    raise exception
  else
    event(service: "#{payload[:service]}.success", tags: payload[:tags]) rescue result
  end
  result
end

# File lib/mettric/mettric.rb, line 26
def self.track(payload)
  return false unless @config
  ensure_worker_running
  QUEUE << payload
  QUEUE.size
end

# File lib/mettric/mettric.rb, line 87
def self.worker_running?
  @worker_thread && @worker_thread.alive?
end