commit 5aaef5fa807cc5ae2e56744b23cc5ec37a7626c5 · knotbin.com/airport

+29 -12

routes/api/migrate/data/blobs.ts

···

       12
       12
        
             const newAgent = await getSessionAgent(ctx.req, res, true);

     

       13
       13
        
             console.log("Blob migration: Got new agent:", !!newAgent);

     

       14
       14
        
       

     

       15
       15
       -
             if (!oldAgent || !newAgent || !oldAgent.did) {

     

       16
       16
       -
               return new Response(JSON.stringify({

     

       17
       17
       -
                 success: false,

     

       18
       18
       -
                 message: "Not authenticated"

     

       19
       19
       -
               }), {

     

       20
       20
       -
                 status: 401,

     

       21
       21
       -
                 headers: { "Content-Type": "application/json" }

     

       22
       22
       -
               });

     

       15
       15
       +
             if (!oldAgent) {

     

       16
       16
       +
               return new Response(

     

       17
       17
       +
                 JSON.stringify({

     

       18
       18
       +
                   success: false,

     

       19
       19
       +
                   message: "Unauthorized",

     

       20
       20
       +
                 }),

     

       21
       21
       +
                 {

     

       22
       22
       +
                   status: 401,

     

       23
       23
       +
                   headers: { "Content-Type": "application/json" },

     

       24
       24
       +
                 },

     

       25
       25
       +
               );

     

       26
       26
       +
             }

     

       27
       27
       +
             if (!newAgent) {

     

       28
       28
       +
               return new Response(

     

       29
       29
       +
                 JSON.stringify({

     

       30
       30
       +
                   success: false,

     

       31
       31
       +
                   message: "Migration session not found or invalid",

     

       32
       32
       +
                 }),

     

       33
       33
       +
                 {

     

       34
       34
       +
                   status: 400,

     

       35
       35
       +
                   headers: { "Content-Type": "application/json" },

     

       36
       36
       +
                 },

     

       37
       37
       +
               );

     

       23
       38
        
             }

     

       24
       39
        
       

     

       25
       40
        
             // Migrate blobs

     
···

       38
       53
        
             // First count total blobs

     

       39
       54
        
             console.log(`[${new Date().toISOString()}] Starting blob count...`);

     

       40
       55
        
             migrationLogs.push(`[${new Date().toISOString()}] Starting blob count...`);

     

       56
       56
       +
       

     

       57
       57
       +
             const session = await oldAgent.com.atproto.server.getSession();

     

       58
       58
       +
             const accountDid = session.data.did;

     

       41
       59
        
             

     

       42
       60
        
             do {

     

       43
       61
        
               const pageStartTime = Date.now();

     

       44
       62
        
               console.log(`[${new Date().toISOString()}] Counting blobs on page ${pageCount + 1}...`);

     

       45
       63
        
               migrationLogs.push(`[${new Date().toISOString()}] Counting blobs on page ${pageCount + 1}...`);

     

       46
       46
       -
       

     

       47
       64
        
               const listedBlobs = await oldAgent.com.atproto.sync.listBlobs({

     

       48
       48
       -
                 did: oldAgent.did,

     

       65
       65
       +
                 did: accountDid,

     

       49
       66
        
                 cursor: blobCursor,

     

       50
       67
        
               });

     

       51
       68
        
       

     
···

       74
       91
        
               migrationLogs.push(`[${new Date().toISOString()}] Fetching blob list page ${pageCount + 1}...`);

     

       75
       92
        
       

     

       76
       93
        
               const listedBlobs = await oldAgent.com.atproto.sync.listBlobs({

     

       77
       77
       -
                 did: oldAgent.did,

     

       94
       94
       +
                 did: accountDid,

     

       78
       95
        
                 cursor: blobCursor,

     

       79
       96
        
               });

     

       80
       97
        
       

     
···

       91
       108
        
                   migrationLogs.push(`[${new Date().toISOString()}] Starting migration for blob ${cid} (${processedBlobs + 1} of ${totalBlobs})...`);

     

       92
       109
        
       

     

       93
       110
        
                   const blobRes = await oldAgent.com.atproto.sync.getBlob({

     

       94
       94
       -
                     did: oldAgent.did,

     

       111
       111
       +
                     did: accountDid,

     

       95
       112
        
                     cid,

     

       96
       113
        
                   });

     

       97
       114

+4 -2

routes/api/migrate/data/repo.ts

···

       13
       13
        
             const newAgent = await getSessionAgent(ctx.req, res, true);

     

       14
       14
        
             console.log("Repo migration: Got new agent:", !!newAgent);

     

       15
       15
        
       

     

       16
       16
       -
             if (!oldAgent || !newAgent || !oldAgent.did) {

     

       16
       16
       +
             if (!oldAgent || !newAgent) {

     

       17
       17
        
               return new Response(JSON.stringify({

     

       18
       18
        
                 success: false,

     

       19
       19
        
                 message: "Not authenticated"

     
···

       23
       23
        
               });

     

       24
       24
        
             }

     

       25
       25
        
       

     

       26
       26
       +
             const session = await oldAgent.com.atproto.server.getSession();

     

       27
       27
       +
             const accountDid = session.data.did;

     

       26
       28
        
             // Migrate repo data

     

       27
       29
        
             const migrationLogs: string[] = [];

     

       28
       30
        
             const startTime = Date.now();

     
···

       35
       37
        
             

     

       36
       38
        
             const fetchStartTime = Date.now();

     

       37
       39
        
             const repoData = await oldAgent.com.atproto.sync.getRepo({

     

       38
       38
       -
               did: oldAgent.did,

     

       40
       40
       +
               did: accountDid,

     

       39
       41
        
             });

     

       40
       42
        
             const fetchTime = Date.now() - fetchStartTime;

     

       41
       43