ManageIQ/manageiq-providers-ibm_cloud

# frozen_string_literal: true

module ManageIQ
  module Providers
    module IbmCloud
      module CloudTools
        class ActivityTracker < Sdk::Branch
          def initialize(cloudtools:, region:, service_key:)
            super(:cloudtools => cloudtools)
            service_url = "https://api.#{region}.logging.cloud.ibm.com"
            @sdk_params = {:service_url => service_url, :service_key => service_key}
          end

          # Return a new Activty Tracker SDK instance.
          def sdk_client
            require 'ibm_cloud_activity_tracker'

            @sdk_params[:authenticator] = @cloudtools.authenticator
            @sdk_client ||= IbmCloudActivityTracker::ActivityTrackerApiV1.new(@sdk_params)
          end

          private

          # Create a generator that removes the need for pagination.
          # @param call_back [String] The method name to use for pagination.
          # @param array_key [String] The specific key in the returned array to use.
          #
          # @return [Enumerator] Object to page through results.
          # @yield [Hash] Result of request.
          def each_resource(call_back, array_key: nil, **kwargs)
            start = kwargs[:start]

            loop do
              # Send request.
              response = request(call_back, :start => start, **kwargs)
              array_key = get_common(response.keys) if array_key.nil?

              resources = response.fetch(array_key.to_sym)

              resources&.each { |value| yield value }

              # VPC has a next key that holds the next URL.
              return unless response.key?(:next)

              # The :next data structure is a hash with a href member.
              next_url = response.dig(:next, :href)
              return unless next_url

              start = Addressable::URI.parse(next_url).query_values['start']
            end
          end

          #  Try to determine
          def get_common(array_keys)
            keys = array_keys - [:limit, :first, :total_count, :next]
            return keys.first unless keys.empty?

            raise "No array key found in #{array_keys}"
          end
        end
      end
    end
  end
end