feat(DecisionListener): Adds experiment decision listener.

Author: rashidsp

lib/optimizely.rb

@@ -143,12 +143,19 @@ def get_variation(experiment_key, user_id, attributes = nil)
       end
 
       variation_id = @decision_service.get_variation(experiment_key, user_id, attributes)
+      variation = @config.get_variation_from_id(experiment_key, variation_id) unless variation_id.nil?
+      variation_key = variation['key'] if variation
 
-      unless variation_id.nil?
-        variation = @config.get_variation_from_id(experiment_key, variation_id)
-        return variation['key'] if variation
-      end
-      nil
+      @notification_center.send_notifications(
+        NotificationCenter::NOTIFICATION_TYPES[:ON_DECISION],
+        Helpers::Constants::DECISION_INFO_TYPES['EXPERIMENT'], user_id, attributes,
+        decision_info: {
+          experiment_key: experiment_key,
+          variation_key: variation_key
+        }
+      )
+
+      variation_key
     end
 
     # Force a user into a variation for a given experiment.

lib/optimizely/helpers/constants.rb

@@ -352,6 +352,12 @@ module Constants
         'UNKNOWN_MATCH_TYPE' => 'Audience condition %s uses an unknown match type. You may need ' \
         'to upgrade to a newer release of the Optimizely SDK.'
       }.freeze
+
+      DECISION_INFO_TYPES = {
+        'EXPERIMENT' => 'experiment',
+        'FEATURE' => 'feature',
+        'FEATURE_VARIABLE' => 'feature_variable'
+      }.freeze
     end
   end
 end

lib/optimizely/notification_center.rb

@@ -1,7 +1,7 @@
 # frozen_string_literal: true
 
 #
-#    Copyright 2017-2018, Optimizely and contributors
+#    Copyright 2017-2019, Optimizely and contributors
 #
 #    Licensed under the Apache License, Version 2.0 (the "License");
 #    you may not use this file except in compliance with the License.
@@ -22,6 +22,7 @@ class NotificationCenter
 
     NOTIFICATION_TYPES = {
       ACTIVATE: 'ACTIVATE: experiment, user_id, attributes, variation, event',
+      ON_DECISION: 'ON_DECISION: type, user_id, attributes, decision_info',
       TRACK: 'TRACK: event_key, user_id, attributes, event_tags, event'
     }.freeze
 

spec/project_spec.rb

@@ -498,9 +498,21 @@ class InvalidErrorHandler; end
       expect(project_instance.activate('test_experiment_not_started', 'test_user')).to eq(nil)
     end
 
-    it 'should return nil when audience conditions do not match' do
+    it 'should log, return nil and call decision listener with variation key nil when audience conditions do not match' do
       user_attributes = {'browser_type' => 'chrome'}
+
+      expect(project_instance.notification_center).to receive(:send_notifications).with(
+        Optimizely::NotificationCenter::NOTIFICATION_TYPES[:ON_DECISION],
+        'experiment', 'test_user', {'browser_type' => 'chrome'},
+        decision_info: {
+          experiment_key: 'test_experiment_with_audience', variation_key: nil
+        }
+      )
+
       expect(project_instance.activate('test_experiment_with_audience', 'test_user', user_attributes)).to eq(nil)
+
+      expect(spy_logger).to have_received(:log)
+        .once.with(Logger::INFO, "User 'test_user' does not meet the conditions to be in experiment 'test_experiment_with_audience'.")
     end
 
     it 'should return nil when attributes are invalid' do
@@ -583,7 +595,7 @@ class InvalidErrorHandler; end
       expect(project_instance.event_dispatcher).to_not have_received(:dispatch_event)
     end
 
-    it 'should log and send activate notification when an impression event is dispatched' do
+    it 'should log and send activate and decision notifications when an impression event is dispatched' do
       params = @expected_activate_params
       variation_to_return = project_instance.config.get_variation_from_id('test_experiment', '111128')
       allow(project_instance.decision_service.bucketer).to receive(:bucket).and_return(variation_to_return)
@@ -592,11 +604,19 @@ class InvalidErrorHandler; end
         .with('test_experiment')
         .and_return([])
       experiment = project_instance.config.get_experiment_from_key('test_experiment')
+
+      expect(project_instance.notification_center).to receive(:send_notifications).with(
+        Optimizely::NotificationCenter::NOTIFICATION_TYPES[:ON_DECISION],
+        'experiment', 'test_user', nil,
+        decision_info: {experiment_key: 'test_experiment', variation_key: 'control'}
+      ).ordered
+
       expect(project_instance.notification_center).to receive(:send_notifications).with(
         Optimizely::NotificationCenter::NOTIFICATION_TYPES[:ACTIVATE],
         experiment, 'test_user', nil, variation_to_return,
         instance_of(Optimizely::Event)
-      )
+      ).ordered
+
       project_instance.activate('test_experiment', 'test_user')
 
       expect(spy_logger).to have_received(:log).once.with(Logger::INFO, include('Dispatching impression event to' \
@@ -999,6 +1019,13 @@ class InvalidErrorHandler; end
 
     it 'should have get_variation return expected variation when audience conditions match' do
       user_attributes = {'browser_type' => 'firefox'}
+
+      expect(project_instance.notification_center).to receive(:send_notifications).with(
+        Optimizely::NotificationCenter::NOTIFICATION_TYPES[:ON_DECISION],
+        'experiment', 'test_user', {'browser_type' => 'firefox'},
+        decision_info: {experiment_key: 'test_experiment_with_audience', variation_key: 'control_with_audience'}
+      )
+
       expect(project_instance.get_variation('test_experiment_with_audience', 'test_user', user_attributes))
         .to eq('control_with_audience')
     end
@@ -1020,6 +1047,13 @@ class InvalidErrorHandler; end
 
     it 'should have get_variation return nil when audience conditions do not match' do
       user_attributes = {'browser_type' => 'chrome'}
+
+      expect(project_instance.notification_center).to receive(:send_notifications).with(
+        Optimizely::NotificationCenter::NOTIFICATION_TYPES[:ON_DECISION],
+        'experiment', 'test_user', {'browser_type' => 'chrome'},
+        decision_info: {experiment_key: 'test_experiment_with_audience', variation_key: nil}
+      )
+
       expect(project_instance.get_variation('test_experiment_with_audience', 'test_user', user_attributes))
         .to eq(nil)
     end