datalust / pino-seq Goto Github PK

2020-11-19T07:41:47.743700409Z events.js:306 2020-11-19T07:41:47.743785314Z throw err;
// Unhandled 'error' event 2020-11-19T07:41:47.743803315Z ^ 2020-11-19T07:41:47.743807616Z
2020-11-19T07:41:47.743811616Z Error [ERR_UNHANDLED_ERROR]: Unhandled error.
('HTTP log shipping failed: 502') 2020-11-19T07:41:47.743815916Z at PinoSeqStream.emit (events.js:304:17)
2020-11-19T07:41:47.743819816Z at emitErrorNT (internal/streams/destroy.js:92:8) 
2020-11-19T07:41:47.743823717Z at emitErrorAndCloseNT (internal/streams/destroy.js:60:3) 
2020-11-19T07:41:47.743827917Z at processTicksAndRejections (internal/process/task_queues.js:84:21) 
{
 2020-11-19T07:41:47.743831817Z code: 'ERR_UNHANDLED_ERROR',
2020-11-19T07:41:47.743835517Z context: 'HTTP log shipping failed: 502' 2020-11-19T07:41:47.743839318Z } 2020-11-19T07:41:47.763250218Z error Command failed with exit code 1.
2020-11-19T07:41:47.763348224Z info Visit https://yarnpkg.com/en/docs/cli/run for documentation about this command.

git checkout master
git branch -m master main
git fetch
git branch --unset-upstream
//if fork: git push -u origin main
git branch -u origin/main
git symbolic-ref refs/remotes/origin/HEAD refs/remotes/origin/main

class PinoSeqStream extends stream.Writable {
  constructor() {
    super();
  }

  _write(message, _enc, cb) {
    if (message) {
      try {
        const eventCopy = JSON.parse(message);

        const { time, level, msg, err, error, stack, ...props } = eventCopy;

        // Get the properties from the error
        const { message: errMessage, stack: errStack, ...errorProps } = err || error || {};

        const forSeq = {
          "@t": new Date(time),
          "@l": LEVEL_NAMES[level],
          "@mt": msg || errMessage,
          "@x": stack || errStack,
          ...errorProps,
          ...props
        };

        try {
          console.log(JSON.stringify(forSeq));
        } catch (errorMessage) {
          console.error(errorMessage);
        }
      } catch (err) {
        const msg = String(message);
        console.error(msg);
      }
    }
    cb();
  }
}