feat(dart_frog_cli): static file support (#110)

Author: felangel

packages/dart_frog_cli/e2e/test/helpers/kill_dart_frog_server.dart

@@ -17,7 +17,19 @@ Future<void> killDartFrogServer(int pid) async {
     return;
   }
 
-  if (Platform.isLinux || Platform.isMacOS) {
+  if (Platform.isLinux) {
+    final result = await Process.run('fuser', ['-n', 'tcp', '-k', '8080']);
+
+    if (result.exitCode != 0) {
+      throw Exception(
+        'fuser -n tcp -k 8080 exited with code ${result.exitCode}',
+      );
+    }
+
+    return;
+  }
+
+  if (Platform.isMacOS) {
     final result = await Process.run('pkill', ['-f', 'dart_frog']);
 
     if (result.exitCode != 0) {

packages/dart_frog_cli/lib/src/commands/build/templates/dart_frog_prod_server_bundle.dart

@@ -144,8 +144,17 @@ class DevCommand extends DartFrogCommand {
     await serve();
     progress.complete('Running on http://localhost:$port');
 
-    final watcher = _directoryWatcher(path.join(cwd.path, 'routes'));
-    final subscription = watcher.events.listen((_) => codegen());
+    final public = path.join(cwd.path, 'public');
+    final routes = path.join(cwd.path, 'routes');
+
+    bool shouldRunCodegen(WatchEvent event) {
+      return path.isWithin(routes, event.path) ||
+          path.isWithin(public, event.path);
+    }
+
+    final watcher = _directoryWatcher(path.join(cwd.path));
+    final subscription =
+        watcher.events.where(shouldRunCodegen).listen((_) => codegen());
 
     await subscription.asFuture<void>();
     await subscription.cancel();

packages/dart_frog_cli/lib/src/commands/dev/dev.dart

@@ -6,6 +6,7 @@ import 'package:args/args.dart';
 import 'package:dart_frog_cli/src/commands/commands.dart';
 import 'package:mason/mason.dart';
 import 'package:mocktail/mocktail.dart';
+import 'package:path/path.dart' as path;
 import 'package:test/test.dart';
 import 'package:watcher/watcher.dart';
 
@@ -123,7 +124,101 @@ void main() {
           workingDirectory: any(named: 'workingDirectory'),
           onVarsChanged: any(named: 'onVarsChanged'),
         ),
-      ).called(2);
+      ).called(1);
+    });
+
+    test('runs codegen when changes are made to the public/routes directory',
+        () async {
+      final controller = StreamController<WatchEvent>();
+      final generatorHooks = _MockGeneratorHooks();
+      when(
+        () => generatorHooks.preGen(
+          vars: any(named: 'vars'),
+          workingDirectory: any(named: 'workingDirectory'),
+          onVarsChanged: any(named: 'onVarsChanged'),
+        ),
+      ).thenAnswer((invocation) async {
+        (invocation.namedArguments[const Symbol('onVarsChanged')] as Function(
+          Map<String, dynamic> vars,
+        ))
+            .call(<String, dynamic>{});
+      });
+      when(
+        () => generator.generate(
+          any(),
+          vars: any(named: 'vars'),
+          fileConflictResolution: FileConflictResolution.overwrite,
+        ),
+      ).thenAnswer((_) async => []);
+      when(() => generator.hooks).thenReturn(generatorHooks);
+      when(() => process.stdout).thenAnswer(
+        (_) => Stream.value(utf8.encode('[hotreload] hot reload enabled.')),
+      );
+      when(() => process.stderr).thenAnswer((_) => const Stream.empty());
+      when(() => directoryWatcher.events).thenAnswer((_) => controller.stream);
+
+      command.run().ignore();
+
+      await Future<void>.delayed(Duration.zero);
+
+      verify(
+        () => generator.generate(
+          any(),
+          vars: any(named: 'vars'),
+          fileConflictResolution: FileConflictResolution.overwrite,
+        ),
+      ).called(1);
+
+      controller.add(
+        WatchEvent(
+          ChangeType.MODIFY,
+          path.join(Directory.current.path, 'routes', 'index.dart'),
+        ),
+      );
+
+      await Future<void>.delayed(Duration.zero);
+
+      verify(
+        () => generator.generate(
+          any(),
+          vars: any(named: 'vars'),
+          fileConflictResolution: FileConflictResolution.overwrite,
+        ),
+      ).called(1);
+
+      controller.add(
+        WatchEvent(
+          ChangeType.MODIFY,
+          path.join(Directory.current.path, 'public', 'hello.txt'),
+        ),
+      );
+
+      await Future<void>.delayed(Duration.zero);
+
+      verify(
+        () => generator.generate(
+          any(),
+          vars: any(named: 'vars'),
+          fileConflictResolution: FileConflictResolution.overwrite,
+        ),
+      ).called(1);
+
+      controller.add(
+        WatchEvent(
+          ChangeType.MODIFY,
+          path.join(Directory.current.path, 'tmp', 'message.txt'),
+        ),
+      );
+
+      await Future<void>.delayed(Duration.zero);
+
+      verifyNever(
+        () => generator.generate(
+          any(),
+          vars: any(named: 'vars'),
+          fileConflictResolution: FileConflictResolution.overwrite,
+        ),
+      );
     });
 
     test('caches snapshot when hotreload runs successfully', () async {