feat: Support bundlers.

lib/transport.js

@@ -81,6 +81,8 @@ function transport (fullOptions) {
   const { pipeline, targets, options = {}, worker = {}, caller = getCaller() } = fullOptions
   // This function call MUST stay in the top-level function of this module
   const callerRequire = createRequire(caller)
+  // This will be eventually modified by bundlers
+  const bundlerOverrides = '__bundlerPathsOverrides' in globalThis ? globalThis.__bundlerPathsOverrides : {}
 
   let target = fullOptions.target
 
@@ -89,15 +91,15 @@ function transport (fullOptions) {
   }
 
   if (targets) {
-    target = join(__dirname, 'worker.js')
+    target = bundlerOverrides['pino-worker'] || join(__dirname, 'worker.js')
     options.targets = targets.map((dest) => {
       return {
         ...dest,
         target: fixTarget(dest.target)
       }
     })
   } else if (fullOptions.pipeline) {
-    target = join(__dirname, 'worker-pipeline.js')
+    target = bundlerOverrides['pino-pipeline-worker'] || join(__dirname, 'worker-pipeline.js')
     options.targets = pipeline.map((dest) => {
       return {
         ...dest,
@@ -109,6 +111,8 @@ function transport (fullOptions) {
   return buildStream(fixTarget(target), options, worker)
 
   function fixTarget (origin) {
+    origin = bundlerOverrides[origin] || origin
+
     if (isAbsolute(origin) || origin.indexOf('file://') === 0) {
       return origin
     }

lib/worker-pipeline.js

@@ -1,6 +1,7 @@
 'use strict'
 
 const EE = require('events')
+const { realImport, realRequire } = require('real-require')
 const { pipeline, PassThrough } = require('stream')
 
 // This file is not checked by the code coverage tool,
@@ -13,11 +14,11 @@ module.exports = async function ({ targets }) {
     let fn
     try {
       const toLoad = 'file://' + t.target
-      fn = (await import(toLoad)).default
+      fn = (await realImport(toLoad)).default
     } catch (error) {
       // See this PR for details: https://github.com/pinojs/thread-stream/pull/34
       if ((error.code === 'ENOTDIR' || error.code === 'ERR_MODULE_NOT_FOUND')) {
-        fn = require(t.target)
+        fn = realRequire(t.target)
       } else {
         throw error
       }

lib/worker.js

@@ -2,6 +2,7 @@
 
 const pino = require('../pino.js')
 const build = require('pino-abstract-transport')
+const { realImport, realRequire } = require('real-require')
 
 // This file is not checked by the code coverage tool,
 // as it is not reliable.
@@ -13,11 +14,11 @@ module.exports = async function ({ targets }) {
     let fn
     try {
       const toLoad = 'file://' + t.target
-      fn = (await import(toLoad)).default
+      fn = (await realImport(toLoad)).default
     } catch (error) {
       // See this PR for details: https://github.com/pinojs/thread-stream/pull/34
       if ((error.code === 'ENOTDIR' || error.code === 'ERR_MODULE_NOT_FOUND')) {
-        fn = require(t.target)
+        fn = realRequire(t.target)
       } else {
         throw error
       }

package.json

@@ -109,6 +109,7 @@
     "pino-abstract-transport": "v0.4.0",
     "pino-std-serializers": "^4.0.0",
     "quick-format-unescaped": "^4.0.3",
+    "real-require": "^0.1.0",
     "safe-stable-stringify": "^2.1.0",
     "sonic-boom": "^2.2.1",
     "thread-stream": "^0.11.1"