class SplitIoClient::Telemetry::MemoryRuntimeProducer

def add_tag(tag)
  return if tag.length >= 9
  @adapter.tags << tag
end

def initialize(config)
  @config = config
  @adapter = config.telemetry_adapter
end

def record_auth_rejections
  @adapter.auth_rejections.increment
rescue StandardError => e
  @config.log_found_exception(__method__.to_s, e)
end

def record_events_stats(type, count)
  @adapter.events_data_records.find { |l| l[:type] == type }[:value].value += count unless count.zero?
rescue StandardError => e
  @config.log_found_exception(__method__.to_s, e)
end

def record_impressions_stats(type, count)
  @adapter.impressions_data_records.find { |l| l[:type] == type }[:value].value += count unless count.zero?
rescue StandardError => e
  @config.log_found_exception(__method__.to_s, e)
end

def record_session_length(session)
  @adapter.session_length.value = session
rescue StandardError => e
  @config.log_found_exception(__method__.to_s, e)
end

def record_streaming_event(type, data = nil, timestamp = nil)
  timestamp ||= (Time.now.to_f * 1000.0).to_i
  @adapter.streaming_events << { e: type, d: data, t: timestamp } unless @adapter.streaming_events.length >= 19
rescue StandardError => e
  @config.log_found_exception(__method__.to_s, e)
end

def record_successful_sync(type, value = nil)
  value = (Time.now.to_f * 1000.0).to_i if value.nil?
  @adapter.last_synchronization.find { |l| l[:type] == type }[:value] = Concurrent::AtomicFixnum.new(value)
rescue StandardError => e
  @config.log_found_exception(__method__.to_s, e)
end

def record_sync_error(type, status)
  http_errors = @adapter.http_errors.find { |l| l[:type] == type }[:value]
  begin
    http_errors[status] += 1
  rescue StandardError => _e
    http_errors[status] = 1
  end
rescue StandardError => e
  @config.log_found_exception(__method__.to_s, e)
end

def record_sync_latency(type, bucket)
  @adapter.http_latencies.find { |l| l[:type] == type }[:value][bucket] += 1
rescue StandardError => e
  @config.log_found_exception(__method__.to_s, e)
end

def record_token_refreshes
  @adapter.token_refreshes.increment
rescue StandardError => e
  @config.log_found_exception(__method__.to_s, e)
end

def record_updates_from_sse(event)
  @adapter.updates_from_sse[event] += 1
rescue StandardError => e
  @config.log_found_exception(__method__.to_s, e)
end