Upgraded SDK constraints + lints.

Author: isoos

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Changelog
 
+## 3.5.8
+
+- Upgraded SDK constraints and lints.
+
 ## 3.5.7.
 
 - Supporting URL-based connection-string specification in `Connection.openFromUrl` and `Pool.withUrl`. (Note: feature and supported settings is considered experimental.)

example/example.dart

@@ -32,10 +32,12 @@ void main() async {
   print('has connection!');
 
   // Simple query without results
-  await conn.execute('CREATE TABLE IF NOT EXISTS a_table ('
-      '  id TEXT NOT NULL, '
-      '  totals INTEGER NOT NULL DEFAULT 0'
-      ')');
+  await conn.execute(
+    'CREATE TABLE IF NOT EXISTS a_table ('
+    '  id TEXT NOT NULL, '
+    '  totals INTEGER NOT NULL DEFAULT 0'
+    ')',
+  );
 
   // simple query
   final result0 = await conn.execute("SELECT 'foo'");
@@ -71,8 +73,9 @@ void main() async {
   await statement.dispose();
 
   // preared statement with types
-  final anotherStatement =
-      await conn.prepare(Sql(r'SELECT $1;', types: [Type.bigInteger]));
+  final anotherStatement = await conn.prepare(
+    Sql(r'SELECT $1;', types: [Type.bigInteger]),
+  );
   final bound = anotherStatement.bind([1]);
   final subscription = bound.listen((row) {
     print('row: $row');

lib/postgres.dart

@@ -177,7 +177,7 @@ abstract class Session {
   Future<Result> execute(
     Object /* String | Sql */ query, {
     Object? /* List<Object?|TypedValue> | Map<String, Object?|TypedValue> */
-        parameters,
+    parameters,
     bool ignoreRows = false,
     QueryMode? queryMode,
     Duration? timeout,
@@ -227,8 +227,10 @@ abstract class Connection implements Session, SessionExecutor {
     Endpoint endpoint, {
     ConnectionSettings? settings,
   }) {
-    return PgConnectionImplementation.connect(endpoint,
-        connectionSettings: settings);
+    return PgConnectionImplementation.connect(
+      endpoint,
+      connectionSettings: settings,
+    );
   }
 
   /// Open a new connection where the endpoint and the settings are encoded as an URL as
@@ -275,12 +277,13 @@ abstract class ResultStreamSubscription
 
 abstract class Statement {
   ResultStream bind(
-      Object? /* List<Object?|TypedValue> | Map<String, Object?|TypedValue> */
-          parameters);
+    Object? /* List<Object?|TypedValue> | Map<String, Object?|TypedValue> */
+    parameters,
+  );
 
   Future<Result> run(
     Object? /* List<Object?|TypedValue> | Map<String, Object?|TypedValue> */
-        parameters, {
+    parameters, {
     Duration? timeout,
   });
 
@@ -306,8 +309,8 @@ class ResultRow extends UnmodifiableListView<Object?> {
     required List<Object?> values,
     required this.schema,
     List<bool>? sqlNulls,
-  })  : _sqlNulls = sqlNulls,
-        super(values);
+  }) : _sqlNulls = sqlNulls,
+       super(values);
 
   /// Returns true if the result at [columnIndex] returned SQL `NULL` value.
   ///
@@ -432,14 +435,8 @@ final class Endpoint {
   });
 
   @override
-  int get hashCode => Object.hash(
-        host,
-        port,
-        database,
-        username,
-        password,
-        isUnixSocket,
-      );
+  int get hashCode =>
+      Object.hash(host, port, database, username, password, isUnixSocket);
 
   @override
   bool operator ==(Object other) {
@@ -468,8 +465,7 @@ enum SslMode {
   require,
 
   /// Always use SSL and verify certificates.
-  verifyFull,
-  ;
+  verifyFull;
 
   bool get ignoreCertificateIssues => this == SslMode.require;
 
@@ -599,8 +595,7 @@ enum IsolationLevel {
 
   /// One transaction may see uncommitted changes made by some other transaction.
   /// In PostgreSQL READ UNCOMMITTED is treated as READ COMMITTED.
-  readUncommitted._('READ UNCOMMITTED'),
-  ;
+  readUncommitted._('READ UNCOMMITTED');
 
   /// The SQL identifier of the isolation level including "ISOLATION LEVEL" prefix
   /// and leading space.
@@ -622,8 +617,7 @@ enum AccessMode {
   /// GRANT, REVOKE, TRUNCATE; and EXPLAIN ANALYZE and EXECUTE if the command
   /// they would execute is among those listed. This is a high-level notion of
   /// read-only that does not prevent all writes to disk.
-  readOnly._('READ ONLY'),
-  ;
+  readOnly._('READ ONLY');
 
   /// The SQL identifier of the access mode including leading space.
   @internal
@@ -644,8 +638,7 @@ enum DeferrableMode {
   deferrable._('DEFERRABLE'),
 
   /// The default mode.
-  notDeferrable._('NOT DEFERRABLE'),
-  ;
+  notDeferrable._('NOT DEFERRABLE');
 
   /// The SQL identifier of the deferrable mode including leading space.
   @internal
@@ -662,11 +655,7 @@ class Retry<R> {
   final FutureOr<R> Function()? orElse;
   final FutureOr<bool> Function(Exception)? retryIf;
 
-  Retry({
-    required this.maxAttempts,
-    this.orElse,
-    this.retryIf,
-  });
+  Retry({required this.maxAttempts, this.orElse, this.retryIf});
 }
 
 /// The characteristics of the current transaction.

lib/src/auth/auth.dart

@@ -6,11 +6,7 @@ import 'clear_text_authenticator.dart';
 import 'md5_authenticator.dart';
 import 'sasl_authenticator.dart';
 
-enum AuthenticationScheme {
-  md5,
-  scramSha256,
-  clear,
-}
+enum AuthenticationScheme { md5, scramSha256, clear }
 
 /// A small interface to obtain the username and password used for a postgres
 /// connection, as well as sending messages.
@@ -37,16 +33,22 @@ abstract class PostgresAuthenticator {
   void onMessage(AuthenticationMessage message);
 }
 
-PostgresAuthenticator createAuthenticator(PostgresAuthConnection connection,
-    AuthenticationScheme authenticationScheme) {
+PostgresAuthenticator createAuthenticator(
+  PostgresAuthConnection connection,
+  AuthenticationScheme authenticationScheme,
+) {
   switch (authenticationScheme) {
     case AuthenticationScheme.md5:
       return MD5Authenticator(connection);
     case AuthenticationScheme.scramSha256:
       final credentials = UsernamePasswordCredential(
-          username: connection.username, password: connection.password);
+        username: connection.username,
+        password: connection.password,
+      );
       return PostgresSaslAuthenticator(
-          connection, ScramAuthenticator('SCRAM-SHA-256', sha256, credentials));
+        connection,
+        ScramAuthenticator('SCRAM-SHA-256', sha256, credentials),
+      );
     case AuthenticationScheme.clear:
       return ClearAuthenticator(connection);
   }

lib/src/auth/md5_authenticator.dart

@@ -16,8 +16,11 @@ class MD5Authenticator extends PostgresAuthenticator {
     final reader = ByteDataReader()..add(message.bytes);
     final salt = reader.read(4, copy: true);
 
-    final authMessage =
-        AuthMD5Message(connection.username!, connection.password!, salt);
+    final authMessage = AuthMD5Message(
+      connection.username!,
+      connection.password!,
+      salt,
+    );
 
     connection.sendMessage(authMessage);
   }
@@ -28,11 +31,15 @@ class AuthMD5Message extends ClientMessage {
 
   AuthMD5Message._(this._hashedAuthString);
   factory AuthMD5Message(
-      String username, String password, List<int> saltBytes) {
+    String username,
+    String password,
+    List<int> saltBytes,
+  ) {
     final passwordHash = md5.convert('$password$username'.codeUnits).toString();
     final saltString = String.fromCharCodes(saltBytes);
-    final md5Hash =
-        md5.convert('$passwordHash$saltString'.codeUnits).toString();
+    final md5Hash = md5
+        .convert('$passwordHash$saltString'.codeUnits)
+        .toString();
     return AuthMD5Message._('md5$md5Hash');
   }
 

lib/src/auth/sasl_authenticator.dart

@@ -20,27 +20,34 @@ class PostgresSaslAuthenticator extends PostgresAuthenticator {
     switch (message.type) {
       case AuthenticationMessageType.sasl:
         final bytesToSend = authenticator.handleMessage(
-            SaslMessageType.AuthenticationSASL, message.bytes);
+          SaslMessageType.AuthenticationSASL,
+          message.bytes,
+        );
         if (bytesToSend == null) {
           throw PgException('KindSASL: No bytes to send');
         }
         msg = SaslClientFirstMessage(bytesToSend, authenticator.mechanism.name);
         break;
       case AuthenticationMessageType.saslContinue:
         final bytesToSend = authenticator.handleMessage(
-            SaslMessageType.AuthenticationSASLContinue, message.bytes);
+          SaslMessageType.AuthenticationSASLContinue,
+          message.bytes,
+        );
         if (bytesToSend == null) {
           throw PgException('KindSASLContinue: No bytes to send');
         }
         msg = SaslClientLastMessage(bytesToSend);
         break;
       case AuthenticationMessageType.saslFinal:
         authenticator.handleMessage(
-            SaslMessageType.AuthenticationSASLFinal, message.bytes);
+          SaslMessageType.AuthenticationSASLFinal,
+          message.bytes,
+        );
         return;
       default:
         throw PgException(
-            'Unsupported authentication type ${message.type}, closing connection.');
+          'Unsupported authentication type ${message.type}, closing connection.',
+        );
     }
     connection.sendMessage(msg);
   }

lib/src/buffer.dart

@@ -16,10 +16,7 @@ class EncodedString {
 class PgByteDataWriter extends ByteDataWriter {
   final Encoding encoding;
 
-  PgByteDataWriter({
-    super.bufferLength,
-    required this.encoding,
-  });
+  PgByteDataWriter({super.bufferLength, required this.encoding});
 
   late final encodingName = encodeString(encoding.name);
 
@@ -45,9 +42,7 @@ const _emptyString = '';
 class PgByteDataReader extends ByteDataReader {
   final CodecContext codecContext;
 
-  PgByteDataReader({
-    required this.codecContext,
-  });
+  PgByteDataReader({required this.codecContext});
 
   Encoding get encoding => codecContext.encoding;
 

lib/src/connection_string.dart

@@ -11,12 +11,14 @@ import '../postgres.dart';
   ReplicationMode? replicationMode,
   SecurityContext? securityContext,
   SslMode? sslMode,
-}) parseConnectionString(String connectionString) {
+})
+parseConnectionString(String connectionString) {
   final uri = Uri.parse(connectionString);
 
   if (uri.scheme != 'postgresql' && uri.scheme != 'postgres') {
     throw ArgumentError(
-        'Invalid connection string scheme: ${uri.scheme}. Expected "postgresql" or "postgres".');
+      'Invalid connection string scheme: ${uri.scheme}. Expected "postgresql" or "postgres".',
+    );
   }
 
   final host = uri.host.isEmpty ? 'localhost' : uri.host;
@@ -33,7 +35,7 @@ import '../postgres.dart';
     'connect_timeout',
     'application_name',
     'client_encoding',
-    'replication'
+    'replication',
   };
 
   final params = uri.queryParameters;
@@ -58,7 +60,8 @@ import '../postgres.dart';
         break;
       default:
         throw ArgumentError(
-            'Invalid sslmode value: ${params['sslmode']}. Expected: disable, require, verify-ca, verify-full');
+          'Invalid sslmode value: ${params['sslmode']}. Expected: disable, require, verify-ca, verify-full',
+        );
     }
   }
 
@@ -83,7 +86,8 @@ import '../postgres.dart';
     final timeoutSeconds = int.tryParse(params['connect_timeout']!);
     if (timeoutSeconds == null || timeoutSeconds <= 0) {
       throw ArgumentError(
-          'Invalid connect_timeout value: ${params['connect_timeout']}. Expected positive integer.');
+        'Invalid connect_timeout value: ${params['connect_timeout']}. Expected positive integer.',
+      );
     }
     connectTimeout = Duration(seconds: timeoutSeconds);
   }
@@ -103,7 +107,8 @@ import '../postgres.dart';
         break;
       default:
         throw ArgumentError(
-            'Unsupported client_encoding: ${params['client_encoding']}. Supported: UTF8, LATIN1');
+          'Unsupported client_encoding: ${params['client_encoding']}. Supported: UTF8, LATIN1',
+        );
     }
   }
 
@@ -123,7 +128,8 @@ import '../postgres.dart';
         break;
       default:
         throw ArgumentError(
-            'Invalid replication value: ${params['replication']}. Expected: database, true, physical, false, no_select');
+          'Invalid replication value: ${params['replication']}. Expected: database, true, physical, false, no_select',
+        );
     }
   }
 
@@ -190,7 +196,8 @@ SecurityContext _createSecurityContext({
       context.setTrustedCertificates(caPath);
     } catch (e) {
       throw ArgumentError(
-          'Failed to load SSL CA certificates from $caPath: $e');
+        'Failed to load SSL CA certificates from $caPath: $e',
+      );
     }
   }