feat: add Kysely queue adapter

Author: RomainLanz

.yarnrc.yml

@@ -1,5 +1,5 @@
 approvedGitRepositories:
-  - "**"
+  - '**'
 
 enableScripts: true
 

README.md

@@ -20,7 +20,7 @@ npm install @boringnode/queue
 
 ## Features
 
-- **Multiple Queue Adapters**: Redis, Knex (PostgreSQL, MySQL, SQLite), and Sync
+- **Multiple Queue Adapters**: Redis, Knex, Kysely (PostgreSQL, MySQL, SQLite), and Sync
 - **Type-Safe Jobs**: TypeScript classes with typed payloads
 - **Delayed Jobs**: Schedule jobs to run after a delay
 - **Priority Queues**: Process high-priority jobs first
@@ -267,18 +267,18 @@ const { jobId, deduped } = await SaveDraftJob.dispatch({ content: '...' })
 - `retryJob` does not touch the dedup entry — a retried job continues to occupy the dedup slot. TTL runs on wall-clock time, so long-running retries may outlive the TTL window. Use a generous TTL or no TTL if retries must stay deduped.
 - Atomic and race-free:
   - **Redis**: a single Lua script per dispatch performs the dedup-key lookup, state check (pending/delayed ZSCORE), payload swap, and TTL refresh atomically.
-  - **Knex**: transactional `SELECT ... FOR UPDATE` + insert/update inside a transaction. A nested savepoint catches unique-constraint violations under concurrent inserts and returns `{ deduped: 'skipped' }` pointing at the winner.
+  - **Knex/Kysely**: transactional `SELECT ... FOR UPDATE` + insert/update inside a transaction. A savepoint catches unique-constraint violations under concurrent inserts and returns `{ deduped: 'skipped' }` pointing at the winner.
   - **SyncAdapter**: executes inline, no dedup support.
 
 ### Caveats
 
 - Without `.dedup()`, jobs use auto-generated UUIDs and are never deduplicated.
-- The **Sync adapter** ignores `.dedup()` entirely — every dispatch executes inline and `deduped` is always `undefined` on the result. Use Redis or Knex if you need real deduplication.
+- The **Sync adapter** ignores `.dedup()` entirely — every dispatch executes inline and `deduped` is always `undefined` on the result. Use Redis, Knex, or Kysely if you need real deduplication.
 - `.dedup()` is only available on single dispatch. `dispatchMany` / `pushManyOn` reject jobs with a `dedup` field.
 - Scheduled jobs (`.schedule()`) do not support dedup — each cron/interval fire is an independent dispatch.
 - With no `ttl`, dedup persists until the job is removed (completed/failed without retention). When retention keeps the record, re-dispatch stays blocked until the record is pruned.
 - With `ttl`, dedup expires after the window — a new job (new UUID) is created. The old job still runs.
-- Knex MySQL concurrent race: MySQL does not support partial unique indexes, so two `pushOn` calls with the same dedup id firing at the exact same instant can both succeed. Serialize at the app layer if strict guarantees are required, or use Postgres / SQLite / Redis (all of which serialize correctly via the partial unique index or Lua atomicity).
+- Knex/Kysely MySQL concurrent race: MySQL does not support partial unique indexes, so two `pushOn` calls with the same dedup id firing at the exact same instant can both succeed. Serialize at the app layer if strict guarantees are required, or use Postgres / SQLite / Redis (all of which serialize correctly via the partial unique index or Lua atomicity).
 
 ## Job History & Retention
 
@@ -405,6 +405,43 @@ export default class extends BaseSchema {
 
 </details>
 
+### Kysely (PostgreSQL, MySQL, SQLite)
+
+Pass the application-owned Kysely instance to the adapter factory.
+
+```typescript
+import {
+  kysely,
+  KyselyQueueSchemaService,
+  type QueueDatabase,
+} from '@boringnode/queue/drivers/kysely_adapter'
+
+interface Database extends QueueDatabase {
+  orders: OrderTable
+}
+
+const adapter = kysely<Database>(db, { dialect: 'postgres' })
+```
+
+The adapter never destroys the application-owned Kysely instance. Use `tableName` and
+`schedulesTableName` in the options when your migration uses custom names.
+
+<details>
+<summary><strong>Database setup with KyselyQueueSchemaService</strong></summary>
+
+```typescript
+const schema = new KyselyQueueSchemaService(db, { dialect: 'postgres' })
+
+await schema.createJobsTable()
+await schema.createSchedulesTable()
+
+// down
+await schema.dropSchedulesTable()
+await schema.dropJobsTable()
+```
+
+</details>
+
 ### Fake (testing + assertions)
 
 ```typescript

compose.yml

@@ -12,3 +12,11 @@ services:
       POSTGRES_USER: postgres
       POSTGRES_PASSWORD: postgres
       POSTGRES_DB: queue_test
+
+  mysql:
+    image: mysql:8.4
+    ports:
+      - '3307:3306'
+    environment:
+      MYSQL_ROOT_PASSWORD: mysql
+      MYSQL_DATABASE: queue_test

package.json

@@ -57,6 +57,8 @@
     "hot-hook": "^1.0.0",
     "ioredis": "^5.11.1",
     "knex": "3.1.0",
+    "kysely": "^0.29.2",
+    "mysql2": "^3.0.0",
     "oxfmt": "^0.56.0",
     "oxlint": "^1.71.0",
     "oxlint-tsgolint": "^0.17.4",
@@ -70,7 +72,8 @@
     "@opentelemetry/core": "^1.30.0 || ^2.0.0",
     "@opentelemetry/instrumentation": "^0.200.0",
     "ioredis": "^5.0.0",
-    "knex": "^3.0.0"
+    "knex": "^3.0.0",
+    "kysely": "^0.29.0"
   },
   "peerDependenciesMeta": {
     "@opentelemetry/api": {
@@ -87,6 +90,9 @@
     },
     "knex": {
       "optional": true
+    },
+    "kysely": {
+      "optional": true
     }
   },
   "author": "Romain Lanz <romain.lanz@pm.me>",

src/contracts/adapter.ts

@@ -32,7 +32,7 @@ export interface AcquiredJob extends JobData {
  * Adapter interface for queue storage backends.
  *
  * Implementations handle job persistence, atomic operations, and
- * concurrency control. Built-in adapters: Redis, Knex (PostgreSQL/SQLite).
+ * concurrency control. Built-in adapters: Redis, Knex, Kysely, and Sync.
  *
  * @example
  * ```typescript