diff options
| -rw-r--r-- | lib/migrate.js | 8 |
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 { |
