Foxyz/sync_replay_project
1
0 Fork 1
Code Issues Pull Requests Actions Packages Projects Releases 13 Wiki Activity

Server test: flaky_link's silence limit 1.5 s (600 ms marked a reporting client gone on a busy CI runner)

Browse Source 
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
This commit is contained in:
foxyzandClaude Opus 5.5 committed 2026-10-17 02:05:44 +03:00
1 parent e16cf50f2c
commit f9b79aa47c
1 file changed
+4 -3
Download Patch File Download Diff File Expand all files Collapse all files
packages/server/test/flaky_link_test.dart
+4 -3
View File
@@ -72,9 +72,10 @@ void main() {
final clients = <_Client>[]; final clients = <_Client>[];
setUp(() async { setUp(() async {
// Short limits so the demo runs in a couple of seconds. // Short limits so the demo runs in a few seconds; silence well above
// a busy CI runner's stalls (600 ms marked a reporting client gone).
server = SyncServer(AppConfig(port: 0, secret: 'shh', name: 'test'), server = SyncServer(AppConfig(port: 0, secret: 'shh', name: 'test'),
liveness: const Liveness(silence: Duration(milliseconds: 600))); liveness: const Liveness(silence: Duration(milliseconds: 1500)));
await server.start(); await server.start();
proxy = await FlakyProxy.start(server.boundPort); proxy = await FlakyProxy.start(server.boundPort);
}); });
@@ -106,7 +107,7 @@ void main() {
.toJson()); .toJson());
c.send(const SwapIntent(media: HelloMedia(name: 'mine.mkv', size: 100, duration: 0, relay: MediaRelay())).toJson()); c.send(const SwapIntent(media: HelloMedia(name: 'mine.mkv', size: 100, duration: 0, relay: MediaRelay())).toJson());
await until(() => engine.queue.length == 1 && server.hub.relay != null && member()!.ready, 'ready, queued, relayed'); await until(() => engine.queue.length == 1 && server.hub.relay != null && member()!.ready, 'ready, queued, relayed');
await Future<void>.delayed(const Duration(milliseconds: 1200)); await Future<void>.delayed(const Duration(milliseconds: 2000));
expect(member()!.presence, isNot(Presence.gone), reason: 'reports through the proxy keep it present'); expect(member()!.presence, isNot(Presence.gone), reason: 'reports through the proxy keep it present');
proxy.last!.blackhole(); proxy.last!.blackhole();