rustauth-sqlx 0.2.0

SQLx database adapters for RustAuth.
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

use rustauth_core::db::{DbFieldType, DbValue, IdGeneration, SqlParam};
use rustauth_core::error::RustAuthError;
use sqlx::postgres::PgArguments;
use sqlx::Arguments;
use time::OffsetDateTime;

use super::errors::argument_error;

pub(super) fn bind_param(args: &mut PgArguments, param: &SqlParam) -> Result<(), RustAuthError> {
    match &param.value {
        DbValue::String(value) if param.generated_id == Some(IdGeneration::Uuid) => {
            let value = uuid::Uuid::parse_str(value).map_err(|error| {
                RustAuthError::Adapter(format!("invalid postgres UUID: {error}"))
            })?;
            args.add(value).map_err(argument_error)
        }
        DbValue::String(value) => args.add(value.clone()).map_err(argument_error),
        DbValue::Number(value) => args.add(*value).map_err(argument_error),
        DbValue::Boolean(value) => args.add(*value).map_err(argument_error),
        DbValue::Timestamp(value) => args.add(*value).map_err(argument_error),
        DbValue::Json(value) => args.add(value.clone()).map_err(argument_error),
        DbValue::StringArray(value) => args.add(value.clone()).map_err(argument_error),
        DbValue::NumberArray(value) => args.add(value.clone()).map_err(argument_error),
        DbValue::Record(_) | DbValue::RecordArray(_) => Err(RustAuthError::Adapter(
            "joined records cannot be bound as SQL values".to_owned(),
        )),
        DbValue::Null => match param.field_type {
            DbFieldType::String if param.generated_id == Some(IdGeneration::Uuid) => {
                args.add(Option::<uuid::Uuid>::None).map_err(argument_error)
            }
            DbFieldType::String => args.add(Option::<String>::None).map_err(argument_error),
            DbFieldType::Number => args.add(Option::<i64>::None).map_err(argument_error),
            DbFieldType::Boolean => args.add(Option::<bool>::None).map_err(argument_error),
            DbFieldType::Timestamp => args
                .add(Option::<OffsetDateTime>::None)
                .map_err(argument_error),
            DbFieldType::Json => args
                .add(Option::<serde_json::Value>::None)
                .map_err(argument_error),
            DbFieldType::StringArray => args
                .add(Option::<Vec<String>>::None)
                .map_err(argument_error),
            DbFieldType::NumberArray => args.add(Option::<Vec<i64>>::None).map_err(argument_error),
        },
    }
}