get issue and repo from label add event

src/main.rs

···
         value::Data,
     },
 };
+use std::time::Duration;
 
 type Result<T> = std::result::Result<T, Box<dyn std::error::Error>>;
 
···
     Ok(())
 }
 
+async fn get_record(client: &reqwest::Client, at_uri: &str) -> Result<serde_json::Map<String, serde_json::Value>> {
+    let mut url: Url = "https://slingshot.microcosm.blue".parse()?;
+    url.set_path("/xrpc/com.bad-example.repo.getUriRecord");
+    url.query_pairs_mut().append_pair("at_uri", at_uri);
+    let record_map = client
+        .get(url)
+        .send()
+        .await?
+        .error_for_status()?
+        .json::<serde_json::Value>()
+        .await?
+        .as_object()
+        .ok_or("get_record response was not a json object")?
+        .get("value")
+        .ok_or("get_record response obj did not have 'value' key")?
+        .as_object()
+        .ok_or("get_record response.value was not an object")?
+        .clone();
+    Ok(record_map)
+}
+
 #[tokio::main]
 async fn main() -> Result<()> {
     env_logger::init();
···
     let mut receiver = JetstreamConnector::new(jetstream_config)?
         .connect_cursor(args.jetstream_cursor.map(Cursor::from_raw_u64))
         .await?;
+
+    let req_client = reqwest::Client::builder()
+        .user_agent("hacktober_bot")
+        .timeout(Duration::from_secs(9))
+        .build()?;
 
     println!("receiving jetstream messages...");
     loop {
···
             continue;
         };
 
-        eprintln!("got {subject} {o:?}");
+        let issue_record = match get_record(&req_client, subject).await {
+            Ok(m) => m,
+            Err(e) => {
+                eprintln!("failed to get issue record: {e} for {subject}");
+                continue;
+            }
+        };
+        let Some(serde_json::Value::String(title)) = issue_record.get("title") else {
+            eprintln!("failed to get title from issue for {subject}");
+            continue;
+        };
+        let Some(serde_json::Value::String(repo)) = issue_record.get("repo") else {
+            eprintln!("failed to get repo from issue for {subject}");
+            continue;
+        };
+
+        let repo_record = match get_record(&req_client, repo).await {
+            Ok(m) => m,
+            Err(e) => {
+                eprintln!("failed to get repo record: {e} for {subject}");
+                continue;
+            }
+        };
+        let Some(serde_json::Value::String(name)) = repo_record.get("name") else {
+            eprintln!("failed to get name for repo for {subject}");
+            continue;
+        };
+
+        eprintln!("got {subject} {title:?} for {name}");
     }
 
     // let u2: Url = "https://bad-example.com".parse()?;