✨ adds profile api

Konnektoren · Jun 30, 2024 · a6f3e53 · a6f3e53
1 parent 3d38886
commit a6f3e53
Show file tree

Hide file tree

Showing 9 changed files with 106 additions and 45 deletions.
diff --git a/Cargo.toml b/Cargo.toml
@@ -24,4 +24,6 @@ gloo-timers = "0.3.0"
 gloo-utils = "0.2.0"
 web-sys = { version="0.3.69", features = ["HtmlAudioElement"] }
 serde = { version = "1.0.203", features = ["derive"] }
-serde_json = "1.0.117"
+serde_json = "1.0.117"
+reqwest = { version = "0.12.5", features = ["json"] }
+anyhow = "1.0.86"
diff --git a/src/api/mod.rs b/src/api/mod.rs
@@ -0,0 +1 @@
+pub mod profile;
diff --git a/src/api/profile.rs b/src/api/profile.rs
@@ -0,0 +1,24 @@
+use anyhow::Result;
+use konnektoren_core::prelude::PlayerProfile;
+
+pub async fn fetch_profile(id: String, name: String) -> Result<PlayerProfile> {
+    let url = format!("https://api.konnektoren.help/api/v1/profiles/{}", id);
+
+    save_profile(PlayerProfile {
+        id: id.clone(),
+        name: name.clone(),
+        xp: 0,
+    })
+    .await?;
+
+    let response = reqwest::get(&url).await?;
+    let profile = response.json::<PlayerProfile>().await?;
+    Ok(profile)
+}
+
+pub async fn save_profile(profile: PlayerProfile) -> Result<()> {
+    let url = format!("https://api.konnektoren.help/api/v1/profiles");
+    let client = reqwest::Client::new();
+    let _response = client.post(&url).json(&profile).send().await?;
+    Ok(())
+}
diff --git a/src/app.rs b/src/app.rs
@@ -1,3 +1,4 @@
+use crate::api::profile::fetch_profile;
 use crate::challenge::ChallengeComp;
 use crate::footer::FooterComp;
 use crate::points::PointsComp;
