···

       
176
       
176
       
 
       
        }

     

       
177
       
177
       
 
       
    };

     

       
178
       
178
       
 
       


     

       
179
       
179
       
-
       
    let password = password.clone();

     

       
180
       
179
       
 
       
    let describe_res = match new_agent.api.com.atproto.server.describe_server().await {

     

       
181
       
180
       
 
       
        Ok(response) => response,

     

       
182
       
181
       
 
       
        Err(err) => {

     
···

       
269
       
268
       
 
       
            return;

     

       
270
       
269
       
 
       
        }

     

       
271
       
270
       
 
       
    };

     

       
272
       
272
       
-
       
    println!("CAR file downloaded");

     

       
271
       
271
       
+
       
    println!("Repository downloaded from old PDS. Importing to new PDS.");

     

       
273
       
272
       
 
       


     

       
274
       
273
       
 
       
    match new_agent.api.com.atproto.repo.import_repo(car).await {

     

       
275
       
274
       
 
       
        Ok(_) => (),

     
···

       
326
       
325
       
 
       
        };

     

       
327
       
326
       
 
       


     

       
328
       
327
       
 
       
        match new_agent.api.com.atproto.repo.upload_blob(blob).await {

     

       
329
       
329
       
-
       
            Ok(_) => (),

     

       
328
       
328
       
+
       
            Ok(_) => {

     

       
329
       
329
       
+
       
                println!("Blob with CID {:?} migrated", cid)

     

       
330
       
330
       
+
       
            },

     

       
330
       
331
       
 
       
            Err(err) => {

     

       
331
       
332
       
 
       
                println!("com.atproto.repo.uploadBlob at new PDS failed due to error: {err}");

     

       
332
       
333
       
 
       
                return;

     
···

       
382
       
383
       
 
       
            };

     

       
383
       
384
       
 
       


     

       
384
       
385
       
 
       
            match new_agent.api.com.atproto.repo.upload_blob(blob).await {

     

       
385
       
385
       
-
       
                Ok(_) => (),

     

       
386
       
386
       
+
       
                Ok(_) => {

     

       
387
       
387
       
+
       
                    println!("Blob with CID {:?} migrated", cid)

     

       
388
       
388
       
+
       
                },

     

       
386
       
389
       
 
       
                Err(err) => {

     

       
387
       
390
       
 
       
                    println!("com.atproto.repo.uploadBlob at new PDS failed due to error: {err}");

     

       
388
       
391
       
 
       
                    return;