upload: get a list of all remote records for the site

upload/src/main.rs

···
 use clap::{ArgAction, Parser};
 use jacquard::{
+  Data,
+  api::com_atproto::{self, repo::list_records::ListRecords},
   client::{Agent, credential_session::CredentialSession},
+  cowstr::ToCowStr,
   identity::JacquardResolver,
   session::MemorySessionStore,
+  types::{ident::AtIdentifier, nsid::Nsid, string::AtprotoStr, uri::Uri},
+  xrpc::XrpcExt,
 };
 use std::{path::PathBuf, sync::Arc};
 
···
   let store = MemorySessionStore::default();
   let session = CredentialSession::new(Arc::new(store), Arc::new(client));
 
-  match session
+  let auth = match session
     .login(config.user.into(), config.password.into(), None, None, None)
     .await
   {
     Ok(val) => {
       println!("Authenticated {} ({})", val.handle, val.did);
+      val
     }
     Err(err) => {
       println!("Got error while authenticating:\n{}", err);
+      return Err(());
     }
   };
 
   let agent = Agent::from(session);
 
-  // upload local site blobs
-
   // find live site records
+  let mut cursor = None;
+  let mut remote_records = Vec::new();
+  loop {
+    let req = com_atproto::repo::list_records::ListRecords::new()
+      .collection(
+        Nsid::new("dev.atcities.route").expect("failed to generate dev.atcities.route nsid"),
+      )
+      .repo(AtIdentifier::Did(auth.did.clone()))
+      .limit(100)
+      .maybe_cursor(cursor)
+      .build();
+
+    let res = agent
+      .xrpc(agent.endpoint().await)
+      .send::<ListRecords>(&req)
+      .await
+      .or(Err(()))?
+      .into_output()
+      .or(Err(()))?;
+
+    for record in res.records {
+      match record {
+        Data::Object(obj) => {
+          let obj = obj.0.clone();
+          let uri = obj.get_key_value("uri").and_then(|x| match x.1 {
+            Data::String(str) => Some(str),
+            _ => None,
+          });
+
+          if let Some(uri) = uri
+            && let AtprotoStr::Uri(uri) = uri
+            && let Uri::At(uri) = uri
+            && let Some(rkey) = uri.rkey()
+          {
+            let rkey = rkey.0.to_cowstr().to_string();
+            remote_records.push(rkey);
+          } else {
+            panic!("Warning: pds returned invalid data.")
+          }
+        }
+        _ => {
+          panic!("Warning: pds returned invalid data.")
+        }
+      }
+    }
+
+    cursor = res.cursor;
+    if cursor.is_none() {
+      break;
+    }
+  }
+
+  print!("{remote_records:?}");
+
+  // upload local site blobs
 
   // batch delete/upload records