✨ Added passing of custom http client

Author: Guldem

lib/src/oauth_chopper.dart

@@ -1,5 +1,6 @@
 import 'dart:async';
 
+import 'package:http/http.dart' as http;
 import 'package:oauth2/oauth2.dart' as oauth2;
 import 'package:oauth_chopper/src/oauth_authenticator.dart';
 import 'package:oauth_chopper/src/oauth_grant.dart';
@@ -36,11 +37,15 @@ class OAuthChopper {
   /// See [OAuthStorage] for more information.
   final OAuthStorage _storage;
 
+  /// Provide a custom [http.Client] which will be passed to [oauth2] and used for making new requests.
+  final http.Client? httpClient;
+
   OAuthChopper({
     required this.authorizationEndpoint,
     required this.identifier,
     required this.secret,
     this.endSessionEndpoint,
+    this.httpClient,
 
     /// OAuth storage for storing credentials.
     /// By default it will use a in memory storage [MemoryStorage]. For persisting the credentials implement a custom [OAuthStorage].
@@ -51,9 +56,7 @@ class OAuthChopper {
   /// Get stored [OAuthToken].
   Future<OAuthToken?> get token async {
     final credentialsJson = await _storage.fetchCredentials();
-    return credentialsJson != null
-        ? OAuthToken.fromJson(credentialsJson)
-        : null;
+    return credentialsJson != null ? OAuthToken.fromJson(credentialsJson) : null;
   }
 
   /// Provides an [OAuthAuthenticator] instance.
@@ -75,8 +78,11 @@ class OAuthChopper {
     if (credentialsJson == null) return null;
     final credentials = oauth2.Credentials.fromJson(credentialsJson);
     try {
-      final newCredentials =
-          await credentials.refresh(identifier: identifier, secret: secret);
+      final newCredentials = await credentials.refresh(
+        identifier: identifier,
+        secret: secret,
+        httpClient: httpClient,
+      );
       await _storage.saveCredentials(newCredentials.toJson());
       return OAuthToken.fromCredentials(newCredentials);
     } on oauth2.AuthorizationException {
@@ -92,8 +98,7 @@ class OAuthChopper {
   ///  - [AuthorizationCodeGrant]
   /// Throws an exception if the grant fails.
   Future<OAuthToken> requestGrant(OAuthGrant grant) async {
-    final credentials =
-        await grant.handle(authorizationEndpoint, identifier, secret);
+    final credentials = await grant.handle(authorizationEndpoint, identifier, secret, httpClient);
 
     await _storage.saveCredentials(credentials);
 

lib/src/oauth_grant.dart

@@ -1,29 +1,38 @@
+import 'package:http/http.dart' as http;
 import 'package:oauth2/oauth2.dart' as oauth;
 
 abstract class OAuthGrant {
   const OAuthGrant();
 
   Future<String> handle(
-      Uri authorizationEndpoint, String identifier, String secret);
+    Uri authorizationEndpoint,
+    String identifier,
+    String secret,
+    http.Client? httpClient,
+  );
 }
 
 /// Obtains credentials using a [resource owner password grant](https://tools.ietf.org/html/rfc6749#section-1.3.3).
 class ResourceOwnerPasswordGrant extends OAuthGrant {
   final String username;
   final String password;
 
-  const ResourceOwnerPasswordGrant(
-      {required this.username, required this.password});
+  const ResourceOwnerPasswordGrant({required this.username, required this.password});
 
   @override
   Future<String> handle(
-      Uri authorizationEndpoint, String identifier, String secret) async {
+    Uri authorizationEndpoint,
+    String identifier,
+    String secret,
+    http.Client? httpClient,
+  ) async {
     final client = await oauth.resourceOwnerPasswordGrant(
       authorizationEndpoint,
       username,
       password,
       secret: secret,
       identifier: identifier,
+      httpClient: httpClient,
     );
     return client.credentials.toJson();
   }
@@ -35,11 +44,16 @@ class ClientCredentialsGrant extends OAuthGrant {
 
   @override
   Future<String> handle(
-      Uri authorizationEndpoint, String identifier, String secret) async {
+    Uri authorizationEndpoint,
+    String identifier,
+    String secret,
+    http.Client? httpClient,
+  ) async {
     final client = await oauth.clientCredentialsGrant(
       authorizationEndpoint,
       identifier,
       secret,
+      httpClient: httpClient,
     );
     return client.credentials.toJson();
   }
@@ -63,18 +77,21 @@ class AuthorizationCodeGrant extends OAuthGrant {
 
   @override
   Future<String> handle(
-      Uri authorizationEndpoint, String identifier, String secret) async {
+    Uri authorizationEndpoint,
+    String identifier,
+    String secret,
+    http.Client? httpClient,
+  ) async {
     final grant = oauth.AuthorizationCodeGrant(
       identifier,
       authorizationEndpoint,
       tokenEndpoint,
+      httpClient: httpClient,
     );
-    var authorizationUrl =
-        grant.getAuthorizationUrl(redirectUrl, scopes: scopes);
+    var authorizationUrl = grant.getAuthorizationUrl(redirectUrl, scopes: scopes);
     await redirect(authorizationUrl);
     var responseUrl = await listen(redirectUrl);
-    oauth.Client client =
-        await grant.handleAuthorizationResponse(responseUrl.queryParameters);
+    oauth.Client client = await grant.handleAuthorizationResponse(responseUrl.queryParameters);
 
     return client.credentials.toJson();
   }

pubspec.yaml

@@ -8,10 +8,10 @@ environment:
 
 dependencies:
   chopper: ^7.2.0
+  http: ^1.2.1
   oauth2: ^2.0.2
 
 dev_dependencies:
-  http: ^1.2.1
   lints: ">=2.1.1 <4.0.0"
   mocktail: ^1.0.3
   test: ^1.25.2

test/oauth_chopper_test.dart

@@ -89,7 +89,7 @@ void main() {
   test("Successful grant is stored", () async {
     // arrange
     when(() => storageMock.saveCredentials(any())).thenAnswer((_) => null);
-    when(() => grantMock.handle(any(), any(), any()))
+    when(() => grantMock.handle(any(), any(), any(), null))
         .thenAnswer((_) async => testJson);
     final oauthChopper = OAuthChopper(
         authorizationEndpoint: Uri.parse('endpoint'),
@@ -101,7 +101,7 @@ void main() {
     final token = await oauthChopper.requestGrant(grantMock);
 
     // assert
-    verify(() => grantMock.handle(any(), 'identifier', 'secret')).called(1);
+    verify(() => grantMock.handle(any(), 'identifier', 'secret', null)).called(1);
     verify(() => storageMock.saveCredentials(testJson)).called(1);
     expect(token.accessToken, 'accesToken');
     expect(token.idToken, 'idToken');