Chunks handling

README.md

@@ -20,7 +20,7 @@ There are 2 possible options of configuration:
 Piped output can be useful when formatter is installed as a dev dependency.
 
 ```bash
-npx ts-node service.ts | npx @tsxper/log-stream-formatter-visual
+npx ts-node service.ts | npx @tsxper/log-stream-formatter-visual [logDepth]
 ```
 
 ### Replace Default Formatter

examples/README.md

@@ -1,8 +1,6 @@
 ### Modify stdout
 ```bash
-bun std.ts | bun ../src/std.ts
-# or "npx ts-node"
-# npx ts-node std.ts | npx ts-node ../src/std.ts
+npx ts-node std.ts | npx ts-node ../src/std.ts 3
 ```
 
 ### Modify stream output

examples/std.ts

@@ -5,20 +5,17 @@ class A {
   constructor(public a: A[]) { }
 }
 
-Logger.replaceLogStreams(process.stdout, process.stderr);
+Logger.replaceLogStreams(process.stdout, process.stdout);
 const logger = new Logger(4, 'std');
 
 const log = async () => {
   const pause = 500;
-  await new Promise(r => setTimeout(r, pause));
   logger.debug('debug');
-  await new Promise(r => setTimeout(r, pause));
   logger.log('info', [1, 2]);
   await new Promise(r => setTimeout(r, pause));
   logger.error('error', new Error('test'));
   await new Promise(r => setTimeout(r, pause));
   logger.warn('info', { a: { b: { c: { d: 'f' } } } });
-  await new Promise(r => setTimeout(r, pause));
 
   const arr: A[] = [];
   const obj = new A(arr);

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@tsxper/log-stream-formatter-visual",
-  "version": "1.0.2",
+  "version": "1.0.3",
   "description": "Visual formatter for @tsxper/log-stream",
   "scripts": {
     "test": "jest",

src/std.ts

@@ -1,9 +1,12 @@
 #!/usr/bin/env node
-import { stdin, stdout } from 'node:process';
+import { argv, stdin, stdout } from 'node:process';
 import { pipeline, Transform, TransformCallback } from 'node:stream';
 import { LOG_LEVEL, FormatterVisual } from './FormatterVisual';
 import { EOL } from 'os';
 
+const args = argv.slice(2);
+const logDepth = parseInt(args[0] || '');
+
 type DEFAULT_FORMAT = {
   t: number;
   l: LOG_LEVEL;
@@ -14,20 +17,34 @@ type DEFAULT_FORMAT = {
 };
 
 const formatter = new FormatterVisual();
+if (!isNaN(logDepth)) {
+  formatter.setDepth(logDepth);
+}
 pipeline(
   stdin,
   new Transform({
     transform(chunk: Buffer, encoding: BufferEncoding, callback: TransformCallback) {
-      let line = chunk.toString().trim();
-      try {
-        const decoded = JSON.parse(line) as DEFAULT_FORMAT;
-        if (decoded.t) {
-          line = formatter.formatter(decoded.t, decoded.n, decoded.s, decoded.l, decoded.e || decoded.d);
+      const lines = chunk.toString().trim().split(`}${EOL}{`).map((l) => l.trim());
+      if (!lines.length) {
+        return callback(null, `${EOL}`);
+      }
+      for (let i = 0; i < lines.length; i++) {
+        let line = lines[i];
+        if (!line) continue;
+        if (!line.startsWith('{')) line = `{${line}`;
+        if (!line.endsWith('}')) line = `${line}}`;
+        try {
+          const decoded = JSON.parse(line) as DEFAULT_FORMAT;
+          if (decoded.t) {
+            line = formatter.formatter(decoded.t, decoded.n, decoded.s, decoded.l, decoded.e || decoded.d);
+          }
+        } catch (e) {
+          //
         }
-      } catch (e) {
-        //
+        lines[i] = line;
       }
-      callback(null, `${line}${EOL}`);
+
+      callback(null, `${lines.join(EOL)}${EOL}`);
     },
   }),
   stdout,