fix: add organization_id to provider error and stream error logs (#522)

* fix: add organization_id to provider error and stream error logs

Add organization_id to all log statements in:
- map_provider_error(): all 17 error/warn logs now include org_id
  for correlating provider failures to specific tenants
- create_signature_future(): attestation storage errors now include
  org_id and model_id for debugging E2EE issues
- Route handler streaming errors: serialization failures, stream
  errors, and multi-error completions now include org_id

This enables filtering Datadog logs by organization to identify
whether failures are tenant-specific or systemic.

* fix: address review comments on org_id logging

- Rename org_id_for_stream → organization_id for tracing shorthand (%organization_id)
- Use .0 on OrganizationId for raw UUID in log fields
- Clone model string into chain closure instead of capturing full request
- Use structured error field (error = ?e) instead of {:?} in message
  for signature storage log

* chore: gitignore repro scripts

* fix: sort mod general alphabetically in e2e_all/main.rs

* fix: add missing organization_id arg to NoPubKeyProvider test

Author: Evrard-Nil

crates/api/src/routes/completions.rs

@@ -394,6 +394,8 @@ pub async fn chat_completions(
 
                 if inference_id.is_none() {
                     tracing::warn!(
+                        organization_id = %api_key.organization.id.0,
+                        model = %request.model,
                         "Could not extract inference ID from first chunk for chat completion (streaming)"
                     );
                 }
@@ -407,6 +409,7 @@ pub async fn chat_completions(
                 let chat_id_clone = chat_id_state.clone();
                 let error_count_clone = stream_error_count.clone();
                 let request_model = request.model.clone();
+                let organization_id = api_key.organization.id.0;
 
                 // Convert to raw bytes stream with proper SSE formatting
                 let byte_stream = peekable_stream
@@ -432,6 +435,7 @@ pub async fn chat_completions(
                                     let json_data = serde_json::to_string(&event.chunk)
                                         .unwrap_or_else(|e| {
                                             tracing::error!(
+                                                %organization_id,
                                                 "Failed to serialize stream chunk: {e}"
                                             );
                                             "{}".to_string()
@@ -447,6 +451,7 @@ pub async fn chat_completions(
                                         .fetch_add(1, std::sync::atomic::Ordering::Relaxed);
                                     if count == 0 {
                                         tracing::error!(
+                                            %organization_id,
                                             model = %model_for_err,
                                             error_type = %completion_stream_error_category(&e),
                                             "Completion stream error"
@@ -459,24 +464,29 @@ pub async fn chat_completions(
                             }
                         }
                     })
-                    .chain(futures::stream::once(async move {
-                        let error_count_final =
-                            stream_error_count.load(std::sync::atomic::Ordering::Relaxed);
-                        if error_count_final > 1 {
-                            tracing::error!(
-                                model = %request.model,
-                                total_stream_errors = error_count_final,
-                                "Completion stream ended with multiple errors"
-                            );
-                        }
+                    .chain(futures::stream::once({
+                        let organization_id = api_key.organization.id.0;
+                        let model_name = request.model.clone();
+                        async move {
+                            let error_count_final =
+                                stream_error_count.load(std::sync::atomic::Ordering::Relaxed);
+                            if error_count_final > 1 {
+                                tracing::error!(
+                                    %organization_id,
+                                    model = %model_name,
+                                    total_stream_errors = error_count_final,
+                                    "Completion stream ended with multiple errors"
+                                );
+                            }
 
-                        let done_bytes = Bytes::from_static(b"data: [DONE]\n\n");
-                        accumulated_bytes
-                            .lock()
-                            .await
-                            .extend_from_slice(&done_bytes);
+                            let done_bytes = Bytes::from_static(b"data: [DONE]\n\n");
+                            accumulated_bytes
+                                .lock()
+                                .await
+                                .extend_from_slice(&done_bytes);
 
-                        Ok::<Bytes, Infallible>(done_bytes)
+                            Ok::<Bytes, Infallible>(done_bytes)
+                        }
                     }));
 
                 // Return raw streaming response with SSE headers

crates/api/tests/e2e_all/main.rs

@@ -25,6 +25,7 @@ mod error_msg;
 mod external_providers;
 mod files;
 mod function_tools;
+mod general;
 mod mcp;
 mod mcp_server;
 mod message_metadata;
@@ -40,7 +41,6 @@ mod rerank;
 mod response_signature_verification;
 mod score;
 mod signature_verification;
-mod general;
 mod usage_chat_completions;
 mod usage_recording;
 mod usage_responses;