save borked

bluesky-social · Nov 10, 2023 · 5976564 · 5976564
1 parent eb92915
commit 5976564
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 0 deletions.
diff --git a/packages/pds/src/migrate-script/migrate-all.ts b/packages/pds/src/migrate-script/migrate-all.ts
@@ -9,6 +9,7 @@ import PQueue from 'p-queue'
 import {
   AdminHeaders,
   PdsInfo,
+  checkBorked,
   getPds,
   getUserAccount,
   repairBlob,
@@ -81,6 +82,9 @@ export const runScript = async () => {
           .where('did', '=', status.did)
           .execute()
         failed++
+
+        // check if the did is caught in a bad state where migration failed but plc got updated
+        await checkBorked(ctx, status.did)
       }
       if (completed % 5 === 0) {
         console.log(`completed: ${completed}, failed: ${failed}`)

diff --git a/packages/pds/src/migrate-script/util.ts b/packages/pds/src/migrate-script/util.ts
@@ -1,3 +1,4 @@
+import fs from 'fs/promises'
 import dotenv from 'dotenv'
 import axios from 'axios'
 import * as ui8 from 'uint8arrays'
@@ -298,3 +299,15 @@ const logFailedTakedown = async (db: MigrateDb, takedown: FailedTakedown) => {
     .onConflict((oc) => oc.doNothing())
     .execute()
 }
+
+export const checkBorked = async (ctx: AppContext, did: string) => {
+  try {
+    const data = await ctx.plcClient.getDocumentData(did)
+    const endpoint = data.services['atproto_pds'].endpoint
+    if (endpoint !== 'https://bsky.social') {
+      await fs.appendFile('borked_dids.tx', `${did}\n`)
+    }
+  } catch {
+    // noop
+  }
+}