upstream sync 0.23.1

Author: ifsheldon

async-openai-wasm/src/audio.rs

@@ -12,7 +12,7 @@ use crate::{
     },
 };
 
-/// Turn audio into text
+/// Turn audio into text or text into audio.
 /// Related guide: [Speech to text](https://platform.openai.com/docs/guides/speech-to-text)
 pub struct Audio<'c, C: Config> {
     client: &'c Client<C>,
@@ -69,6 +69,16 @@ impl<'c, C: Config> Audio<'c, C> {
         self.client.post_form("/audio/translations", request).await
     }
 
+    /// Transcribes audio into the input language.
+    pub async fn translate_raw(
+        &self,
+        request: CreateTranslationRequest,
+    ) -> Result<Bytes, OpenAIError> {
+        self.client
+            .post_form_raw("/audio/translations", request)
+            .await
+    }
+
     /// Generates audio from the input text.
     pub async fn speech(
         &self,

async-openai-wasm/src/types/chat.rs

@@ -483,6 +483,10 @@ pub struct CreateChatCompletionRequest {
     #[serde(skip_serializing_if = "Option::is_none")]
     pub tool_choice: Option<ChatCompletionToolChoiceOption>,
 
+    /// Whether to enable [parallel function calling](https://platform.openai.com/docs/guides/function-calling/parallel-function-calling) during tool use.
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub parallel_tool_calls: Option<bool>,
+
     /// A unique identifier representing your end-user, which can help OpenAI to monitor and detect abuse. [Learn more](https://platform.openai.com/docs/guides/safety-best-practices/end-user-ids).
     #[serde(skip_serializing_if = "Option::is_none")]
     pub user: Option<String>,

async-openai-wasm/src/types/message.rs

@@ -5,7 +5,7 @@ use serde::{Deserialize, Serialize};
 
 use crate::error::OpenAIError;
 
-use super::{AssistantToolsFileSearch, ImageDetail, ImageUrl};
+use super::{ImageDetail, ImageUrl};
 
 #[derive(Clone, Serialize, Debug, Deserialize, PartialEq, Default)]
 #[serde(rename_all = "lowercase")]
@@ -94,7 +94,7 @@ pub struct MessageAttachment {
 #[serde(rename_all = "snake_case")]
 pub enum MessageAttachmentTool {
     CodeInterpreter,
-    FileSearch(AssistantToolsFileSearch),
+    FileSearch,
 }
 
 #[derive(Clone, Serialize, Debug, Deserialize, PartialEq)]

async-openai-wasm/src/types/run.rs

@@ -79,6 +79,9 @@ pub struct RunObject {
 
     pub tool_choice: Option<AssistantsApiToolChoiceOption>,
 
+    /// Whether to enable [parallel function calling](https://platform.openai.com/docs/guides/function-calling/parallel-function-calling) during tool use.
+    pub parallel_tool_calls: bool,
+
     pub response_format: Option<AssistantsApiResponseFormatOption>,
 }
 
@@ -224,6 +227,9 @@ pub struct CreateRunRequest {
 
     pub tool_choice: Option<AssistantsApiToolChoiceOption>,
 
+    /// Whether to enable [parallel function calling](https://platform.openai.com/docs/guides/function-calling/parallel-function-calling) during tool use.
+    pub parallel_tool_calls: Option<bool>,
+
     pub response_format: Option<AssistantsApiResponseFormatOption>,
 }
 

async-openai-wasm/src/types/thread.rs

@@ -125,6 +125,10 @@ pub struct CreateThreadAndRunRequest {
     #[serde(skip_serializing_if = "Option::is_none")]
     pub tool_choice: Option<AssistantsApiToolChoiceOption>,
 
+    /// Whether to enable [parallel function calling](https://platform.openai.com/docs/guides/function-calling/parallel-function-calling) during tool use.
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub parallel_tool_calls: Option<bool>,
+
     #[serde(skip_serializing_if = "Option::is_none")]
     pub response_format: Option<AssistantsApiResponseFormatOption>,
 }

async-openai-wasm/src/types/vector_store.rs

@@ -63,7 +63,7 @@ pub struct VectorStoreObject {
     /// The Unix timestamp (in seconds) for when the vector store was created.
     pub created_at: u32,
     /// The name of the vector store.
-    pub name: String,
+    pub name: Option<String>,
     /// The total number of bytes used by the files in the vector store.
     pub usage_bytes: u64,
     pub file_counts: VectorStoreFileCounts,
@@ -192,7 +192,9 @@ pub enum VectorStoreFileErrorCode {
 pub enum VectorStoreFileObjectChunkingStrategy {
     /// This is returned when the chunking strategy is unknown. Typically, this is because the file was indexed before the `chunking_strategy` concept was introduced in the API.
     Other,
-    Static(StaticChunkingStrategy),
+    Static {
+        r#static: StaticChunkingStrategy,
+    },
 }
 
 #[derive(Debug, Serialize, Default, Clone, Builder, PartialEq)]

async-openai-wasm/src/vector_store_files.rs

@@ -75,3 +75,59 @@ impl<'c, C: Config> VectorStoreFiles<'c, C> {
             .await
     }
 }
+
+#[cfg(test)]
+mod tests {
+    use crate::types::{
+        CreateFileRequest, CreateVectorStoreFileRequest, CreateVectorStoreRequest, FileInput,
+        FilePurpose,
+    };
+    use crate::Client;
+
+    #[tokio::test]
+    async fn vector_store_file_creation_and_deletion(
+    ) -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
+        let client = Client::new();
+
+        // Create a file
+        let file_handle = client
+            .files()
+            .create(CreateFileRequest {
+                file: FileInput::from_vec_u8(
+                    String::from("meow.txt"),
+                    String::from(":3").into_bytes(),
+                ),
+                purpose: FilePurpose::Assistants,
+            })
+            .await?;
+
+        // Create a vector store
+        let vector_store_handle = client
+            .vector_stores()
+            .create(CreateVectorStoreRequest {
+                file_ids: Some(vec![file_handle.id.clone()]),
+                name: None,
+                expires_after: None,
+                chunking_strategy: None,
+                metadata: None,
+            })
+            .await?;
+        let vector_store_file = client
+            .vector_stores()
+            .files(&vector_store_handle.id)
+            .retrieve(&file_handle.id)
+            .await?;
+
+        assert_eq!(vector_store_file.id, file_handle.id);
+        // Delete the vector store
+        client
+            .vector_stores()
+            .delete(&vector_store_handle.id)
+            .await?;
+
+        // Delete the file
+        client.files().delete(&file_handle.id).await?;
+
+        Ok(())
+    }
+}