Migrate to null safety

Author: robbecker-wf

analysis_options.yaml

@@ -1 +1 @@
-include: package:pedantic/analysis_options.yaml
+include: package:lints/recommended.yaml

lib/src/command_runner.dart

@@ -11,7 +11,7 @@
 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 // See the License for the specific language governing permissions and
 // limitations under the License.
-
+import 'dart:async';
 import 'package:args/args.dart';
 import 'package:args/command_runner.dart';
 import 'package:logging/logging.dart';
@@ -33,11 +33,11 @@ class WebdevProxy extends CommandRunner<int> {
   @override
   Future<int> run(Iterable<String> args) async {
     // The help command returns null, so return success code in that case.
-    return await super.run(args) ?? 0;
+    return (await super.run(args)) ?? 0;
   }
 
   @override
-  Future<int> runCommand(ArgResults topLevelResults) async {
+  Future<int?> runCommand(ArgResults topLevelResults) async {
     final verbose = topLevelResults[verboseFlag] == true;
     Logger.root.level = verbose ? Level.ALL : Level.INFO;
     Logger.root.onRecord.listen(stdIOLogListener(verbose: verbose));

lib/src/logging.dart

@@ -28,8 +28,7 @@ const _logSuffix = '\n';
 
 final Logger log = Logger('Proxy');
 
-StringBuffer colorLog(LogRecord record, {bool verbose}) {
-  verbose ??= false;
+StringBuffer colorLog(LogRecord record, {bool verbose = false}) {
 
   AnsiCode color;
   if (record.level < Level.WARNING) {
@@ -44,13 +43,13 @@ StringBuffer colorLog(LogRecord record, {bool verbose}) {
   final lines = <Object>[
     '$eraseLine$level ${_loggerName(record, verbose)}${record.message}'
   ];
-
-  if (record.error != null) {
-    lines.add(record.error);
+  var error = record.error;
+  if (error != null) {
+    lines.add(error);
   }
 
   if (record.stackTrace != null && verbose) {
-    final trace = Trace.from(record.stackTrace).terse;
+    final trace = Trace.from(record.stackTrace!).terse;
     lines.add(trace);
   }
 
@@ -130,7 +129,7 @@ T logTimedSync<T>(
   return result;
 }
 
-Function(LogRecord) stdIOLogListener({bool verbose}) =>
+Function(LogRecord) stdIOLogListener({bool verbose = false}) =>
     (record) => io.stdout.write(colorLog(record, verbose: verbose));
 
 String _loggerName(LogRecord record, bool verbose) {

lib/src/serve_command.dart

@@ -18,7 +18,6 @@ import 'dart:io';
 import 'package:args/command_runner.dart';
 import 'package:io/ansi.dart';
 import 'package:io/io.dart';
-import 'package:pedantic/pedantic.dart';
 
 import 'package:webdev_proxy/src/command_runner.dart';
 import 'package:webdev_proxy/src/command_utils.dart';
@@ -52,15 +51,15 @@ class ServeCommand extends Command<int> {
       '[-- [webdev serve arguments]]';
 
   @override
-  String get usageFooter => _webdevCompatibilityHelp;
+  String? get usageFooter => _webdevCompatibilityHelp;
 
   @override
   String get name => 'serve';
 
   bool get _canUseWebdev => !_missingWebdev && _hasCompatibleWebdev;
 
   bool get _hasCompatibleWebdev =>
-      webdevCompatibility.allows(getGlobalWebdevVersion());
+      webdevCompatibility.allows(getGlobalWebdevVersion()!);
 
   bool get _missingWebdev => getGlobalWebdevVersion() == null;
 
@@ -78,7 +77,7 @@ class ServeCommand extends Command<int> {
     }
   }
 
-  String get _webdevCompatibilityHelp {
+  String? get _webdevCompatibilityHelp {
     if (_missingWebdev) {
       return red.wrap(
         'This command requires that `webdev` be activated globally.\n'
@@ -109,19 +108,19 @@ class ServeCommand extends Command<int> {
     //
     // To enforce this, we validate that [argResults.rest] is exactly equal to
     // all the arguments after the `--`.
-    assertNoPositionalArgsBeforeSeparator(name, argResults, usageException);
+    assertNoPositionalArgsBeforeSeparator(name, argResults!, usageException);
 
     final exitCodeCompleter = Completer<int>();
     var interruptReceived = false;
     final proxies = <WebdevProxyServer>[];
     var proxiesFailed = false;
-    StreamSubscription sigintSub;
-    WebdevServer webdevServer;
+    StreamSubscription? sigintSub;
+    WebdevServer? webdevServer;
 
     void shutDown(int code) async {
       await Future.wait([
-        sigintSub?.cancel(),
-        webdevServer?.close(),
+        if (sigintSub != null) sigintSub.cancel(),
+        if (webdevServer != null) webdevServer.close(),
         ...proxies.map((proxy) => proxy.close()),
       ]);
       if (!exitCodeCompleter.isCompleted) {
@@ -137,13 +136,13 @@ class ServeCommand extends Command<int> {
     });
 
     // Parse the hostname to serve each dir on (defaults to 0.0.0.0)
-    final hostnameResults = parseHostname(argResults.rest);
+    final hostnameResults = parseHostname(argResults!.rest);
     final hostname = hostnameResults.hostname;
     final remainingArgs = hostnameResults.remainingArgs;
 
     // Parse the directory:port mappings that will be used by the proxy servers.
     // Each proxy will be mapped to a `webdev serve` instance on another port.
-    final portsToServeByDir = parseDirectoryArgs(argResults.rest);
+    final portsToServeByDir = parseDirectoryArgs(argResults!.rest);
 
     // Find open ports for each of the directories to be served by webdev.
     final portsToProxyByDir = {
@@ -174,7 +173,7 @@ class ServeCommand extends Command<int> {
           hostname: hostname,
           portToProxy: portsToProxyByDir[dir],
           portToServe: portsToServeByDir[dir],
-          rewrite404s: argResults[rewrite404sFlag] == true,
+          rewrite404s: argResults![rewrite404sFlag] == true,
         ));
       } catch (e, stackTrace) {
         proxiesFailed = true;

lib/src/sse_proxy_handler.dart

@@ -34,14 +34,14 @@ String _sseHeaders(String origin) => 'HTTP/1.1 200 OK\r\n'
 /// simply forwards data back and forth between clients and the actual server.
 class SseProxyHandler {
   final _httpClient = http.Client();
-  shelf.Handler _incomingMessageProxyHandler;
-  final String _proxyName;
+  shelf.Handler? _incomingMessageProxyHandler;
+  final String? _proxyName;
   final Uri _proxyUri;
   final Uri _serverUri;
 
   /// Creates an SSE proxy handler that will handle EventSource requests to
   /// [proxyUri] by proxying them to [serverUri].
-  SseProxyHandler(Uri proxyUri, Uri serverUri, {String proxyName})
+  SseProxyHandler(Uri proxyUri, Uri serverUri, {String? proxyName})
       : _proxyUri = proxyUri,
         _serverUri = serverUri,
         _proxyName = proxyName;
@@ -61,10 +61,10 @@ class SseProxyHandler {
 
     req.hijack((channel) {
       final sink = utf8.encoder.startChunkedConversion(channel.sink)
-        ..add(_sseHeaders(req.headers['origin']));
+        ..add(_sseHeaders(req.headers['origin']!));
 
       StreamSubscription serverSseSub;
-      StreamSubscription reqChannelSub;
+      StreamSubscription? reqChannelSub;
 
       serverSseSub =
           utf8.decoder.bind(serverResponse.stream).listen(sink.add, onDone: () {
@@ -75,7 +75,7 @@ class SseProxyHandler {
       reqChannelSub = channel.stream.listen((_) {
         // SSE is unidirectional.
       }, onDone: () {
-        serverSseSub?.cancel();
+        serverSseSub.cancel();
         sink.close();
       });
     });
@@ -105,6 +105,6 @@ class SseProxyHandler {
       client: _httpClient,
       proxyName: _proxyName,
     );
-    return _incomingMessageProxyHandler(req);
+    return _incomingMessageProxyHandler!(req);
   }
 }

lib/src/webdev_proc_utils.dart

@@ -24,20 +24,20 @@ import 'package:pub_semver/pub_semver.dart';
 final webdevCompatibility = VersionConstraint.parse('>=1.0.1 <3.0.0');
 
 @visibleForTesting
-ProcessResult cachedWebdevVersionResult;
+ProcessResult? cachedWebdevVersionResult;
 
 /// Returns the version of the `webdev` package that is currently globally
 /// activated, or `null` if it is not activated.
-Version getGlobalWebdevVersion() {
+Version? getGlobalWebdevVersion() {
   cachedWebdevVersionResult ??= Process.runSync(
     'dart',
     ['pub', 'global', 'run', 'webdev', '--version'],
     stdoutEncoding: utf8,
   );
-  if (cachedWebdevVersionResult.exitCode != 0) {
+  if (cachedWebdevVersionResult!.exitCode != 0) {
     return null;
   }
-  return Version.parse(cachedWebdevVersionResult.stdout.toString().trim());
+  return Version.parse(cachedWebdevVersionResult!.stdout.toString().trim());
 }
 
 /// Prints the output from `webdev help serve` with a header that explains how

lib/src/webdev_proxy_server.dart

@@ -16,7 +16,6 @@ import 'dart:io';
 
 import 'package:http_multi_server/http_multi_server.dart';
 import 'package:io/ansi.dart';
-import 'package:meta/meta.dart';
 import 'package:shelf/shelf.dart' as shelf;
 import 'package:shelf/shelf_io.dart' as shelf_io;
 import 'package:shelf_proxy/shelf_proxy.dart' as shelf_proxy;
@@ -37,7 +36,7 @@ class WebdevProxyServer {
 
   /// Permanently stops this proxy server from listening for new connections and
   /// closes all active connections immediately.
-  Future<Null> close() async {
+  Future<void> close() async {
     await _server.close(force: true);
   }
 
@@ -51,14 +50,12 @@ class WebdevProxyServer {
   /// request that fetches the root index path (`/`) unless [rewrite404s] is
   /// false.
   static Future<WebdevProxyServer> start({
-    @required String dir,
-    @required String hostname,
-    @required int portToProxy,
-    int portToServe,
-    bool rewrite404s,
+    required String dir,
+    required String hostname,
+    required int? portToProxy,
+    int portToServe = 0,
+    bool rewrite404s = true,
   }) async {
-    portToServe ??= 0;
-    rewrite404s ??= true;
 
     final serverHostname = hostname == 'any' ? 'localhost' : hostname;
     final serverUri = Uri.parse('http://$serverHostname:$portToProxy');
@@ -77,9 +74,7 @@ class WebdevProxyServer {
     final server = await HttpMultiServer.bind(hostname, portToServe);
     shelf_io.serveRequests(server, cascade.handler);
     final proxyHostname = hostname == 'any' ? '::' : hostname;
-    log.info(green.wrap('Serving `$dir` proxy on '
-            'http://$proxyHostname:$portToServe') +
-        '\n');
+    log.info(green.wrap('Serving `$dir` proxy on http://$proxyHostname:$portToServe\n'));
     log.fine('... forwards to http://$serverHostname:$portToProxy');
     return WebdevProxyServer._(server);
   }

lib/src/webdev_server.dart

@@ -30,7 +30,7 @@ class WebdevServer {
 
   /// Permanently stops this proxy server from listening for new connections and
   /// closes all active connections immediately.
-  Future<Null> close() async {
+  Future<void> close() async {
     _process.kill();
     await _process.exitCode;
   }

pubspec.yaml

@@ -8,7 +8,7 @@ description: >
   routing by rewriting 404s to the root index.
 
 environment:
-  sdk: ">=2.11.0 <3.0.0"
+  sdk: '>=2.18.0 <3.0.0'
 
 dependencies:
   args: ^2.3.1
@@ -18,7 +18,7 @@ dependencies:
   io: ^1.0.3
   logging: ^1.1.0
   meta: ^1.8.0
-  pedantic: ^1.11.1
+  lints: ^2.0.1
   pub_semver: ^2.1.2
   shelf: ^1.2.0
   shelf_proxy: ^1.0.0
@@ -27,7 +27,7 @@ dependencies:
 dev_dependencies:
   # These two build deps are required by webdev.
   build_runner: ^2.1.2
-  build_web_compilers: ^3.0.0
+  build_web_compilers: '>=3.0.0 <5.0.0'
 
   shelf_static: ^1.1.0
   sse: ^4.1.0

test/command_utils_test.dart

@@ -21,7 +21,7 @@ import 'package:webdev_proxy/src/command_utils.dart';
 void main() {
   group('assertNoPositionalArgsBeforeSeparator', () {
     final argParser = ArgParser()..addCommand('command');
-    String capturedUsageException;
+    String? capturedUsageException;
     void usageException(String msg) => capturedUsageException = msg;
 
     tearDown(() {
@@ -32,22 +32,22 @@ void main() {
       test('if rest args are empty', () {
         final argResults = argParser.parse(['command']);
         assertNoPositionalArgsBeforeSeparator(
-            'serve', argResults.command, usageException);
+            'serve', argResults.command!, usageException);
         expect(capturedUsageException, isNull);
       });
 
       test('if expected flag is parsed', () {
         argParser.addFlag('flag');
         final argResults = argParser.parse(['command', '--flag']);
         assertNoPositionalArgsBeforeSeparator(
-            'serve', argResults.command, usageException);
+            'serve', argResults.command!, usageException);
         expect(capturedUsageException, isNull);
       });
 
       test('if args are only passed after -- separator', () {
         final argResults = argParser.parse(['command', '--', 'after']);
         assertNoPositionalArgsBeforeSeparator(
-            'serve', argResults.command, usageException);
+            'serve', argResults.command!, usageException);
         expect(capturedUsageException, isNull);
       });
     });
@@ -56,15 +56,15 @@ void main() {
       test('-- separator is missing before webdev args', () {
         final argResults = argParser.parse(['command', 'foo']);
         assertNoPositionalArgsBeforeSeparator(
-            'serve', argResults.command, usageException);
+            'serve', argResults.command!, usageException);
         expect(capturedUsageException, isNotNull);
       });
 
       test('positional args exist before -- separator', () {
         final argResults =
             argParser.parse(['command', 'before', '--', 'after']);
         assertNoPositionalArgsBeforeSeparator(
-            'serve', argResults.command, usageException);
+            'serve', argResults.command!, usageException);
         expect(capturedUsageException, isNotNull);
       });
     });

test/port_utils_test.dart

@@ -23,7 +23,7 @@ void main() {
   group('findUnusedPort()', () {
     test('should return an open port', () async {
       final port = await findUnusedPort();
-      ServerSocket socket;
+      late ServerSocket socket;
       try {
         socket = await ServerSocket.bind('localhost', port);
       } catch (e) {

test/proxy_server_test.dart

@@ -28,9 +28,9 @@ import 'package:webdev_proxy/src/webdev_proxy_server.dart';
 import 'chromedriver_utils.dart';
 
 void main() {
-  WebdevProxyServer proxy;
-  HttpServer server;
-  SseHandler serverSse;
+  late WebdevProxyServer proxy;
+  late HttpServer server;
+  late SseHandler serverSse;
 
   setUpAll(() async {
     await startChromeDriver();

test/sse_proxy_handler_test.dart

@@ -15,10 +15,10 @@ import 'package:webdev_proxy/src/sse_proxy_handler.dart';
 import 'chromedriver_utils.dart';
 
 void main() {
-  HttpServer proxy;
-  HttpServer server;
-  SseHandler serverSse;
-  WebDriver webdriver;
+  late HttpServer proxy;
+  late HttpServer server;
+  late SseHandler serverSse;
+  late WebDriver webdriver;
 
   setUpAll(() async {
     await startChromeDriver();