add custom_api directory with create and update

src/endpoints/admin/balance/create_balance.rs

@@ -72,6 +72,8 @@ pub async fn handler(
         discord_guild_id: None,
         quiz_name: None,
         contracts: Some(parsed_contracts),
+        api_url: None,
+        regex: None,
     };
 
     // insert document to boost collection

src/endpoints/admin/custom/create_custom.rs

@@ -63,6 +63,8 @@ pub async fn handler(
         discord_guild_id: None,
         quiz_name: None,
         contracts: None,
+        api_url: None,
+        regex: None,
     };
 
     // insert document to boost collection

src/endpoints/admin/custom_api/create_custom_api.rs

@@ -0,0 +1,89 @@
+use crate::models::{QuestDocument, QuestTaskDocument};
+use crate::utils::verify_quest_auth;
+use crate::{models::AppState, utils::get_error};
+use crate::middleware::auth::auth_middleware;
+use axum::{
+    extract::{Extension, State},
+    http::StatusCode,
+    response::{IntoResponse, Json}
+};
+use axum_auto_routes::route;
+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; CreateCustomAPI {
+    quest_id: i64,
+    name: String,
+    desc: String,
+    href: String,
+    cta: String,
+    api_url: String,
+    regex: String,
+});
+
+#[route(post, "/admin/tasks/custom_api/create", auth_middleware)]
+pub async fn handler(
+    State(state): State<Arc<AppState>>,
+    Extension(sub): Extension<String>,
+    Json(body): Json<CreateCustomAPI>,
+) -> impl IntoResponse {
+    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(sub, &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(),
+        total_amount: None,
+        quest_id: body.quest_id,
+        id: next_id,
+        cta: body.cta.clone(),
+        verify_endpoint: "quests/verify_custom_api".to_string(),
+        verify_endpoint_type: "default".to_string(),
+        task_type: Some("custom_api".to_string()),
+        discord_guild_id: None,
+        quiz_name: None,
+        contracts: None,
+        api_url: Some(body.api_url.clone()),
+        regex: Some(body.regex.clone()),
+    };
+
+    // 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()),
+    };
+}

src/endpoints/admin/custom_api/mod.rs

@@ -0,0 +1,2 @@
+pub mod create_custom_api;
+pub mod update_custom_api;

src/endpoints/admin/custom_api/update_custom_api.rs

@@ -0,0 +1,87 @@
+use crate::models::QuestTaskDocument;
+use crate::{models::AppState, utils::get_error};
+use crate::middleware::auth::auth_middleware;
+use crate::utils::verify_task_auth;
+
+use axum::{
+    extract::{Extension, State},
+    http::StatusCode,
+    response::{IntoResponse, Json},
+};
+use axum_auto_routes::route;
+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; UpdateCustomAPI {
+    id: i64,
+    name: Option<String>,
+    desc: Option<String>,
+    href: Option<String>,
+    cta: Option<String>,
+    api_url: Option<String>,
+    regex: 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/custom_api/update", auth_middleware)]
+pub async fn handler(
+    State(state): State<Arc<AppState>>,
+    Extension(sub): Extension<String>,
+    Json(body): Json<UpdateCustomAPI>,
+) -> impl IntoResponse {
+    let collection = state.db.collection::<QuestTaskDocument>("tasks");
+
+    let res = verify_task_auth(sub, &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(api_url) = &body.api_url {
+        update_doc.insert("api_url", api_url);
+    }
+    if let Some(regex) = &body.regex {
+        update_doc.insert("regex", regex);
+    }
+
+    // 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()),
+    };
+}

src/endpoints/admin/discord/create_discord.rs

@@ -62,6 +62,8 @@ pub async fn handler(
         quiz_name: None,
         verify_redirect: None,
         contracts: None,
+        api_url: None,
+        regex: None,
     };
 
     // insert document to boost collection

src/endpoints/admin/domain/create_domain.rs

@@ -59,6 +59,8 @@ pub async fn handler(
         quiz_name: None,
         verify_redirect: None,
         contracts: None,
+        api_url: None,
+        regex: None,
     };
 
     // insert document to boost collection

src/endpoints/admin/quiz/create_quiz.rs

@@ -90,6 +90,8 @@ pub async fn handler(
         discord_guild_id: None,
         verify_redirect: None,
         contracts: None,
+        api_url: None,
+        regex: None,
     };
 
     return match tasks_collection.insert_one(new_document, None).await {

src/endpoints/admin/twitter/create_twitter_fw.rs

@@ -63,6 +63,8 @@ pub async fn handler(
         discord_guild_id: None,
         quiz_name: None,
         contracts: None,
+        api_url: None,
+        regex: None,
     };
 
     // insert document to boost collection

src/endpoints/admin/twitter/create_twitter_rw.rs

@@ -61,6 +61,8 @@ pub async fn handler(
         discord_guild_id: None,
         quiz_name: None,
         contracts: None,
+        api_url: None,
+        regex: None,
     };
 
     // insert document to boost collection

src/models.rs

@@ -128,6 +128,8 @@ pub struct QuestTaskDocument {
     pub(crate) discord_guild_id: Option<String>,
     #[serde(default)]
     pub(crate) contracts: Option<Vec<FieldElement>>,
+    pub api_url: Option<String>,
+    pub regex: Option<String>,
 }
 
 pub_struct!(Serialize; Reward {