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;

  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',
    ['run', '-r', serverFile.path],
    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',
        ['run', '-r', serverFile.path],
        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((_) async {
    process?.kill();
    Process.runSync('dart', ['compilation-server', 'shutdown']);
    exit(0);
  });

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