From 0ed0550e73a1c29d73b0396ab8459943403f36f9 Mon Sep 17 00:00:00 2001
From: Martin McKeaveney <martin@shogunsystems.co.uk>
Date: Sun, 16 May 2021 21:25:37 +0100
Subject: [PATCH] revert functionality working

---
 packages/auth/src/db/Replication.js           |   9 +-
 packages/auth/src/db/utils.js                 |   4 +
 .../src/builderStore/store/frontend.js        |   4 +-
 .../src/components/deploy/DeployModal.svelte  | 110 ++++++++++++++++++
 .../src/components/deploy/RevertModal.svelte  |  35 ++++++
 .../src/components/start/AppCard.svelte       |   2 +-
 .../src/components/start/AppRow.svelte        |   2 +-
 .../components/start/CreateAppModal.svelte    |   4 +-
 .../builder/app/[application]/_layout.svelte  |  25 ++--
 .../deploy => deploy_old}/_layout.svelte      |   2 +-
 .../deploy => deploy_old}/index.svelte        |   0
 .../pages/builder/portal/apps/index.svelte    |   8 +-
 packages/builder/src/stores/portal/apps.js    |   1 +
 packages/builder/src/stores/portal/index.js   |   2 +-
 packages/server/scripts/replicateApp.js       |   5 +-
 .../server/src/api/controllers/application.js |  14 +--
 .../server/src/api/controllers/component.js   |   3 +-
 .../src/api/controllers/deploy/index.js       |  39 ++++---
 packages/server/src/api/controllers/dev.js    |  37 ++++++
 .../src/api/controllers/static/index.js       |   5 +-
 packages/server/src/api/routes/dev.js         |   8 +-
 .../routes/tests/utilities/TestFunctions.js   |   2 +-
 packages/server/src/db/utils.js               |   1 +
 .../src/tests/utilities/TestConfiguration.js  |   4 +-
 packages/server/src/utilities/index.js        |   6 +-
 packages/worker/src/api/controllers/app.js    |   7 +-
 26 files changed, 266 insertions(+), 73 deletions(-)
 create mode 100644 packages/builder/src/components/deploy/DeployModal.svelte
 create mode 100644 packages/builder/src/components/deploy/RevertModal.svelte
 rename packages/builder/src/pages/builder/app/{[application]/deploy => deploy_old}/_layout.svelte (64%)
 rename packages/builder/src/pages/builder/app/{[application]/deploy => deploy_old}/index.svelte (100%)

