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

use async_graphql::*;

use super::{convert::ToGlobalId, primitives::*};

#[derive(InputObject)]
pub struct TransactionInput {
    pub transaction_id: UUID,
    pub tx_template_code: String,
    pub params: Option<JSON>,
}

#[derive(Clone, SimpleObject)]
pub struct Transaction {
    id: ID,
    transaction_id: UUID,
    version: u32,
    tx_template_id: UUID,
    journal_id: UUID,
    effective: Date,
    correlation_id: String,
    external_id: Option<String>,
    description: Option<String>,
    metadata: Option<JSON>,
    created_at: Timestamp,
    modified_at: Timestamp,
}

#[derive(SimpleObject)]
pub struct TransactionPostPayload {
    pub transaction: Transaction,
}

impl ToGlobalId for cala_ledger::TransactionId {
    fn to_global_id(&self) -> async_graphql::types::ID {
        use base64::{engine::general_purpose, Engine as _};
        let id = format!(
            "transaction:{}",
            general_purpose::STANDARD_NO_PAD.encode(self.to_string())
        );
        async_graphql::types::ID::from(id)
    }
}

impl From<cala_ledger::transaction::Transaction> for Transaction {
    fn from(entity: cala_ledger::transaction::Transaction) -> Self {
        let created_at = entity.created_at();
        let modified_at = entity.modified_at();
        let values = entity.into_values();
        Self {
            id: values.id.to_global_id(),
            transaction_id: UUID::from(values.id),
            version: values.version,
            tx_template_id: UUID::from(values.tx_template_id),
            journal_id: UUID::from(values.journal_id),
            effective: Date::from(values.effective),
            correlation_id: values.correlation_id,
            external_id: values.external_id,
            description: values.description,
            metadata: values.metadata.map(JSON::from),
            created_at: Timestamp::from(created_at),
            modified_at: Timestamp::from(modified_at),
        }
    }
}

impl From<cala_ledger::transaction::Transaction> for TransactionPostPayload {
    fn from(value: cala_ledger::transaction::Transaction) -> Self {
        Self {
            transaction: Transaction::from(value),
        }
    }
}