make ToolDyn public

Author: cyborg42

async-openai/src/client.rs

@@ -485,7 +485,7 @@ where
                         if message.data == "[DONE]" {
                             break;
                         }
-
+                        println!("message: {:?}", message.data);
                         let response = match serde_json::from_str::<O>(&message.data) {
                             Err(e) => Err(map_deserialization_error(e, message.data.as_bytes())),
                             Ok(output) => Ok(output),

async-openai/src/lib.rs

@@ -149,7 +149,7 @@ mod projects;
 mod runs;
 mod steps;
 mod threads;
-mod tools;
+pub mod tools;
 pub mod traits;
 pub mod types;
 mod uploads;
@@ -181,7 +181,6 @@ pub use projects::Projects;
 pub use runs::Runs;
 pub use steps::Steps;
 pub use threads::Threads;
-pub use tools::{Tool, ToolManager, ToolCallStreamManager};
 pub use uploads::Uploads;
 pub use users::Users;
 pub use vector_store_file_batches::VectorStoreFileBatches;

async-openai/src/tools.rs

@@ -65,7 +65,7 @@ pub trait Tool: Send + Sync {
 
 /// A dynamic trait for tools that allows for runtime tool management.
 /// This trait provides a way to work with tools without knowing their concrete types at compile time.
-trait ToolDyn: Send + Sync {
+pub trait ToolDyn: Send + Sync {
     /// Returns the tool's definition as a ChatCompletionTool.
     fn definition(&self) -> ChatCompletionTool;
 

examples/tool-call-stream/src/main.rs

@@ -1,12 +1,12 @@
 use std::error::Error;
 use std::io::{stdout, Write};
 
+use async_openai::tools::{Tool, ToolCallStreamManager, ToolManager};
 use async_openai::types::{
     ChatCompletionRequestAssistantMessageArgs, ChatCompletionRequestMessage,
     ChatCompletionRequestUserMessageArgs, FinishReason,
 };
 use async_openai::{types::CreateChatCompletionRequestArgs, Client};
-use async_openai::{Tool, ToolCallStreamManager, ToolManager};
 use futures::StreamExt;
 use rand::seq::SliceRandom;
 use rand::{thread_rng, Rng};
@@ -67,7 +67,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     }
 
     if !is_end_with_tool_call {
-        return Err("The response is not ended with tool call".into());
+        println!("The response is not ended with tool call");
     }
     let tool_calls = tool_call_stream_manager.finish_stream();
     let function_responses = tool_manager.call(tool_calls.clone()).await;

examples/tool-call/src/main.rs

@@ -1,11 +1,11 @@
 use std::io::{stdout, Write};
 
+use async_openai::tools::{Tool, ToolManager};
 use async_openai::types::{
     ChatCompletionRequestAssistantMessageArgs, ChatCompletionRequestMessage,
     ChatCompletionRequestUserMessageArgs,
 };
 use async_openai::{types::CreateChatCompletionRequestArgs, Client};
-use async_openai::{Tool, ToolManager};
 use futures::StreamExt;
 use rand::seq::SliceRandom;
 use rand::{thread_rng, Rng};