send method

@override Future<StreamedResponse> send(BaseRequest request)

Sends an HTTP request and asynchronously returns the response.

Implementation

@override
Future<http.StreamedResponse> send(http.BaseRequest request) async {
  try {
    // Log request details
    String requestData = (request is http.Request)
        ? '\n📤 Request Data: ${request.body}'
        : '\n📤 Request Data: Not applicable for this type of request';
    _logger.i(
        '🚀 🌐 Request 🌐 🚀\n🔗 URL: ${request.url}\n🤔 Method: ${request.method}\n📋 Headers: ${jsonEncode(request.headers)}\n🔍 Query Parameters: ${request.url.queryParameters}$requestData');

    // Send the request and get the response
    final streamedResponse = await _inner.send(request);

    // Log response details
    String responseData =
        '\n🔗 URL: ${streamedResponse.request?.url}\n🔒 Status Code: ${streamedResponse.statusCode}\n📋 Headers: ${jsonEncode(streamedResponse.headers)}';
    _logger.i('✅ 🌐 Response 🌐 ✅$responseData');

    // Read the response stream and create a new http.Response
    final body = await streamedResponse.stream.bytesToString();
    final response = http.Response(
      body,
      streamedResponse.statusCode,
      headers: streamedResponse.headers,
      request: request as http.Request,
    ); // Cast to http.Request

    _logger.i('📥 Response Data: ${response.body}');

    return streamedResponse;
  } catch (error) {
    // Log request error
    String requestErrorData =
        (request is http.Request) ? '\n❗ Request Data: ${request.body}' : '';
    _logger.e('❌ ❗ ERROR ❗ ❌\n❗ Error Message: $error$requestErrorData');
    rethrow; // Rethrow the error after logging
  }
}