loop prevention

.changeset/unlucky-otters-scream.md

@@ -0,0 +1,6 @@
+---
+'@elbwalker/walker.js': minor
+'@elbwalker/source-node': minor
+---
+
+loop prevention [#484](https://github.com/elbwalker/walkerOS/issues/484)

packages/sources/node/src/__tests__/destination.test.ts

@@ -433,4 +433,20 @@ describe('Destination', () => {
       // timing: 0, // @TODO should be set to default type
     });
   });
+
+  test('loop prevention', async () => {
+    mockDestination.type = 'foo';
+    const { elb } = getSource({
+      destinations: { mockDestination },
+    });
+
+    await elb({ event: 'e a' });
+    await elb({ event: 'e a', source: { type: 'another one' } });
+    expect(mockPush).toHaveBeenCalledTimes(2);
+
+    jest.clearAllMocks();
+    await elb({ event: 'e a', source: { type: 'foo' } });
+
+    expect(mockPush).toHaveBeenCalledTimes(0);
+  });
 });

packages/sources/node/src/lib/destination.ts

@@ -103,6 +103,10 @@ export async function destinationPush(
     }
   }
 
+  // Prevent recursive loops between sources and destinations
+  if (isDefined(destination.type) && destination.type === event.source.type)
+    return false;
+
   const options = { data, instance };
 
   if (eventMapping?.batch && destination.pushBatch) {