-
Notifications
You must be signed in to change notification settings - Fork 44
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #229 from starknet-id/feat/nimbora-quest-2
feat: adding balance tasks
- Loading branch information
Showing
18 changed files
with
433 additions
and
153 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,91 @@ | ||
| use crate::models::{JWTClaims, QuestDocument, QuestTaskDocument}; | ||
| use crate::utils::verify_quest_auth; | ||
| use crate::{models::AppState, utils::get_error}; | ||
| use axum::http::HeaderMap; | ||
| use axum::{ | ||
| extract::State, | ||
| http::StatusCode, | ||
| response::{IntoResponse, Json}, | ||
| }; | ||
| use axum_auto_routes::route; | ||
| use jsonwebtoken::{decode, Algorithm, DecodingKey, Validation}; | ||
| use mongodb::bson::doc; | ||
| use mongodb::options::FindOneOptions; | ||
| use serde::Deserialize; | ||
| use serde_json::json; | ||
| use starknet::core::types::FieldElement; | ||
| use std::str::FromStr; | ||
| use std::sync::Arc; | ||
|
|
||
| pub_struct!(Deserialize; CreateBalance { | ||
| quest_id: i64, | ||
| name: String, | ||
| desc: String, | ||
| contracts: String, | ||
| href: String, | ||
| cta: String, | ||
| }); | ||
|
|
||
| #[route( | ||
| post, | ||
| "/admin/tasks/balance/create", | ||
| crate::endpoints::admin::balance::create_balance | ||
| )] | ||
| pub async fn handler( | ||
| State(state): State<Arc<AppState>>, | ||
| headers: HeaderMap, | ||
| body: Json<CreateBalance>, | ||
| ) -> impl IntoResponse { | ||
| let user = check_authorization!(headers, &state.conf.auth.secret_key.as_ref()) as String; | ||
| let collection = state.db.collection::<QuestTaskDocument>("tasks"); | ||
| // Get the last id in increasing order | ||
| let last_id_filter = doc! {}; | ||
| let options = FindOneOptions::builder().sort(doc! {"id": -1}).build(); | ||
| let last_doc = &collection.find_one(last_id_filter, options).await.unwrap(); | ||
|
|
||
| let quests_collection = state.db.collection::<QuestDocument>("quests"); | ||
|
|
||
| let res = verify_quest_auth(user, &quests_collection, &(body.quest_id as i64)).await; | ||
| if !res { | ||
| return get_error("Error creating task".to_string()); | ||
| }; | ||
|
|
||
| let mut next_id = 1; | ||
| if let Some(doc) = last_doc { | ||
| let last_id = doc.id; | ||
| next_id = last_id + 1; | ||
| } | ||
|
|
||
| // Build a vector of FieldElement from the comma separated contracts string | ||
| let parsed_contracts: Vec<FieldElement> = body | ||
| .contracts | ||
| .split(",") | ||
| .map(|x| FieldElement::from_str(&x).unwrap()) | ||
| .collect(); | ||
|
|
||
| let new_document = QuestTaskDocument { | ||
| name: body.name.clone(), | ||
| desc: body.desc.clone(), | ||
| verify_redirect: None, | ||
| href: body.href.clone(), | ||
| quest_id: body.quest_id, | ||
| id: next_id, | ||
| cta: body.cta.clone(), | ||
| verify_endpoint: "/quests/verify_balance".to_string(), | ||
| verify_endpoint_type: "default".to_string(), | ||
| task_type: Some("balance".to_string()), | ||
| discord_guild_id: None, | ||
| quiz_name: None, | ||
| contracts: Some(parsed_contracts), | ||
| }; | ||
|
|
||
| // insert document to boost collection | ||
| return match collection.insert_one(new_document, None).await { | ||
| Ok(_) => ( | ||
| StatusCode::OK, | ||
| Json(json!({"message": "Task created successfully"})).into_response(), | ||
| ) | ||
| .into_response(), | ||
| Err(_e) => get_error("Error creating tasks".to_string()), | ||
| }; | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,2 @@ | ||
| pub mod create_balance; | ||
| pub mod update_balance; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,94 @@ | ||
| use crate::models::{JWTClaims, QuestTaskDocument}; | ||
| use crate::utils::verify_task_auth; | ||
| use crate::{models::AppState, utils::get_error}; | ||
| use axum::http::HeaderMap; | ||
| use axum::{ | ||
| extract::State, | ||
| http::StatusCode, | ||
| response::{IntoResponse, Json}, | ||
| }; | ||
| use axum_auto_routes::route; | ||
| use jsonwebtoken::{decode, Algorithm, DecodingKey, Validation}; | ||
| use mongodb::bson::doc; | ||
| use serde::Deserialize; | ||
| use serde_json::json; | ||
| use starknet::core::types::FieldElement; | ||
| use std::str::FromStr; | ||
| use std::sync::Arc; | ||
|
|
||
| pub_struct!(Deserialize; CreateBalance { | ||
| id: i64, | ||
| name: Option<String>, | ||
| desc: Option<String>, | ||
| contracts: Option<String>, | ||
| href: Option<String>, | ||
| cta: Option<String>, | ||
| }); | ||
|
|
||
| // Helper function to convert FieldElement to Bson | ||
| fn field_element_to_bson(fe: &FieldElement) -> mongodb::bson::Bson { | ||
| mongodb::bson::Bson::String(fe.to_string()) | ||
| } | ||
|
|
||
| #[route( | ||
| post, | ||
| "/admin/tasks/balance/update", | ||
| crate::endpoints::admin::balance::update_balance | ||
| )] | ||
| pub async fn handler( | ||
| State(state): State<Arc<AppState>>, | ||
| headers: HeaderMap, | ||
| body: Json<CreateBalance>, | ||
| ) -> impl IntoResponse { | ||
| let user = check_authorization!(headers, &state.conf.auth.secret_key.as_ref()) as String; | ||
| let collection = state.db.collection::<QuestTaskDocument>("tasks"); | ||
|
|
||
| let res = verify_task_auth(user, &collection, &(body.id as i32)).await; | ||
| if !res { | ||
| return get_error("Error updating tasks".to_string()); | ||
| } | ||
|
|
||
| // filter to get existing quest | ||
| let filter = doc! { | ||
| "id": &body.id, | ||
| }; | ||
|
|
||
| let mut update_doc = doc! {}; | ||
|
|
||
| if let Some(name) = &body.name { | ||
| update_doc.insert("name", name); | ||
| } | ||
| if let Some(desc) = &body.desc { | ||
| update_doc.insert("desc", desc); | ||
| } | ||
| if let Some(href) = &body.href { | ||
| update_doc.insert("href", href); | ||
| } | ||
| if let Some(cta) = &body.cta { | ||
| update_doc.insert("cta", cta); | ||
| } | ||
| if let Some(contracts) = &body.contracts { | ||
| let parsed_contracts: Vec<FieldElement> = contracts | ||
| .split(",") | ||
| .map(|x| FieldElement::from_str(&x).unwrap()) | ||
| .collect(); | ||
| let contracts_bson: Vec<mongodb::bson::Bson> = | ||
| parsed_contracts.iter().map(field_element_to_bson).collect(); | ||
| update_doc.insert("contracts", contracts_bson); | ||
| } | ||
|
|
||
| // update quest query | ||
| let update = doc! { | ||
| "$set": update_doc | ||
| }; | ||
|
|
||
| // insert document to boost collection | ||
| return match collection.find_one_and_update(filter, update, None).await { | ||
| Ok(_) => ( | ||
| StatusCode::OK, | ||
| Json(json!({"message": "Task updated successfully"})).into_response(), | ||
| ) | ||
| .into_response(), | ||
| Err(_e) => get_error("Error updating tasks".to_string()), | ||
| }; | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.