Merge branch 'feature/smbcloud-oauth' into development

Author: setoelkahfi

Cargo.lock

@@ -3,6 +3,7 @@ pub mod app_auth;
 pub mod error_codes;
 pub mod forgot;
 pub mod login;
+pub mod oauth;
 pub mod project;
 pub mod repository;
 pub mod runner;

crates/smbcloud-model/src/lib.rs

@@ -0,0 +1,36 @@
+use {
+    serde::{Deserialize, Serialize},
+    tsync::tsync,
+};
+
+#[derive(Serialize, Deserialize, Debug, Clone)]
+#[tsync]
+pub struct TokenResponse {
+    pub access_token: String,
+    pub expires_in: i32,
+    pub refresh_token: Option<String>,
+    pub refresh_token_expires_in: Option<String>,
+    pub scope: String,
+    pub token_type: String,
+}
+
+#[derive(Serialize, Deserialize, Debug, Clone)]
+#[tsync]
+pub struct OauthRedirect {
+    pub code: String,
+    pub scope: String,
+    pub authuser: i32,
+    pub prompt: String,
+}
+
+#[derive(Serialize, Deserialize, Debug, Clone)]
+#[tsync]
+pub struct UserInfo {
+    pub id: String,
+    pub email: String,
+    pub verified_email: bool,
+    pub name: String,
+    pub given_name: String,
+    pub family_name: String,
+    pub picture: String,
+}

crates/smbcloud-model/src/oauth.rs

@@ -18,7 +18,10 @@ categories = [
 readme = "README.md"
 
 [dependencies]
-reqwest = { workspace = true, features = ["json"] }
+log = { workspace = true }
+reqwest = { workspace = true, features = ["json", "rustls-tls-native-roots"] }
+openssl = { version = "0.10", features = ["vendored"] }
+serde_json = { workspace = true }
 smbcloud-model = { workspace = true }
 smbcloud-network = { workspace = true }
 smbcloud-networking = { workspace = true }

crates/smbcloud-networking-account/Cargo.toml

@@ -2,5 +2,6 @@ pub mod check_email;
 pub mod login;
 pub mod logout;
 pub mod me;
+pub mod oauth;
 pub mod remove;
 pub mod signup;

crates/smbcloud-networking-account/src/lib.rs

@@ -0,0 +1,15 @@
+use {
+    log::debug,
+    reqwest::Client,
+    smbcloud_model::{error_codes::ErrorResponse, oauth::UserInfo},
+    smbcloud_network::network::{self},
+};
+
+pub async fn get_profile(access_token: String) -> Result<UserInfo, ErrorResponse> {
+    let base_url = "https://www.googleapis.com/oauth2/v1/userinfo?alt=json";
+    debug!("Get profile with token: {}", access_token);
+    let builder = Client::new()
+        .get(base_url)
+        .header("Authorization", format!("Bearer {}", access_token));
+    network::request(builder).await
+}

crates/smbcloud-networking-account/src/oauth/get_profile.rs

@@ -0,0 +1,28 @@
+use {
+    log::debug,
+    reqwest::Client,
+    serde_json::json,
+    smbcloud_model::{
+        error_codes::ErrorResponse,
+        oauth::{OauthRedirect, TokenResponse},
+    },
+    smbcloud_network::network::{self},
+};
+
+pub async fn get_token(
+    oauth_redirect: OauthRedirect,
+    client_id: String,
+    client_secret: String,
+) -> Result<TokenResponse, ErrorResponse> {
+    let base_url = format!("https://oauth2.googleapis.com/token");
+    debug!("Exchange code with token: {}", oauth_redirect.code);
+    let paylod = json!({
+        "client_id": client_id,
+        "client_secret": client_secret,
+        "code": oauth_redirect.code,
+        "grant_type": "authorization_code",
+        "redirect_uri": "http://localhost:8000"
+    });
+    let builder = Client::new().post(base_url).json(&paylod);
+    network::request(builder).await
+}

crates/smbcloud-networking-account/src/oauth/get_token.rs

@@ -0,0 +1,2 @@
+pub mod get_profile;
+pub mod get_token;