feat: add automatic retry on 401 responses

Author: freekvandeven

CHANGELOG.md

@@ -1,5 +1,6 @@
 ## 1.2.1
 - Added field and request method option for the multipart file upload
+- Added automatic retry on 401 Unauthorized errors after refreshing credentials
 
 ## 1.2.0
 - Added support for multipart file uploads.

lib/src/api_service.dart

@@ -56,47 +56,61 @@ class HttpApiService<DefaultRepresentation extends Object> {
     Encoding? encoding,
     bool isAuthenticated = false,
   }) async {
-    var headersWithAuth = headers ?? {};
-    if (isAuthenticated) {
-      var credentials = await authenticationService.getCredentials();
-      headersWithAuth = {
-        ...headersWithAuth,
-        ...credentials.headers,
+    Future<http.Response> makeRequest() async {
+      var headersWithAuth = headers ?? {};
+      if (isAuthenticated) {
+        var credentials = await authenticationService.getCredentials();
+        headersWithAuth = {
+          ...headersWithAuth,
+          ...credentials.headers,
+        };
+      }
+
+      return switch (method) {
+        RequestMethod.delete => _client.delete(
+            endpoint,
+            headers: headersWithAuth,
+            body: body,
+            encoding: encoding,
+          ),
+        RequestMethod.get => _client.get(
+            endpoint,
+            headers: headersWithAuth,
+          ),
+        RequestMethod.patch => _client.patch(
+            endpoint,
+            headers: headersWithAuth,
+            body: body,
+            encoding: encoding,
+          ),
+        RequestMethod.post => _client.post(
+            endpoint,
+            headers: headersWithAuth,
+            body: body,
+            encoding: encoding,
+          ),
+        RequestMethod.put => _client.put(
+            endpoint,
+            headers: headersWithAuth,
+            body: body,
+            encoding: encoding,
+          ),
       };
     }
 
-    var result = switch (method) {
-      RequestMethod.delete => _client.delete(
-          endpoint,
-          headers: headersWithAuth,
-          body: body,
-          encoding: encoding,
-        ),
-      RequestMethod.get => _client.get(
-          endpoint,
-          headers: headersWithAuth,
-        ),
-      RequestMethod.patch => _client.patch(
-          endpoint,
-          headers: headersWithAuth,
-          body: body,
-          encoding: encoding,
-        ),
-      RequestMethod.post => _client.post(
-          endpoint,
-          headers: headersWithAuth,
-          body: body,
-          encoding: encoding,
-        ),
-      RequestMethod.put => _client.put(
-          endpoint,
-          headers: headersWithAuth,
-          body: body,
-          encoding: encoding,
-        ),
-    };
+    var response = await makeRequest();
+
+    if (response.statusCode == 401 && isAuthenticated) {
+      try {
+        await authenticationService.refreshCredentials();
+
+        response = await makeRequest();
+      } on Exception {
+        return response;
+      }
+    }
 
-    return result;
+    return response;
   }
 
   Future<http.Response> _upload({