refactor api-nango

Signed-off-by: Yujong Lee <yujonglee.dev@gmail.com>

Author: yujonglee

Cargo.lock

@@ -23,3 +23,10 @@ tracing = { workspace = true }
 serde = { workspace = true, features = ["derive"] }
 serde_json = { workspace = true }
 thiserror = { workspace = true }
+
+[dev-dependencies]
+hex = "0.4"
+hmac = { workspace = true }
+sha2 = { workspace = true }
+tokio = { workspace = true }
+wiremock = { workspace = true }

crates/api-nango/Cargo.toml

@@ -22,6 +22,19 @@ impl NangoConfig {
             supabase_service_role_key,
         }
     }
+
+    #[cfg(test)]
+    pub(crate) fn for_test(nango_base: &str, supabase_base: &str) -> Self {
+        Self {
+            nango: NangoEnv {
+                nango_api_base: Some(nango_base.to_string()),
+                nango_secret_key: "test-secret".to_string(),
+            },
+            supabase_url: supabase_base.to_string(),
+            supabase_anon_key: "test-anon-key".to_string(),
+            supabase_service_role_key: Some("test-service-role-key".to_string()),
+        }
+    }
 }
 
 pub(crate) fn build_nango_client(config: &NangoConfig) -> Result<NangoClient, hypr_nango::Error> {

crates/api-nango/src/config.rs

@@ -0,0 +1,58 @@
+use hypr_nango::OwnedNangoProxy;
+
+#[derive(serde::Deserialize)]
+struct GoogleUserInfo {
+    email: Option<String>,
+    name: Option<String>,
+}
+
+#[derive(serde::Deserialize)]
+struct OutlookMe {
+    mail: Option<String>,
+    #[serde(rename = "userPrincipalName")]
+    user_principal_name: Option<String>,
+    #[serde(rename = "displayName")]
+    display_name: Option<String>,
+}
+
+pub(crate) async fn fetch_identity(
+    nango: &hypr_nango::NangoClient,
+    integration_id: &str,
+    connection_id: &str,
+) -> std::result::Result<(Option<String>, Option<String>), String> {
+    let proxy = OwnedNangoProxy::new(nango, integration_id.to_string(), connection_id.to_string());
+
+    match integration_id {
+        // https://docs.cloud.google.com/identity-platform/docs/reference/rest/v1/UserInfo
+        "google-calendar" | "google-drive" => {
+            let resp = proxy
+                .get("/oauth2/v1/userinfo?alt=json")
+                .map_err(|e| e.to_string())?
+                .send()
+                .await
+                .map_err(|e| e.to_string())?
+                .error_for_status()
+                .map_err(|e| e.to_string())?;
+
+            let me: GoogleUserInfo = resp.json().await.map_err(|e| e.to_string())?;
+            Ok((me.email, me.name))
+        }
+
+        // https://learn.microsoft.com/en-us/graph/api/user-get
+        "outlook" => {
+            let resp = proxy
+                .get("/v1.0/me?$select=mail,userPrincipalName,displayName")
+                .map_err(|e| e.to_string())?
+                .send()
+                .await
+                .map_err(|e| e.to_string())?
+                .error_for_status()
+                .map_err(|e| e.to_string())?;
+
+            let me: OutlookMe = resp.json().await.map_err(|e| e.to_string())?;
+            Ok((me.mail.or(me.user_principal_name), me.display_name))
+        }
+
+        other => Err(format!("unsupported integration: {other}")),
+    }
+}

crates/api-nango/src/routes/identity.rs

@@ -1,5 +1,6 @@
 pub(crate) mod connect;
 pub(crate) mod disconnect;
+pub(crate) mod identity;
 pub(crate) mod status;
 pub(crate) mod webhook;
 pub(crate) mod whoami;