[napi] fix thread safe function callback (#3162)

* fixup

* add debug log message to event loop unexpected tag

* fix fmt

2 files changed, 10 insertions, 4 deletions

diff --git a/src/bun.js/event_loop.zig b/src/bun.js/event_loop.zig
index ea7551b7f..c2125e64f 100644
--- a/src/bun.js/event_loop.zig
+++ b/src/bun.js/event_loop.zig
@@ -407,6 +407,7 @@ pub const EventLoop = struct {
     forever_timer: ?*uws.Timer = null,
 
     pub const Queue = std.fifo.LinearFifo(Task, .Dynamic);
+    const log = bun.Output.scoped(.EventLoop, false);
 
     pub fn tickWithCount(this: *EventLoop) u32 {
         var global = this.global;
@@ -442,6 +443,10 @@ pub const EventLoop = struct {
                     var transform_task: *JSC.napi.napi_async_work = task.get(JSC.napi.napi_async_work).?;
                     transform_task.*.runFromJS();
                 },
+                .ThreadSafeFunction => {
+                    var transform_task: *ThreadSafeFunction = task.as(ThreadSafeFunction);
+                    transform_task.call();
+                },
                 @field(Task.Tag, @typeName(ReadFileTask)) => {
                     var transform_task: *ReadFileTask = task.get(ReadFileTask).?;
                     transform_task.*.runFromJS();
@@ -477,7 +482,10 @@ pub const EventLoop = struct {
                 },
                 else => if (Environment.allow_assert) {
                     bun.Output.prettyln("\nUnexpected tag: {s}\n", .{@tagName(task.tag())});
-                } else unreachable,
+                } else {
+                    log("\nUnexpected tag: {s}\n", .{@tagName(task.tag())});
+                    unreachable;
+                },
             }
 
             global_vm.releaseWeakRefs();
diff --git a/src/bun.js/events.exports.js b/src/bun.js/events.exports.js
index 482ef5f5d..61cff17d6 100644
--- a/src/bun.js/events.exports.js
+++ b/src/bun.js/events.exports.js
@@ -22,9 +22,7 @@ function EventEmitter(opts) {
   }
 
   this._maxListeners ??= undefined;
-  if (
-    (this[kCapture] = opts?.captureRejections ? Boolean(opts?.captureRejections) : EventEmitterPrototype[kCapture])
-  ) {
+  if ((this[kCapture] = opts?.captureRejections ? Boolean(opts?.captureRejections) : EventEmitterPrototype[kCapture])) {
     this.emit = emitWithRejectionCapture;
   }
 }