@@ -12,6 +13,24 @@ pub fn app() -> Html {
 
     use_effect(move || {
         telegram::ready();
+
+        wasm_bindgen_futures::spawn_local(async move {
+            let id: String = telegram::get_user_id()
+                .await
+                .expect("error getting id")
+                .as_string()
+                .expect("error converting id");
+            let username: String = telegram::get_user_name()
+                .await
+                .expect("error getting username")
+                .as_string()
+                .expect("error converting username");
+
+            let profile = fetch_profile(id, username)
+                .await
+                .expect("error loading profile");
+            log::info!("Profile: {:?}", profile);
+        });
     });
 
     let on_address = {

diff --git a/src/challenge.rs b/src/challenge.rs
@@ -7,8 +7,8 @@ use konnektoren_core::{
 use konnektoren_yew::components::challenge::{
     ChallengeComponent, ChallengeEvent, ResultSummaryComponent,
 };
-use web_sys::HtmlAudioElement;
 use std::ops::Div;
+use web_sys::HtmlAudioElement;
 use yew::prelude::*;
 
 #[derive(Properties, PartialEq)]

diff --git a/src/claim.rs b/src/claim.rs
@@ -1,8 +1,8 @@
+use gloo_utils::format::JsValueSerdeExt;
+use serde::Deserialize;
 use wasm_bindgen::prelude::*;
 use wasm_bindgen_futures::{js_sys::Promise, JsFuture};
 use yew::prelude::*;
-use serde::Deserialize;
-use gloo_utils::format::JsValueSerdeExt;
 
 #[wasm_bindgen(module = "/src/js/confetti.js")]
 extern "C" {
@@ -74,60 +74,60 @@ pub fn claim_comp(props: &ClaimCompProps) -> Html {
             let claim_state = claim_state.clone();
 
             wasm_bindgen_futures::spawn_local(async move {
-
                 match CLAIM_VERSION {
-                    ClaimVersion::V1 => {
-                        match JsFuture::from(claim(&address, amount)).await {
-                            Ok(result) => {
-                                log::info!("Claim successful: {:?}", result);
-                                let explorer_url = result.as_string().unwrap_or_default();
-                                log::info!("Claim successful: {}", explorer_url);
-                                claim_state.set(ClaimState::Done(explorer_url));
-                            }
-                            Err(e) => {
-                                let error_message = format!("{:?}", e);
-                                log::error!("Claim failed: {}", error_message);
-                                claim_state.set(ClaimState::Error(error_message));
-                            }
+                    ClaimVersion::V1 => match JsFuture::from(claim(&address, amount)).await {
+                        Ok(result) => {
+                            log::info!("Claim successful: {:?}", result);
+                            let explorer_url = result.as_string().unwrap_or_default();
+                            log::info!("Claim successful: {}", explorer_url);
+                            claim_state.set(ClaimState::Done(explorer_url));
+                        }
+                        Err(e) => {
+                            let error_message = format!("{:?}", e);
+                            log::error!("Claim failed: {}", error_message);
+                            claim_state.set(ClaimState::Error(error_message));
                         }
-                    }
-                    ClaimVersion::V2 => {
-                        match JsFuture::from(claim_v2(&address, amount)).await {
-                            Ok(result) => {
-                                match result.into_serde::<RawTransaction>() {
-                                    Ok(raw_tx) => {
-                                        if raw_tx.success {
-                                            match JsFuture::from(sendRawTransaction(&raw_tx.raw_transaction, &raw_tx.destination)).await {
-                                                Ok(_) => {
-                                                    log::info!("Transaction sent successfully");
-                                                    claim_state.set(ClaimState::Done("Transaction sent successfully".to_string()));
-                                                }
-                                                Err(e) => {
-                                                    let error_message = format!("{:?}", e);
-                                                    log::error!("Transaction failed: {}", error_message);
-                                                    claim_state.set(ClaimState::Error(error_message));
-                                                }
-                                            }
-                                        } else {
-                                            let error_message = "Failed to get raw transaction".to_string();
-                                            log::error!("{}", error_message);
+                    },
+                    ClaimVersion::V2 => match JsFuture::from(claim_v2(&address, amount)).await {
+                        Ok(result) => match result.into_serde::<RawTransaction>() {
+                            Ok(raw_tx) => {
+                                if raw_tx.success {
+                                    match JsFuture::from(sendRawTransaction(
+                                        &raw_tx.raw_transaction,
+                                        &raw_tx.destination,
+                                    ))
+                                    .await
+                                    {
+                                        Ok(_) => {
+                                            log::info!("Transaction sent successfully");
+                                            claim_state.set(ClaimState::Done(
+                                                "Transaction sent successfully".to_string(),
+                                            ));
+                                        }
+                                        Err(e) => {
+                                            let error_message = format!("{:?}", e);
+                                            log::error!("Transaction failed: {}", error_message);
                                             claim_state.set(ClaimState::Error(error_message));
                                         }
                                     }
-                                    Err(e) => {
-                                        let error_message = format!("{:?}", e);
-                                        log::error!("Claim failed: {}", error_message);
-                                        claim_state.set(ClaimState::Error(error_message));
-                                    }
+                                } else {
+                                    let error_message = "Failed to get raw transaction".to_string();
+                                    log::error!("{}", error_message);
+                                    claim_state.set(ClaimState::Error(error_message));
                                 }
                             }
                             Err(e) => {
                                 let error_message = format!("{:?}", e);
                                 log::error!("Claim failed: {}", error_message);
                                 claim_state.set(ClaimState::Error(error_message));
                             }
+                        },
+                        Err(e) => {
+                            let error_message = format!("{:?}", e);
+                            log::error!("Claim failed: {}", error_message);
+                            claim_state.set(ClaimState::Error(error_message));
                         }
-                    }
+                    },
                 }
             });
         })

diff --git a/src/js/telegram.js b/src/js/telegram.js
@@ -6,6 +6,14 @@ export function tma_version() {
     return Telegram.WebApp.version;
 }
 
+export function tma_get_user_id() {
+    return Telegram.WebApp.initDataUnsafe.user.id;
+}
+
+export function tma_get_user_name() {
+    return Telegram.WebApp.initDataUnsafe.user.username;
+}
+
 export function tma_set_header_color(color) {
     return Telegram.WebApp.setHeaderColor(color);
 }

diff --git a/src/lib.rs b/src/lib.rs
@@ -1,3 +1,4 @@
+pub mod api;
 pub mod app;
 pub mod challenge;
 pub mod claim;

diff --git a/src/telegram.rs b/src/telegram.rs
@@ -16,4 +16,10 @@ extern "C" {
 
     #[wasm_bindgen(catch, js_name = tma_get_item)]
     pub async fn get_item(key: &str) -> Result<JsValue, JsValue>;
+
+    #[wasm_bindgen(catch, js_name = tma_get_user_id)]
+    pub async fn get_user_id() -> Result<JsValue, JsValue>;
+
+    #[wasm_bindgen(catch, js_name = tma_get_user_name)]
+    pub async fn get_user_name() -> Result<JsValue, JsValue>;
 }