From b2618ab8b66de5f238c9d09cee9e4ea1f1624663 Mon Sep 17 00:00:00 2001
From: Julia Lange <public@julialange.org>
Date: Wed, 14 May 2025 19:42:38 -0700
Subject: [PATCH] Ingestor, up and running with just logging

---
 src/ingestor.rs | 5 +++--
 src/main.rs     | 4 ++--
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/src/ingestor.rs b/src/ingestor.rs
index 72c6311..1dc31cc 100644
--- a/src/ingestor.rs
+++ b/src/ingestor.rs
@@ -40,9 +40,10 @@ impl LexiconIngestor for SpoorJetstream {
 }
 
 pub async fn start_ingestor() {
+  info!("Starting ingestor");
   let nsids = vec![
-    Activity::NSID.to_string(), 
-    Session::NSID.to_string()
+    Activity::NSID.to_string(),
+    Session::NSID.to_string(),
   ];
   let opts = JetstreamOptions::builder().wanted_collections(nsids.clone()).build();
   let jetstream = JetstreamConnection::new(opts);
diff --git a/src/main.rs b/src/main.rs
index dd97114..399d3be 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -23,7 +23,7 @@ mod router;
 #[tokio::main]
 async fn main() {
   let subscriber = tracing_subscriber::FmtSubscriber::new();
-  tracing::subscriber::set_global_default(subscriber);
+  let _ = tracing::subscriber::set_global_default(subscriber);
 
   let mut router = Router::new();
   let get_nsid = Nsid::new(String::from("me.woach.get")).expect("me.woach.get is a valid nsid");
@@ -31,7 +31,7 @@ async fn main() {
   router = router.add_endpoint(Endpoint::new_xrpc_query(get_nsid, test));
   router = router.add_endpoint(Endpoint::new_xrpc_procedure(post_nsid, test2));
   tokio::spawn(async move {
-    start_ingestor();
+    start_ingestor().await;
   });
   router.serve().await;
 }