tick atomically

Signed-off-by: Tobias Gurtzick <[email protected]>

Author: wzrdtales

lib/state.js

@@ -65,6 +65,10 @@ module.exports = {
     }
   },
 
+  isOwner: function () {
+    return owner;
+  },
+
   init: async function (driver, internals, { emptyState, backupState }) {
     await driver._createKV(internals.migrationState);
     const _schema = await driver._getKV(internals.migrationState, SSTATE);
@@ -149,17 +153,40 @@ module.exports = {
       return Promise.resolve();
     }
 
-    let { value: state } = await driver._getKV(
+    let state = await driver._getKV(
       internals.migrationState,
       MSTATE
     );
+
+    let runOn = state.run_on;
+    state = state.value;
     state = JSON.parse(state);
-    state.s.date = new Date();
-    return driver._updateKV(
+
+    if (!state.s.ID || state.s.ID !== ID) {
+      owner = true;
+      state.s.ID = ID;
+    }
+
+    const d = new Date();
+
+    state.s.date = d;
+    await driver._updateKVC(
       internals.migrationState,
       MSTATE,
-      JSON.stringify(state)
+      JSON.stringify(state),
+      RUNON,
+      runOn
     );
+
+    state = await driver._getKV(internals.migrationState, MSTATE);
+
+    runOn = state.run_on;
+    state = state.value;
+    state = JSON.parse(state);
+
+    if (state.s.ID !== ID) {
+      owner = false;
+    }
   },
 
   step: async function (driver, step, internals) {