diff --git a/packages/auth/src/db/Replication.js b/packages/auth/src/db/Replication.js
index 9720776413..931bc3d496 100644
--- a/packages/auth/src/db/Replication.js
+++ b/packages/auth/src/db/Replication.js
@@ -31,7 +31,7 @@ class Replication {
    * Two way replication operation, intended to be promise based.
    * @param {Object} opts - PouchDB replication options
    */
-  sync(opts) {
+  sync(opts = {}) {
     this.replication = this.promisify(this.source.sync, opts)
     return this.replication
   }
@@ -40,7 +40,7 @@ class Replication {
    * One way replication operation, intended to be promise based.
    * @param {Object} opts - PouchDB replication options
    */
-  replicate(opts) {
+  replicate(opts = {}) {
     this.replication = this.promisify(this.source.replicate.to, opts)
     return this.replication
   }
@@ -61,8 +61,13 @@ class Replication {
       })
   }
 
+  /**
+   * Rollback the target DB back to the state of the source DB
+   */
   async rollback() {
     await this.target.destroy()
+    // Recreate the DB again
+    this.target = getDB(this.target.name)
     await this.replicate()
   }
 
diff --git a/packages/auth/src/db/utils.js b/packages/auth/src/db/utils.js
index 44fe1da2db..c4849a6897 100644
--- a/packages/auth/src/db/utils.js
+++ b/packages/auth/src/db/utils.js
@@ -12,6 +12,9 @@ exports.StaticDatabases = {
   GLOBAL: {
     name: "global-db",
   },
+  DEPLOYMENTS: {
+    name: "deployments",
+  },
 }
 
 const DocumentTypes = {
@@ -21,6 +24,7 @@ const DocumentTypes = {
   TEMPLATE: "template",
   APP: "app",
   APP_DEV: "app_dev",
+  APP_METADATA: "app_metadata",
 }
 
 exports.DocumentTypes = DocumentTypes
diff --git a/packages/builder/src/builderStore/store/frontend.js b/packages/builder/src/builderStore/store/frontend.js
index be553066b9..0d80065f2f 100644
--- a/packages/builder/src/builderStore/store/frontend.js
+++ b/packages/builder/src/builderStore/store/frontend.js
@@ -51,14 +51,14 @@ export const getFrontendStore = () => {
   store.actions = {
     initialise: async pkg => {
       const { layouts, screens, application, clientLibPath } = pkg
-      const components = await fetchComponentLibDefinitions(application._id)
+      const components = await fetchComponentLibDefinitions(application.appId)
       store.update(state => ({
         ...state,
         libraries: application.componentLibraries,
         components,
         name: application.name,
         description: application.description,
-        appId: application._id,
+        appId: application.appId,
         url: application.url,
         layouts,
         screens,
diff --git a/packages/builder/src/components/deploy/DeployModal.svelte b/packages/builder/src/components/deploy/DeployModal.svelte
new file mode 100644
index 0000000000..5fffa4cd55
--- /dev/null
+++ b/packages/builder/src/components/deploy/DeployModal.svelte
@@ -0,0 +1,110 @@
+<script>
+  import { onMount, onDestroy } from "svelte"
+  import { Button, Modal, notifications, ModalContent } from "@budibase/bbui"
+  import { store } from "builderStore"
+  import api from "builderStore/api"
+  import analytics from "analytics"
+  import FeedbackIframe from "components/feedback/FeedbackIframe.svelte"
+
+  const DeploymentStatus = {
+    SUCCESS: "SUCCESS",
+    PENDING: "PENDING",
+    FAILURE: "FAILURE",
+  }
+
+  const POLL_INTERVAL = 1000
+
+
+  let loading = false
+  let feedbackModal
+  let deployments = []
+  let poll
+  let publishModal
+
+  $: appId = $store.appId
+
+  async function deployApp() {
+    try {
+      notifications.info(`Deployment started. Please wait.`)
+      const response = await api.post("/api/deploy")
+      const json = await response.json()
+      if (response.status !== 200) {
+        throw new Error()
+      }
+
+      if (analytics.requestFeedbackOnDeploy()) {
+        feedbackModal.show()
+      }
+    } catch (err) {
+      analytics.captureException(err)
+      notifications.error("Deployment unsuccessful. Please try again later.")
+    }
+  }
+
+  async function fetchDeployments() {
+    try {
+      const response = await api.get(`/api/deployments`)
+      const json = await response.json()
+
+      if (deployments.length > 0) {
+        checkIncomingDeploymentStatus(deployments, json)
+      }
+
+      deployments = json
+    } catch (err) {
+      console.error(err)
+      clearInterval(poll)
+      notifications.error(
+        "Error fetching deployment history. Please try again."
+      )
+    }
+  }
+
+  // Required to check any updated deployment statuses between polls
+  function checkIncomingDeploymentStatus(current, incoming) {
+    for (let incomingDeployment of incoming) {
+      if (incomingDeployment.status === DeploymentStatus.FAILURE || incomingDeployment.status === DeploymentStatus.SUCCESS) {
+        const currentDeployment = current.find(
+          deployment => deployment._id === incomingDeployment._id
+        )
+
+        // We have just been notified of an ongoing deployments status change
+        if (
+          !currentDeployment ||
+          currentDeployment.status === DeploymentStatus.PENDING
+        ) {
+          if (incomingDeployment.status === DeploymentStatus.FAILURE) {
+            notifications.error(incomingDeployment.err)
+          } else {
+            notifications.send("Published to Production.", "success", "CheckmarkCircle")
+          }
+        }
+      } 
+    }
+  }
+
+
+  onMount(() => {
+    fetchDeployments()
+    poll = setInterval(fetchDeployments, POLL_INTERVAL)
+  })
+
+  onDestroy(() => clearInterval(poll))
+</script>
+
+
+<Button
+secondary
+on:click={publishModal.show}
+>
+Publish
+</Button>
+<Modal bind:this={publishModal}>
+<ModalContent
+  title="Publish to Production"
+  confirmText="Publish"
+  onConfirm={deployApp}
+>
+  <span>The changes you have made will be published to the production version of the application.</span>
+</ModalContent>
+</Modal>
diff --git a/packages/builder/src/components/deploy/RevertModal.svelte b/packages/builder/src/components/deploy/RevertModal.svelte
new file mode 100644
index 0000000000..7eaac42bbd
--- /dev/null
+++ b/packages/builder/src/components/deploy/RevertModal.svelte
@@ -0,0 +1,35 @@
+<script>
+  import { onMount, onDestroy } from "svelte"
+  import { Button, Icon, Modal, notifications, ModalContent } from "@budibase/bbui"
+  import { store } from "builderStore"
+  import { apps } from "stores/portal"
+  import api from "builderStore/api"
+
+  let revertModal
+
+  $: appId = $store.appId
+
+  const revert = async () => {
+    try {
+      const response = await api.post(`/api/dev/${appId}/revert`)
+      const json = await response.json()
+      if (response.status !== 200) throw json.message
+
+      notifications.info("Changes reverted.")
+    } catch (err) {
+      notifications.error(`Error reverting changes: ${err}`)
+    }
+  }
+</script>
+
+
+<Icon name="Revert" hoverable on:click={revertModal.show} />
+<Modal bind:this={revertModal}>
+<ModalContent
+  title="Revert Changes"
+  confirmText="Revert"
+  onConfirm={revert}
+>
+  <span>The changes you have made will be deleted and the application reverted back to its production state.</span>
+</ModalContent>
+</Modal>
diff --git a/packages/builder/src/components/start/AppCard.svelte b/packages/builder/src/components/start/AppCard.svelte
index 174ac585d4..7415e2568e 100644
--- a/packages/builder/src/components/start/AppCard.svelte
+++ b/packages/builder/src/components/start/AppCard.svelte
@@ -41,7 +41,7 @@
         </MenuItem>
         {/if}
         {#if app.lockedBy && app.lockedBy?.email === $auth.user?.email}
-          <MenuItem on:click={() => releaseLock(app._id)} icon="LockOpen">
+          <MenuItem on:click={() => releaseLock(app.appId)} icon="LockOpen">
             Release Lock
           </MenuItem>
         {/if}
diff --git a/packages/builder/src/components/start/AppRow.svelte b/packages/builder/src/components/start/AppRow.svelte
index 693c717ab5..1a4ec1a152 100644
--- a/packages/builder/src/components/start/AppRow.svelte
+++ b/packages/builder/src/components/start/AppRow.svelte
@@ -50,7 +50,7 @@
       <MenuItem on:click={() => deleteApp(app)} icon="Delete">Delete</MenuItem>
     {/if}
     {#if app.lockedBy && app.lockedBy?.email === $auth.user?.email}
-      <MenuItem on:click={() => releaseLock(app._id)} icon="LockOpen">
+      <MenuItem on:click={() => releaseLock(app.appId)} icon="LockOpen">
         Release Lock
       </MenuItem>
     {/if}
diff --git a/packages/builder/src/components/start/CreateAppModal.svelte b/packages/builder/src/components/start/CreateAppModal.svelte
index 44859fbb17..8d2ec56655 100644
--- a/packages/builder/src/components/start/CreateAppModal.svelte
+++ b/packages/builder/src/components/start/CreateAppModal.svelte
@@ -96,7 +96,7 @@
 
       // Select Correct Application/DB in prep for creating user
       const applicationPkg = await get(
-        `/api/applications/${appJson._id}/appPackage`
+        `/api/applications/${appJson.instance._id}/appPackage`
       )
       const pkg = await applicationPkg.json()
       if (applicationPkg.ok) {
@@ -112,7 +112,7 @@
       }
       const userResp = await api.post(`/api/users/metadata/self`, user)
       await userResp.json()
-      $goto(`/builder/app/${appJson._id}`)
+      $goto(`/builder/app/${appJson.instance._id}`)
     } catch (error) {
       console.error(error)
       notifications.error(error)
diff --git a/packages/builder/src/pages/builder/app/[application]/_layout.svelte b/packages/builder/src/pages/builder/app/[application]/_layout.svelte
index 98846b3db7..ba4181c6cc 100644
--- a/packages/builder/src/pages/builder/app/[application]/_layout.svelte
+++ b/packages/builder/src/pages/builder/app/[application]/_layout.svelte
@@ -1,10 +1,12 @@
 <script>
   import { store, automationStore } from "builderStore"
   import { roles } from "stores/backend"
-  import { Button, ActionGroup, ActionButton, Tabs, Tab } from "@budibase/bbui"
+  import { Button, Icon, Modal, ModalContent, ActionGroup, ActionButton, Tabs, Tab } from "@budibase/bbui"
   import SettingsLink from "components/settings/Link.svelte"
   import ThemeEditorDropdown from "components/settings/ThemeEditorDropdown.svelte"
   import FeedbackNavLink from "components/feedback/FeedbackNavLink.svelte"
+  import DeployModal from "components/deploy/DeployModal.svelte"
+  import RevertModal from "components/deploy/RevertModal.svelte"
   import { get } from "builderStore/api"
   import { isActive, goto, layout } from "@roxi/routify"
   import Logo from "/assets/bb-logo.svg"
@@ -81,25 +83,13 @@
         <ActionGroup />
       </div>
       <div class="toprightnav">
-        <ThemeEditorDropdown />
-        <FeedbackNavLink />
-        <div class="topnavitemright">
-          <a
-            target="_blank"
-            href="https://github.com/Budibase/budibase/discussions"
-          >
-            <i class="ri-github-fill" />
-          </a>
-        </div>
-        <SettingsLink />
-        <Button
-          secondary
+        <RevertModal />
+        <Icon name="Play" hoverable
           on:click={() => {
             window.open(`/${application}`)
           }}
-        >
-          Preview
-        </Button>
+        />
+        <DeployModal />
       </div>
     </div>
     <div class="beta">
@@ -153,6 +143,7 @@
     flex-direction: row;
     justify-content: flex-end;
     align-items: center;
+    gap: var(--spacing-xl);
   }
 
   .topleftnav {
diff --git a/packages/builder/src/pages/builder/app/[application]/deploy/_layout.svelte b/packages/builder/src/pages/builder/app/deploy_old/_layout.svelte
similarity index 64%
rename from packages/builder/src/pages/builder/app/[application]/deploy/_layout.svelte
rename to packages/builder/src/pages/builder/app/deploy_old/_layout.svelte
index 597bf1518d..ef86cab68c 100644
--- a/packages/builder/src/pages/builder/app/[application]/deploy/_layout.svelte
+++ b/packages/builder/src/pages/builder/app/deploy_old/_layout.svelte
@@ -1,2 +1,2 @@
 <!-- routify:options index=4 -->
-<slot />
+<!-- <slot /> -->
diff --git a/packages/builder/src/pages/builder/app/[application]/deploy/index.svelte b/packages/builder/src/pages/builder/app/deploy_old/index.svelte
similarity index 100%
rename from packages/builder/src/pages/builder/app/[application]/deploy/index.svelte
rename to packages/builder/src/pages/builder/app/deploy_old/index.svelte
diff --git a/packages/builder/src/pages/builder/portal/apps/index.svelte b/packages/builder/src/pages/builder/portal/apps/index.svelte
index 79fee91c96..c7c8d10062 100644
--- a/packages/builder/src/pages/builder/portal/apps/index.svelte
+++ b/packages/builder/src/pages/builder/portal/apps/index.svelte
@@ -62,16 +62,16 @@
 
   const openApp = app => {
     if (appStatus === AppStatus.DEV) {
-      $goto(`../../app/${app._id}`)
+      $goto(`../../app/${app.appId}`)
     } else {
-      window.open(`/${app._id}`, '_blank');
+      window.open(`/${app.appId}`, '_blank');
     }
   }
 
   const exportApp = app => {
     try {
       download(
-        `/api/backups/export?appId=${app._id}&appname=${encodeURIComponent(
+        `/api/backups/export?appId=${app.appId}&appname=${encodeURIComponent(
           app.name
         )}`
       )
@@ -157,7 +157,7 @@
         class:appGrid={layout === "grid"}
         class:appTable={layout === "table"}
       >
-        {#each $apps as app, idx (app._id)}
+        {#each $apps as app, idx (app.appId)}
           <svelte:component
             this={layout === "grid" ? AppCard : AppRow}
             deletable={appStatus === AppStatus.PUBLISHED}
diff --git a/packages/builder/src/stores/portal/apps.js b/packages/builder/src/stores/portal/apps.js
index 9fda7c0054..e0dfe112b5 100644
--- a/packages/builder/src/stores/portal/apps.js
+++ b/packages/builder/src/stores/portal/apps.js
@@ -13,6 +13,7 @@ export function createAppStore() {
       } else {
         store.set([])
       }
+      return json
     } catch (error) {
       store.set([])
     }
diff --git a/packages/builder/src/stores/portal/index.js b/packages/builder/src/stores/portal/index.js
index c3ff18eb3f..0c56286e90 100644
--- a/packages/builder/src/stores/portal/index.js
+++ b/packages/builder/src/stores/portal/index.js
@@ -1,4 +1,4 @@
 export { organisation } from "./organisation"
 export { admin } from "./admin"
 export { apps } from "./apps"
-export { email } from "./email"
+export { email } from "./email"
\ No newline at end of file
diff --git a/packages/server/scripts/replicateApp.js b/packages/server/scripts/replicateApp.js
index 2c66bb26d9..a27f77b9a0 100644
--- a/packages/server/scripts/replicateApp.js
+++ b/packages/server/scripts/replicateApp.js
@@ -6,6 +6,7 @@
  */
 
 const CouchDB = require("../src/db")
+const { DocumentTypes } = require("../src/db/utils")
 
 const appName = process.argv[2].toLowerCase()
 const remoteUrl = process.argv[3]
@@ -18,7 +19,7 @@ const run = async () => {
   let apps = []
   for (let dbName of appDbNames) {
     const db = new CouchDB(dbName)
-    apps.push(db.get(dbName))
+    apps.push(db.get(DocumentTypes.APP_METADATA))
   }
   apps = await Promise.all(apps)
   const app = apps.find(
@@ -32,7 +33,7 @@ const run = async () => {
     return
   }
 
-  const instanceDb = new CouchDB(app._id)
+  const instanceDb = new CouchDB(app.appId)
   const remoteDb = new CouchDB(`${remoteUrl}/${appName}`)
 
   instanceDb.replicate
diff --git a/packages/server/src/api/controllers/application.js b/packages/server/src/api/controllers/application.js
index 306535c087..9eab40ff24 100644
--- a/packages/server/src/api/controllers/application.js
+++ b/packages/server/src/api/controllers/application.js
@@ -88,7 +88,6 @@ async function getAppUrlIfNotInUse(ctx) {
 }
 
 async function createInstance(template) {
-  // TODO: Do we need the normal app ID?
   const baseAppId = generateAppID()
   const appId = generateDevAppID(baseAppId)
 
@@ -126,16 +125,16 @@ exports.fetch = async function (ctx) {
   const isDev = ctx.query.status === AppStatus.DEV
   apps = apps.filter(app => {
     if (isDev) {
-      return app._id.startsWith(DocumentTypes.APP_DEV)
+      return app.appId.startsWith(DocumentTypes.APP_DEV)
     }
-    return !app._id.startsWith(DocumentTypes.APP_DEV)
+    return !app.appId.startsWith(DocumentTypes.APP_DEV)
   })
 
   // get the locks for all the dev apps
   if (isDev) {
     const locks = await getAllLocks()
     for (let app of apps) {
-      const lock = locks.find(lock => lock.appId === app._id)
+      const lock = locks.find(lock => lock.appId === app.appId)
       if (lock) {
         app.lockedBy = lock.user
       } else {
@@ -166,7 +165,7 @@ exports.fetchAppDefinition = async function (ctx) {
 
 exports.fetchAppPackage = async function (ctx) {
   const db = new CouchDB(ctx.params.appId)
-  const application = await db.get(ctx.params.appId)
+  const application = await db.get(DocumentTypes.APP_METADATA)
   const [layouts, screens] = await Promise.all([getLayouts(db), getScreens(db)])
 
   ctx.body = {
@@ -191,7 +190,8 @@ exports.create = async function (ctx) {
   const url = await getAppUrlIfNotInUse(ctx)
   const appId = instance._id
   const newApplication = {
-    _id: appId,
+    _id: DocumentTypes.APP_METADATA,
+    appId: instance._id,
     type: "app",
     version: packageJson.version,
     componentLibraries: ["@budibase/standard-components"],
@@ -254,7 +254,7 @@ exports.delete = async function (ctx) {
 }
 
 const createEmptyAppPackage = async (ctx, app) => {
-  const db = new CouchDB(app._id)
+  const db = new CouchDB(app.instance._id)
 
   let screensAndLayouts = []
   for (let layout of BASE_LAYOUTS) {
diff --git a/packages/server/src/api/controllers/component.js b/packages/server/src/api/controllers/component.js
index 60e1e99e35..c678d8e587 100644
--- a/packages/server/src/api/controllers/component.js
+++ b/packages/server/src/api/controllers/component.js
@@ -1,10 +1,11 @@
 const CouchDB = require("../../db")
+const { DocumentTypes } = require("../../db/utils")
 const { getComponentLibraryManifest } = require("../../utilities/fileSystem")
 
 exports.fetchAppComponentDefinitions = async function (ctx) {
   const appId = ctx.params.appId || ctx.appId
   const db = new CouchDB(appId)
-  const app = await db.get(appId)
+  const app = await db.get(DocumentTypes.APP_METADATA)
 
   let componentManifests = await Promise.all(
     app.componentLibraries.map(async library => {
diff --git a/packages/server/src/api/controllers/deploy/index.js b/packages/server/src/api/controllers/deploy/index.js
index 381ab95444..eda85a32f5 100644
--- a/packages/server/src/api/controllers/deploy/index.js
+++ b/packages/server/src/api/controllers/deploy/index.js
@@ -1,6 +1,8 @@
 const PouchDB = require("../../../db")
 const Deployment = require("./Deployment")
-const { Replication } = require("@budibase/auth").db
+const { Replication, StaticDatabases } = require("@budibase/auth").db
+const { DocumentTypes } = require("../../../db/utils")
+
 // the max time we can wait for an invalidation to complete before considering it failed
 const MAX_PENDING_TIME_MS = 30 * 60000
 const DeploymentStatus = {
@@ -26,16 +28,16 @@ async function checkAllDeployments(deployments) {
   return { updated, deployments }
 }
 
-async function storeLocalDeploymentHistory(deployment) {
+async function storeDeploymentHistory(deployment) {
   const appId = deployment.getAppId()
   const deploymentJSON = deployment.getJSON()
-  const db = new PouchDB(appId)
+  const db = new PouchDB(StaticDatabases.DEPLOYMENTS.name)
 
   let deploymentDoc
   try {
-    deploymentDoc = await db.get("_local/deployments")
+    deploymentDoc = await db.get(appId)
   } catch (err) {
-    deploymentDoc = { _id: "_local/deployments", history: {} }
+    deploymentDoc = { _id: appId, history: {} }
   }
 
   const deploymentId = deploymentJSON._id
@@ -65,12 +67,9 @@ async function deployApp(deployment) {
     })
 
     await replication.replicate()
-
-    // Strip the _dev prefix and update the appID document in the new DB
     const db = new PouchDB(productionAppId)
-    const appDoc = await db.get(deployment.appId)
-    appDoc._id = productionAppId
-    delete appDoc._rev
+    const appDoc = await db.get(DocumentTypes.APP_METADATA)
+    appDoc.appId = productionAppId
     appDoc.instance._id = productionAppId
     await db.put(appDoc)
 
@@ -79,13 +78,17 @@ async function deployApp(deployment) {
       source: productionAppId,
       target: deployment.appId,
     })
-    liveReplication.subscribe()
+    liveReplication.subscribe({
+      filter: function (doc) {
+        return doc._id !== DocumentTypes.APP_METADATA
+      },
+    })
 
     deployment.setStatus(DeploymentStatus.SUCCESS)
-    await storeLocalDeploymentHistory(deployment)
+    await storeDeploymentHistory(deployment)
   } catch (err) {
     deployment.setStatus(DeploymentStatus.FAILURE, err.message)
-    await storeLocalDeploymentHistory(deployment)
+    await storeDeploymentHistory(deployment)
     throw {
       ...err,
       message: `Deployment Failed: ${err.message}`,
@@ -95,8 +98,8 @@ async function deployApp(deployment) {
 
 exports.fetchDeployments = async function (ctx) {
   try {
-    const db = new PouchDB(ctx.appId)
-    const deploymentDoc = await db.get("_local/deployments")
+    const db = new PouchDB(StaticDatabases.DEPLOYMENTS.name)
+    const deploymentDoc = await db.get(ctx.appId)
     const { updated, deployments } = await checkAllDeployments(
       deploymentDoc,
       ctx.user
@@ -112,8 +115,8 @@ exports.fetchDeployments = async function (ctx) {
 
 exports.deploymentProgress = async function (ctx) {
   try {
-    const db = new PouchDB(ctx.appId)
-    const deploymentDoc = await db.get("_local/deployments")
+    const db = new PouchDB(StaticDatabases.DEPLOYMENTS.name)
+    const deploymentDoc = await db.get(ctx.appId)
     ctx.body = deploymentDoc[ctx.params.deploymentId]
   } catch (err) {
     ctx.throw(
@@ -126,7 +129,7 @@ exports.deploymentProgress = async function (ctx) {
 exports.deployApp = async function (ctx) {
   let deployment = new Deployment(ctx.appId)
   deployment.setStatus(DeploymentStatus.PENDING)
-  deployment = await storeLocalDeploymentHistory(deployment)
+  deployment = await storeDeploymentHistory(deployment)
 
   await deployApp(deployment)
 
diff --git a/packages/server/src/api/controllers/dev.js b/packages/server/src/api/controllers/dev.js
index 23132ea724..86b9a11c23 100644
--- a/packages/server/src/api/controllers/dev.js
+++ b/packages/server/src/api/controllers/dev.js
@@ -1,8 +1,11 @@
 const fetch = require("node-fetch")
+const CouchDB = require("../../db")
 const env = require("../../environment")
 const { checkSlashesInUrl } = require("../../utilities")
 const { request } = require("../../utilities/workerRequests")
 const { clearLock } = require("../../utilities/redis")
+const { Replication } = require("@budibase/auth").db
+const { DocumentTypes } = require("../../db/utils")
 
 async function redirect(ctx, method) {
   const { devPath } = ctx.params
@@ -45,3 +48,37 @@ exports.clearLock = async ctx => {
     message: "Lock released successfully.",
   }
 }
+
+exports.revert = async ctx => {
+  const { appId } = ctx.params
+  const productionAppId = appId.replace("_dev", "")
+
+  // App must have been deployed first
+  try {
+    const db = new CouchDB(productionAppId, { skip_setup: true })
+    const info = await db.info()
+    if (info.error) throw info.error
+  } catch (err) {
+    return ctx.throw(400, "App has not yet been deployed")
+  }
+
+  try {
+    const replication = new Replication({
+      source: productionAppId,
+      target: appId,
+    })
+
+    await replication.rollback()
+    // update appID in reverted app to be dev version again
+    const db = new CouchDB(appId)
+    const appDoc = await db.get(DocumentTypes.APP_METADATA)
+    appDoc.appId = appId
+    appDoc.instance._id = appId
+    await db.put(appDoc)
+    ctx.body = {
+      message: "Reverted changes successfully.",
+    }
+  } catch (err) {
+    ctx.throw(400, `Unable to revert. ${err}`)
+  }
+}
diff --git a/packages/server/src/api/controllers/static/index.js b/packages/server/src/api/controllers/static/index.js
index ba922cb9ad..64cfb122f7 100644
--- a/packages/server/src/api/controllers/static/index.js
+++ b/packages/server/src/api/controllers/static/index.js
@@ -18,6 +18,7 @@ const env = require("../../../environment")
 const { objectStoreUrl, clientLibraryPath } = require("../../../utilities")
 const { upload } = require("../../../utilities/fileSystem")
 const { attachmentsRelativeURL } = require("../../../utilities")
+const { DocumentTypes } = require("../../../db/utils")
 
 async function prepareUpload({ s3Key, bucket, metadata, file }) {
   const response = await upload({
@@ -85,7 +86,7 @@ exports.serveApp = async function (ctx) {
   }
   const App = require("./templates/BudibaseApp.svelte").default
   const db = new CouchDB(appId, { skip_setup: true })
-  const appInfo = await db.get(appId)
+  const appInfo = await db.get(DocumentTypes.APP_METADATA)
 
   const { head, html, css } = App.render({
     title: appInfo.name,
@@ -125,7 +126,7 @@ exports.serveComponentLibrary = async function (ctx) {
     return send(ctx, "/index.js", { root: componentLibraryPath })
   }
   const db = new CouchDB(appId)
-  const appInfo = await db.get(appId)
+  const appInfo = await db.get(DocumentTypes.APP_METADATA)
 
   let componentLib = "componentlibrary"
   if (appInfo && appInfo.version) {
diff --git a/packages/server/src/api/routes/dev.js b/packages/server/src/api/routes/dev.js
index 50a97cb345..5467c8286d 100644
--- a/packages/server/src/api/routes/dev.js
+++ b/packages/server/src/api/routes/dev.js
@@ -13,10 +13,8 @@ if (env.isDev() || env.isTest()) {
     .delete("/api/admin/:devPath(.*)", controller.redirectDelete)
 }
 
-router.delete(
-  "/api/dev/:appId/lock",
-  authorized(BUILDER),
-  controller.clearLock
-)
+router
+  .delete("/api/dev/:appId/lock", authorized(BUILDER), controller.clearLock)
+  .post("/api/dev/:appId/revert", authorized(BUILDER), controller.revert)
 
 module.exports = router
diff --git a/packages/server/src/api/routes/tests/utilities/TestFunctions.js b/packages/server/src/api/routes/tests/utilities/TestFunctions.js
index 0e11dd2056..20256fa321 100644
--- a/packages/server/src/api/routes/tests/utilities/TestFunctions.js
+++ b/packages/server/src/api/routes/tests/utilities/TestFunctions.js
@@ -21,7 +21,7 @@ exports.clearAllApps = async () => {
     return
   }
   for (let app of apps) {
-    const appId = app._id
+    const { appId } = app
     await appController.delete(new Request(null, { appId }))
   }
 }
diff --git a/packages/server/src/db/utils.js b/packages/server/src/db/utils.js
index 2c434691e8..ec9fb249de 100644
--- a/packages/server/src/db/utils.js
+++ b/packages/server/src/db/utils.js
@@ -23,6 +23,7 @@ const AppStatus = {
 const DocumentTypes = {
   APP: CoreDocTypes.APP,
   APP_DEV: CoreDocTypes.APP_DEV,
+  APP_METADATA: CoreDocTypes.APP_METADATA,
   TABLE: "ta",
   ROW: "ro",
   USER: "us",
diff --git a/packages/server/src/tests/utilities/TestConfiguration.js b/packages/server/src/tests/utilities/TestConfiguration.js
index c031cf082d..013a15e03d 100644
--- a/packages/server/src/tests/utilities/TestConfiguration.js
+++ b/packages/server/src/tests/utilities/TestConfiguration.js
@@ -89,7 +89,7 @@ class TestConfiguration {
     if (this.server) {
       this.server.close()
     }
-    cleanup(this.allApps.map(app => app._id))
+    cleanup(this.allApps.map(app => app.appId))
   }
 
   defaultHeaders() {
@@ -141,7 +141,7 @@ class TestConfiguration {
 
   async createApp(appName) {
     this.app = await this._req({ name: appName }, null, controllers.app.create)
-    this.appId = this.app._id
+    this.appId = this.app.appId
     this.allApps.push(this.app)
     return this.app
   }
diff --git a/packages/server/src/utilities/index.js b/packages/server/src/utilities/index.js
index ac3b668ad5..cb7a19bb0b 100644
--- a/packages/server/src/utilities/index.js
+++ b/packages/server/src/utilities/index.js
@@ -1,5 +1,5 @@
 const env = require("../environment")
-const { APP_PREFIX } = require("../db/utils")
+const { APP_PREFIX, DocumentTypes } = require("../db/utils")
 const CouchDB = require("../db")
 const { OBJ_STORE_DIRECTORY, ObjectStoreBuckets } = require("../constants")
 
@@ -19,7 +19,9 @@ exports.isDev = env.isDev
 exports.getAllApps = async () => {
   let allDbs = await CouchDB.allDbs()
   const appDbNames = allDbs.filter(dbName => dbName.startsWith(APP_PREFIX))
-  const appPromises = appDbNames.map(db => new CouchDB(db).get(db))
+  const appPromises = appDbNames.map(db =>
+    new CouchDB(db).get(DocumentTypes.APP_METADATA)
+  )
   if (appPromises.length === 0) {
     return []
   } else {
diff --git a/packages/worker/src/api/controllers/app.js b/packages/worker/src/api/controllers/app.js
index bed3b55942..8b556fbb1e 100644
--- a/packages/worker/src/api/controllers/app.js
+++ b/packages/worker/src/api/controllers/app.js
@@ -1,4 +1,5 @@
 const fetch = require("node-fetch")
+const { DocumentTypes } = require("@budibase/auth").db
 const CouchDB = require("../../db")
 const env = require("../../environment")
 
@@ -14,7 +15,9 @@ exports.getApps = async ctx => {
     allDbs = await CouchDB.allDbs()
   }
   const appDbNames = allDbs.filter(dbName => dbName.startsWith(APP_PREFIX))
-  const appPromises = appDbNames.map(db => new CouchDB(db).get(db))
+  const appPromises = appDbNames.map(db =>
+    new CouchDB(db).get(DocumentTypes.APP_METADATA)
+  )
 
   const apps = await Promise.allSettled(appPromises)
   const body = {}
@@ -26,7 +29,7 @@ exports.getApps = async ctx => {
     let url = app.url || encodeURI(`${app.name}`)
     url = `/${url.replace(URL_REGEX_SLASH, "")}`
     body[url] = {
-      appId: app._id,
+      appId: app.instance._id,
       name: app.name,
       url,
     }