nested

Author: alexanderkirtzel

packages/connectors/datalayer/src/__tests__/mapping.test.ts

@@ -23,11 +23,9 @@ describe('mapping', () => {
     quantity: 2,
   };
   const product2 = {
-    data: {
-      name: 'Cool Cap',
-      size: 'one size',
-      prize: 42,
-    },
+    item_id: 'xyz',
+    item_name: 'Cool Cap',
+    price: 42,
   };
 
   beforeEach(() => {});
@@ -293,9 +291,14 @@ describe('mapping', () => {
             total: 'value',
             coupon: 'coupon',
           },
-          // nested: {
-          //   type: { value: 'product' },
-          // },
+          nested: {
+            type: { value: 'product' },
+            data: {
+              id: 'items.*.item_id',
+              name: 'items.*.item_name',
+              price: 'items.*.price',
+            },
+          },
         },
       },
     })!;
@@ -322,6 +325,29 @@ describe('mapping', () => {
           total: 555,
           coupon: 'SUMM3RS4L3',
         },
+        context: {},
+        nested: [
+          {
+            type: 'product',
+            data: {
+              id: 'abc',
+              name: 'Everyday Ruck Snack',
+              price: 420,
+            },
+            nested: [],
+            context: {},
+          },
+          {
+            type: 'product',
+            data: {
+              id: 'xyz',
+              name: 'Cool Cap',
+              price: 42,
+            },
+            nested: [],
+            context: {},
+          },
+        ],
       }),
     );
   });

packages/connectors/datalayer/src/mapping.ts

@@ -59,12 +59,50 @@ export function objToEvent(
       'source',
     ];
 
-    const foo = eventMappingObjectValueKeys.reduce((acc, key) => {
+    const objectValues = eventMappingObjectValueKeys.reduce((acc, key) => {
       const config = mapping[key];
       if (config) acc[key] = mapEntries(obj, config);
       return acc;
     }, {} as WalkerOS.AnyObject);
-    event = { ...event, ...foo };
+    event = { ...event, ...objectValues };
+
+    // @TODO
+    const context = {};
+    event.context = context;
+
+    if (mapping.nested) {
+      const nested: WalkerOS.Entities = [];
+      const config = mapping.nested;
+
+      const nestedData = mapEntries(obj, config.data ?? {});
+      const maxLength = Math.max(
+        ...Object.values(nestedData)
+          .filter((value) => Array.isArray(value))
+          .map((array) => array.length),
+      );
+
+      for (let i = 0; i < maxLength; i++) {
+        const data = Object.entries(nestedData).reduce((acc, [key, value]) => {
+          acc[key] = Array.isArray(value) ? value[i] : value;
+          return acc;
+        }, {} as WalkerOS.Properties);
+        nested.push({
+          type: String(
+            getMappingValue(
+              obj,
+              config.type ?? { value: 'item' },
+              undefined,
+              i,
+            ),
+          ),
+          data: data,
+          nested: [],
+          context,
+        });
+      }
+
+      event.nested = nested;
+    }
   }
 
   // Update the event name

packages/connectors/datalayer/src/types/index.ts

@@ -31,7 +31,7 @@ export type EventMappingObjectValues = {
   globals?: ObjectValue;
   custom?: ObjectValue;
   user?: ObjectValue;
-  // nested?: WalkerOS.Entities; // @TODO
+  nested?: Nested;
   consent?: ObjectValue;
   version?: ObjectValue;
   source?: ObjectValue;
@@ -48,6 +48,11 @@ export type EventMappingValues = {
   count?: Value;
 };
 
+export type Nested = {
+  type?: Value;
+  data?: ObjectValue;
+};
+
 export type ObjectValue = {
   [key: string]: Value;
 };