[FFL-1318] Add OpenFeature component

.rubocop.yml

@@ -47,6 +47,8 @@ Style:
     - "spec/datadog/kit/**/**"
     - "spec/datadog/profiling*"
     - "spec/datadog/profiling/**/*"
+    - "spec/datadog/open_feature*"
+    - "spec/datadog/open_feature/**/*"
     - "yard/**/*.rb"
 
 Layout:

Matrixfile

@@ -351,6 +351,10 @@
     'rails61-mysql2' => '❌ 2.5 / ✅ 2.6 / ✅ 2.7 / ✅ 3.0 / ✅ 3.1 / ✅ 3.2 / ✅ 3.3 / ✅ 3.4 / ❌ 3.5 / ❌ jruby',
     'rails8-mysql2'  => '❌ 2.5 / ❌ 2.6 / ❌ 2.7 / ❌ 3.0 / ❌ 3.1 / ✅ 3.2 / ✅ 3.3 / ✅ 3.4 / ✅ 3.5 / ❌ jruby',
   },
+  'open_feature' => {
+    'openfeature-latest' => '❌ 2.5 / ❌ 2.6 / ❌ 2.7 / ❌ 3.0 / ✅ 3.1 / ✅ 3.2 / ✅ 3.3 / ✅ 3.4 / ✅ 3.5 / ❌ jruby',
+    'openfeature-min'    => '❌ 2.5 / ❌ 2.6 / ❌ 2.7 / ❌ 3.0 / ✅ 3.1 / ✅ 3.2 / ✅ 3.3 / ✅ 3.4 / ✅ 3.5 / ❌ jruby',
+  },
 }.each_with_object({}) do |(tasks, spec_metadata), hash|
   # Explode arrays of task names into individual tasks
   # e.g. ['rails', 'railsdisableenv'] => {'...'} becomes 'rails7' => {'...'}, 'railsdisableenv7' => {'...'}

Rakefile

@@ -77,13 +77,13 @@ namespace :spec do
     :graphql, :graphql_unified_trace_patcher, :graphql_trace_patcher, :graphql_tracing_patcher,
     :rails, :railsredis, :railsredis_activesupport, :railsactivejob,
     :elasticsearch, :http, :redis, :sidekiq, :sinatra, :hanami, :hanami_autoinstrument,
-    :profiling, :core_with_libdatadog_api, :error_tracking]
+    :profiling, :core_with_libdatadog_api, :error_tracking, :open_feature]
 
   desc '' # "Explicitly hiding from `rake -T`"
   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,profiling,crashtracking,error_tracking,rubocop}/**/*_spec.rb,' \
-                        ' spec/**/{auto_instrument,opentelemetry,process_discovery,stable_config,ddsketch}_spec.rb,' \
+    t.exclude_pattern = 'spec/**/{appsec/integration,contrib,benchmark,redis,auto_instrument,opentelemetry,open_feature,profiling,crashtracking,error_tracking,rubocop}/**/*_spec.rb,' \
+                        ' spec/**/{auto_instrument,opentelemetry,open_feature,process_discovery,stable_config,ddsketch}_spec.rb,' \
                         ' spec/datadog/gem_packaging_spec.rb'
     t.rspec_opts = args.to_a.join(' ')
   end
@@ -125,6 +125,12 @@ namespace :spec do
     t.rspec_opts = args.to_a.join(' ')
   end
 
+  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.rspec_opts = args.to_a.join(' ')
+  end
+
   desc '' # "Explicitly hiding from `rake -T`"
   RSpec::Core::RakeTask.new(:rails) do |t, args|
     t.pattern = 'spec/datadog/tracing/contrib/rails/**/*_spec.rb'

appraisal/ruby-3.1.rb

@@ -99,6 +99,7 @@
 build_coverage_matrix('dalli', [2])
 build_coverage_matrix('karafka', min: '2.3.0')
 build_coverage_matrix('devise', min: '3.2.1')
+build_coverage_matrix('openfeature', min: '0.3.1', gem: 'openfeature-sdk')
 
 appraise 'relational_db' do
   gem 'activerecord', '~> 7'

appraisal/ruby-3.2.rb

@@ -144,6 +144,7 @@
 build_coverage_matrix('dalli', [2])
 build_coverage_matrix('karafka', min: '2.3.0')
 build_coverage_matrix('devise', min: '3.2.1')
+build_coverage_matrix('openfeature', min: '0.3.1', gem: 'openfeature-sdk')
 
 appraise 'relational_db' do
   gem 'activerecord', '~> 7'

appraisal/ruby-3.3.rb

