set

elbwalker · Dec 17, 2024 · f821cd4 · f821cd4
1 parent 3f84690
commit f821cd4
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 7 deletions.
diff --git a/packages/types/src/mapping.ts b/packages/types/src/mapping.ts
@@ -38,6 +38,7 @@ export interface ValueConfig {
   key?: string;
   loop?: Loop;
   map?: Map;
+  set?: Value[];
   validate?: Validate;
   value?: WalkerOS.PropertyType;
 }

diff --git a/packages/utils/src/__tests__/mapping.test.ts b/packages/utils/src/__tests__/mapping.test.ts
@@ -229,6 +229,16 @@ describe('getMappingValue', () => {
     ).toStrictEqual([event.event]);
   });
 
+  test('set', () => {
+    const event = getEvent('order complete');
+
+    expect(
+      getMappingValue(event, {
+        set: ['event', 'data', { value: 'static' }, { fn: () => 'fn' }],
+      }),
+    ).toStrictEqual(['order complete', event.data, 'static', 'fn']);
+  });
+
   test('map', () => {
     const event = createEvent();
 

diff --git a/packages/utils/src/core/mapping.ts b/packages/utils/src/core/mapping.ts
@@ -1,7 +1,7 @@
 import type { Mapping, WalkerOS } from '@elbwalker/types';
 import { getGrantedConsent } from './consent';
 import { getByPath } from './byPath';
-import { isArray, isDefined, isObject } from './is';
+import { isArray, isDefined, isObject, isString } from './is';
 import { castToProperty } from './property';
 
 export function getMappingEvent(
@@ -77,8 +77,8 @@ function processMappingValue(
   return mappings.reduce((acc, mappingItem) => {
     if (acc) return acc; // A valid result was already found
 
-    const { condition, consent, fn, key, loop, map, validate, value } =
-      typeof mappingItem == 'string'
+    const { condition, consent, fn, key, loop, map, set, validate, value } =
+      isString(mappingItem)
         ? ({ key: mappingItem } as Mapping.ValueConfig)
         : mappingItem;
 
@@ -100,7 +100,6 @@ function processMappingValue(
     if (loop) {
       const [scope, itemMapping] = loop;
 
-      // Retrieve the array from the event
       const data =
         scope === 'this' ? [obj] : getMappingValue(obj, scope, options);
 
@@ -111,9 +110,7 @@ function processMappingValue(
           )
           .filter(isDefined);
       }
-    }
-
-    if (map) {
+    } else if (map) {
       mappingValue = Object.entries(map).reduce(
         (mappedObj, [mapKey, mapValue]) => {
           const result = getMappingValue(obj, mapValue, options);
@@ -123,6 +120,8 @@ function processMappingValue(
         },
         {} as WalkerOS.AnyObject,
       );
+    } else if (set) {
+      mappingValue = set.map((item) => processMappingValue(obj, item, options));
     }
 
     // Validate the value