From 571d1022f628cb7d2a3125664bd3293bac4471b5 Mon Sep 17 00:00:00 2001 From: sigoden Date: Sat, 1 Jun 2024 17:47:49 +0800 Subject: refactor: rename some client structs and methods (#555) * rename `Completeion*` to `ChatCompletions*` * rename `send_message*` to `chat_completions*` * rename `request_builder` to `chat_completions_builder` * rename `build_body` to `build_chat_completions_body` * rename `extract_completion` to `extract_chat_completions` * format * remove unused config fields --- src/client/vertexai_claude.rs | 29 +++++++++++++++-------------- 1 file changed, 15 insertions(+), 14 deletions(-) (limited to 'src/client/vertexai_claude.rs') diff --git a/src/client/vertexai_claude.rs b/src/client/vertexai_claude.rs index fd06518..bdce7d8 100644 --- a/src/client/vertexai_claude.rs +++ b/src/client/vertexai_claude.rs @@ -1,6 +1,7 @@ use super::{ - access_token::*, claude::*, vertexai::*, Client, CompletionData, CompletionOutput, ExtraConfig, - Model, ModelData, ModelPatches, PromptAction, PromptKind, SseHandler, VertexAIClaudeClient, + access_token::*, claude::*, vertexai::*, ChatCompletionsData, ChatCompletionsOutput, Client, + ExtraConfig, Model, ModelData, ModelPatches, PromptAction, PromptKind, SseHandler, + VertexAIClaudeClient, }; use anyhow::Result; @@ -29,10 +30,10 @@ impl VertexAIClaudeClient { ("location", "Location", true, PromptKind::String), ]; - fn request_builder( + fn chat_completions_builder( &self, client: &ReqwestClient, - data: CompletionData, + data: ChatCompletionsData, ) -> Result { let project_id = self.get_project_id()?; let location = self.get_location()?; @@ -44,7 +45,7 @@ impl VertexAIClaudeClient { self.model.name() ); - let mut body = claude_build_body(data, &self.model)?; + let mut body = claude_build_chat_completions_body(data, &self.model)?; self.patch_request_body(&mut body); if let Some(body_obj) = body.as_object_mut() { body_obj.remove("model"); @@ -63,24 +64,24 @@ impl VertexAIClaudeClient { impl Client for VertexAIClaudeClient { client_common_fns!(); - async fn send_message_inner( + async fn chat_completions_inner( &self, client: &ReqwestClient, - data: CompletionData, - ) -> Result { + data: ChatCompletionsData, + ) -> Result { prepare_gcloud_access_token(client, self.name(), &self.config.adc_file).await?; - let builder = self.request_builder(client, data)?; - claude_send_message(builder).await + let builder = self.chat_completions_builder(client, data)?; + claude_chat_completions(builder).await } - async fn send_message_streaming_inner( + async fn chat_completions_streaming_inner( &self, client: &ReqwestClient, handler: &mut SseHandler, - data: CompletionData, + data: ChatCompletionsData, ) -> Result<()> { prepare_gcloud_access_token(client, self.name(), &self.config.adc_file).await?; - let builder = self.request_builder(client, data)?; - claude_send_message_streaming(builder, handler).await + let builder = self.chat_completions_builder(client, data)?; + claude_chat_completions_streaming(builder, handler).await } } -- cgit v1.2.3