fix: format and examples

.github/workflows/pr-checks.yml

@@ -0,0 +1,43 @@
+name: PR Checks
+
+on:
+  pull_request:
+    types: [opened, synchronize, reopened]
+  pull_request_target:
+    types: [opened, synchronize, reopened]
+
+jobs:
+  build:
+    name: Build Workspace
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Checkout code
+        uses: actions/checkout@v4
+
+      - name: Install Rust
+        uses: actions-rs/toolchain@v1
+        with:
+          toolchain: stable
+          components: rustfmt, clippy
+          override: true
+
+      - name: Cache cargo registry
+        uses: actions/cache@v3
+        with:
+          path: |
+            ~/.cargo/registry
+            ~/.cargo/git
+            target
+          key: ${{ runner.os }}-cargo-${{ hashFiles('**/Cargo.lock') }}
+          restore-keys: |
+            ${{ runner.os }}-cargo-
+
+      - name: Build workspace
+        run: cargo build --workspace --verbose
+
+      - name: Check formatting
+        run: cargo fmt --all -- --check
+
+      # - name: Run clippy
+      #   run: cargo clippy --workspace -- -D warnings

async-openai/src/client.rs

@@ -487,7 +487,7 @@ async fn map_stream_error(value: EventSourceError) -> OpenAIError {
                 "Unreachable because read_response returns err when status_code {status_code} is invalid"
             ))
         }
-        _ => OpenAIError::StreamError(StreamError::ReqwestEventSource(value.into())),
+        _ => OpenAIError::StreamError(StreamError::ReqwestEventSource(value)),
     }
 }
 

async-openai/src/error.rs

@@ -1,7 +1,5 @@
 //! Errors originating from API calls, parsing responses, and reading-or-writing to the file system.
-use std::string::FromUtf8Error;
 
-use reqwest::{header::HeaderValue, Response};
 use serde::{Deserialize, Serialize};
 
 #[derive(Debug, thiserror::Error)]
@@ -82,10 +80,7 @@ pub struct WrappedError {
 
 pub(crate) fn map_deserialization_error(e: serde_json::Error, bytes: &[u8]) -> OpenAIError {
     let json_content = String::from_utf8_lossy(bytes);
-    tracing::error!(
-        "failed deserialization of: {}",
-        json_content
-    );
+    tracing::error!("failed deserialization of: {}", json_content);
 
     OpenAIError::JSONDeserialize(e, json_content.to_string())
 }

async-openai/src/file.rs

@@ -70,7 +70,7 @@ impl<'c, C: Config> Files<'c, C> {
 #[cfg(test)]
 mod tests {
     use crate::{
-        types::{CreateFileRequestArgs, FilePurpose, FileExpiresAfter, FileExpiresAfterAnchor},
+        types::{CreateFileRequestArgs, FileExpiresAfter, FileExpiresAfterAnchor, FilePurpose},
         Client,
     };
 
@@ -89,7 +89,10 @@ mod tests {
         let request = CreateFileRequestArgs::default()
             .file(test_file_path)
             .purpose(FilePurpose::FineTune)
-            .expires_after(FileExpiresAfter{ anchor: FileExpiresAfterAnchor::CreatedAt, seconds: 3600 })
+            .expires_after(FileExpiresAfter {
+                anchor: FileExpiresAfterAnchor::CreatedAt,
+                seconds: 3600,
+            })
             .build()
             .unwrap();
 

async-openai/src/types/file.rs

@@ -23,7 +23,7 @@ pub enum FilePurpose {
 pub enum FileExpiresAfterAnchor {
     #[default]
     #[serde(rename = "created_at")]
-    CreatedAt
+    CreatedAt,
 }
 
 #[derive(Debug, Default, Clone, PartialEq)]

async-openai/src/types/impls.rs

@@ -27,9 +27,9 @@ use super::{
     ChatCompletionRequestUserMessageContentPart, ChatCompletionToolChoiceOption, CreateFileRequest,
     CreateImageEditRequest, CreateImageVariationRequest, CreateMessageRequestContent,
     CreateSpeechResponse, CreateTranscriptionRequest, CreateTranslationRequest, DallE2ImageSize,
-    EmbeddingInput, FileInput, FilePurpose, FunctionName, Image, ImageInput, ImageModel,
-    ImageResponseFormat, ImageSize, ImageUrl, ImagesResponse, ModerationInput, Prompt, Role, Stop,
-    TimestampGranularity, FileExpiresAfterAnchor
+    EmbeddingInput, FileExpiresAfterAnchor, FileInput, FilePurpose, FunctionName, Image,
+    ImageInput, ImageModel, ImageResponseFormat, ImageSize, ImageUrl, ImagesResponse,
+    ModerationInput, Prompt, Role, Stop, TimestampGranularity,
 };
 
 /// for `impl_from!(T, Enum)`, implements
@@ -985,9 +985,10 @@ impl AsyncTryFrom<CreateFileRequest> for reqwest::multipart::Form {
         let mut form = reqwest::multipart::Form::new()
             .part("file", file_part)
             .text("purpose", request.purpose.to_string());
-        
+
         if let Some(expires_after) = request.expires_after {
-            form = form.text("expires_after[anchor]", expires_after.anchor.to_string())
+            form = form
+                .text("expires_after[anchor]", expires_after.anchor.to_string())
                 .text("expires_after[seconds]", expires_after.seconds.to_string());
         }
         Ok(form)

examples/assistants-code-interpreter/src/main.rs

@@ -28,6 +28,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
         .create(CreateFileRequest {
             file: "./input/CASTHPI.csv".into(),
             purpose: FilePurpose::Assistants,
+            expires_after: None,
         })
         .await?;
 

examples/assistants-file-search/src/main.rs

@@ -38,6 +38,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
         .create(CreateFileRequest {
             file: "./input/uber-10k.pdf".into(),
             purpose: FilePurpose::Assistants,
+            expires_after: None,
         })
         .await?;
 
@@ -84,6 +85,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
         .create(CreateFileRequest {
             file: "./input/lyft-10k.pdf".into(),
             purpose: FilePurpose::Assistants,
+            expires_after: None,
         })
         .await?;
 

examples/responses/src/main.rs

@@ -2,7 +2,10 @@ use std::error::Error;
 
 use async_openai::{
     types::responses::{
-        AllowedTools, CreateResponseArgs, Input, InputItem, InputMessageArgs, McpArgs, RequireApproval, RequireApprovalPolicy, Role, TextConfig, ToolDefinition::{Mcp, WebSearchPreview}, Verbosity, WebSearchPreviewArgs
+        AllowedTools, CreateResponseArgs, Input, InputItem, InputMessageArgs, McpArgs,
+        RequireApproval, RequireApprovalPolicy, Role, TextConfig,
+        ToolDefinition::{Mcp, WebSearchPreview},
+        Verbosity, WebSearchPreviewArgs,
     },
     Client,
 };

examples/vector-store-retrieval/src/main.rs

@@ -21,6 +21,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
         .create(CreateFileRequest {
             file: "./input/uber-10k.pdf".into(),
             purpose: FilePurpose::Assistants,
+            expires_after: None,
         })
         .await?;
 
@@ -29,6 +30,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
         .create(CreateFileRequest {
             file: "./input/lyft-10k.pdf".into(),
             purpose: FilePurpose::Assistants,
+            expires_after: None,
         })
         .await?;