use TSFileMigrationProvider

Author: noxify

examples/kysely-postgres/package.json

@@ -18,7 +18,7 @@
   },
   "devDependencies": {
     "dotenv-cli": "10.0.0",
-    "kysely-ctl": "0.14.0",
+    "kysely-ctl": "^0.18.0",
     "tsx": "4.20.3",
     "typescript": "^5.8.3"
   }

packages/adapter-kysely/package.json

@@ -76,6 +76,7 @@
     "@vorsteh-queue/tsconfig": "workspace:*",
     "eslint": "^9.32.0",
     "kysely": "^0.28.4",
+    "kysely-ctl": "^0.18.0",
     "kysely-pglite-dialect": "^1.1.1",
     "prettier": "^3.6.2",
     "rolldown": "1.0.0-beta.31",

…er-kysely/src/migrations/queue_table.mjs …ter-kysely/src/migrations/queue_table.tspackages/adapter-kysely/src/migrations/queue_table.mjs renamed to packages/adapter-kysely/src/migrations/queue_table.ts packages/adapter-kysely/src/migrations/queue_table.mjs renamed to packages/adapter-kysely/src/migrations/queue_table.ts

@@ -1,9 +1,7 @@
+import type { Kysely } from "kysely"
 import { sql } from "kysely"
 
-/**
- * @param {import('kysely').Kysely<unknown>} db
- */
-export async function up(db) {
+export async function up(db: Kysely<unknown>) {
   await db.schema
     .createTable("queue_jobs")
     .addColumn("id", "uuid", (col) => col.defaultTo(sql`gen_random_uuid()`).notNull())
@@ -46,9 +44,6 @@ export async function up(db) {
     .execute()
 }
 
-/**
- * @param {import('kysely').Kysely<unknown>} db
- */
-export async function down(db) {
+export async function down(db: Kysely<unknown>) {
   await db.schema.dropTable("queue_jobs").execute()
 }

packages/adapter-kysely/tests/postgres-adapter.test.ts

@@ -1,7 +1,7 @@
-import { promises as fs } from "fs"
 import * as path from "path"
 import { PGlite } from "@electric-sql/pglite"
-import { FileMigrationProvider, Kysely, Migrator, sql } from "kysely"
+import { Kysely, Migrator, sql } from "kysely"
+import { TSFileMigrationProvider } from "kysely-ctl"
 import { PGliteDialect } from "kysely-pglite-dialect"
 import { afterEach, beforeEach, describe, expect, it } from "vitest"
 
@@ -23,9 +23,7 @@ describe("PostgresQueueAdapter", () => {
 
     const migrator = new Migrator({
       db,
-      provider: new FileMigrationProvider({
-        fs,
-        path,
+      provider: new TSFileMigrationProvider({
         // This needs to be an absolute path.
         migrationFolder: path.join(__dirname, "../src/migrations"),
       }),
@@ -226,9 +224,7 @@ describe("PostgresQueueAdapter - Timezone Handling", () => {
 
     const migrator = new Migrator({
       db,
-      provider: new FileMigrationProvider({
-        fs,
-        path,
+      provider: new TSFileMigrationProvider({
         // This needs to be an absolute path.
         migrationFolder: path.join(__dirname, "../src/migrations"),
       }),
@@ -300,9 +296,7 @@ describe("PostgresQueueAdapter - Result Storage", () => {
 
     const migrator = new Migrator({
       db,
-      provider: new FileMigrationProvider({
-        fs,
-        path,
+      provider: new TSFileMigrationProvider({
         // This needs to be an absolute path.
         migrationFolder: path.join(__dirname, "../src/migrations"),
       }),

packages/adapter-kysely/tests/progress.test.ts

@@ -1,7 +1,7 @@
-import { promises as fs } from "fs"
 import * as path from "path"
 import { PGlite } from "@electric-sql/pglite"
-import { FileMigrationProvider, Kysely, Migrator } from "kysely"
+import { Kysely, Migrator } from "kysely"
+import { TSFileMigrationProvider } from "kysely-ctl"
 import { PGliteDialect } from "kysely-pglite-dialect"
 import { afterEach, beforeEach, describe, expect, it } from "vitest"
 
@@ -23,9 +23,7 @@ describe("PostgresQueueAdapter Progress", () => {
 
     const migrator = new Migrator({
       db,
-      provider: new FileMigrationProvider({
-        fs,
-        path,
+      provider: new TSFileMigrationProvider({
         // This needs to be an absolute path.
         migrationFolder: path.join(__dirname, "../src/migrations"),
       }),

packages/adapter-kysely/tests/timezone-edge-cases.test.ts

@@ -1,7 +1,7 @@
-import { promises as fs } from "fs"
 import * as path from "path"
 import { PGlite } from "@electric-sql/pglite"
-import { FileMigrationProvider, Kysely, Migrator } from "kysely"
+import { Kysely, Migrator } from "kysely"
+import { TSFileMigrationProvider } from "kysely-ctl"
 import { PGliteDialect } from "kysely-pglite-dialect"
 import { afterEach, beforeEach, describe, expect, it } from "vitest"
 
@@ -23,9 +23,7 @@ describe("Timezone Edge Cases", () => {
 
     const migrator = new Migrator({
       db,
-      provider: new FileMigrationProvider({
-        fs,
-        path,
+      provider: new TSFileMigrationProvider({
         // This needs to be an absolute path.
         migrationFolder: path.join(__dirname, "../src/migrations"),
       }),

packages/adapter-kysely/tests/utc-storage.test.ts

@@ -1,7 +1,7 @@
-import { promises as fs } from "fs"
 import * as path from "path"
 import { PGlite } from "@electric-sql/pglite"
-import { FileMigrationProvider, Kysely, Migrator } from "kysely"
+import { Kysely, Migrator } from "kysely"
+import { TSFileMigrationProvider } from "kysely-ctl"
 import { PGliteDialect } from "kysely-pglite-dialect"
 import { afterEach, beforeEach, describe, expect, it } from "vitest"
 
@@ -23,9 +23,7 @@ describe("UTC Storage Verification", () => {
 
     const migrator = new Migrator({
       db,
-      provider: new FileMigrationProvider({
-        fs,
-        path,
+      provider: new TSFileMigrationProvider({
         // This needs to be an absolute path.
         migrationFolder: path.join(__dirname, "../src/migrations"),
       }),