Spoor/appview
2
0
Fork 0
Code Issues 1 Pull requests Projects Releases Packages Wiki Activity Actions

Ingestor, up and running with just logging

Browse source
This commit is contained in:
Julia Lange 2025-05-14 19:42:38 -07:00
parent 028219ded1
commit b2618ab8b6
Signed by: Julia
SSH key fingerprint: SHA256:KI8YxpkPRbnDRkXPgCuQCVz181++Vy7NAvmQj8alOhM
2 changed files with 5 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

3
src/ingestor.rs
View file

@ -40,9 +40,10 @@ impl LexiconIngestor for SpoorJetstream {
} }
pub async fn start_ingestor() { pub async fn start_ingestor() {
info!("Starting ingestor");
let nsids = vec![ let nsids = vec![
Activity::NSID.to_string(), Activity::NSID.to_string(),
Session::NSID.to_string() Session::NSID.to_string(),
]; ];
let opts = JetstreamOptions::builder().wanted_collections(nsids.clone()).build(); let opts = JetstreamOptions::builder().wanted_collections(nsids.clone()).build();
let jetstream = JetstreamConnection::new(opts); let jetstream = JetstreamConnection::new(opts);

4
src/main.rs
View file

@ -23,7 +23,7 @@ mod router;
#[tokio::main] #[tokio::main]
async fn main() { async fn main() {
let subscriber = tracing_subscriber::FmtSubscriber::new(); 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 mut router = Router::new();
let get_nsid = Nsid::new(String::from("me.woach.get")).expect("me.woach.get is a valid nsid"); 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_query(get_nsid, test));
router = router.add_endpoint(Endpoint::new_xrpc_procedure(post_nsid, test2)); router = router.add_endpoint(Endpoint::new_xrpc_procedure(post_nsid, test2));
tokio::spawn(async move { tokio::spawn(async move {
start_ingestor(); start_ingestor().await;
}); });
router.serve().await; router.serve().await;
} }