From d091931db3b99212db9826489523712bb26172a1 Mon Sep 17 00:00:00 2001
From: Tobias Gurtzick <magic@wizardtales.com>
Date: Thu, 7 Sep 2023 15:29:25 +0200
Subject: [PATCH] empty state initializer

Signed-off-by: Tobias Gurtzick <magic@wizardtales.com>
---
 lib/commands/fix.js | 2 +-
 lib/state.js        | 6 +++---
 lib/walker.js       | 8 ++++----
 3 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/lib/commands/fix.js b/lib/commands/fix.js
index 1b490a34..89b8c5de 100644
--- a/lib/commands/fix.js
+++ b/lib/commands/fix.js
@@ -31,7 +31,7 @@ async function prepare (internals, config) {
 
     internals.migrationsDir = migrator.directory;
 
-    await migrator.createMigrationsTable();
+    await migrator.createMigrationsTable({ emptyState: true });
     log.verbose('migration table created');
 
     return migrator;
diff --git a/lib/state.js b/lib/state.js
index 59d03c50..8a11a5b4 100644
--- a/lib/state.js
+++ b/lib/state.js
@@ -29,12 +29,12 @@ module.exports = {
     }
   },
 
-  init: async function (driver, internals) {
+  init: async function (driver, internals, { emptyState }) {
     await driver._createKV(internals.migrationState);
-    const schema = await driver._getKV(internals.migrationState, SSTATE);
+    const schema = emptyState ? await driver._getKV(internals.migrationState, SSTATE) : null;
     if (schema) {
       internals.schema = JSON.parse(schema.value);
-    } else {
+    } else if (!emptyState) {
       await driver._insertKV(internals.migrationState, SSTATE, '{}');
     }
 
diff --git a/lib/walker.js b/lib/walker.js
index 28ead468..8c717348 100644
--- a/lib/walker.js
+++ b/lib/walker.js
@@ -59,12 +59,12 @@ const Walker = function (driver, directory, mode, intern, prefix) {
 };
 
 Walker.prototype = {
-  createTables: async function () {
-    await State.init(this._driver, this.internals);
+  createTables: async function (options) {
+    await State.init(this._driver, this.internals, options);
     return this._driver._createList(this.internals.migrationTable);
   },
 
-  createMigrationsTable: function () {
+  createMigrationsTable: function (options) {
     if (
       typeof this._driver._createList !== 'function' ||
       typeof this._driver._getList !== 'function' ||
@@ -85,7 +85,7 @@ Walker.prototype = {
       }
     }
 
-    return this.createTables();
+    return this.createTables(options);
   },
 
   writeMigrationRecord: function (migration, callback) {