bcode_session 0.0.1-alpha.0

Session lifecycle and attachment management for bcode
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

//! Strict typed accessors for current database rows.

use crate::db::{SessionDbError, SessionDbResult};

pub fn required_string(row: &switchy::database::Row, column: &str) -> SessionDbResult<String> {
    row.get(column)
        .and_then(|value| value.as_str().map(ToOwned::to_owned))
        .ok_or_else(|| SessionDbError::InvalidRow {
            column: column.to_owned(),
        })
}

#[must_use]
pub fn optional_string(row: &switchy::database::Row, column: &str) -> Option<String> {
    row.get(column)
        .and_then(|value| value.as_str().map(ToOwned::to_owned))
}

pub fn required_i64(row: &switchy::database::Row, column: &str) -> SessionDbResult<i64> {
    row.get(column)
        .and_then(|value| value.as_i64())
        .ok_or_else(|| SessionDbError::InvalidRow {
            column: column.to_owned(),
        })
}

pub fn required_non_negative_u64(
    row: &switchy::database::Row,
    column: &str,
) -> SessionDbResult<u64> {
    let value = required_i64(row, column)?;
    if value.is_negative() {
        return Err(SessionDbError::InvalidRow {
            column: column.to_owned(),
        });
    }
    Ok(value.cast_unsigned())
}

pub fn optional_non_negative_u64(
    row: &switchy::database::Row,
    column: &str,
) -> SessionDbResult<Option<u64>> {
    match row.get(column) {
        Some(switchy::database::DatabaseValue::Null) => Ok(None),
        Some(_) => required_non_negative_u64(row, column).map(Some),
        None => Err(SessionDbError::InvalidRow {
            column: column.to_owned(),
        }),
    }
}

#[must_use]
pub fn optional_i64(row: &switchy::database::Row, column: &str) -> Option<i64> {
    row.get(column).and_then(|value| value.as_i64())
}

#[must_use]
pub const fn i64_to_u64(value: i64) -> u64 {
    if value.is_negative() {
        0
    } else {
        value.cast_unsigned()
    }
}