fix(dialect-sqlite-worker): fix incorrect type import and unless await

Author: subframe7536

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

@@ -2,8 +2,8 @@ import type { Buffer } from 'node:buffer'
 import type { DatabaseConnection, DatabaseIntrospector, Dialect, DialectAdapter, Driver, Kysely, QueryCompiler } from 'kysely'
 import { SqliteAdapter, SqliteIntrospector, SqliteQueryCompiler } from 'kysely'
 import type { Options } from 'better-sqlite3'
-import type { Promisable } from '../../dialect-wasm/src'
 import { SqliteWorkerDriver } from './driver'
+import type { Promisable } from './type'
 
 export type SqliteWorkerDialectConfig = {
   /**

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

@@ -1,5 +1,7 @@
 import type { QueryResult } from 'kysely'
 
+export type Promisable<T> = T | Promise<T>
+
 export type SqlData = {
   sql: string
   parameters?: readonly unknown[]

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

@@ -9,13 +9,13 @@ if (!parentPort) {
 const { src, option } = workerData
 const db = new Database(src, option)
 
-parentPort.on('message', async (msg: MainMsg) => {
+parentPort.on('message', (msg: MainMsg) => {
   const ret: WorkerMsg = {
     type: msg.type,
     data: null,
     err: null,
   }
-  const run = async () => {
+  const run = () => {
     try {
       if (msg.type === 'close') {
         db.close()
@@ -45,6 +45,6 @@ parentPort.on('message', async (msg: MainMsg) => {
       ret.err = error
     }
   }
-  await run()
+  run()
   parentPort?.postMessage(ret)
 })