pino - npm Package Compare versions

Comparing version 8.14.2 to 8.15.0

docs/transports.md

@@ -153,3 +153,3 @@ # Transports
     for await (let obj of source) {
-      const toDrain = !destination.write(obj.message.toUpperCase() + '\n')
+      const toDrain = !destination.write(obj.msg.toUpperCase() + '\n')
       // This block will handle backpressure
@@ -402,3 +402,5 @@ if (toDrain) {
 + [pino-datadog-transport](#pino-datadog-transport)
-+ [pino-slack-webhook](#pino-slack-webhook)
++ [pino-slack-webhook](#pino-slack-webhook) 
++ [pino-axiom](#pino-axiom)
++ [pino-opentelemetry-transport](#pino-opentelemetry-transport)
 
@@ -939,2 +941,45 @@ ### Legacy
 
+For full documentation of command line switches read the [README](https://github.com/abeai/pino-websocket#readme).
+
+<a id="pino-axiom"></a>
+### pino-axiom
+
+[pino-axiom](https://www.npmjs.com/package/pino-axiom) is a transport that will forward logs to [Axiom](https://axiom.co).
+
+```javascript
+const pino = require('pino')
+const transport = pino.transport({
+  target: 'pino-axiom',
+  options: {
+    orgId: 'YOUR-ORG-ID', 
+    token: 'YOUR-TOKEN', 
+    dataset: 'YOUR-DATASET', 
+  },
+})
+pino(transport)
+```
+
+<a id="pino-opentelemetry-transport"></a>
+### pino-opentelemetry-transport
+
+[pino-opentelemetry-transport](https://www.npmjs.com/package/pino-opentelemetry-transport) is a transport that will forward logs to an [OpenTelemetry log collector](https://opentelemetry.io/docs/collector/) using [OpenTelemetry JS instrumentation](https://opentelemetry.io/docs/instrumentation/js/).
+
+```javascript
+const pino = require('pino')
+
+const transport = pino.transport({
+  target: 'pino-opentelemetry-transport',
+  options: {
+    resourceAttributes: {
+      'service.name': 'test-service',
+      'service.version': '1.0.0'
+    }
+  }
+})
+
+pino(transport)
+```
+
+Documentation on running a minimal example is available in the [README](https://github.com/Vunovati/pino-opentelemetry-transport#minimalistic-example).
+
 <a id="communication-between-pino-and-transport"></a>
@@ -941,0 +986,0 @@ ## Communication between Pino and Transports

lib/meta.js

 'use strict'
 
-module.exports = { version: '8.14.2' }
+module.exports = { version: '8.15.0' }

lib/multistream.js

@@ -6,5 +6,2 @@ 'use strict'
 
-const defaultLevels = Object.create(levels)
-defaultLevels.silent = Infinity
-
 const DEFAULT_INFO_LEVEL = levels.info
@@ -17,5 +14,8 @@
 
-  let levels = defaultLevels
+  const streamLevels = Object.create(levels)
+  streamLevels.silent = Infinity
   if (opts.levels && typeof opts.levels === 'object') {
-    levels = opts.levels
+    Object.keys(opts.levels).forEach(i => {
+      streamLevels[i] = opts.levels[i]
+    })
   }
@@ -31,3 +31,4 @@
     clone,
-    [metadata]: true
+    [metadata]: true,
+    streamLevels
   }
@@ -105,3 +106,3 @@
 
-    const { streams } = this
+    const { streams, streamLevels } = this
 
@@ -112,3 +113,3 @@ let level
     } else if (typeof dest.level === 'string') {
-      level = levels[dest.level]
+      level = streamLevels[dest.level]
     } else if (typeof dest.level === 'number') {
@@ -115,0 +116,0 @@ level = dest.level

package.json

 {
   "name": "pino",
-  "version": "8.14.2",
+  "version": "8.15.0",
   "description": "super fast, all natural json logger",
@@ -5,0 +5,0 @@ "main": "pino.js",

test/transport/core.test.js

@@ -204,2 +204,26 @@ 'use strict'
 
+test('pino.transport without specifying default levels', async ({ same, teardown }) => {
+  const dest = file()
+  const transport = pino.transport({
+    targets: [{
+      level: 'foo',
+      target: join(__dirname, '..', 'fixtures', 'to-file-transport.js'),
+      options: { destination: dest }
+    }],
+    levels: { foo: 25 }
+  })
+  teardown(transport.end.bind(transport))
+  const instance = pino(transport)
+  instance.info('hello')
+  await Promise.all([watchFileCreated(dest)])
+  const result1 = JSON.parse(await readFile(dest))
+  delete result1.time
+  same(result1, {
+    pid,
+    hostname,
+    level: 30,
+    msg: 'hello'
+  })
+})
+
 test('pino.transport with two files and dedupe', async ({ same, teardown }) => {
@@ -206,0 +230,0 @@ const dest1 = file()

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

679412

increased by0.31%

Lines of code

13255

increased by0.19%

No dependency changes