nederlandskie/src/processes/post_indexer.rs

use anyhow::Result;
use async_trait::async_trait;

use crate::algos;
use crate::services::bluesky::{Bluesky, Operation, OperationProcessor};
use crate::services::Database;

pub struct PostIndexer<'a> {
    database: &'a Database,
    bluesky: &'a Bluesky,
}

impl<'a> PostIndexer<'a> {
    pub fn new(database: &'a Database, bluesky: &'a Bluesky) -> Self {
        Self { database, bluesky }
    }
}

impl<'a> PostIndexer<'a> {
    pub async fn start(&self) -> Result<()> {
        Ok(self.bluesky.subscribe_to_operations(self).await?)
    }
}

#[async_trait]
impl<'a> OperationProcessor for PostIndexer<'a> {
    async fn process_operation(&self, operation: &Operation) -> Result<()> {
        match operation {
            Operation::CreatePost {
                author_did,
                cid,
                uri,
                languages,
                text,
            } => {
                if algos::iter_all().any(|a| a.should_index_post(author_did, languages, text)) {
                    println!("received insertable post from {author_did}: {text}");

                    self.database
                        .insert_profile_if_it_doesnt_exist(&author_did)
                        .await?;
                    self.database.insert_post(&author_did, &cid, &uri).await?;
                }
            }
            Operation::DeletePost { uri } => {
                println!("received a post do delete: {uri}");

                // TODO: Delete posts from db
                // self.database.delete_post(&self.db_connection_pool, &uri).await?;
            }
        };

        Ok(())
    }
}