raisfast 0.2.23

The last backend you'll ever need. Rust-powered headless CMS with built-in blog, ecommerce, wallet, payment and 4 plugin engines.
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

//! tenantable Protocol — multi-tenant isolation
//!
//! Provides a `tenant_id` column; automatically injects the current tenant ID and filters by tenant on list queries.

use std::sync::Arc;

use async_trait::async_trait;

use crate::aspects::{Aspect, ColumnDef, Pointcut, SqlType};
use crate::constants::COL_TENANT_ID;
use crate::protocols::Protocol;

pub struct TenantableAspect;

#[async_trait]
impl Aspect for TenantableAspect {
    fn name(&self) -> &str {
        "tenantable"
    }

    fn priority(&self) -> i32 {
        -600
    }

    fn pointcuts(&self) -> Vec<Pointcut> {
        vec![]
    }

    fn columns(&self) -> Vec<ColumnDef> {
        vec![ColumnDef {
            name: COL_TENANT_ID.into(),
            sql_type: SqlType::Varchar,
            default: Some(format!("'{}'", crate::constants::DEFAULT_TENANT)),
        }]
    }
}

pub struct TenantableProtocol;

impl Protocol for TenantableProtocol {
    fn name(&self) -> &str {
        "tenantable"
    }

    fn description(&self) -> &str {
        "Multi-tenant isolation; automatically filters data by tenant ID"
    }

    fn aspects(&self) -> Vec<Arc<dyn Aspect>> {
        vec![Arc::new(TenantableAspect)]
    }

    fn behaviors(&self) -> Vec<&'static str> {
        vec!["tenantable"]
    }

    fn built_in(&self) -> bool {
        true
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn provides_tenant_id_column() {
        let cols = TenantableAspect.columns();
        assert_eq!(cols.len(), 1);
        assert_eq!(cols[0].name, COL_TENANT_ID);
        assert_eq!(cols[0].sql_type, SqlType::Varchar);
        assert!(cols[0].default.is_some());
    }

    #[test]
    fn protocol_declares_tenantable_behavior() {
        let p = TenantableProtocol;
        assert_eq!(p.name(), "tenantable");
        assert!(p.behaviors().contains(&"tenantable"));
        assert!(p.built_in());
    }
}

crate::register_protocol!(
    crate::protocols::tenantable::TenantableProtocol,
    crate::protocols::tenantable::TenantableProtocol
);