@@ -146,6 +146,7 @@
 build_coverage_matrix('dalli', [2])
 build_coverage_matrix('karafka', min: '2.3.0')
 build_coverage_matrix('devise', min: '3.2.1')
+build_coverage_matrix('openfeature', min: '0.3.1', gem: 'openfeature-sdk')
 
 appraise 'relational_db' do
   gem 'activerecord', '~> 7'

appraisal/ruby-3.4.rb

@@ -145,6 +145,7 @@
 build_coverage_matrix('dalli', [2])
 build_coverage_matrix('karafka', min: '2.3.0')
 build_coverage_matrix('devise', min: '3.2.1')
+build_coverage_matrix('openfeature', min: '0.3.1', gem: 'openfeature-sdk')
 
 appraise 'relational_db' do
   # ActiveRecord locked because tests are failing with 7.1, which was attempted as a part of Ruby 3.4 testing in CI.
@@ -186,7 +187,7 @@
   gem 'resque'
   gem 'roda', '>= 2.0.0'
   gem 'semantic_logger', '~> 4.0'
-  # Note: Sidekiq 8 uses different timestamp formatting compared to prior versions. As long as
+  # NOTE: Sidekiq 8 uses different timestamp formatting compared to prior versions. As long as
   # versions <8 are supported, make sure there's some CI running both older and newer versions.
   gem 'sidekiq', '~> 8'
   gem 'sneakers', '>= 2.12.0'

appraisal/ruby-3.5.rb

@@ -94,6 +94,7 @@
 build_coverage_matrix('dalli', [2])
 build_coverage_matrix('karafka', min: '2.3.0')
 build_coverage_matrix('devise', min: '3.2.1')
+build_coverage_matrix('openfeature', min: '0.3.1', gem: 'openfeature-sdk')
 
 appraise 'relational_db' do
   # ActiveRecord locked because tests are failing with 7.1, which was attempted as a part of Ruby 3.4 testing in CI.

lib/datadog.rb

@@ -8,6 +8,7 @@
 require_relative 'datadog/profiling'
 require_relative 'datadog/appsec'
 require_relative 'datadog/di'
+require_relative 'datadog/open_feature'
 
 # Line probes will not work on Ruby < 2.6 because of lack of :script_compiled
 # trace point. Activate DI automatically on supported Ruby versions but

lib/datadog/core/configuration/components.rb

@@ -15,6 +15,7 @@
 require_relative '../../profiling/component'
 require_relative '../../appsec/component'
 require_relative '../../di/component'
+require_relative '../../open_feature/component'
 require_relative '../../error_tracking/component'
 require_relative '../crashtracking/component'
 require_relative '../environment/agent_info'
@@ -90,6 +91,7 @@ def build_crashtracker(settings, agent_settings, logger:)
           :error_tracking,
           :dynamic_instrumentation,
           :appsec,
+          :open_feature,
           :agent_info
 
         def initialize(settings)
@@ -124,6 +126,7 @@ def initialize(settings)
           @runtime_metrics = self.class.build_runtime_metrics_worker(settings, @logger, telemetry)
           @health_metrics = self.class.build_health_metrics(settings, @logger, telemetry)
           @appsec = Datadog::AppSec::Component.build_appsec_component(settings, telemetry: telemetry)
+          @open_feature = OpenFeature::Component.build(settings, agent_settings, logger: @logger, telemetry: telemetry)
           @dynamic_instrumentation = Datadog::DI::Component.build(settings, agent_settings, @logger, telemetry: telemetry)
           @error_tracking = Datadog::ErrorTracking::Component.build(settings, @tracer, @logger)
           @environment_logger_extra[:dynamic_instrumentation_enabled] = !!@dynamic_instrumentation

lib/datadog/core/configuration/supported_configurations.rb

@@ -42,6 +42,7 @@ module Configuration
          "DD_ENV" => {version: ["A"]},
          "DD_ERROR_TRACKING_HANDLED_ERRORS" => {version: ["A"]},
          "DD_ERROR_TRACKING_HANDLED_ERRORS_INCLUDE" => {version: ["A"]},
+         "DD_EXPERIMENTAL_FLAGGING_PROVIDER_ENABLED" => {version: ["A"]},
          "DD_GIT_COMMIT_SHA" => {version: ["A"]},
          "DD_GIT_REPOSITORY_URL" => {version: ["A"]},
          "DD_HEALTH_METRICS_ENABLED" => {version: ["A"]},

lib/datadog/core/remote/client/capabilities.rb

@@ -3,6 +3,7 @@
 require_relative '../../utils/base64'
 require_relative '../../../appsec/remote'
 require_relative '../../../tracing/remote'
+require_relative '../../../open_feature/remote'
 
 module Datadog
   module Core
