run method

@override Future<void> run()

Runs this command.

The return value is wrapped in a Future if necessary and returned by CommandRunner.runCommand.

Implementation

@override
Future<void> run() async {
  Process? process;
  final serverFile = await getServerFile();
  final cwd = Directory.current.path;
  final packageConfig = findPackageConfig();

  bool shouldReload(WatchEvent event) {
    return path.isWithin(path.join(cwd, 'bin'), event.path) ||
        path.isWithin(path.join(cwd, 'lib'), event.path);
  }

  Process.runSync('dart', ['compilation-server', 'start']);

  process = await Process.start(
    'dart',
    _buildDartRunArgs(serverFile.path, packageConfig),
    workingDirectory: cwd,
  );

  var stdoutSubscription = process.stdout.listen((event) {
    stdout.add(event);
  });
  var stderrSubscription = process.stderr.listen((event) {
    stderr.add(event);
  });

  bool isReloading = false;
  DirectoryWatcher(cwd).events
      .where(shouldReload)
      .debounceBuffer(const Duration(milliseconds: 500))
      .listen(
        (_) async {
          if (!isReloading) {
            print('Restarting server...');
            isReloading = true;
          }
          stdoutSubscription.cancel();
          stderrSubscription.cancel();
          process?.kill();
          process = null;
          final now = DateTime.now();

          process = await Process.start(
            'dart',
            _buildDartRunArgs(serverFile.path, packageConfig),
            workingDirectory: cwd,
          );
          stdoutSubscription = process!.stdout.listen((event) {
            final data = String.fromCharCodes(event);

            if (data.contains('Server running on port')) {
              final time = DateTime.now().difference(now).inMilliseconds;
              print('Restarted server in $time ms');
              isReloading = false;
              return;
            }

            stdout.add(event);
          });
          stderrSubscription = process!.stderr.listen((event) {
            stderr.add(event);
          });
        },
      );

  ProcessSignal.sigint.watch().listen((_) {
    process?.kill();
    Process.runSync('dart', ['compilation-server', 'shutdown']);
    exit(0);
  });

  ProcessSignal.sigterm.watch().listen((_) {
    process?.kill();
    exit(0);
  });
}