feat: 🎸 add reverse option to [OBJFlatten]

packages/basics/src/index.js

@@ -49,7 +49,6 @@ export default {
     // aliases
     bufferify: BUFObject.BUFObject,
     jsonify: JSONString.JSONString,
-    flatten: OBJFlatten.OBJFlatten,
     concat: TXTConcat.TXTConcat,
     standardize: OBJStandardize.OBJStandardize,
     split: TXTParse.TXTParse,

packages/basics/src/obj-flatten.js

@@ -1,27 +1,24 @@
 import flatten from 'flat';
 
-function OBJFlatten(data, feed) {
-    const opts = {
-        delimiter: this.getParam('separator', '/'),
-        safe: this.getParam('safe', true),
-    };
-    if (this.isLast()) {
-        feed.close();
-    } else {
-        feed.send(flatten(data, opts));
-    }
-}
-
 /**
  * Take `Object` and flat it with delimited character.
  *
  * @name OBJFlatten
- * @alias flatten
  * @param {String} [separator=/] choose a character for  flatten keys
  * @param {Boolean} [safe=false] preserve arrays and their contents,
  * @returns {Object}
  * @see https://www.npmjs.com/package/flat
  */
-export default {
-    OBJFlatten,
-};
+export default function OBJFlatten(data, feed) {
+    if (this.isLast()) {
+        return feed.close();
+    }
+    const opts = {
+        delimiter: String(this.getParam('separator', '/')),
+        safe: Boolean(this.getParam('safe', true)),
+    };
+    if (this.getParam('reverse', false)) {
+        return feed.send(unflatten(data, opts));
+    }
+    return feed.send(flatten(data, opts));
+}

packages/basics/test/obj-flatten.js

@@ -40,6 +40,18 @@ describe('OBJFlatten', () => {
                 done();
             });
     });
+    it('should unflatten the nested objects', (done) => {
+        from([{ a: { b: 1, c: 2 } }])
+            .pipe(ezs('OBJFlatten'))
+            .pipe(ezs('OBJFlatten', { reverse: true }))
+            .on('data', (data) => {
+                expect(data).toStrictEqual({ a: { b: 1, c: 2 } });
+            })
+            .on('end', () => {
+                done();
+            });
+    });
+
 
     it('should use the given separator', (done) => {
         from([{ a: { b: 1, c: 2 } }])