file actor

This commit is contained in:
randogoth 2026-06-07 15:26:11 +03:00
parent 11e55a4f44
commit 8c165edc0c
5 changed files with 83 additions and 1 deletions

1
.gitignore vendored Normal file
View file

@ -0,0 +1 @@
.dart_tool/

View file

@ -7,7 +7,6 @@ analyzer:
linter: linter:
rules: rules:
- public_member_api_docs
- prefer_final_fields - prefer_final_fields
- prefer_const_constructors - prefer_const_constructors
- prefer_const_declarations - prefer_const_declarations

39
lib/src/file_actor.dart Normal file
View file

@ -0,0 +1,39 @@
import 'dart:io';
import 'package:actors/actors.dart';
sealed class FileMessage {
const FileMessage();
}
final class LoadFile extends FileMessage {
final String path;
const LoadFile(this.path);
}
final class SaveFile extends FileMessage {
final String path;
final String content;
const SaveFile(this.path, this.content);
}
sealed class FileResult {
const FileResult();
}
final class FileLoaded extends FileResult {
final String content;
const FileLoaded(this.content);
}
final class FileSaved extends FileResult {
const FileSaved();
}
class FileActor with Handler<FileMessage, FileResult> {
@override
Future<FileResult> handle(FileMessage message) => switch (message) {
LoadFile(:final path) => File(path).readAsString().then(FileLoaded.new),
SaveFile(:final path, :final content) =>
File(path).writeAsString(content).then((_) => const FileSaved()),
};
}

1
lib/swarm.dart Normal file
View file

@ -0,0 +1 @@
export 'src/file_actor.dart';

42
test/file_actor_test.dart Normal file
View file

@ -0,0 +1,42 @@
import 'dart:io';
import 'package:actors/actors.dart';
import 'package:swarm/swarm.dart';
import 'package:test/test.dart';
void main() {
group('FileActor', () {
late Actor<FileMessage, FileResult> actor;
late Directory tempDir;
setUp(() async {
actor = Actor.create(FileActor.new);
tempDir = await Directory.systemTemp.createTemp('swarm_test_');
});
tearDown(() async {
await actor.close();
await tempDir.delete(recursive: true);
});
test('saves a file', () async {
final path = '${tempDir.path}/hello.txt';
final result = await actor.send(SaveFile(path, 'hello world'));
expect(result, isA<FileSaved>());
});
test('loads a saved file', () async {
final path = '${tempDir.path}/hello.txt';
await actor.send(SaveFile(path, 'hello world'));
final result = await actor.send(LoadFile(path));
expect(result, isA<FileLoaded>());
expect((result as FileLoaded).content, equals('hello world'));
});
test('load throws PathNotFoundException for missing file', () {
expect(
actor.send(LoadFile('${tempDir.path}/nonexistent.txt')),
throwsA(isA<PathNotFoundException>()),
);
});
});
}