gatekeep-sqlx 1.0.1

SQLx query lowering adapter for gatekeep
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

use gatekeep::AuditEntry;
use sqlx::Row;

use super::{DecisionAuditRecord, SqlxAuditError};

#[cfg(any(feature = "postgres", feature = "mysql"))]
pub(super) fn records_from_json_rows<R>(
    rows: Vec<R>,
) -> Result<Vec<DecisionAuditRecord>, SqlxAuditError>
where
    R: Row,
    for<'r> &'r str: sqlx::ColumnIndex<R>,
    for<'r> i64: sqlx::Decode<'r, R::Database> + sqlx::Type<R::Database>,
    for<'r> serde_json::Value: sqlx::Decode<'r, R::Database> + sqlx::Type<R::Database>,
{
    rows.into_iter()
        .map(|row| {
            let id: i64 = row.try_get("id")?;
            let entry = serde_json::from_value::<AuditEntry>(row.try_get("entry")?)?;
            Ok(DecisionAuditRecord { id, entry })
        })
        .collect()
}

#[cfg(feature = "sqlite")]
pub(super) fn records_from_text_rows<R>(
    rows: Vec<R>,
) -> Result<Vec<DecisionAuditRecord>, SqlxAuditError>
where
    R: Row,
    for<'r> &'r str: sqlx::ColumnIndex<R>,
    for<'r> i64: sqlx::Decode<'r, R::Database> + sqlx::Type<R::Database>,
    for<'r> String: sqlx::Decode<'r, R::Database> + sqlx::Type<R::Database>,
{
    rows.into_iter()
        .map(|row| {
            let id: i64 = row.try_get("id")?;
            let entry_json: String = row.try_get("entry")?;
            let entry = serde_json::from_str(&entry_json)?;
            Ok(DecisionAuditRecord { id, entry })
        })
        .collect()
}

pub(super) const fn effect_label(entry: &AuditEntry) -> &'static str {
    match entry.effect {
        gatekeep::EffectKind::Permit => "permit",
        gatekeep::EffectKind::Deny => "deny",
    }
}

pub(super) const fn deny_shape_label(shape: gatekeep::DenyShape) -> &'static str {
    match shape {
        gatekeep::DenyShape::Forbidden => "forbidden",
        gatekeep::DenyShape::Hidden => "hidden",
    }
}

pub(super) fn position_i32(position: usize) -> i32 {
    i32::try_from(position).unwrap_or(i32::MAX)
}

pub(super) const fn presence_label(presence: gatekeep::Presence) -> &'static str {
    match presence {
        gatekeep::Presence::Present => "present",
        gatekeep::Presence::Absent => "absent",
        gatekeep::Presence::Unknown => "unknown",
    }
}