🧪 [Test] Add error path test for _drainStreamedResponse in Dart HTTP shared client

app/analysis_baseline.json

@@ -13,7 +13,7 @@
   "no_leading_underscores_for_local_identifiers": 5,
   "non_constant_identifier_names": 1,
   "overridden_fields": 1,
-  "prefer_final_fields": 4,
+  "prefer_final_fields": 3,
   "prefer_function_declarations_over_variables": 1,
   "prefer_interpolation_to_compose_strings": 5,
   "prefer_is_empty": 1,

app/lib/backend/http/shared.dart

@@ -1,4 +1,4 @@
 import 'dart:async';
 import 'dart:convert';
 import 'dart:io';
 
@@ -240,6 +240,9 @@
   }
 }
 
+@visibleForTesting
+Future<void> drainStreamedResponseForTesting(http.StreamedResponse response) => _drainStreamedResponse(response);
+
 http.StreamedResponse _authUnavailableStreamedResponse() =>
     http.StreamedResponse(const Stream<List<int>>.empty(), 401, reasonPhrase: 'Authentication unavailable');
 

app/test/unit/backend/http/shared_test.dart

@@ -3,6 +3,7 @@ import 'dart:convert';
 import 'dart:io';
 
 import 'package:flutter_test/flutter_test.dart';
+import 'package:http/http.dart' as http;
 import 'package:package_info_plus/package_info_plus.dart';
 import 'package:shared_preferences/shared_preferences.dart';
 
@@ -11,6 +12,7 @@ import 'package:omi/backend/http/clock_skew_detector.dart';
 import 'package:omi/backend/preferences.dart';
 import 'package:omi/env/env.dart';
 import 'package:omi/services/auth/auth_token_result.dart';
+import 'package:omi/services/auth_service.dart';
 import 'package:omi/utils/platform/platform_manager.dart';
 
 Future<String> simulateGetAuthHeader({required bool isSignedIn, required String token}) async {
@@ -64,6 +66,26 @@ void main() {
 
       expect(headers['Authorization'], equals('Bearer fresh-token'));
     });
+
+    test('_drainStreamedResponse suppresses exceptions from aborted streams before replaying', () async {
+      var replayCount = 0;
+      final service = AuthService.forTesting(tokenGateway: _TestAuthTokenGateway(), refreshDelay: (_) async {});
+
+      final response = await refreshAndReplayAfter401(
+        firstResponse: http.StreamedResponse(_abortedResponseBody(), HttpStatus.unauthorized),
+        statusCode: (value) => value.statusCode,
+        disposeUnauthorizedResponse: drainStreamedResponseForTesting,
+        replay: () async {
+          replayCount++;
+          return http.StreamedResponse(const Stream<List<int>>.empty(), HttpStatus.ok);
+        },
+        expireTerminalSession: true,
+        authService: service,
+      );
+
+      expect(response.statusCode, HttpStatus.ok);
+      expect(replayCount, 1);
+    });
   });
 
   group('streaming clock-skew detection', () {
@@ -128,6 +150,23 @@ void main() {
   });
 }
 
+Stream<List<int>> _abortedResponseBody() async* {
+  yield [1, 2, 3];
+  throw StateError('aborted response');
+}
+
+final class _TestAuthTokenGateway implements AuthTokenGateway {
+  @override
+  AuthUserSnapshot? get currentUser => const AuthUserSnapshot(uid: 'test-user');
+
+  @override
+  Future<RefreshedAuthToken?> forceRefresh() async =>
+      RefreshedAuthToken(token: 'fresh-token', expirationTime: DateTime.now().add(const Duration(hours: 1)));
+
+  @override
+  Future<void> signOut() async {}
+}
+
 class _TestEnvFields implements EnvFields {
   String _requestBaseUrl = '';