add: user seller_data

crates/app/src/routes/api/v1/auth/connections/stripe.rs

@@ -1,6 +1,7 @@
-use std::time::Duration;
+use std::{str::FromStr, time::Duration};
 
 use axum::{http::HeaderMap, response::IntoResponse, Extension, Json};
+use axum_extra::extract::CookieJar;
 use tetratto_core::model::{
     auth::{User, Notification},
     moderation::AuditLogEntry,
@@ -8,7 +9,7 @@ use tetratto_core::model::{
     ApiReturn, Error,
 };
 use stripe::{EventObject, EventType};
-use crate::State;
+use crate::{get_user_from_token, State};
 
 pub async fn stripe_webhook(
     Extension(data): Extension<State>,
@@ -320,3 +321,102 @@ pub async fn stripe_webhook(
         payload: (),
     })
 }
+
+pub async fn onboarding_account_link_request(
+    jar: CookieJar,
+    Extension(data): Extension<State>,
+) -> impl IntoResponse {
+    let data = &(data.read().await);
+    let user = match get_user_from_token!(jar, data.0) {
+        Some(ua) => ua,
+        None => return Json(Error::NotAllowed.into()),
+    };
+
+    let client = match data.3 {
+        Some(ref c) => c,
+        None => return Json(Error::Unknown.into()),
+    };
+
+    match stripe::AccountLink::create(
+        &client,
+        stripe::CreateAccountLink {
+            account: match user.seller_data.account_id {
+                Some(id) => stripe::AccountId::from_str(&id).unwrap(),
+                None => return Json(Error::NotAllowed.into()),
+            },
+            type_: stripe::AccountLinkType::AccountOnboarding,
+            collect: None,
+            expand: &[],
+            refresh_url: Some(&format!(
+                "{}/auth/connections_link/seller/refresh",
+                data.0.0.0.host
+            )),
+            return_url: Some(&format!(
+                "{}/auth/connections_link/seller/return",
+                data.0.0.0.host
+            )),
+            collection_options: None,
+        },
+    )
+    .await
+    {
+        Ok(x) => Json(ApiReturn {
+            ok: true,
+            message: "Acceptable".to_string(),
+            payload: Some(x.url),
+        }),
+        Err(e) => Json(Error::MiscError(e.to_string()).into()),
+    }
+}
+
+pub async fn create_seller_account_request(
+    jar: CookieJar,
+    Extension(data): Extension<State>,
+) -> impl IntoResponse {
+    let data = &(data.read().await);
+    let mut user = match get_user_from_token!(jar, data.0) {
+        Some(ua) => ua,
+        None => return Json(Error::NotAllowed.into()),
+    };
+
+    let client = match data.3 {
+        Some(ref c) => c,
+        None => return Json(Error::Unknown.into()),
+    };
+
+    let account = match stripe::Account::create(
+        &client,
+        stripe::CreateAccount {
+            type_: Some(stripe::AccountType::Express),
+            capabilities: Some(stripe::CreateAccountCapabilities {
+                card_payments: Some(stripe::CreateAccountCapabilitiesCardPayments {
+                    requested: Some(true),
+                }),
+                transfers: Some(stripe::CreateAccountCapabilitiesTransfers {
+                    requested: Some(true),
+                }),
+                ..Default::default()
+            }),
+            ..Default::default()
+        },
+    )
+    .await
+    {
+        Ok(a) => a,
+        Err(e) => return Json(Error::MiscError(e.to_string()).into()),
+    };
+
+    user.seller_data.account_id = Some(account.id.to_string());
+    match data
+        .0
+        .update_user_seller_data(user.id, user.seller_data)
+        .await
+    {
+        Ok(_) => Json(ApiReturn {
+            ok: true,
+            message: "Acceptable".to_string(),
+            payload: (),
+        }),
+        Err(e) => return Json(e.into()),
+    }
+}

crates/app/src/routes/api/v1/mod.rs

@@ -512,6 +512,14 @@ pub fn routes() -> Router {
             "/service_hooks/stripe",
             post(auth::connections::stripe::stripe_webhook),
         )
+        .route(
+            "/service_hooks/stripe/seller/register",
+            post(auth::connections::stripe::create_seller_account_request),
+        )
+        .route(
+            "/service_hooks/stripe/seller/onboarding",
+            post(auth::connections::stripe::onboarding_account_link_request),
+        )
         // channels
         .route("/channels", post(channels::channels::create_request))
         .route(

crates/app/src/routes/assets.rs

@@ -19,5 +19,4 @@ serve_asset!(atto_js_request: ATTO_JS("text/javascript"));
 serve_asset!(me_js_request: ME_JS("text/javascript"));
 serve_asset!(streams_js_request: STREAMS_JS("text/javascript"));
 serve_asset!(carp_js_request: CARP_JS("text/javascript"));
-serve_asset!(layout_editor_js_request: LAYOUT_EDITOR_JS("text/javascript"));
 serve_asset!(proto_links_request: PROTO_LINKS_JS("text/javascript"));

crates/app/src/routes/mod.rs

@@ -20,10 +20,6 @@ pub fn routes(config: &Config) -> Router {
         .route("/js/me.js", get(assets::me_js_request))
         .route("/js/streams.js", get(assets::streams_js_request))
         .route("/js/carp.js", get(assets::carp_js_request))
-        .route(
-            "/js/layout_editor.js",
-            get(assets::layout_editor_js_request),
-        )
         .route("/js/proto_links.js", get(assets::proto_links_request))
         .nest_service(
             "/public",

crates/app/src/routes/pages/mod.rs

@@ -17,11 +17,10 @@ use axum::{
 use axum_extra::extract::CookieJar;
 use serde::Deserialize;
 use tetratto_core::{
-    DataManager,
     model::{Error, auth::User},
 };
 
-use crate::{assets::initial_context, get_lang};
+use crate::{assets::initial_context, get_lang, InnerState};
 
 pub fn routes() -> Router {
     Router::new()
@@ -156,7 +155,7 @@ pub fn lw_routes() -> Router {
 pub async fn render_error(
     e: Error,
     jar: &CookieJar,
-    data: &(DataManager, tera::Tera, reqwest::Client),
+    data: &InnerState,
     user: &Option<User>,
 ) -> String {
     let lang = get_lang!(jar, data.0);