Struct EventProcessor 

pub struct EventProcessor {
    pub homeserver: Homeserver,
    pub files_path: PathBuf,
    pub tracer_name: String,
    pub moderation: Moderation,
    /* private fields */
}

Fields

homeserver: Homeserver

files_path: PathBuf

tracer_name: String

moderation: Moderation

Implementations

impl EventProcessor

pub async fn test(homeserver_id: String) -> Self

Creates a new EventProcessor instance for testing purposes.

This function initializes an EventProcessor configured with:

• A mock homeserver constructed using the provided homeserver_url and homeserver_pubky.
• A default configuration, including an HTTP client, a limit of 1000 events, and a sender channel.

It is designed for use in integration tests, benchmarking scenarios, or other test environments where a controlled and predictable EventProcessor instance is required.

Parameters

• homeserver_id: A String representing the URL of the homeserver to be used in the test environment.
• tx: A RetryManagerSenderChannel used to handle outgoing messages or events.

pub async fn from_config(config: &WatcherConfig) -> Result<Self, DynError>

pub async fn run(&mut self) -> Result<(), DynError>

pub async fn process_event_lines( &mut self, lines: Vec<String>, ) -> Result<(), DynError>

Processes a batch of event lines retrieved from the homeserver.

This function iterates over a vector of event URIs, handling each line based on its content:

• Lines starting with cursor: update the cursor for the homeserver and save it to the index.
• Other lines are parsed into events and processed accordingly. If parsing fails, an error is logged.

Parameters

• lines: A vector of strings representing event lines retrieved from the homeserver.