Reduce boilerplate in OpenFeature transport

Author: Strech

Rakefile

@@ -28,6 +28,7 @@ CORE_WITH_LIBDATADOG_API = [
   'spec/datadog/core/configuration/stable_config_spec.rb',
   'spec/datadog/core/ddsketch_spec.rb',
   'spec/datadog/data_streams/**/*_spec.rb',
+  'spec/datadog/open_feature_spec.rb',
 ].freeze
 
 # Data Streams Monitoring (DSM) requires libdatadog_api for DDSketch
@@ -91,7 +92,7 @@ namespace :spec do
   RSpec::Core::RakeTask.new(:main) do |t, args|
     t.pattern = 'spec/**/*_spec.rb'
     t.exclude_pattern = 'spec/**/{appsec/integration,contrib,benchmark,redis,auto_instrument,opentelemetry,open_feature,profiling,crashtracking,error_tracking,rubocop,data_streams}/**/*_spec.rb,' \
-                        ' spec/**/{auto_instrument,opentelemetry,process_discovery,stable_config,ddsketch}_spec.rb,' \
+                        ' spec/**/{auto_instrument,opentelemetry,process_discovery,stable_config,ddsketch,open_feature}_spec.rb,' \
                         ' spec/datadog/gem_packaging_spec.rb'
     t.rspec_opts = args.to_a.join(' ')
   end
@@ -135,7 +136,7 @@ namespace :spec do
 
   desc '' # "Explicitly hiding from `rake -T`"
   RSpec::Core::RakeTask.new(:open_feature) do |t, args|
-    t.pattern = 'spec/datadog/open_feature/**/*_spec.rb,spec/datadog/open_feature_spec.rb'
+    t.pattern = 'spec/datadog/open_feature/**/*_spec.rb'
     t.rspec_opts = args.to_a.join(' ')
   end
 

lib/datadog/open_feature/component.rb

@@ -1,11 +1,11 @@
 # frozen_string_literal: true
 
+require_relative 'transport'
 require_relative 'evaluation_engine'
 require_relative 'exposures/buffer'
 require_relative 'exposures/worker'
 require_relative 'exposures/deduplicator'
 require_relative 'exposures/reporter'
-require_relative 'transport/http'
 
 module Datadog
   module OpenFeature

lib/datadog/open_feature/transport.rb

@@ -0,0 +1,72 @@
+# frozen_string_literal: true
+
+require_relative '../core/transport/http'
+require_relative '../core/transport/http/env'
+require_relative '../core/transport/parcel'
+require_relative '../core/transport/request'
+
+module Datadog
+  module OpenFeature
+    module Transport
+      class EncodedParcel
+        include Core::Transport::Parcel
+
+        def encode_with(encoder)
+          encoder.encode(data)
+        end
+      end
+
+      class HTTP
+        class Spec < Core::Transport::HTTP::API::Spec
+          def initialize
+            @endpoint = Core::Transport::HTTP::API::Endpoint.new(
+              :post, '/evp_proxy/v2/api/v2/exposures'
+            )
+
+            super
+          end
+
+          def call(env, &block)
+            @endpoint.call(env) do |request_env|
+              request_env.headers['Content-Type'] = Core::Encoding::JSONEncoder.content_type
+              request_env.headers['X-Datadog-EVP-Subdomain'] = 'event-platform-intake'
+              request_env.body = env.request.parcel.encode_with(Core::Encoding::JSONEncoder)
+
+              block.call(request_env)
+            end
+          end
+        end
+
+        class Instance < Core::Transport::HTTP::API::Instance
+          def send_exposures(env)
+            @spec.call(env) { |request_env| call(request_env) }
+          end
+        end
+
+        def self.build(agent_settings:, logger:)
+          Core::Transport::HTTP.build(
+            api_instance_class: HTTP::Instance,
+            agent_settings: agent_settings,
+            logger: logger
+          ) { |t| t.api('exposures', HTTP::Spec.new) }.to_transport(self)
+        end
+
+        def initialize(apis, default_api, logger:)
+          @api = apis[default_api]
+          @logger = logger
+        end
+
+        def send_exposures(payload)
+          request = Core::Transport::Request.new(EncodedParcel.new(payload))
+          @api.send_exposures(Core::Transport::HTTP::Env.new(request))
+        rescue => e
+          message = "Internal error during request. Cause: #{e.class.name} #{e.message} " \
+                    "Location: #{Array(e.backtrace).first}"
+          @logger.debug(message)
+
+          Core::Transport::InternalErrorResponse.new(e)
+        end
+      end
+    end
+  end
+end

lib/datadog/open_feature/transport/exposures.rb

@@ -20,7 +20,7 @@ module Datadog
 
         def initialize: (
           settings: Core::Configuration::Settings,
-          transport: Transport::Exposures::Transport,
+          transport: Transport::HTTP,
           telemetry: Core::Telemetry::Component,
           logger: Core::Logger,
           ?flush_interval_seconds: ::Integer,