feat: enhance response handling with reasoning support (#178)

* feat: enhance response handling with reasoning support

* Updated ConversationId struct to derive Copy trait for improved usability.
* Introduced reasoning token tracking in ResponseStreamContext to accumulate reasoning tokens during response processing.
* Added new methods in ResponseServiceImpl for emitting reasoning events and processing reasoning tags in text deltas.
* Enhanced Usage model to include reasoning tokens in usage calculations.
* Implemented tests for reasoning tag processing and token estimation to ensure functionality and correctness.

* refactor: few fixes and clippy

* Removed unnecessary cloning of conversation_id in service methods for improved performance and clarity.
* Updated related function calls to directly use conversation_id, enhancing code readability and efficiency.

* refactor: streamline code formatting and improve readability

* Removed unnecessary line breaks and simplified function calls in `service.rs` and `service_helpers.rs` for better clarity.
* Enhanced the formatting of method parameters and function calls across multiple files to maintain consistency and improve code readability.
* Updated tests to reflect changes in function call formatting, ensuring all tests remain functional and clear.

Author: PierreLeGuen

crates/services/src/conversations/models.rs

@@ -4,7 +4,7 @@ use uuid::Uuid;
 
 use crate::{conversations::errors, workspace::WorkspaceId};
 
-#[derive(Debug, Clone, Serialize, Deserialize)]
+#[derive(Debug, Clone, Copy, Serialize, Deserialize)]
 pub struct ConversationId(pub Uuid);
 
 impl std::str::FromStr for ConversationId {

crates/services/src/conversations/service.rs

@@ -297,7 +297,7 @@ impl ports::ConversationServiceTrait for ConversationServiceImpl {
         // Verify conversation exists
         let conversation = self
             .conv_repo
-            .get_by_id(conversation_id.clone(), workspace_id.clone())
+            .get_by_id(conversation_id, workspace_id.clone())
             .await
             .map_err(|e| {
                 errors::ConversationError::InternalError(format!(
@@ -367,12 +367,7 @@ impl ports::ConversationServiceTrait for ConversationServiceImpl {
         for item in items {
             let created_item = self
                 .response_items_repo
-                .create(
-                    response_id.clone(),
-                    api_key_id,
-                    Some(conversation_id.clone()),
-                    item,
-                )
+                .create(response_id.clone(), api_key_id, Some(conversation_id), item)
                 .await
                 .map_err(|e| {
                     errors::ConversationError::InternalError(format!(

crates/services/src/responses/models.rs

@@ -732,4 +732,20 @@ impl Usage {
             total_tokens: input_tokens + output_tokens,
         }
     }
+
+    pub fn new_with_reasoning(
+        input_tokens: i32,
+        output_tokens: i32,
+        reasoning_tokens: i32,
+    ) -> Self {
+        Self {
+            input_tokens,
+            input_tokens_details: Some(InputTokensDetails { cached_tokens: 0 }),
+            output_tokens,
+            output_tokens_details: Some(OutputTokensDetails {
+                reasoning_tokens: reasoning_tokens as i64,
+            }),
+            total_tokens: input_tokens + output_tokens,
+        }
+    }
 }