# typed: false

module Datadog
  module Profiling
    # Used to report profiling data to Datadog.
    # Methods prefixed with _native_ are implemented in `http_transport.c`
    class HttpTransport
      def initialize(agent_settings:, site:, api_key:, upload_timeout_seconds:)
        @upload_timeout_milliseconds = (upload_timeout_seconds * 1_000).to_i

        validate_agent_settings(agent_settings)

        @exporter_configuration =
          if agentless?(site, api_key)
            [:agentless, site, api_key]
          else
            [:agent, base_url_from(agent_settings)]
          end

        status, result = validate_exporter(@exporter_configuration)

        raise(ArgumentError, "Failed to initialize transport: #{result}") if status == :error
      end

      def export(flush)
        status, result = do_export(
          exporter_configuration: @exporter_configuration,
          upload_timeout_milliseconds: @upload_timeout_milliseconds,

          # why "timespec"?
          # libdatadog represents time using POSIX's struct timespec, see
          # https://www.gnu.org/software/libc/manual/html_node/Time-Types.html
          # aka it represents the seconds part separate from the nanoseconds part
          start_timespec_seconds: flush.start.tv_sec,
          start_timespec_nanoseconds: flush.start.tv_nsec,
          finish_timespec_seconds: flush.finish.tv_sec,
          finish_timespec_nanoseconds: flush.finish.tv_nsec,

          pprof_file_name: flush.pprof_file_name,
          pprof_data: flush.pprof_data,
          code_provenance_file_name: flush.code_provenance_file_name,
          code_provenance_data: flush.code_provenance_data,

          tags_as_array: flush.tags_as_array,
        )

        if status == :ok
          if (200..299).cover?(result)
            Datadog.logger.debug('Successfully reported profiling data')
            true
          else
            Datadog.logger.error("Failed to report profiling data: server returned unexpected HTTP #{result} status code")
            false
          end
        else
          Datadog.logger.error("Failed to report profiling data: #{result}")
          false
        end
      end

      # Used to log soft failures in `ddprof_ffi_Vec_tag_push` (e.g. we still report the profile in these cases)
      # Called from native code
      def self.log_failure_to_process_tag(failure_details)
        Datadog.logger.warn("Failed to add tag to profiling request: #{failure_details}")
      end

      private

      def base_url_from(agent_settings)
        case agent_settings.adapter
        when Datadog::Transport::Ext::HTTP::ADAPTER
          "#{agent_settings.ssl ? 'https' : 'http'}://#{agent_settings.hostname}:#{agent_settings.port}/"
        when Datadog::Transport::Ext::UnixSocket::ADAPTER
          "unix://#{agent_settings.uds_path}"
        else
          raise ArgumentError, "Unexpected adapter: #{agent_settings.adapter}"
        end
      end

      def validate_agent_settings(agent_settings)
        supported_adapters = [Datadog::Transport::Ext::HTTP::ADAPTER, Datadog::Transport::Ext::UnixSocket::ADAPTER]
        unless supported_adapters.include?(agent_settings.adapter)
          raise ArgumentError,
            "Unsupported transport configuration for profiling: Adapter #{agent_settings.adapter} " \
                        ' is not supported'
        end

        if agent_settings.deprecated_for_removal_transport_configuration_proc
          Datadog.logger.warn(
            'Ignoring custom c.tracing.transport_options setting as the profiler does not support it.'
          )
        end
      end

      def agentless?(site, api_key)
        site && api_key && Core::Environment::VariableHelpers.env_to_bool(Profiling::Ext::ENV_AGENTLESS, false)
      end

      def validate_exporter(exporter_configuration)
        self.class._native_validate_exporter(exporter_configuration)
      end

      def do_export(
        exporter_configuration:,
        upload_timeout_milliseconds:,
        start_timespec_seconds:,
        start_timespec_nanoseconds:,
        finish_timespec_seconds:,
        finish_timespec_nanoseconds:,
        pprof_file_name:,
        pprof_data:,
        code_provenance_file_name:,
        code_provenance_data:,
        tags_as_array:
      )
        self.class._native_do_export(
          exporter_configuration,
          upload_timeout_milliseconds,
          start_timespec_seconds,
          start_timespec_nanoseconds,
          finish_timespec_seconds,
          finish_timespec_nanoseconds,
          pprof_file_name,
          pprof_data,
          code_provenance_file_name,
          code_provenance_data,
          tags_as_array,
        )
      end
    end
  end
end