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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90

use crate::common::database::test_tenant_db;
use docbox_core::{
    document_box::create_document_box::{
        CreateDocumentBox, CreateDocumentBoxError, create_document_box,
    },
    events::{
        TenantEventMessage, TenantEventPublisher, mpsc::MpscEventPublisher,
        noop::NoopEventPublisher,
    },
};

mod common;

/// Creating a document box that doesn't exist should succeed
#[tokio::test]
async fn test_create_document_box_success() {
    let (db, _db_container) = test_tenant_db().await;

    let events = TenantEventPublisher::Noop(NoopEventPublisher);
    create_document_box(
        &db,
        &events,
        CreateDocumentBox {
            scope: "test".to_string(),
            created_by: None,
        },
    )
    .await
    .unwrap();
}

/// Creating a document box should emit a creation event
#[tokio::test]
async fn test_create_document_box_success_event() {
    let (db, _db_container) = test_tenant_db().await;

    let (events, mut events_rx) = MpscEventPublisher::new();
    let events = TenantEventPublisher::Mpsc(events);
    let (document_box, _root) = create_document_box(
        &db,
        &events,
        CreateDocumentBox {
            scope: "test".to_string(),
            created_by: None,
        },
    )
    .await
    .unwrap();

    let event = events_rx.recv().await.unwrap();
    assert!(matches!(
        event,
        TenantEventMessage::DocumentBoxCreated(created) if created.scope == document_box.scope
    ));
}

/// Attempting to create a document box with a duplicate scope should
/// produce an error
#[tokio::test]
async fn test_create_document_box_duplicate_scope() {
    let (db, _db_container) = test_tenant_db().await;

    let events = TenantEventPublisher::Noop(NoopEventPublisher);

    // Should succeed
    create_document_box(
        &db,
        &events,
        CreateDocumentBox {
            scope: "test".to_string(),
            created_by: None,
        },
    )
    .await
    .unwrap();

    // Should fail
    let error = create_document_box(
        &db,
        &events,
        CreateDocumentBox {
            scope: "test".to_string(),
            created_by: None,
        },
    )
    .await
    .unwrap_err();

    assert!(matches!(error, CreateDocumentBoxError::ScopeAlreadyExists))
}