Commit from GitHub Actions (Format and push)

Author: ChiragAgg5k

lib/query.dart

@@ -160,26 +160,26 @@ class Query {
       between('\$updatedAt', start, end);
 
   static String or(List<String> queries) => Query._(
-    'or',
-    null,
-    queries.map((query) => jsonDecode(query)).toList(),
-  ).toString();
+        'or',
+        null,
+        queries.map((query) => jsonDecode(query)).toList(),
+      ).toString();
 
   static String and(List<String> queries) => Query._(
-    'and',
-    null,
-    queries.map((query) => jsonDecode(query)).toList(),
-  ).toString();
+        'and',
+        null,
+        queries.map((query) => jsonDecode(query)).toList(),
+      ).toString();
 
   /// Filter array elements where at least one element matches all the specified queries.
   ///
   /// [attribute] The attribute containing the array to filter on.
   /// [queries] The list of query strings to match against array elements.
   static String elemMatch(String attribute, List<String> queries) => Query._(
-    'elemMatch',
-    attribute,
-    queries.map((query) => jsonDecode(query)).toList(),
-  ).toString();
+        'elemMatch',
+        attribute,
+        queries.map((query) => jsonDecode(query)).toList(),
+      ).toString();
 
   /// Specify which attributes should be returned by the API call.
   static String select(List<String> attributes) =>
@@ -226,39 +226,43 @@ class Query {
     List<dynamic> values,
     num distance, [
     bool meters = true,
-  ]) => Query._('distanceEqual', attribute, [
-    [values, distance, meters],
-  ]).toString();
+  ]) =>
+      Query._('distanceEqual', attribute, [
+        [values, distance, meters],
+      ]).toString();
 
   /// Filter resources where [attribute] is not at a specific distance from the given coordinates.
   static String distanceNotEqual(
     String attribute,
     List<dynamic> values,
     num distance, [
     bool meters = true,
-  ]) => Query._('distanceNotEqual', attribute, [
-    [values, distance, meters],
-  ]).toString();
+  ]) =>
+      Query._('distanceNotEqual', attribute, [
+        [values, distance, meters],
+      ]).toString();
 
   /// Filter resources where [attribute] is at a distance greater than the specified value from the given coordinates.
   static String distanceGreaterThan(
     String attribute,
     List<dynamic> values,
     num distance, [
     bool meters = true,
-  ]) => Query._('distanceGreaterThan', attribute, [
-    [values, distance, meters],
-  ]).toString();
+  ]) =>
+      Query._('distanceGreaterThan', attribute, [
+        [values, distance, meters],
+      ]).toString();
 
   /// Filter resources where [attribute] is at a distance less than the specified value from the given coordinates.
   static String distanceLessThan(
     String attribute,
     List<dynamic> values,
     num distance, [
     bool meters = true,
-  ]) => Query._('distanceLessThan', attribute, [
-    [values, distance, meters],
-  ]).toString();
+  ]) =>
+      Query._('distanceLessThan', attribute, [
+        [values, distance, meters],
+      ]).toString();
 
   /// Filter resources where [attribute] intersects with the given geometry.
   static String intersects(String attribute, List<dynamic> values) =>

lib/src/client.dart

@@ -27,7 +27,8 @@ abstract class Client {
   factory Client({
     String endPoint = 'https://cloud.appwrite.io/v1',
     bool selfSigned = false,
-  }) => createClient(endPoint: endPoint, selfSigned: selfSigned);
+  }) =>
+      createClient(endPoint: endPoint, selfSigned: selfSigned);
 
   /// Handle OAuth2 session creation.
   Future webAuth(Uri url, {String? callbackUrlScheme});

lib/src/client_io.dart

