test sweep: foundational systems — files / ipc errno / panes (T-91)
test / unit + widget + golden + a11y (push) Failing after 32s
test / integration_test (xvfb) (push) Has been skipped
test / bundle smoke (xvfb 5s) (push) Has been skipped
test / daemon subprocess + web WASM smoke (push) Has been skipped
test / dart doc (lib API) (push) Failing after 1m2s
test / unit + widget + golden + a11y (push) Failing after 32s
test / integration_test (xvfb) (push) Has been skipped
test / bundle smoke (xvfb 5s) (push) Has been skipped
test / daemon subprocess + web WASM smoke (push) Has been skipped
test / dart doc (lib API) (push) Failing after 1m2s
Three small foundational test additions: - test/files/watcher_test.dart (new, 8 tests): FileChangeKind fromEvent across every FileSystemEvent.type + wire getter, FileChange.toJson, FileWatcher end-to-end (created event, ignored-path filtering, idempotent start, stop teardown). - ignore_test: trailing /**, bare **, ? glob-pattern branches in the regex compiler. - path_safety_test: PathOutsideRoot.toString embeds the three fields. - ipc/errno_mapping_test: ENOTDIR / ENOMEM / EAGAIN branches in errnoToIpcError that weren't previously hit. - panes/registry_test: RecordingEventSink.ofSubsystem filter. Coverage: src/files/watcher.dart 10/36 -> ~ all; ignore.dart + path_safety.dart residuals closed; ipc/errno_mapping.dart 3 added branches; panes/event_sink.dart 100%. Total coverage 90.53% -> 90.99%. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
This commit is contained in:
@@ -76,5 +76,23 @@ void main() {
|
||||
expect(s.isIgnored('docs/a.draft.md', isDirectory: false), isTrue);
|
||||
expect(s.isIgnored('other/a.draft.md', isDirectory: false), isFalse);
|
||||
});
|
||||
|
||||
test('trailing /** matches every descendant', () {
|
||||
final s = IgnoreSet.parse(['build/**']);
|
||||
expect(s.isIgnored('build/a/b/c.txt', isDirectory: false), isTrue);
|
||||
expect(s.isIgnored('src/a.txt', isDirectory: false), isFalse);
|
||||
});
|
||||
|
||||
test('bare ** (not adjacent to /) matches across path separators', () {
|
||||
final s = IgnoreSet.parse(['a**z']);
|
||||
expect(s.isIgnored('axyz', isDirectory: false), isTrue);
|
||||
expect(s.isIgnored('amiddlez', isDirectory: false), isTrue);
|
||||
});
|
||||
|
||||
test('? matches exactly one non-slash character', () {
|
||||
final s = IgnoreSet.parse(['a?c']);
|
||||
expect(s.isIgnored('abc', isDirectory: false), isTrue);
|
||||
expect(s.isIgnored('a/c', isDirectory: false), isFalse);
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
@@ -58,5 +58,10 @@ void main() {
|
||||
if (twin.existsSync()) twin.deleteSync(recursive: true);
|
||||
}
|
||||
});
|
||||
|
||||
test('PathOutsideRoot.toString embeds requested + resolved + root', () {
|
||||
final e = PathOutsideRoot('r', '/abs', '/root');
|
||||
expect(e.toString(), allOf(contains('r'), contains('/abs'), contains('/root')));
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
@@ -0,0 +1,98 @@
|
||||
/// Tests for `lib/src/files/watcher.dart`. Drives a real
|
||||
/// Directory.watch against a tempdir.
|
||||
library;
|
||||
|
||||
import 'dart:async';
|
||||
import 'dart:io';
|
||||
|
||||
import 'package:clide/src/files/ignore.dart';
|
||||
import 'package:clide/src/files/watcher.dart';
|
||||
import 'package:test/test.dart';
|
||||
|
||||
void main() {
|
||||
group('FileChangeKind', () {
|
||||
test('fromEvent maps every FileSystemEvent.type to a wire kind', () {
|
||||
final dir = Directory.systemTemp;
|
||||
FileSystemEvent ev(int type) => switch (type) {
|
||||
FileSystemEvent.create => FileSystemCreateEvent('${dir.path}/f', false),
|
||||
FileSystemEvent.delete => FileSystemDeleteEvent('${dir.path}/f', false),
|
||||
FileSystemEvent.modify => FileSystemModifyEvent('${dir.path}/f', false, false),
|
||||
FileSystemEvent.move => FileSystemMoveEvent('${dir.path}/f', false, '${dir.path}/g'),
|
||||
_ => FileSystemModifyEvent('${dir.path}/f', false, false),
|
||||
};
|
||||
expect(FileChangeKind.fromEvent(ev(FileSystemEvent.create)), FileChangeKind.created);
|
||||
expect(FileChangeKind.fromEvent(ev(FileSystemEvent.delete)), FileChangeKind.deleted);
|
||||
expect(FileChangeKind.fromEvent(ev(FileSystemEvent.modify)), FileChangeKind.modified);
|
||||
expect(FileChangeKind.fromEvent(ev(FileSystemEvent.move)), FileChangeKind.renamed);
|
||||
});
|
||||
|
||||
test('wire getter is the enum name', () {
|
||||
expect(FileChangeKind.created.wire, 'created');
|
||||
expect(FileChangeKind.deleted.wire, 'deleted');
|
||||
expect(FileChangeKind.modified.wire, 'modified');
|
||||
expect(FileChangeKind.renamed.wire, 'renamed');
|
||||
});
|
||||
});
|
||||
|
||||
group('FileChange', () {
|
||||
test('toJson encodes kind / path / isDirectory', () {
|
||||
const c = FileChange(kind: FileChangeKind.modified, path: 'a/b.txt', isDirectory: false);
|
||||
final j = c.toJson();
|
||||
expect(j['kind'], 'modified');
|
||||
expect(j['path'], 'a/b.txt');
|
||||
expect(j['isDirectory'], isFalse);
|
||||
});
|
||||
});
|
||||
|
||||
group('FileWatcher', () {
|
||||
late Directory sandbox;
|
||||
late FileWatcher watcher;
|
||||
|
||||
setUp(() async {
|
||||
sandbox = await Directory.systemTemp.createTemp('clide-watcher-');
|
||||
watcher = FileWatcher(root: sandbox, ignore: IgnoreSet.builtin());
|
||||
});
|
||||
|
||||
tearDown(() async {
|
||||
await watcher.stop();
|
||||
if (sandbox.existsSync()) sandbox.deleteSync(recursive: true);
|
||||
});
|
||||
|
||||
test('emits a created event when a file is added under root', () async {
|
||||
await watcher.start();
|
||||
final received = <FileChange>[];
|
||||
final sub = watcher.stream.listen(received.add);
|
||||
addTearDown(sub.cancel);
|
||||
// Give inotify a moment to settle, then create a file.
|
||||
await Future<void>.delayed(const Duration(milliseconds: 50));
|
||||
await File('${sandbox.path}/new.txt').writeAsString('hi');
|
||||
await Future<void>.delayed(const Duration(milliseconds: 200));
|
||||
expect(received.any((c) => c.path == 'new.txt'), isTrue);
|
||||
});
|
||||
|
||||
test('filters ignored paths', () async {
|
||||
await watcher.start();
|
||||
final received = <FileChange>[];
|
||||
final sub = watcher.stream.listen(received.add);
|
||||
addTearDown(sub.cancel);
|
||||
// .dart_tool/ is in the builtin ignore set.
|
||||
await Future<void>.delayed(const Duration(milliseconds: 50));
|
||||
final dt = Directory('${sandbox.path}/.dart_tool')..createSync();
|
||||
await File('${dt.path}/hidden').writeAsString('x');
|
||||
await Future<void>.delayed(const Duration(milliseconds: 200));
|
||||
expect(received.any((c) => c.path.startsWith('.dart_tool')), isFalse);
|
||||
});
|
||||
|
||||
test('second start() is a no-op (idempotent)', () async {
|
||||
await watcher.start();
|
||||
await watcher.start();
|
||||
});
|
||||
|
||||
test('stop() cancels the subscription and closes the stream', () async {
|
||||
await watcher.start();
|
||||
await watcher.stop();
|
||||
// A second stop is also safe.
|
||||
await watcher.stop();
|
||||
});
|
||||
});
|
||||
}
|
||||
@@ -51,5 +51,24 @@ void main() {
|
||||
expect(err.message, contains('kernel exploded'));
|
||||
expect(err.message, isNot(contains('errno=999')));
|
||||
});
|
||||
|
||||
test('ENOTDIR → user_error', () {
|
||||
final e = errnoToIpcError(errno: PosixErrno.enotdir, op: 'files.ls', target: '/x');
|
||||
expect(e.kind, IpcErrorKind.userError);
|
||||
expect(e.message, contains('not a directory'));
|
||||
});
|
||||
|
||||
test('ENOMEM → tool_error', () {
|
||||
final e = errnoToIpcError(errno: PosixErrno.enomem, op: 'pty.spawn');
|
||||
expect(e.kind, IpcErrorKind.toolError);
|
||||
expect(e.message, contains('out of memory'));
|
||||
});
|
||||
|
||||
test('EAGAIN → tool_error with retry hint', () {
|
||||
final e = errnoToIpcError(errno: PosixErrno.eagain, op: 'pty.read');
|
||||
expect(e.kind, IpcErrorKind.toolError);
|
||||
expect(e.message, contains('temporarily unavailable'));
|
||||
expect(e.hint, contains('retry'));
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
@@ -103,4 +103,17 @@ void main() {
|
||||
expect(pane.toJson()['kind'], 'claude');
|
||||
});
|
||||
});
|
||||
|
||||
group('RecordingEventSink filters', () {
|
||||
test('ofSubsystem narrows events to a single subsystem', () {
|
||||
final s = RecordingEventSink();
|
||||
final ts = DateTime.now().toUtc();
|
||||
s.emit(IpcEvent(subsystem: 'pane', kind: 'spawned', timestamp: ts, data: const {}));
|
||||
s.emit(IpcEvent(subsystem: 'git', kind: 'changed', timestamp: ts, data: const {}));
|
||||
s.emit(IpcEvent(subsystem: 'pane', kind: 'closed', timestamp: ts, data: const {}));
|
||||
expect(s.ofSubsystem('pane'), hasLength(2));
|
||||
expect(s.ofSubsystem('git'), hasLength(1));
|
||||
expect(s.ofSubsystem('files'), isEmpty);
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user