cleanup

codex-rs/codex-api/src/endpoint/responses_websocket.rs

@@ -45,7 +45,6 @@ pub struct ResponsesWebsocketConnection {
     server_reasoning_included: bool,
     models_etag: Option<String>,
     telemetry: Option<Arc<dyn WebsocketTelemetry>>,
-    turn_state: Option<Arc<OnceLock<String>>>,
 }
 
 impl ResponsesWebsocketConnection {
@@ -55,7 +54,6 @@ impl ResponsesWebsocketConnection {
         server_reasoning_included: bool,
         models_etag: Option<String>,
         telemetry: Option<Arc<dyn WebsocketTelemetry>>,
-        turn_state: Option<Arc<OnceLock<String>>>,
     ) -> Self {
         Self {
             stream: Arc::new(Mutex::new(Some(stream))),
@@ -63,7 +61,6 @@ impl ResponsesWebsocketConnection {
             server_reasoning_included,
             models_etag,
             telemetry,
-            turn_state,
         }
     }
 
@@ -157,7 +154,6 @@ impl<A: AuthProvider> ResponsesWebsocketClient<A> {
             server_reasoning_included,
             models_etag,
             telemetry,
-            turn_state,
         ))
     }
 }

codex-rs/codex-api/src/rate_limits.rs

@@ -78,7 +78,10 @@ pub fn parse_rate_limit_event(payload: &str) -> Option<RateLimitSnapshot> {
         return None;
     }
     let (primary, secondary) = if let Some(details) = event.rate_limits.as_ref() {
-        (map_event_window(details.primary.as_ref()), map_event_window(details.secondary.as_ref()))
+        (
+            map_event_window(details.primary.as_ref()),
+            map_event_window(details.secondary.as_ref()),
+        )
     } else {
         (None, None)
     };

codex-rs/core/tests/suite/client_websockets.rs

@@ -16,8 +16,8 @@ use codex_core::protocol::SessionSource;
 use codex_otel::OtelManager;
 use codex_otel::metrics::MetricsClient;
 use codex_otel::metrics::MetricsConfig;
-use codex_protocol::account::PlanType;
 use codex_protocol::ThreadId;
+use codex_protocol::account::PlanType;
 use codex_protocol::config_types::ReasoningSummary;
 use core_test_support::load_default_config_for_test;
 use core_test_support::responses::WebSocketConnectionConfig;