feat(transport): Client 抽离出 HTTP Transport

Author: bao-cn

Cargo.lock

@@ -41,4 +41,5 @@ thiserror = "2.0.18"
 hex = "0.4.3"
 dotenv = "0.15.0"
 bytes = "1.11.1"
-rand = "0.10.1"
+rand = "0.10.1"
+retry = "2.2.0"

Cargo.toml

@@ -0,0 +1,37 @@
+use reqwest::{Client, Request, Response};
+use crate::core::client::config::ClientConfig;
+
+#[derive(Clone)]
+pub struct BaseClient {
+    inner: Client,
+}
+
+impl BaseClient {
+    pub fn new(config: ClientConfig) -> anyhow::Result<Self> {
+        let mut builder = Client::builder()
+            .timeout(config.timeout)
+            .connect_timeout(config.connect_timeout)
+            .user_agent(config.user_agent);
+
+        if let Some(proxy) = config.proxy {
+            builder = builder.proxy(reqwest::Proxy::all(proxy)?);
+        }
+
+        let client = builder.build()?;
+
+        Ok(Self {
+            inner: client,
+        })
+    }
+
+    pub async fn execute(
+        &self,
+        request: Request,
+    ) -> Result<Response, reqwest::Error> {
+        self.inner.execute(request).await
+    }
+
+    pub fn inner(&self) -> &Client {
+        &self.inner
+    }
+}

src/core/client/base_client.rs

@@ -0,0 +1,20 @@
+use std::time::Duration;
+
+#[derive(Clone)]
+pub struct ClientConfig {
+    pub timeout: Duration,
+    pub connect_timeout: Duration,
+    pub proxy: Option<String>,
+    pub user_agent: String,
+}
+
+impl Default for ClientConfig {
+    fn default() -> Self {
+        Self {
+            timeout: Duration::from_secs(300),
+            connect_timeout: Duration::from_secs(10),
+            proxy: None,
+            user_agent: "agent-runtime/0.1.0".into(),
+        }
+    }
+}