log

Cargo.lock

···
  "env_logger",
  "jacquard",
  "jetstream",
+ "log",
  "reqwest",
  "serde",
  "serde_json",

Cargo.toml

···
 env_logger = "0.11.8"
 jacquard = "0.2.1"
 jetstream = { path = "../links/jetstream" }
+log = "0.4.28"
 reqwest = { version = "0.12.23", features = ["json"] }
 serde = { version = "1.0.228", features = ["derive"] }
 serde_json = "1.0.145"

src/main.rs

···
     let json = serde_json::to_value(post)?;
     let data = Data::from_json(&json)?;
 
-    println!("\nposting...");
+    log::info!("\nposting...");
     client
         .send(
             CreateRecord::new()
···
             .await?
             .into_output()?,
     );
-    println!("logged in as {} ({})", session.handle, session.did);
+    log::debug!("logged in as {} ({})", session.handle, session.did);
     client.set_session(session).await?;
 
     let slingshot_client = reqwest::Client::builder()
···
         .connect_cursor(args.jetstream_cursor.map(Cursor::from_raw_u64))
         .await?;
 
-    println!("receiving jetstream messages...");
+    log::info!("receiving jetstream messages...");
     loop {
         let Some(event) = receiver.recv().await else {
-            eprintln!("consumer: could not receive event, bailing");
+            log::error!("consumer: could not receive event, bailing");
             break;
         };
 
···
             if added.key
                 == "at://did:plc:wshs7t2adsemcrrd4snkeqli/sh.tangled.label.definition/good-first-issue"
             {
-                println!("found a good first issue label!! {:?}", cursor);
+                log::info!("found a good first issue label!! {:?}", cursor);
                 added_good_first_issue = true;
                 break; // inner
             }
-            eprintln!("found a label but it wasn't good-first-issue, ignoring...");
+            log::debug!("found a label but it wasn't good-first-issue, ignoring...");
         }
         if !added_good_first_issue {
             continue;
···
         let IssueRecord { title, repo } = match get_record(&slingshot_client, &subject).await {
             Ok(m) => m,
             Err(e) => {
-                eprintln!("failed to get issue record: {e} for {subject}");
+                log::warn!("failed to get issue record: {e} for {subject}");
                 continue;
             }
         };
 
         let Ok(repo_uri) = AtUri::new(&repo) else {
-            eprintln!("failed to parse repo to aturi for {subject}");
+            log::warn!("failed to parse repo to aturi for {subject}");
             continue;
         };
 
         let RepoRecord { name: repo_name } = match get_record(&slingshot_client, &repo).await {
             Ok(m) => m,
             Err(e) => {
-                eprintln!("failed to get repo record: {e} for {subject}");
+                log::warn!("failed to get repo record: {e} for {subject}");
                 continue;
             }
         };
···
             AtIdentifier::Handle(h) => format!("@{h}"),
             AtIdentifier::Did(did) => match get_handle(&slingshot_client, did.as_str()).await {
                 Err(e) => {
-                    eprintln!("failed to get mini doc from repo identifier: {e} for {subject}");
+                    log::warn!("failed to get mini doc from repo identifier: {e} for {subject}");
                     continue;
                 }
                 Ok(None) => did.to_string(),
···
         let issues_url = format!("https://tangled.org/{nice_tangled_repo_id}/{repo_name}/issues");
 
         if args.dry_run {
-            println!("--dry-run, but would have posted:");
-            println!("good-first-issue label added for {repo_full_name} ({repo_url}):");
-            println!("> {title} ({issues_url})\n");
+            log::info!(
+                r#"--dry-run, but would have posted:
+
+good-first-issue label added for {repo_full_name} ({repo_url}):
+
+> {title} ({issues_url})"#
+            );
             continue;
         }
 
···
         )
         .await
         {
-            eprintln!("failed to post for {subject}: {e}");
+            log::error!("failed to post for {subject}: {e}");
         };
 
         break;