feat(providers): 适配供应商，抽象接口

Cargo.toml

@@ -42,4 +42,5 @@ hex = "0.4.3"
 dotenv = "0.15.0"
 bytes = "1.11.1"
 rand = "0.10.1"
-retry = "2.2.0"
+retry = "2.2.0"
+async-trait = "0.1.89"

src/core/providers/claude_messages/adapter.rs

@@ -0,0 +1,18 @@
+use crate::core::providers::claude_messages::request::ClaudeMessage;
+use crate::core::providers::types::{Message, Role};
+
+impl From<Message> for ClaudeMessage {
+    fn from(value: Message) -> Self {
+        Self {
+            role: match value.role {
+                Role::User => "user",
+                Role::Assistant => "assistant",
+
+                Role::System => "user",
+            }
+                .into(),
+
+            content: value.content,
+        }
+    }
+}

src/core/providers/claude_messages/mod.rs

@@ -0,0 +1,4 @@
+mod request;
+mod response;
+mod adapter;
+mod provider;

src/core/providers/claude_messages/provider.rs

@@ -0,0 +1,57 @@
+use async_trait::async_trait;
+use reqwest::Client;
+use crate::core::providers::claude_messages::request::ClaudeRequest;
+use crate::core::providers::claude_messages::response::ClaudeResponse;
+use crate::core::providers::provider::Provider;
+use crate::core::providers::types::{CompletionRequest, CompletionResponse};
+
+pub struct ClaudeProvider {
+    client: Client,
+
+    api_key: String,
+}
+
+impl ClaudeProvider {
+    pub fn new(
+        api_key: String,
+    ) -> Self {
+        Self {
+            client: Client::new(),
+            api_key,
+        }
+    }
+}
+
+#[async_trait]
+impl Provider for ClaudeProvider {
+    async fn complete(
+        &self,
+        request: CompletionRequest,
+    ) -> Result<CompletionResponse> {
+
+        let body =
+            ClaudeRequest::from(request);
+
+        let resp = self
+            .client
+            .post(
+                "https://api.anthropic.com/v1/messages"
+            )
+            .header(
+                "x-api-key",
+                &self.api_key,
+            )
+            .header(
+                "anthropic-version",
+                "2023-06-01",
+            )
+            .json(&body)
+            .send()
+            .await?;
+
+        let response: ClaudeResponse =
+            resp.json().await?;
+
+        Ok(response.into())
+    }
+}