[FSSDK-11459] Ruby - Add SDK Multi-Region Support for Data Hosting (#365)

* [FSSDK-11459] Ruby - Add SDK Multi-Region Support for Data Hosting

* Fix lint issues

* Fix lint

* Fix test

* Add with region

* Fix lint

* Fix lint issue

* Correct the Region default value

* Fix failed tests

* Fix lint

* Fix test cases

* Fix event builder

* Fix the issue

* Fix typo

* Correct the event name

* Fix errors

* Fix errors

* Fix test cases

* Fix test cases

* Implement copilot review comments

* Fix lint

* Implement changes and add new tests

* Fix lint issue

* Remove unnecessary region params

* Remove region from expected param

* Remove region from impression expected

* Add region to builder

* Add region to as_json

* Implement

* Update region EU

* Fix test

Author: esrakartalOpt

lib/optimizely/config/datafile_project_config.rb

@@ -33,7 +33,7 @@ class DatafileProjectConfig < ProjectConfig
                 :group_id_map, :rollout_id_map, :rollout_experiment_id_map, :variation_id_map,
                 :variation_id_to_variable_usage_map, :variation_key_map, :variation_id_map_by_experiment_id,
                 :variation_key_map_by_experiment_id, :flag_variation_map, :integration_key_map, :integrations,
-                :public_key_for_odp, :host_for_odp, :all_segments
+                :public_key_for_odp, :host_for_odp, :all_segments, :region
     # Boolean - denotes if Optimizely should remove the last block of visitors' IP address before storing event data
     attr_reader :anonymize_ip
 
@@ -69,6 +69,10 @@ def initialize(datafile, logger, error_handler)
       @rollouts = config.fetch('rollouts', [])
       @send_flag_decisions = config.fetch('sendFlagDecisions', false)
       @integrations = config.fetch('integrations', [])
+      @region = config.fetch('region', 'US')
+
+      # Default to US region if not specified
+      @region = 'US' if @region.nil? || @region.empty?
 
       # Json type is represented in datafile as a subtype of string for the sake of backwards compatibility.
       # Converting it to a first-class json type while creating Project Config

lib/optimizely/event/entity/event_context.rb

@@ -26,14 +26,16 @@ def initialize(
       anonymize_ip:,
       revision:,
       client_name:,
-      client_version:
+      client_version:,
+      region:
     )
       @account_id = account_id
       @project_id = project_id
       @anonymize_ip = anonymize_ip
       @revision = revision
       @client_name = client_name
       @client_version = client_version
+      @region = region
     end
 
     def as_json
@@ -43,7 +45,8 @@ def as_json
         anonymize_ip: @anonymize_ip,
         revision: @revision,
         client_name: @client_name,
-        client_version: @client_version
+        client_version: @client_version,
+        region: @region
       }
     end
   end

lib/optimizely/event/event_factory.rb

@@ -28,7 +28,10 @@ class EventFactory
     # EventFactory builds LogEvent objects from a given user_event.
     class << self
       CUSTOM_ATTRIBUTE_FEATURE_TYPE = 'custom'
-      ENDPOINT = 'https://logx.optimizely.com/v1/events'
+      ENDPOINTS = {
+        US: 'https://logx.optimizely.com/v1/events',
+        EU: 'https://eu.logx.optimizely.com/v1/events'
+      }.freeze
       POST_HEADERS = {'Content-Type' => 'application/json'}.freeze
       ACTIVATE_EVENT_KEY = 'campaign_activated'
 
@@ -67,7 +70,10 @@ def create_log_event(user_events, logger)
 
         builder.with_visitors(visitors)
         event_batch = builder.build
-        Event.new(:post, ENDPOINT, event_batch.as_json, POST_HEADERS)
+
+        endpoint = ENDPOINTS[user_context[:region].to_s.upcase.to_sym] || ENDPOINTS[:US]
+
+        Event.new(:post, endpoint, event_batch.as_json, POST_HEADERS)
       end
 
       def build_attribute_list(user_attributes, project_config)

lib/optimizely/event/user_event_factory.rb

