fix naming convention

This commit is contained in:
Julia Lange 2025-06-05 16:20:31 -07:00
parent 0ce9c0e288
commit 05b33f0243
Signed by: Julia
SSH key fingerprint: SHA256:5DJcfxa5/fKCYn57dcabJa2vN2e6eT0pBerYi5SUbto
5 changed files with 10 additions and 13 deletions

View file

@ -70,12 +70,10 @@ macro_rules! create_commit_collection {
);
}
pub mod my_spoor_session;
pub use my_spoor_session::MySpoorSession;
pub mod my_spoor_activity;
pub use my_spoor_activity::MySpoorActivity;
pub mod app_bsky_post;
pub use app_bsky_post::AppBskyPost;
pub mod my_spoor_log_session;
pub use my_spoor_log_session::MySpoorLogSession;
pub mod my_spoor_log_activity;
pub use my_spoor_log_activity::MySpoorLogActivity;
struct CommitIngestorState;

View file

@ -20,7 +20,7 @@ async fn handle_delete(
Ok(())
}
create_commit_collection!(AppBskyPost, "app.bsky.feed.post".to_string(),
create_commit_collection!(AppBskyFeedPost, "app.bsky.feed.post".to_string(),
change => handle_change,
delete => handle_delete,
);

View file

@ -24,7 +24,7 @@ async fn handle_delete(
Ok(())
}
create_commit_collection!(MySpoorActivity, Activity::NSID.to_string(),
create_commit_collection!(MySpoorLogActivity, Activity::NSID.to_string(),
change => handle_change,
delete => handle_delete,
);

View file

@ -24,7 +24,7 @@ async fn handle_delete(
Ok(())
}
create_commit_collection!(MySpoorSession, Session::NSID.to_string(),
create_commit_collection!(MySpoorLogSession, Session::NSID.to_string(),
change => handle_change,
delete => handle_delete,
);

View file

@ -1,7 +1,7 @@
use crate::{
collections::{
Collection,
MySpoorActivity, MySpoorSession, AppBskyPost,
MySpoorLogActivity, MySpoorLogSession,
},
ingestor::Ingestor,
};
@ -15,8 +15,7 @@ async fn main() {
let _ = tracing::subscriber::set_global_default(subscriber);
let mut ingestor = Ingestor::new();
ingestor.add_collection(MySpoorActivity::new());
ingestor.add_collection(MySpoorSession::new());
ingestor.add_collection(AppBskyPost::new());
ingestor.add_collection(MySpoorLogActivity::new());
ingestor.add_collection(MySpoorLogSession::new());
ingestor.start().await;
}