Update dependency: @synor/core

Author: MunifTanjim

Diff for: package.json

@@ -27,12 +27,12 @@
     "test": "jest"
   },
   "dependencies": {
-    "better-sqlite3": "^5.4.3",
+    "better-sqlite3": "^6.0.1",
     "connection-string": "^3.1.1",
     "debug": "^4.1.1"
   },
   "devDependencies": {
-    "@synor/core": "^0.8.2",
+    "@synor/core": "^0.9.0",
     "@types/better-sqlite3": "^5.4.0",
     "@types/debug": "^4.1.5",
     "@types/jest": "^24.0.25",
@@ -42,7 +42,7 @@
     "eslint": "^6.8.0",
     "eslint-config-prettier": "^6.9.0",
     "eslint-config-standard-with-typescript": "^11.0.1",
-    "eslint-plugin-import": "^2.20.0",
+    "eslint-plugin-import": "^2.20.1",
     "eslint-plugin-node": "^11.0.0",
     "eslint-plugin-prettier": "^3.1.2",
     "eslint-plugin-promise": "^4.2.1",
@@ -59,7 +59,7 @@
     "typescript": "^3.7.4"
   },
   "peerDependencies": {
-    "@synor/core": "^0.8.2"
+    "@synor/core": "^0.9.0"
   },
   "publishConfig": {
     "access": "public"

Diff for: src/__snapshots__/index.test.ts.snap

@@ -65,7 +65,7 @@ Array [
 ]
 `;
 
-exports[`methods run 2`] = `
+exports[`methods run (with body) 2`] = `
 Array [
   Object {
     "applied_at": "2020-01-01T00:00:00.000Z",
@@ -102,3 +102,30 @@ Array [
   },
 ]
 `;
+
+exports[`methods run (with run) 1`] = `
+Array [
+  Object {
+    "applied_at": "2020-01-01T00:00:00.000Z",
+    "applied_by": "Synor",
+    "dirty": 0,
+    "execution_time": 0,
+    "hash": "",
+    "id": 1,
+    "title": "Base Migration",
+    "type": "do",
+    "version": "0",
+  },
+  Object {
+    "applied_at": "2020-01-01T00:00:00.000Z",
+    "applied_by": "Jest",
+    "dirty": 0,
+    "execution_time": 0,
+    "hash": "hash-02-do",
+    "id": 2,
+    "title": "Test Two",
+    "type": "do",
+    "version": "02",
+  },
+]
+`;

Diff for: src/index.test.ts

@@ -27,7 +27,10 @@ const getTableColumnCount = (
     .all({ tableName }).length
 }
 
-const migrationSource: Record<'01.do' | '01.undo', MigrationSource> = {
+const migrationSource: Record<
+  '01.do' | '01.undo' | '02.do',
+  MigrationSource
+> = {
   '01.do': {
     version: '01',
     type: 'do',
@@ -41,6 +44,15 @@ const migrationSource: Record<'01.do' | '01.undo', MigrationSource> = {
     title: 'Test One',
     body: 'SELEC -1;',
     hash: 'hash-01-undo'
+  },
+  '02.do': {
+    version: '02',
+    type: 'do',
+    title: 'Test Two',
+    hash: 'hash-02-do',
+    run: async (client: Database) => {
+      client.exec('SELECT 2;')
+    }
   }
 }
 
@@ -246,7 +258,7 @@ describe('methods', () => {
     expect(getTableColumnCount(database, schemaName, tableName)).toBe(0)
   })
 
-  test('run', async () => {
+  test('run (with body)', async () => {
     await expect(engine.run(migrationSource['01.do'])).resolves.toBeUndefined()
     await expect(
       engine.run(migrationSource['01.undo'])
@@ -263,6 +275,18 @@ describe('methods', () => {
     await engine.drop()
   })
 
+  test('run (with run)', async () => {
+    await expect(engine.run(migrationSource['02.do'])).resolves.toBeUndefined()
+
+    const rows = database
+      .prepare(`SELECT * FROM ${schemaName}.${tableName};`)
+      .all()
+
+    expect(rows).toMatchSnapshot()
+
+    await engine.drop()
+  })
+
   test('repair', async () => {
     await expect(engine.run(migrationSource['01.do'])).resolves.toBeUndefined()
     await expect(

Diff for: src/index.ts

@@ -10,6 +10,8 @@ type DatabaseEngine = import('@synor/core').DatabaseEngine
 type DatabaseEngineFactory = import('@synor/core').DatabaseEngineFactory
 type MigrationSource = import('@synor/core').MigrationSource
 
+export type MigrationSourceContentRunner = (client: Database) => Promise<void>
+
 export const SQLiteDatabaseEngine: DatabaseEngineFactory = (
   uri,
   { baseVersion, getUserInfo }
@@ -61,14 +63,19 @@ export const SQLiteDatabaseEngine: DatabaseEngineFactory = (
     type,
     title,
     hash,
-    body
+    body,
+    run
   }: MigrationSource) => {
     let dirty = false
 
     const startTime = performance.now()
 
     try {
-      database.exec(body)
+      if (body) {
+        database.exec(body)
+      } else {
+        await (run as MigrationSourceContentRunner)(database)
+      }
     } catch (err) {
       dirty = true