check for existing migration

1 files changed, 7 insertions, 1 deletions

diff --git a/lib/migrate.js b/lib/migrate.js
index 49207902..7ff13649 100644
--- a/lib/migrate.js
+++ b/lib/migrate.js
@@ -8,7 +8,13 @@ async function migrate(id) {
   let user = await ga(`user:${id}`);
 
   if (typeof user === "string") {
+    if (await g(`user:${user}`)) {
+      warn("user already migrated", id);
+      s(`user:${id}`, user);
+    }
+
     id = user;
+
     user = await ga(`user:${id}`);
   }
 
@@ -51,7 +57,7 @@ async function migrate(id) {
         multi = await multi
           .lPush(`${id}:invoices`, iid)
           .set(`invoice:${iid}`, JSON.stringify(inv));
-      })
+      }),
     );
 
     try {