openauth-plugins 0.0.3

Official OpenAuth plugin modules.
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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142

use openauth_core::db::{DbRecord, DbValue};
use openauth_core::error::OpenAuthError;

use super::models::{
    optional_json, optional_string, optional_timestamp, required_string, required_timestamp,
    Invitation, InvitationStatus, Member, Organization, OrganizationRoleRecord, Team, TeamMember,
};

pub fn organization_from_record(record: &DbRecord) -> Result<Organization, OpenAuthError> {
    Ok(Organization {
        id: required_string(record, "id")?,
        name: required_string(record, "name")?,
        slug: required_string(record, "slug")?,
        logo: optional_string(record, "logo")?,
        metadata: optional_json(record, "metadata")?,
        created_at: required_timestamp(record, "created_at")?,
        updated_at: optional_timestamp(record, "updated_at")?,
        additional_fields: crate::organization::additional_fields::extract_record_fields(
            record,
            &[
                "id",
                "name",
                "slug",
                "logo",
                "metadata",
                "created_at",
                "updated_at",
            ],
        )?,
    })
}

pub fn member_from_record(record: &DbRecord) -> Result<Member, OpenAuthError> {
    Ok(Member {
        id: required_string(record, "id")?,
        organization_id: required_string(record, "organization_id")?,
        user_id: required_string(record, "user_id")?,
        role: required_string(record, "role")?,
        created_at: required_timestamp(record, "created_at")?,
        additional_fields: crate::organization::additional_fields::extract_record_fields(
            record,
            &["id", "organization_id", "user_id", "role", "created_at"],
        )?,
    })
}

pub fn invitation_from_record(record: &DbRecord) -> Result<Invitation, OpenAuthError> {
    let status = required_string(record, "status")?;
    Ok(Invitation {
        id: required_string(record, "id")?,
        organization_id: required_string(record, "organization_id")?,
        email: required_string(record, "email")?,
        role: required_string(record, "role")?,
        status: InvitationStatus::try_from(status.as_str())?,
        team_id: optional_string(record, "team_id")?,
        expires_at: required_timestamp(record, "expires_at")?,
        created_at: required_timestamp(record, "created_at")?,
        inviter_id: required_string(record, "inviter_id")?,
        additional_fields: crate::organization::additional_fields::extract_record_fields(
            record,
            &[
                "id",
                "organization_id",
                "email",
                "role",
                "status",
                "team_id",
                "expires_at",
                "created_at",
                "inviter_id",
            ],
        )?,
    })
}

pub fn team_from_record(record: &DbRecord) -> Result<Team, OpenAuthError> {
    Ok(Team {
        id: required_string(record, "id")?,
        name: required_string(record, "name")?,
        organization_id: required_string(record, "organization_id")?,
        created_at: required_timestamp(record, "created_at")?,
        updated_at: optional_timestamp(record, "updated_at")?,
        additional_fields: crate::organization::additional_fields::extract_record_fields(
            record,
            &["id", "name", "organization_id", "created_at", "updated_at"],
        )?,
    })
}

pub fn team_member_from_record(record: &DbRecord) -> Result<TeamMember, OpenAuthError> {
    Ok(TeamMember {
        id: required_string(record, "id")?,
        team_id: required_string(record, "team_id")?,
        user_id: required_string(record, "user_id")?,
        created_at: required_timestamp(record, "created_at")?,
        additional_fields: crate::organization::additional_fields::extract_record_fields(
            record,
            &["id", "team_id", "user_id", "created_at"],
        )?,
    })
}

pub fn organization_role_from_record(
    record: &DbRecord,
) -> Result<OrganizationRoleRecord, OpenAuthError> {
    Ok(OrganizationRoleRecord {
        id: required_string(record, "id")?,
        organization_id: required_string(record, "organization_id")?,
        role: required_string(record, "role")?,
        permission: optional_json(record, "permission")?.unwrap_or(serde_json::Value::Null),
        created_at: required_timestamp(record, "created_at")?,
        updated_at: optional_timestamp(record, "updated_at")?,
        additional_fields: crate::organization::additional_fields::extract_record_fields(
            record,
            &[
                "id",
                "organization_id",
                "role",
                "permission",
                "created_at",
                "updated_at",
            ],
        )?,
    })
}

pub fn user_from_record(record: &DbRecord) -> Result<openauth_core::db::User, OpenAuthError> {
    Ok(openauth_core::db::User {
        id: required_string(record, "id")?,
        name: required_string(record, "name")?,
        email: required_string(record, "email")?,
        email_verified: match record.get("email_verified") {
            Some(DbValue::Boolean(value)) => *value,
            _ => false,
        },
        image: optional_string(record, "image")?,
        username: optional_string(record, "username")?,
        display_username: optional_string(record, "display_username")?,
        created_at: required_timestamp(record, "created_at")?,
        updated_at: required_timestamp(record, "updated_at")?,
    })
}