alibi-sqlx 0.10.0

SQLx integration for Alibi
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

use crate::{JsonMetadata, SqlxModel};
use chrono::{DateTime, Utc};
#[derive(
    Clone, Debug, PartialEq, serde::Serialize, serde::Deserialize, sqlx::FromRow, SqlxModel,
)]
#[auth(table = "oauthClient")]
pub struct Model {
    pub id: String,
    #[sqlx(rename = "clientId")]
    #[serde(rename = "clientId")]
    pub client_id: String,
    #[sqlx(rename = "clientSecret")]
    #[serde(rename = "clientSecret")]
    pub client_secret: Option<String>,
    #[sqlx(rename = "clientDiscoveryId")]
    #[serde(rename = "clientDiscoveryId")]
    pub client_discovery_id: Option<String>,
    #[serde(rename = "disabled")]
    pub disabled: Option<bool>,
    #[sqlx(rename = "skipConsent")]
    #[serde(rename = "skipConsent")]
    pub skip_consent: Option<bool>,
    #[sqlx(rename = "enableEndSession")]
    #[serde(rename = "enableEndSession")]
    pub enable_end_session: Option<bool>,
    #[sqlx(rename = "subjectType")]
    #[serde(rename = "subjectType")]
    pub subject_type: Option<String>,
    #[serde(rename = "scopes")]
    pub scopes: Option<JsonMetadata>,
    #[sqlx(rename = "clientCredentialsScopes")]
    #[serde(rename = "clientCredentialsScopes")]
    pub client_credentials_scopes: Option<JsonMetadata>,
    #[sqlx(rename = "userId")]
    #[serde(rename = "userId")]
    pub user_id: Option<String>,
    #[sqlx(rename = "createdAt")]
    #[serde(rename = "createdAt")]
    pub created_at: Option<DateTime<Utc>>,
    #[sqlx(rename = "updatedAt")]
    #[serde(rename = "updatedAt")]
    pub updated_at: Option<DateTime<Utc>>,
    #[serde(rename = "name")]
    pub name: Option<String>,
    #[serde(rename = "uri")]
    pub uri: Option<String>,
    #[serde(rename = "icon")]
    pub icon: Option<String>,
    #[serde(rename = "contacts")]
    pub contacts: Option<JsonMetadata>,
    #[serde(rename = "tos")]
    pub tos: Option<String>,
    #[serde(rename = "policy")]
    pub policy: Option<String>,
    #[sqlx(rename = "softwareId")]
    #[serde(rename = "softwareId")]
    pub software_id: Option<String>,
    #[sqlx(rename = "softwareVersion")]
    #[serde(rename = "softwareVersion")]
    pub software_version: Option<String>,
    #[sqlx(rename = "softwareStatement")]
    #[serde(rename = "softwareStatement")]
    pub software_statement: Option<String>,
    #[sqlx(rename = "redirectUris")]
    #[serde(rename = "redirectUris")]
    pub redirect_uris: JsonMetadata,
    #[sqlx(rename = "postLogoutRedirectUris")]
    #[serde(rename = "postLogoutRedirectUris")]
    pub post_logout_redirect_uris: Option<JsonMetadata>,
    #[sqlx(rename = "backchannelLogoutUri")]
    #[serde(rename = "backchannelLogoutUri")]
    pub backchannel_logout_uri: Option<String>,
    #[sqlx(rename = "backchannelLogoutSessionRequired")]
    #[serde(rename = "backchannelLogoutSessionRequired")]
    pub backchannel_logout_session_required: Option<bool>,
    #[sqlx(rename = "tokenEndpointAuthMethod")]
    #[serde(rename = "tokenEndpointAuthMethod")]
    pub token_endpoint_auth_method: Option<String>,
    #[sqlx(rename = "applicationType")]
    #[serde(rename = "applicationType")]
    pub application_type: Option<String>,
    #[serde(rename = "jwks")]
    pub jwks: Option<String>,
    #[sqlx(rename = "jwksUri")]
    #[serde(rename = "jwksUri")]
    pub jwks_uri: Option<String>,
    #[sqlx(rename = "grantTypes")]
    #[serde(rename = "grantTypes")]
    pub grant_types: Option<JsonMetadata>,
    #[sqlx(rename = "responseTypes")]
    #[serde(rename = "responseTypes")]
    pub response_types: Option<JsonMetadata>,
    #[sqlx(rename = "requirePKCE")]
    #[serde(rename = "requirePKCE")]
    pub require_pkce: Option<bool>,
    #[sqlx(rename = "dpopBoundAccessTokens")]
    #[serde(rename = "dpopBoundAccessTokens")]
    pub dpop_bound_access_tokens: Option<bool>,
    #[sqlx(rename = "referenceId")]
    #[serde(rename = "referenceId")]
    pub reference_id: Option<String>,
    #[serde(rename = "metadata")]
    pub metadata: Option<JsonMetadata>,
}

impl TryFrom<Model> for alibi_core::store::OAuthClient {
    type Error = alibi_core::AuthError;
    fn try_from(model: Model) -> Result<Self, Self::Error> {
        let metadata = alibi_core::store::oauth_clients::metadata_from_columns(
            &serde_json::to_value(&model)?,
        )?;
        Ok(Self {
            id: model.id,
            client_id: model.client_id,
            user_id: model.user_id,
            client_secret: model.client_secret,
            metadata,
            created_at: model.created_at,
            updated_at: model.updated_at,
        })
    }
}
impl Model {
    pub(crate) fn columns_from_metadata(
        metadata: serde_json::Value,
    ) -> alibi_core::AuthResult<Self> {
        let mut fields = alibi_core::store::oauth_clients::metadata_to_columns(metadata)?;
        let object = fields.as_object_mut().ok_or_else(|| {
            alibi_core::AuthError::internal("OAuth client fields must be an object")
        })?;
        _ = object.insert("id".into(), serde_json::Value::String(String::new()));
        _ = object.insert("clientId".into(), serde_json::Value::String(String::new()));
        Ok(serde_json::from_value(fields)?)
    }
}