From b68ef0b9dd6c50bf905ed42e1e5ae31b9d6a88b4 Mon Sep 17 00:00:00 2001
From: Aleksandar Kiselicki <aleksandar@rayn.io>
Date: Tue, 18 Jun 2024 18:10:20 +0200
Subject: [PATCH] update rayn rtd provider module with rayn persona taxonomy

---
 .../gpt/raynRtdProvider_example.html          |  1 +
 modules/raynRtdProvider.js                    | 39 +++++++++++++++++--
 test/spec/modules/raynRtdProvider_spec.js     | 25 ++++++++++++
 3 files changed, 62 insertions(+), 3 deletions(-)

diff --git a/integrationExamples/gpt/raynRtdProvider_example.html b/integrationExamples/gpt/raynRtdProvider_example.html
index 2d43c37513a..7965daa6e85 100644
--- a/integrationExamples/gpt/raynRtdProvider_example.html
+++ b/integrationExamples/gpt/raynRtdProvider_example.html
@@ -6,6 +6,7 @@
           "3": ["264", "267", "261"],
           "4": ["438"]
         },
+        "103015": ['agdv23', 'avscg3'],
         "903555595": {
           "7": {
             "2": ["51", "246"]
diff --git a/modules/raynRtdProvider.js b/modules/raynRtdProvider.js
index d558c360c4a..ee3d18be381 100644
--- a/modules/raynRtdProvider.js
+++ b/modules/raynRtdProvider.js
@@ -14,6 +14,7 @@ import { deepAccess, deepSetValue, logError, logMessage, mergeDeep } from '../sr
 const MODULE_NAME = 'realTimeData';
 const SUBMODULE_NAME = 'rayn';
 const RAYN_TCF_ID = 1220;
+const RAYN_PERSONA_TAXONOMY_ID = 103015;
 const LOG_PREFIX = 'RaynJS: ';
 export const SEGMENTS_RESOLVER = 'rayn.io';
 export const RAYN_LOCAL_STORAGE_KEY = 'rayn-segtax';
@@ -77,6 +78,32 @@ export function generateOrtbDataObject(segtax, segment, maxTier) {
   };
 }
 
+/**
+ * Create and return ORTB2 object with segtax and personaIds
+ * @param {number} segtax
+ * @param {Array} personaIds
+ * @return {Array}
+ */
+export function generatePersonaOrtbDataObject(segtax, personaIds) {
+  const segmentIds = [];
+
+  try {
+    segmentIds.push(...personaIds.map((id) => {
+      return { id };
+    }))
+  } catch (error) {
+    logError(LOG_PREFIX, error);
+  }
+
+  return {
+    name: SEGMENTS_RESOLVER,
+    ext: {
+      segtax,
+    },
+    segment: segmentIds,
+  };
+}
+
 /**
  * Generates checksum
  * @param {string} url
@@ -127,8 +154,14 @@ export function setSegmentsAsBidderOrtb2(bidConfig, bidders, integrationConfig,
     deepSetValue(raynOrtb2, 'site.content.data', raynContentData);
   }
 
+  const raynUserData = [];
   if (integrationConfig.iabAudienceCategories.v1_1.enabled && segments[4]) {
-    const raynUserData = [generateOrtbDataObject(4, segments[4], integrationConfig.iabAudienceCategories.v1_1.tier)];
+    raynUserData.push(generateOrtbDataObject(4, segments[4], integrationConfig.iabAudienceCategories.v1_1.tier));
+  }
+  if (segments[RAYN_PERSONA_TAXONOMY_ID]) {
+    raynUserData.push(generatePersonaOrtbDataObject(RAYN_PERSONA_TAXONOMY_ID, segments[RAYN_PERSONA_TAXONOMY_ID]));
+  }
+  if (raynUserData.length > 0) {
     deepSetValue(raynOrtb2, 'user.data', raynUserData);
   }
 
@@ -163,8 +196,8 @@ function alterBidRequests(reqBidsConfigObj, callback, config, userConsent) {
       segments[checksum] || (segments[4] &&
         integrationConfig.iabAudienceCategories.v1_1.enabled &&
         !integrationConfig.iabContentCategories.v2_2.enabled &&
-        !integrationConfig.iabContentCategories.v3_0.enabled
-      )
+        !integrationConfig.iabContentCategories.v3_0.enabled) ||
+      segments[RAYN_PERSONA_TAXONOMY_ID]
     )) {
       logMessage(LOG_PREFIX, `Segtax data from localStorage: ${JSON.stringify(segments)}`);
       setSegmentsAsBidderOrtb2(reqBidsConfigObj, bidders, integrationConfig, segments, checksum);
diff --git a/test/spec/modules/raynRtdProvider_spec.js b/test/spec/modules/raynRtdProvider_spec.js
index 69ea316e8b5..3920d090550 100644
--- a/test/spec/modules/raynRtdProvider_spec.js
+++ b/test/spec/modules/raynRtdProvider_spec.js
@@ -152,6 +152,7 @@ describe('rayn RTD Submodule', function () {
         2: ['71', '313'],
         4: ['33', '145', '712']
       };
+      TEST_SEGMENTS['103015'] = ['agdv23', 'avscg3'];
 
       const bidderOrtb2 = {};
       const bidders = RTD_CONFIG.dataProviders[0].params.bidders;
@@ -174,6 +175,9 @@ describe('rayn RTD Submodule', function () {
         TEST_SEGMENTS['4']['3'].forEach((id) => {
           expect(ortb2.user.data[0].segment.find(segment => segment.id === id)).to.exist;
         });
+        TEST_SEGMENTS['103015'].forEach((id) => {
+          expect(ortb2.user.data[1].segment.find(segment => segment.id === id)).to.exist;
+        });
       });
     });
   });
@@ -229,6 +233,27 @@ describe('rayn RTD Submodule', function () {
       logMessageSpy.restore();
     });
 
+    it('should update reqBidsConfigObj and execute callback using persona segment from localStorage', function () {
+      const callbackSpy = sinon.spy();
+      const logMessageSpy = sinon.spy(utils, 'logMessage');
+      const testSegments = {
+        103015: ['agdv23', 'avscg3']
+      };
+
+      getDataFromLocalStorageStub
+        .withArgs(raynRTD.RAYN_LOCAL_STORAGE_KEY)
+        .returns(JSON.stringify(testSegments));
+
+      const reqBidsConfigObj = { ortb2Fragments: { bidder: {} } };
+
+      raynRTD.raynSubmodule.getBidRequestData(reqBidsConfigObj, callbackSpy, RTD_CONFIG.dataProviders[0]);
+
+      expect(callbackSpy.calledOnce).to.be.true;
+      expect(logMessageSpy.lastCall.lastArg).to.equal(`Segtax data from localStorage: ${JSON.stringify(testSegments)}`);
+
+      logMessageSpy.restore();
+    });
+
     it('should update reqBidsConfigObj and execute callback using segments from raynJS', function () {
       const callbackSpy = sinon.spy();
       const logMessageSpy = sinon.spy(utils, 'logMessage');