nexus-watcher 0.4.1

Nexus Watcher constructs a social graph out of all of the events on pubky-core homeservers
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

use nexus_common::models::post::PostRelationships;
use nexus_common::types::DynError;

/// Checks if a post is a reply based on its relationships.
/// # Arguments
/// * `author_id` - The ID of the author of the post
/// * `post_id` - The ID of the post to check
///
pub async fn post_relationships_is_reply(author_id: &str, post_id: &str) -> Result<bool, DynError> {
    match PostRelationships::get_by_id(author_id, post_id).await? {
        Some(relationship) => Ok(relationship.replied.is_some()),
        // If the post does not exist, it is treated as a reply to avoid incorrect assumptions
        None => Ok(true),
    }
}

/// A macro to handle the results of `tokio::join!` by checking for errors and propagating them.
///
/// This macro takes multiple `Result<T, E>` values (such as those returned from `tokio::join!`)
/// and iterates over them. If any result is an `Err`, it maps the error into an `EventProcessorError`
/// and propagates
#[macro_export]
macro_rules! handle_indexing_results {
    ($($res:expr),+) => {
        {   // Convert tuple to array
            let results = [$($res),+];
            for result in results {
                result.map_err(|e| EventProcessorError::IndexWriteFailed {
                    message: e.to_string(),
                })?;
            }
        }
    };
}