atrium-oauth 0.1.6

Core library for implementing AT Protocol OAuth clients
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

use super::{OAuthServerAgent, Result};
use crate::{
    keyset::Keyset,
    resolver::OAuthResolver,
    types::{OAuthAuthorizationServerMetadata, OAuthClientMetadata},
};
use atrium_api::{
    did_doc::DidDocument,
    types::string::{Did, Handle},
};
use atrium_common::resolver::Resolver;
use atrium_identity::Error;
use atrium_xrpc::HttpClient;
use jose_jwk::Key;
use std::sync::Arc;

pub struct OAuthServerFactory<T, D, H>
where
    T: HttpClient + Send + Sync + 'static,
{
    client_metadata: OAuthClientMetadata,
    resolver: Arc<OAuthResolver<T, D, H>>,
    http_client: Arc<T>,
    keyset: Option<Keyset>,
}

impl<T, D, H> OAuthServerFactory<T, D, H>
where
    T: HttpClient + Send + Sync + 'static,
{
    pub fn new(
        client_metadata: OAuthClientMetadata,
        resolver: Arc<OAuthResolver<T, D, H>>,
        http_client: Arc<T>,
        keyset: Option<Keyset>,
    ) -> Self {
        OAuthServerFactory { client_metadata, resolver, http_client, keyset }
    }
}

impl<T, D, H> OAuthServerFactory<T, D, H>
where
    T: HttpClient + Send + Sync + 'static,
    D: Resolver<Input = Did, Output = DidDocument, Error = Error> + Send + Sync,
    H: Resolver<Input = Handle, Output = Did, Error = Error> + Send + Sync,
{
    pub async fn build_from_issuer(
        &self,
        dpop_key: Key,
        issuer: impl AsRef<str>,
    ) -> Result<OAuthServerAgent<T, D, H>> {
        let server_metadata = self.resolver.get_authorization_server_metadata(&issuer).await?;
        self.build_from_metadata(dpop_key, server_metadata)
    }
    pub fn build_from_metadata(
        &self,
        dpop_key: Key,
        server_metadata: OAuthAuthorizationServerMetadata,
    ) -> Result<OAuthServerAgent<T, D, H>> {
        OAuthServerAgent::new(
            dpop_key,
            server_metadata,
            self.client_metadata.clone(),
            Arc::clone(&self.resolver),
            Arc::clone(&self.http_client),
            self.keyset.clone(),
        )
    }
}