Contents

# frozen_string_literal: true

module Flagsmith
  # Used to control how often we send data(in seconds)
  class AnalyticsProcessor
    ENDPOINT = 'analytics/flags/'
    TIMER = 10
    attr_reader :last_flushed, :timeout, :analytics_data

    # AnalyticsProcessor is used to track how often individual Flags are evaluated within
    # the Flagsmith SDK. Docs: https://docs.flagsmith.com/advanced-use/flag-analytics.
    #
    # data[:environment_key] environment key obtained from the Flagsmith UI
    # data[:base_api_url] base api url to override when using self hosted version
    # data[:timeout] used to tell requests to stop waiting for a response after a
    #                given number of seconds
    def initialize(data)
      @last_flushed = Time.now
      @analytics_data = {}
      @api_client = data.fetch(:api_client)
      @timeout = data.fetch(:timeout, 3)
      @logger = data.fetch(:logger)
    end

    # Sends all the collected data to the api asynchronously and resets the timer
    def flush
      return if @analytics_data.empty?

      begin
        @api_client.post(ENDPOINT, @analytics_data.to_json)
        @analytics_data = {}
      rescue StandardError => e
        @logger.warn "Temporarily unable to access flag analytics endpoint for exception: #{e}"
      end

      @last_flushed = Time.now
    end

    def track_feature(feature_name)
      @analytics_data[feature_name] = @analytics_data.fetch(feature_name, 0) + 1
      flush if (Time.now - @last_flushed) > TIMER
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
flagsmith-4.1.0	lib/flagsmith/sdk/analytics_processor.rb