@@ -33,6 +33,7 @@ def self.create_impression_event(project_config, experiment, variation_id, metad
       #
       # Returns Event encapsulating the impression event.
       event_context = Optimizely::EventContext.new(
+        region: project_config.region,
         account_id: project_config.account_id,
         project_id: project_config.project_id,
         anonymize_ip: project_config.anonymize_ip,
@@ -67,6 +68,7 @@ def self.create_conversion_event(project_config, event, user_id, user_attributes
       # Returns Event encapsulating the conversion event.
 
       event_context = Optimizely::EventContext.new(
+        region: project_config.region,
         account_id: project_config.account_id,
         project_id: project_config.project_id,
         anonymize_ip: project_config.anonymize_ip,

lib/optimizely/event_builder.rb

@@ -101,13 +101,17 @@ def get_common_params(project_config, user_id, attributes)
         revision: project_config.revision,
         client_name: CLIENT_ENGINE,
         enrich_decisions: true,
-        client_version: VERSION
+        client_version: VERSION,
+        region: project_config.region || 'US'
       }
     end
   end
 
   class EventBuilder < BaseEventBuilder
-    ENDPOINT = 'https://logx.optimizely.com/v1/events'
+    ENDPOINTS = {
+      US: 'https://logx.optimizely.com/v1/events',
+      EU: 'https://eu.logx.optimizely.com/v1/events'
+    }.freeze
     POST_HEADERS = {'Content-Type' => 'application/json'}.freeze
     ACTIVATE_EVENT_KEY = 'campaign_activated'
 
@@ -122,11 +126,14 @@ def create_impression_event(project_config, experiment, variation_id, user_id, a
       #
       # Returns +Event+ encapsulating the impression event.
 
+      region = project_config.region || 'US'
       event_params = get_common_params(project_config, user_id, attributes)
       impression_params = get_impression_params(project_config, experiment, variation_id)
       event_params[:visitors][0][:snapshots].push(impression_params)
 
-      Event.new(:post, ENDPOINT, event_params, POST_HEADERS)
+      endpoint = ENDPOINTS[region.to_s.upcase.to_sym]
+
+      Event.new(:post, endpoint, event_params, POST_HEADERS)
     end
 
     def create_conversion_event(project_config, event, user_id, attributes, event_tags)
@@ -140,11 +147,14 @@ def create_conversion_event(project_config, event, user_id, attributes, event_ta
       #
       # Returns +Event+ encapsulating the conversion event.
 
+      region = project_config.region || 'US'
       event_params = get_common_params(project_config, user_id, attributes)
       conversion_params = get_conversion_params(event, event_tags)
       event_params[:visitors][0][:snapshots] = [conversion_params]
 
-      Event.new(:post, ENDPOINT, event_params, POST_HEADERS)
+      endpoint = ENDPOINTS[region.to_s.upcase.to_sym]
+
+      Event.new(:post, endpoint, event_params, POST_HEADERS)
     end
 
     private

lib/optimizely/project_config.rb

@@ -62,6 +62,8 @@ def host_for_odp; end
 
     def all_segments; end
 
+    def region; end
+
     def experiment_running?(experiment); end
 
     def get_experiment_from_key(experiment_key); end

spec/config/datafile_project_config_spec.rb

@@ -57,6 +57,7 @@
       expect(project_config.sdk_key).to eq(config_body['sdkKey'])
       expect(project_config.environment_key).to eq(config_body['environmentKey'])
       expect(project_config.send_flag_decisions).to eq(config_body['sendFlagDecisions'])
+      expect(project_config.region).to eq(config_body['region'])
 
       expected_attribute_key_map = {
         'browser_type' => config_body['attributes'][0],
@@ -756,6 +757,23 @@
       expect(project_config.rollout_experiment_id_map).to eq(expected_rollout_experiment_id_map)
     end
 
+    it 'should use US region when no region is specified in datafile' do
+      project_config = Optimizely::DatafileProjectConfig.new(config_body_JSON, logger, error_handler)
+      expect(project_config.region).to eq('US')
+    end
+
+    it 'should parse region specified in datafile correctly' do
+      project_config_us = Optimizely::DatafileProjectConfig.new(config_body_JSON, logger, error_handler)
+      expect(project_config_us.region).to eq('US')
+
+      config_body_eu = config_body.dup
+      config_body_eu['region'] = 'EU'
+      config_body_json = JSON.dump(config_body_eu)
+      project_config_eu = Optimizely::DatafileProjectConfig.new(config_body_json, logger, error_handler)
+
+      expect(project_config_eu.region).to eq('EU')
+    end
+
     it 'should initialize properties correctly upon creating project with typed audience dict' do
       project_config = Optimizely::DatafileProjectConfig.new(JSON.dump(OptimizelySpec::CONFIG_DICT_WITH_TYPED_AUDIENCES), logger, error_handler)
       config_body = OptimizelySpec::CONFIG_DICT_WITH_TYPED_AUDIENCES