Use a common HTTP Client.

Author: SaadArdati

example/lib/main.dart

@@ -94,7 +94,7 @@ class _MyAppState extends State<MyApp> {
             name: 'Pricing Card',
             builder: (context) {
               return CodelesslyWidget(
-                layoutID: '0RZGVlSiIb7yITaXrIxo',
+                layoutID: '0RbIfjMG9TmGHNt4FmNI',
                 loadingBuilder: (context) {
                   return const CupertinoActivityIndicator();
                 },

lib/src/auth/codelessly_auth_manager.dart

@@ -4,7 +4,7 @@ import 'dart:io';
 
 import 'package:firebase_auth/firebase_auth.dart';
 import 'package:flutter/foundation.dart';
-import 'package:http/http.dart';
+import 'package:http/http.dart' as http;
 import 'package:jwt_decoder/jwt_decoder.dart';
 
 import '../../codelessly_sdk.dart';
@@ -16,6 +16,9 @@ class CodelesslyAuthManager extends AuthManager {
   /// The configuration used to authenticate the token.
   final CodelesslyConfig config;
 
+  /// The client used to make HTTP requests.
+  final http.Client client;
+
   /// The cache manager used to store the auth data after authentication.
   final CacheManager cacheManager;
 
@@ -63,6 +66,7 @@ class CodelesslyAuthManager extends AuthManager {
     required this.cacheManager,
     required this.firebaseAuth,
     required this.errorHandler,
+    required this.client,
     AuthData? authData,
   }) : _authData = authData {
     if (_authData != null) {
@@ -305,6 +309,7 @@ class CodelesslyAuthManager extends AuthManager {
       final AuthData? authData = await verifyProjectAuthToken(
         userToken: _idTokenResult!.token!,
         config: config,
+        client: client,
         postSuccess: postAuthSuccess,
       );
 
@@ -358,6 +363,7 @@ class CodelesslyAuthManager extends AuthManager {
   static Future<AuthData?> verifyProjectAuthToken({
     required String userToken,
     required CodelesslyConfig config,
+    required http.Client client,
     required Future<void> Function(AuthData authData) postSuccess,
   }) async {
     const String label = 'verifyProjectAuthToken';
@@ -371,9 +377,8 @@ class CodelesslyAuthManager extends AuthManager {
     );
 
     try {
-      // TODO(Saad): Use an HTTP client.
       // Make a POST request to the server to verify the token.
-      final Response result = await post(
+      final http.Response result = await client.post(
         Uri.parse(
             '${config.firebaseCloudFunctionsBaseURL}/api/verifyProjectAuthToken'),
         headers: <String, String>{

lib/src/codelessly.dart

@@ -6,9 +6,11 @@ import 'package:collection/collection.dart';
 import 'package:firebase_auth/firebase_auth.dart';
 import 'package:firebase_core/firebase_core.dart';
 import 'package:flutter/widgets.dart';
+import 'package:http/http.dart';
 
 import '../codelessly_sdk.dart';
 import 'logging/reporter.dart';
+import 'utils/codelessly_http_client.dart';
 
 typedef NavigationListener = void Function(BuildContext context);
 typedef BreakpointsListener = void Function(
@@ -34,6 +36,11 @@ class Codelessly {
   /// Initialization is needed before usage.
   static Codelessly get instance => _instance;
 
+  final Client _client = CodelesslyHttpClient();
+
+  /// Returns the HTTP client used by this SDK instance.
+  Client get client => _client;
+
   CodelesslyConfig? _config;
 
   /// Returns the configuration options provided to this SDK.
@@ -126,7 +133,7 @@ class Codelessly {
   final StreamController<CStatus> _statusStreamController =
       StreamController.broadcast()..add(CStatus.empty());
 
-  final StatTracker _tracker = CodelesslyStatTracker();
+  late final StatTracker _tracker = CodelesslyStatTracker(client: _client);
 
   /// Tracks statistics of various operations in the SDK.
   StatTracker get tracker => _tracker;
@@ -229,6 +236,7 @@ class Codelessly {
     _previewDataManager = null;
     _config = null;
     _navigationListeners.clear();
+    _client.close();
   }
 
   /// Resets the state of the SDK. This is useful for resetting the data without
@@ -549,6 +557,7 @@ class Codelessly {
             config: _config!,
             cacheManager: _cacheManager!,
             firebaseAuth: _firebaseAuth!,
+            client: _client,
             errorHandler: errorHandler,
           );
 
@@ -561,15 +570,15 @@ class Codelessly {
             authManager: _authManager!,
             networkDataRepository: FirebaseDataRepository(
               firestore: firebaseFirestore,
-              tracker: tracker,
+              tracker: _tracker,
               config: _config!,
             ),
             localDataRepository: LocalDataRepository(
               cacheManager: _cacheManager!,
             ),
             firebaseFirestore: firebaseFirestore,
             errorHandler: errorHandler,
-            tracker: tracker,
+            tracker: _tracker,
           );
 
       // Create the preview data manager.
@@ -582,14 +591,14 @@ class Codelessly {
             networkDataRepository: FirebaseDataRepository(
               firestore: firebaseFirestore,
               config: _config!,
-              tracker: tracker,
+              tracker: _tracker,
             ),
             localDataRepository: LocalDataRepository(
               cacheManager: _cacheManager!,
             ),
             firebaseFirestore: firebaseFirestore,
             errorHandler: errorHandler,
-            tracker: tracker,
+            tracker: _tracker,
           );
 
       // Create the template data manager. This is always automatically
@@ -606,14 +615,14 @@ class Codelessly {
             networkDataRepository: FirebaseDataRepository(
               firestore: firebaseFirestore,
               config: _config!,
-              tracker: tracker,
+              tracker: _tracker,
             ),
             localDataRepository: LocalDataRepository(
               cacheManager: _cacheManager!,
             ),
             firebaseFirestore: firebaseFirestore,
             errorHandler: errorHandler,
-            tracker: tracker,
+            tracker: _tracker,
           );
 
       _updateStatus(CStatus.loading(CLoadingState.createdManagers));

lib/src/constants.dart

@@ -58,7 +58,7 @@ const String templatesPath = 'templates';
 /// STAT TRACKING
 const String statsCollection = 'stats';
 const String lostStatsDoc = '_lost';
-const String loadsField = 'loads';
+const String viewsField = 'views';
 const String writesField = 'writes';
 const String readsField = 'reads';
 const String bundleDownloadsField = 'bundle_downloads';

lib/src/data/firebase_data_repository.dart

@@ -53,13 +53,17 @@ class FirebaseDataRepository extends NetworkDataRepository {
         .doc(layoutID);
 
     return layoutDoc.get().then((value) {
+      if (!value.exists) {
+        throw CodelesslyException('Layout [$layoutID] does not exist.');
+      }
       tracker.trackRead('${source.serverPath}/downloadLayoutModel');
 
       final Map<String, dynamic> data = value.data() ?? {};
 
       // Layout does not exist or there's a network error.
       if (data.isEmpty) {
-        throw CodelesslyException('Failed to download layout [$layoutID].');
+        throw CodelesslyException(
+            'Failed to download layout [$layoutID], no data found.');
       }
 
       final SDKPublishLayout layout = SDKPublishLayout.fromJson(

lib/src/data/web_data_repository.dart

@@ -2,30 +2,29 @@ import 'dart:async';
 import 'dart:convert';
 import 'dart:developer';
 
-import 'package:http/http.dart';
+import 'package:http/http.dart' as http;
 
 import '../../codelessly_sdk.dart';
 
 /// A [NetworkDataRepository] implementation that utilizes the Firebase Cloud
 /// Functions to retrieve the relevant data.
-///
-/// Since Firedart is not compatible with Flutter Web, this implementation
-/// utilizes the http package instead.
 @Deprecated('Use [FirebaseDataRepository] instead.')
 class WebDataRepository extends NetworkDataRepository {
+  final http.Client client;
+
   /// Creates a [WebDataRepository] instance.
   WebDataRepository({
     required super.config,
     required super.tracker,
+    required this.client,
   });
 
   @override
   Stream<SDKPublishModel?> streamPublishModel({
     required String projectID,
     required PublishSource source,
   }) async* {
-    // TODO(Saad): Use an HTTP client.
-    final Response result = await post(
+    final http.Response result = await client.post(
       Uri.parse(
           '${config.firebaseCloudFunctionsBaseURL}/api/getPublishModelRequest'),
       headers: <String, String>{'Content-Type': 'application/json'},
@@ -57,8 +56,7 @@ class WebDataRepository extends NetworkDataRepository {
     required String layoutID,
     required PublishSource source,
   }) async {
-    // TODO(Saad): Use an HTTP client.
-    final Response result = await post(
+    final http.Response result = await client.post(
       Uri.parse(
           '${config.firebaseCloudFunctionsBaseURL}/api/getLayoutModelRequest'),
       headers: <String, String>{'Content-Type': 'application/json'},
@@ -94,8 +92,7 @@ class WebDataRepository extends NetworkDataRepository {
     required PublishSource source,
   }) async {
     try {
-      // TODO(Saad): Use an HTTP client.
-      final Response result = await post(
+      final http.Response result = await client.post(
         Uri.parse(
             '${config.firebaseCloudFunctionsBaseURL}/api/getFontModelRequest'),
         headers: <String, String>{'Content-Type': 'application/json'},
@@ -132,8 +129,7 @@ class WebDataRepository extends NetworkDataRepository {
     required PublishSource source,
   }) async {
     try {
-      // TODO(Saad): Use an HTTP client.
-      final Response result = await post(
+      final http.Response result = await client.post(
         Uri.parse(
             '${config.firebaseCloudFunctionsBaseURL}/api/getPublishedApiRequest'),
         headers: <String, String>{'Content-Type': 'application/json'},
@@ -172,8 +168,7 @@ class WebDataRepository extends NetworkDataRepository {
     required PublishSource source,
   }) async {
     try {
-      // TODO(Saad): Use an HTTP client.
-      final Response result = await post(
+      final http.Response result = await client.post(
         Uri.parse(
             '${config.firebaseCloudFunctionsBaseURL}/api/getPublishedLayoutVariablesRequest'),
         headers: <String, String>{'Content-Type': 'application/json'},
@@ -214,8 +209,7 @@ class WebDataRepository extends NetworkDataRepository {
   }) async {
     log('[WebDataRepo] Downloading conditions for $layoutID');
     try {
-      // TODO(Saad): Use an HTTP client.
-      final Response result = await post(
+      final http.Response result = await client.post(
         Uri.parse(
             '${config.firebaseCloudFunctionsBaseURL}/api/getPublishedLayoutConditionsRequest'),
         headers: <String, String>{'Content-Type': 'application/json'},

lib/src/functions/functions_repository.dart

@@ -403,14 +403,17 @@ class FunctionsRepository {
     try {
       final http.Response response;
       if (kIsWeb && useCloudFunctionForWeb) {
+        final codelessly = context.read<Codelessly>();
+        final client = codelessly.client;
         final String cloudFunctionsURL =
-            context.read<Codelessly>().config!.firebaseCloudFunctionsBaseURL;
+            codelessly.config!.firebaseCloudFunctionsBaseURL;
         final receivedResponse = await makeApiRequestWeb(
           method: method,
           url: url,
           headers: headers,
           body: body,
           cloudFunctionsURL: cloudFunctionsURL,
+          client: client,
         );
 
         // cloud function returns actual response in body.
@@ -422,14 +425,16 @@ class FunctionsRepository {
           reasonPhrase: actualResponse['reasonPhrase']?.toString(),
         );
       } else {
-        // TODO(Saad): Use an HTTP client.
+        final codelessly = context.read<Codelessly>();
+        final client = codelessly.client;
         final Uri uri = Uri.parse(url);
         response = switch (method) {
-          HttpMethod.get => await http.get(uri, headers: headers),
-          HttpMethod.post => await http.post(uri, headers: headers, body: body),
+          HttpMethod.get => await client.get(uri, headers: headers),
+          HttpMethod.post =>
+            await client.post(uri, headers: headers, body: body),
           HttpMethod.delete =>
-            await http.delete(uri, headers: headers, body: body),
-          HttpMethod.put => await http.put(uri, headers: headers, body: body)
+            await client.delete(uri, headers: headers, body: body),
+          HttpMethod.put => await client.put(uri, headers: headers, body: body)
         };
       }
 
@@ -522,9 +527,9 @@ ${response.body.contains('{') ? const JsonEncoder.withIndent('  ').convert(json.
     required Map<String, dynamic> headers,
     required Object? body,
     required String cloudFunctionsURL,
+    required http.Client client,
   }) async {
-    // TODO(Saad): Use an HTTP client.
-    return http.post(
+    return client.post(
       Uri.parse('$cloudFunctionsURL/makeApiRequest'),
       headers: {'content-type': 'application/json'},
       body: jsonEncode({