Skip to content

Commit 6758f9d

Browse files
committed
feat(dialect-sqlite-worker): custom worker path
1 parent 6ad9811 commit 6758f9d

File tree

3 files changed

+10
-5
lines changed

3 files changed

+10
-5
lines changed

packages/dialect-sqlite-worker/README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,4 +28,4 @@ export type SqliteWorkerDialectConfig = {
2828
2929
## Notice
3030
31-
the worker script is read from `join(__dirname, 'worker.js')`, please make sure it exists
31+
the worker script is read from `join(__dirname, 'worker.js')` by default, you can customize the path

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,12 +18,12 @@ export class SqliteWorkerDriver implements Driver {
1818
}
1919

2020
async init(): Promise<void> {
21-
const { option, source, onCreateConnection } = this.config
21+
const { dbOption, source, onCreateConnection } = this.config
2222
const src = typeof source === 'function' ? await source() : source
2323
this.emit = new EventEmitter()
2424
this.worker = new Worker(
25-
join(__dirname, 'worker.js'),
26-
{ workerData: { src, option } },
25+
this.config.workerPath || join(__dirname, 'worker.js'),
26+
{ workerData: { src, option: dbOption } },
2727
)
2828
this.worker.on('message', ({ data, type, err }: WorkerMsg) => {
2929
this.emit?.emit(type, data, err)

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

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,12 @@ export type SqliteWorkerDialectConfig = {
1212
/**
1313
* better-sqlite3 initiate option
1414
*/
15-
option?: Options
15+
dbOption?: Options
16+
/**
17+
* db worker path
18+
* @default join(__dirname, 'worker.js')
19+
*/
20+
workerPath?: string
1621
onCreateConnection?: (connection: DatabaseConnection) => Promisable<void>
1722
}
1823

0 commit comments

Comments
 (0)