feat: use retry client instead of http.get

witnet · Dec 13, 2023 · e8e6851 · e8e6851
1 parent 404bcc1
commit e8e6851
Showing 1 changed file with 28 additions and 6 deletions.
diff --git a/lib/src/network/explorer/explorer_client.dart b/lib/src/network/explorer/explorer_client.dart
@@ -1,6 +1,7 @@
 import 'dart:convert';
 
 import 'package:http/http.dart' as http;
+import 'package:http/retry.dart';
 import 'dart:convert' as convert;
 import 'dart:io' show HttpException;
 
@@ -32,10 +33,12 @@ class ExplorerClient {
   ExplorerClient({
     required this.url,
     required this.mode,
-  }) : SSL = (mode == ExplorerMode.production) ? true : false;
+  })  : SSL = (mode == ExplorerMode.production) ? true : false,
+        client = http.Client();
 
   final String url;
   final ExplorerMode mode;
+  http.Client client;
   late bool SSL;
 
   Uri api(String method, [Map<String, dynamic> params = const {}]) {
@@ -47,7 +50,18 @@ class ExplorerClient {
   }
 
   Future<Map<String, dynamic>> _processGet(Uri uri) async {
-    var response = await http.get(uri);
+    var response;
+    try {
+      RetryClient retryClient = RetryClient(client);
+      response = await retryClient.get(uri);
+    } on http.ClientException catch (e) {
+      if (e.message.contains('Client is already closed')) {
+        client = http.Client();
+        RetryClient retryClient = RetryClient(client);
+        response = await retryClient.get(uri);
+      }
+    }
+
     if (response.statusCode == 200) {
       // response is okay
       return convert.jsonDecode(response.body) as Map<String, dynamic>;
@@ -58,10 +72,18 @@ class ExplorerClient {
 
   Future<Map<String, dynamic>> _processPost(
       Uri uri, Map<String, dynamic> postData) async {
-    var response = await http.post(
-      uri,
-      body: json.encode(postData),
-    );
+    var response;
+    try {
+      RetryClient retryClient = RetryClient(client);
+      response = await retryClient.post(uri, body: json.encode(postData));
+    } on http.ClientException catch (e) {
+      if (e.message.contains('Client is already closed')) {
+        client = http.Client();
+        RetryClient retryClient = RetryClient(client);
+        response = await retryClient.post(uri, body: json.encode(postData));
+      }
+    }
+
     if (response.statusCode == 200) {
       // response is okay
       return convert.jsonDecode(response.body) as Map<String, dynamic>;