Expand description
§Nexus Watcher
The nexus-watcher crate is responsible for monitoring a Pubky homeserver’s /events endpoint and processing
events into the Nexus databases. It integrates with nexus-common to manage database connections (Neo4j and Redis),
configuration, logging, metrics, and stack initialization.
Key responsibilities include:
- Listening to a homeserver’s events stream.
- Processing various event types (posts, bookmarks, follows, mutes, tags, user updates, etc.).
- Applying retry logic for events that fail to index.
- Updating both the graph database and Redis indexes based on incoming events.
The crate provides a builder interface via NexusWatcher::builder() and supports configuration from files.
The main entry point is in main.rs, which simply calls the builder’s run() method to start the event loop.
Modules§
Macros§
- handle_
indexing_ results - A macro to handle the results of
tokio::join!by checking for errors and propagating them.