@@ -429,9 +429,8 @@ class ClientIO extends ClientBase with ClientMixin {
 
     var nextChunk = 0;
     Future<void> uploadNext() async {
-      final raf = file.bytes == null
-          ? await iofile!.open(mode: FileMode.read)
-          : null;
+      final raf =
+          file.bytes == null ? await iofile!.open(mode: FileMode.read) : null;
       try {
         while (nextChunk < chunks.length) {
           final chunk = chunks[nextChunk++];

lib/src/cookie_manager.dart

@@ -15,15 +15,14 @@ class CookieManager extends Interceptor {
     await cookieJar
         .loadForRequest(Uri(scheme: request.url.scheme, host: request.url.host))
         .then((cookies) {
-          var cookie = getCookies(cookies);
-          if (cookie.isNotEmpty) {
-            request.headers.addAll({HttpHeaders.cookieHeader: cookie});
-          }
-          return request;
-        })
-        .catchError((e, stackTrace) {
-          return request;
-        });
+      var cookie = getCookies(cookies);
+      if (cookie.isNotEmpty) {
+        request.headers.addAll({HttpHeaders.cookieHeader: cookie});
+      }
+      return request;
+    }).catchError((e, stackTrace) {
+      return request;
+    });
     return request;
   }
 

lib/src/realtime_io.dart

@@ -79,8 +79,8 @@ class RealtimeIO extends RealtimeBase with RealtimeMixin {
       var client = HttpClient(context: SecurityContext());
       client.badCertificateCallback =
           (X509Certificate cert, String host, int port) {
-            return true;
-          };
+        return true;
+      };
 
       uri = Uri(
         scheme: uri.scheme == 'wss' ? 'https' : 'http',

lib/src/realtime_mixin.dart

@@ -141,9 +141,9 @@ mixin RealtimeMixin {
               final message = RealtimeMessage.fromMap(messageData);
               final subscriptions =
                   (messageData['subscriptions'] as List<dynamic>?)
-                      ?.map((x) => x.toString())
-                      .toList() ??
-                  <String>[];
+                          ?.map((x) => x.toString())
+                          .toList() ??
+                      <String>[];
 
               if (subscriptions.isEmpty) {
                 break;
@@ -201,10 +201,10 @@ mixin RealtimeMixin {
     return _retries < 5
         ? 1
         : _retries < 15
-        ? 5
-        : _retries < 100
-        ? 10
-        : 60;
+            ? 5
+            : _retries < 100
+                ? 10
+                : 60;
   }
 
   Uri _prepareUri() {
@@ -322,10 +322,8 @@ mixin RealtimeMixin {
     List<String> queries = const [],
   ]) {
     StreamController<RealtimeMessage> controller = StreamController.broadcast();
-    final channelStrings = channels
-        .map((ch) => _channelToString(ch))
-        .toList()
-        .cast<String>();
+    final channelStrings =
+        channels.map((ch) => _channelToString(ch)).toList().cast<String>();
     final queryStrings = List<String>.from(queries);
 
     final subscriptionId = _generateUniqueSubscriptionId();
@@ -348,10 +346,8 @@ mixin RealtimeMixin {
         return;
       }
       if (channels != null) {
-        final nextChannels = channels
-            .map((ch) => _channelToString(ch))
-            .toList()
-            .cast<String>();
+        final nextChannels =
+            channels.map((ch) => _channelToString(ch)).toList().cast<String>();
         current.channels
           ..clear()
           ..addAll(nextChannels);

lib/src/realtime_stub.dart

@@ -3,5 +3,5 @@ import 'client.dart';
 
 /// Implemented in `realtime_browser.dart` and `realtime_io.dart`.
 RealtimeBase createRealtime(Client client) => throw UnsupportedError(
-  'Cannot create a client without dart:html or dart:io.',
-);
+      'Cannot create a client without dart:html or dart:io.',
+    );

lib/src/realtime_subscription.dart

@@ -21,7 +21,7 @@ class RealtimeSubscription {
 
   /// Replace the channels and/or queries on this subscription without recreating it.
   final Future<void> Function({List<Object>? channels, List<String>? queries})
-  update;
+      update;
 
   /// Alias of [unsubscribe] that also closes the socket when this was the last active
   /// subscription. Prefer [unsubscribe] plus [Realtime.disconnect] for explicit control.