✨ 添加脱机蹲饼器配置信息接口

src/router/front_end/config/datasource.rs

@@ -1,4 +1,7 @@
-use axum::{routing::get, Router};
+use axum::{
+    routing::{get, post},
+    Router,
+};
 
 use crate::router::ServerRoute;
 
@@ -7,4 +10,8 @@ pub struct ConfigDatasourceFrontend;
 pub(super) fn datasource_router() -> ServerRoute {
     Router::new()
         .route("/list", get(ConfigDatasourceFrontend::datasource_list))
+        .route(
+            "/standalone-fetcher-config",
+            post(ConfigDatasourceFrontend::standalone_fetcher_config),
+        )
 }

src/serves/frontend/config/datasource/controllers.rs

@@ -1,10 +1,20 @@
+use axum::extract::{Path, State};
+use bitmap_convert::{
+    base70::BitmapBase70Conv, vec_usize::BitmapVecUsizeConv,
+};
+use bitmaps::Bitmap;
 use fetcher::{datasource_config::ToDatasource, ToFetcher};
+use general_request_client::{client::RequestClient, traits::Requester};
+use http::Method;
 use orm_migrate::{
     sql_connection::SqlDatabaseOperate,
     sql_models::fetcher::datasource_config::models::model_datasource_config::FrontendDatasource,
 };
-use resp_result::rtry;
+use resp_result::{resp_try, rtry};
+use scheduler_notifier::SchedulerUrl;
+use serde_json::{json, Value};
 use tracing::instrument;
+use url::Url;
 
 use crate::{
     router::ConfigDatasourceFrontend,
@@ -22,4 +32,59 @@ impl ConfigDatasourceFrontend {
         ))
         .into()
     }
+    #[instrument(skip(request_client))]
+    // #[axum_macros::debug_handler]
+    pub async fn standalone_fetcher_config(
+        Path(combine_id): Path<String>,
+        State(request_client): State<RequestClient>,
+        State(url): State<SchedulerUrl>,
+    ) -> DatasourceRResult<Value> {
+        struct StandAloneFetcherConfigRequester {
+            url: SchedulerUrl,
+            bitmap: Vec<usize>,
+        }
+
+        impl Requester for StandAloneFetcherConfigRequester {
+            const METHOD: http::Method = Method::POST;
+
+            fn get_url(&self) -> Url {
+                self.url.take_url()
+            }
+            fn prepare_request<
+                B: general_request_client::traits::RequestBuilder,
+            >(
+                self, builder: B,
+            ) -> Result<B::Request, B::Error> {
+                builder
+                    .body(
+                        json!({"datasource_id_list":self.bitmap})
+                            .to_string()
+                            .into_bytes(),
+                    )
+                    .build()
+            }
+        }
+
+        resp_try(async {
+            let bitmap = Bitmap::<256>::from_base_70(combine_id)
+                .map(|bitmap| bitmap.bitmap_to_usize())?;
+
+            let resp = request_client
+                .send_request(StandAloneFetcherConfigRequester {
+                    url,
+                    bitmap,
+                })
+                .await?;
+            #[derive(serde::Deserialize)]
+            struct ConfigPayload {
+                #[serde(rename = "code")]
+                _code: i32,
+                config: Value,
+            }
+            let ConfigPayload { config, .. } =
+                resp.json::<ConfigPayload>().await?;
+            Ok(config)
+        })
+        .await
+    }
 }

src/serves/frontend/config/datasource/error.rs

@@ -9,6 +9,8 @@ error_generate! {
 
     Query = QueryRejection
     DatasourceOperate = DatasourceOperateError
+    Base70ConvBitmap = bitmap_convert::error::Error
+    RequestError = reqwest::Error
 }
 
 pub type DatasourceRResult<T> = RespResult<T, DatasourceError>;