Fix the TODO I left myself last night.

packages/backend-core/src/db/Replication.ts

@@ -5,56 +5,33 @@ import { DocumentType } from "../constants"
 class Replication {
   source: PouchDB.Database
   target: PouchDB.Database
-  replication?: Promise<any>
 
-  /**
-   *
-   * @param source - the DB you want to replicate or rollback to
-   * @param target - the DB you want to replicate to, or rollback from
-   */
   constructor({ source, target }: { source: string; target: string }) {
     this.source = getPouchDB(source)
     this.target = getPouchDB(target)
   }
 
-  close() {
+  async close() {
-    return Promise.all([closePouchDB(this.source), closePouchDB(this.target)])
+    await Promise.all([closePouchDB(this.source), closePouchDB(this.target)])
   }
 
-  promisify(operation: any, opts = {}) {
+  replicate(opts: PouchDB.Replication.ReplicateOptions = {}) {
-    return new Promise(resolve => {
+    return new Promise<PouchDB.Replication.ReplicationResult<{}>>(resolve => {
-      operation(this.target, opts)
+      this.source.replicate
-        .on("denied", function (err: any) {
+        .to(this.target, opts)
+        .on("denied", function (err) {
           // a document failed to replicate (e.g. due to permissions)
           throw new Error(`Denied: Document failed to replicate ${err}`)
         })
-        .on("complete", function (info: any) {
+        .on("complete", function (info) {
           return resolve(info)
         })
-        .on("error", function (err: any) {
+        .on("error", function (err) {
           throw new Error(`Replication Error: ${err}`)
         })
     })
   }
 
-  /**
-   * Two way replication operation, intended to be promise based.
-   * @param opts - PouchDB replication options
-   */
-  sync(opts: PouchDB.Replication.SyncOptions = {}) {
-    this.replication = this.promisify(this.source.sync, opts)
-    return this.replication
-  }
-
-  /**
-   * One way replication operation, intended to be promise based.
-   * @param opts - PouchDB replication options
-   */
-  replicate(opts: PouchDB.Replication.ReplicateOptions = {}) {
-    this.replication = this.promisify(this.source.replicate.to, opts)
-    return this.replication
-  }
-
   appReplicateOpts(
     opts: PouchDB.Replication.ReplicateOptions = {}
   ): PouchDB.Replication.ReplicateOptions {

packages/server/src/api/controllers/role.ts

@@ -107,17 +107,20 @@ export async function save(ctx: UserCtx<SaveRoleRequest, SaveRoleResponse>) {
   role._rev = result.rev
   ctx.body = role
 
-  // TODO: need to check that the prod DB actually exists, I think it won't
+  const devDb = context.getDevAppDB()
-  // if the app has never been published.
+  const prodDb = context.getProdAppDB()
-  const replication = new dbCore.Replication({
+
-    source: context.getDevAppDB().name,
+  if (await prodDb.exists()) {
-    target: context.getProdAppDB().name,
+    const replication = new dbCore.Replication({
-  })
+      source: devDb.name,
-  await replication.replicate({
+      target: prodDb.name,
-    filter: (doc: any, params: any) => {
+    })
-      return doc._id === _id
+    await replication.replicate({
-    },
+      filter: (doc: any, params: any) => {
-  })
+        return doc._id === _id
+      },
+    })
+  }
 }
 
 export async function destroy(ctx: UserCtx<void, DestroyRoleResponse>) {