feat(dialect-bun-worker): remove dumplicate zen-mitt

Author: subframe7536

packages/dialect-bun-worker/package.json

@@ -37,9 +37,6 @@
   "peerDependencies": {
     "kysely": ">=0.26"
   },
-  "dependencies": {
-    "zen-mitt": "^0.3.0"
-  },
   "devDependencies": {
     "bun-types": "latest"
   }

packages/dialect-bun-worker/src/driver.ts

@@ -1,7 +1,6 @@
+import { EventEmitter } from 'node:events'
 import type { DatabaseConnection, Driver, QueryResult } from 'kysely'
 import { CompiledQuery, SelectQueryNode } from 'kysely'
-import type { Emitter } from 'zen-mitt'
-import { mitt } from 'zen-mitt'
 import type { EventWithError, MainMsg, WorkerMsg } from './type'
 import type { BunWorkerDialectConfig } from '.'
 
@@ -10,7 +9,7 @@ export class BunWorkerDriver implements Driver {
   private worker?: Worker
   private connection?: DatabaseConnection
   private connectionMutex = new ConnectionMutex()
-  private mitt?: Emitter<EventWithError>
+  private mitt?: EventEmitter<EventWithError>
   constructor(config?: BunWorkerDialectConfig) {
     this.config = config
   }
@@ -20,7 +19,7 @@ export class BunWorkerDriver implements Driver {
       new URL('./worker', import.meta.url),
       { type: 'module' },
     )
-    this.mitt = mitt<EventWithError>()
+    this.mitt = new EventEmitter()
     this.worker.onmessage = ({ data: { data, err, type } }: MessageEvent<WorkerMsg>) => {
       this.mitt?.emit(type, { data, err })
     }
@@ -73,7 +72,7 @@ export class BunWorkerDriver implements Driver {
           reject(err)
         } else {
           this.worker?.terminate()
-          this.mitt?.off()
+          this.mitt?.removeAllListeners()
           this.mitt = undefined
           resolve()
         }
@@ -107,12 +106,10 @@ class ConnectionMutex {
 }
 
 class BunWorkerConnection implements DatabaseConnection {
-  readonly worker: Worker
-  readonly mitt?: Emitter<EventWithError>
-  constructor(worker: Worker, mitt?: Emitter<EventWithError>) {
-    this.worker = worker
-    this.mitt = mitt
-  }
+  constructor(
+    private worker: Worker,
+    private mitt?: EventEmitter<EventWithError>,
+  ) { }
 
   streamQuery<R>(): AsyncIterableIterator<QueryResult<R>> {
     throw new Error('Bun:sqlite-worker driver doesn\'t support streaming')

packages/dialect-bun-worker/src/type.ts

@@ -27,14 +27,16 @@ export type WorkerMsg = {
     err: unknown
   }
 }[keyof Events]
+
 type Events = {
   run: QueryResult<any> | null
   init: null
   close: null
 }
+
 export type EventWithError = {
-  [K in keyof Events]: {
+  [K in keyof Events]: [{
     data: Events[K]
     err: unknown
-  }
+  }]
 }

packages/dialect-sqlite-worker/src/driver.ts

@@ -96,12 +96,10 @@ class ConnectionMutex {
   }
 }
 export class SqliteWorkerConnection implements DatabaseConnection {
-  readonly worker: Worker
-  readonly emit?: EventEmitter
-  constructor(worker: Worker, emit?: EventEmitter) {
-    this.worker = worker
-    this.emit = emit
-  }
+  constructor(
+    private worker: Worker,
+    private emit?: EventEmitter,
+  ) { }
 
   async *streamQuery<R>(): AsyncIterableIterator<QueryResult<R>> {
     throw new Error('sqlite-worker driver doesn\'t support streaming')