docbox-core 0.13.2

Docbox core business logic and functionality
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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

use crate::events::{TenantEventMessage, TenantEventPublisher};
use docbox_database::{
    DbErr, DbPool,
    models::{
        document_box::{DocumentBoxScopeRaw, WithScope},
        link::Link,
    },
};
use docbox_search::{SearchError, TenantSearchIndex};
use thiserror::Error;

#[derive(Debug, Error)]
pub enum DeleteLinkError {
    #[error(transparent)]
    Database(#[from] DbErr),
    #[error(transparent)]
    Search(SearchError),
}

#[tracing::instrument(skip_all, fields(%scope, link_id = %link.id))]
pub async fn delete_link(
    db: &DbPool,
    search: &TenantSearchIndex,
    events: &TenantEventPublisher,
    link: Link,
    scope: DocumentBoxScopeRaw,
) -> Result<(), DeleteLinkError> {
    // Delete the indexed file contents
    search
        .delete_data(link.id)
        .await
        .map_err(DeleteLinkError::Search)?;

    // Delete the link itself from the db
    let result = link
        .delete(db)
        .await
        .inspect_err(|error| tracing::error!(?error, "failed to delete link"))?;

    // Check we actually removed something before emitting an event
    if result.rows_affected() < 1 {
        return Ok(());
    }

    // Publish an event
    events.publish_event(TenantEventMessage::LinkDeleted(WithScope::new(link, scope)));

    Ok(())
}