@@ -38,6 +39,12 @@ def register(settings)
               register_receivers(Datadog::DI::Remote.receivers(@telemetry))
             end
 
+            if settings.respond_to?(:open_feature) && settings.open_feature.enabled
+              register_capabilities(Datadog::OpenFeature::Remote.capabilities)
+              register_products(Datadog::OpenFeature::Remote.products)
+              register_receivers(Datadog::OpenFeature::Remote.receivers(@telemetry))
+            end
+
             register_capabilities(Datadog::Tracing::Remote.capabilities)
             register_products(Datadog::Tracing::Remote.products)
             register_receivers(Datadog::Tracing::Remote.receivers(@telemetry))

lib/datadog/open_feature.rb

@@ -0,0 +1,18 @@
+# frozen_string_literal: true
+
+require_relative 'open_feature/extensions'
+
+module Datadog
+  # A namespace for the OpenFeature component.
+  module OpenFeature
+    Extensions.activate!
+
+    def self.enabled?
+      Datadog.configuration.open_feature.enabled
+    end
+
+    def self.engine
+      Datadog.send(:components).open_feature&.engine
+    end
+  end
+end

lib/datadog/open_feature/binding.rb

@@ -0,0 +1,11 @@
+# frozen_string_literal: true
+
+module Datadog
+  module OpenFeature
+    # A namespace for binding code
+    module Binding
+    end
+  end
+end
+
+require_relative 'binding/evaluator'

lib/datadog/open_feature/binding/evaluator.rb

@@ -0,0 +1,44 @@
+# frozen_string_literal: true
+
+require_relative 'resolution_details'
+
+module Datadog
+  module OpenFeature
+    module Binding
+      class Evaluator
+        def initialize(ufc_json)
+          # NOTE: In real binding we will parse and create Configuration
+          @ufc_json = ufc_json
+        end
+
+        def get_assignment(_flag_key, _evaluation_context, expected_type, _time)
+          ResolutionDetails.new(
+            value: generate(expected_type),
+            reason: 'TARGETING_MATCH',
+            variant: 'hardcoded-variant',
+            allocation_key: 'hardcoded-allocation-key',
+            flag_metadata: {
+              'doLog' => true,
+              'allocationKey' => 'hardcoded-allocation-key'
+            },
+            do_log: true,
+            extra_logging: {}
+          )
+        end
+
+        private
+
+        def generate(expected_type)
+          case expected_type
+          when :boolean then true
+          when :string then 'hello'
+          when :number then 9000
+          when :integer then 42
+          when :float then 36.6
+          when :object then [1, 2, 3]
+          end
+        end
+      end
+    end
+  end
+end

lib/datadog/open_feature/binding/resolution_details.rb

@@ -0,0 +1,21 @@
+# frozen_string_literal: true
+
+module Datadog
+  module OpenFeature
+    # A namespace for binding code
+    module Binding
+      ResolutionDetails = Struct.new(
+        :value,
+        :reason,
+        :variant,
+        :error_code,
+        :error_message,
+        :flag_metadata,
+        :allocation_key,
+        :do_log,
+        :extra_logging,
+        keyword_init: true
+      )
+    end
+  end
+end

lib/datadog/open_feature/component.rb

@@ -0,0 +1,41 @@
+# frozen_string_literal: true
+
+require_relative 'evaluation_engine'
+
+module Datadog
+  module OpenFeature
+    # This class is the entry point for the OpenFeature component
+    class Component
+      attr_reader :telemetry, :engine
+
+      def self.build(settings, agent_settings, logger:, telemetry:)
+        return unless settings.respond_to?(:open_feature) && settings.open_feature.enabled
+
+        unless settings.respond_to?(:remote) && settings.remote.enabled
+          logger.warn('OpenFeature: Could not be enabled without Remote Configuration Management available')
+
+          return
+        end
+
+        new(settings, agent_settings, logger: logger, telemetry: telemetry)
+      rescue
+        Datadog.logger.warn('OpenFeature is disabled, see logged errors above')
+
+        nil
+      end
+
+      def initialize(settings, agent_settings, logger:, telemetry:)
+        @settings = settings
+        @agent_settings = agent_settings
+        @logger = logger
+        @telemetry = telemetry
+
+        @engine = EvaluationEngine.new(telemetry, logger: logger)
+      end
+
+      def shutdown!
+        # no-op
+      end
+    end
+  end
+end

lib/datadog/open_feature/configuration.rb

@@ -0,0 +1,10 @@
+# frozen_string_literal: true
+
+require_relative 'configuration/settings'
+
+module Datadog
+  module OpenFeature
+    module Configuration
+    end
+  end
+end