openauth-plugins 0.0.4

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

use indexmap::IndexMap;
use openauth_core::db::{DbField, DbFieldType, DbTable, ForeignKey, OnDelete};
use openauth_core::plugin::PluginSchemaContribution;

pub fn oauth_application_schema() -> PluginSchemaContribution {
    PluginSchemaContribution::table(
        "oauthApplication",
        table(
            "oauth_applications",
            30,
            [
                ("name", field("name", DbFieldType::String)),
                ("icon", field("icon", DbFieldType::String).optional()),
                (
                    "metadata",
                    field("metadata", DbFieldType::String).optional(),
                ),
                ("clientId", field("clientId", DbFieldType::String).unique()),
                (
                    "clientSecret",
                    field("clientSecret", DbFieldType::String).optional(),
                ),
                ("redirectUrls", field("redirectUrls", DbFieldType::String)),
                ("type", field("type", DbFieldType::String)),
                (
                    "authenticationScheme",
                    field("authenticationScheme", DbFieldType::String),
                ),
                (
                    "disabled",
                    field("disabled", DbFieldType::Boolean).optional(),
                ),
                (
                    "userId",
                    field("userId", DbFieldType::String)
                        .optional()
                        .indexed()
                        .references(ForeignKey::new("users", "id", OnDelete::Cascade)),
                ),
                ("createdAt", field("createdAt", DbFieldType::Timestamp)),
                ("updatedAt", field("updatedAt", DbFieldType::Timestamp)),
            ],
        ),
    )
}

pub fn oauth_access_token_schema() -> PluginSchemaContribution {
    PluginSchemaContribution::table(
        "oauthAccessToken",
        table(
            "oauth_access_tokens",
            31,
            [
                (
                    "accessToken",
                    field("accessToken", DbFieldType::String).unique(),
                ),
                (
                    "refreshToken",
                    field("refreshToken", DbFieldType::String).unique(),
                ),
                (
                    "accessTokenExpiresAt",
                    field("accessTokenExpiresAt", DbFieldType::Timestamp),
                ),
                (
                    "refreshTokenExpiresAt",
                    field("refreshTokenExpiresAt", DbFieldType::Timestamp),
                ),
                (
                    "clientId",
                    field("clientId", DbFieldType::String)
                        .indexed()
                        .references(ForeignKey::new(
                            "oauth_applications",
                            "clientId",
                            OnDelete::Cascade,
                        )),
                ),
                (
                    "userId",
                    field("userId", DbFieldType::String)
                        .optional()
                        .indexed()
                        .references(ForeignKey::new("users", "id", OnDelete::Cascade)),
                ),
                ("scopes", field("scopes", DbFieldType::String)),
                ("createdAt", field("createdAt", DbFieldType::Timestamp)),
                ("updatedAt", field("updatedAt", DbFieldType::Timestamp)),
            ],
        ),
    )
}

pub fn oauth_consent_schema() -> PluginSchemaContribution {
    PluginSchemaContribution::table(
        "oauthConsent",
        table(
            "oauth_consents",
            32,
            [
                (
                    "clientId",
                    field("clientId", DbFieldType::String)
                        .indexed()
                        .references(ForeignKey::new(
                            "oauth_applications",
                            "clientId",
                            OnDelete::Cascade,
                        )),
                ),
                (
                    "userId",
                    field("userId", DbFieldType::String)
                        .indexed()
                        .references(ForeignKey::new("users", "id", OnDelete::Cascade)),
                ),
                ("scopes", field("scopes", DbFieldType::String)),
                ("createdAt", field("createdAt", DbFieldType::Timestamp)),
                ("updatedAt", field("updatedAt", DbFieldType::Timestamp)),
                ("consentGiven", field("consentGiven", DbFieldType::Boolean)),
            ],
        ),
    )
}

fn table<const N: usize>(name: &str, order: u16, fields: [(&str, DbField); N]) -> DbTable {
    DbTable {
        name: name.to_owned(),
        order: Some(order),
        fields: fields
            .into_iter()
            .map(|(name, field)| (name.to_owned(), field))
            .collect::<IndexMap<_, _>>(),
    }
}

fn field(name: &str, field_type: DbFieldType) -> DbField {
    DbField::new(name, field_type)
}