Added acceptObjects.

uhop · Dec 22, 2024 · 2c54b7d · 2c54b7d
1 parent d1526bd
commit 2c54b7d
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 3 deletions.
diff --git a/src/filters/filter.js b/src/filters/filter.js
@@ -8,12 +8,11 @@ const filterBase = require('./filter-base.js');
 const withParser = require('../utils/with-parser.js');
 
 const filter = options => {
+  const specialAction = options?.acceptObjects ? 'accept' : 'accept-token';
   let previousStack = [];
   return filterBase({
-    specialAction: 'accept-token',
+    specialAction,
     transition(stack, chunk, _action, options) {
-      // debugger;
-      // console.log('STACK:', previousStack, stack, chunk, _action, '\n');
       const returnTokens = [];
 
       // find the common part

diff --git a/tests/test-filter.mjs b/tests/test-filter.mjs
@@ -115,6 +115,20 @@ test.asPromise('filter: array with skipped values', (t, resolve, reject) => {
   pipeline.resume();
 });
 
+test.asPromise('filter: accept objects', (t, resolve, reject) => {
+  const data = {a: 1, b: true, c: ['d']},
+    asm = assembler(),
+    pipeline = chain([readString(JSON.stringify(data)), filter.withParser({acceptObjects: true, filter: /^(a|c)$/}), asm.tapChain]);
+
+  pipeline.on('error', reject);
+  pipeline.on('end', () => {
+    t.deepEqual(asm.current, {a: 1, c: ['d']});
+    resolve();
+  });
+
+  pipeline.resume();
+});
+
 test.asPromise('filter: bug46', (t, resolve, reject) => {
   const data = [
       {data: {a: 1, b: 2}, x: 1},