diff --git a/test/backend/chaos_monkey_test.dart b/test/backend/chaos_monkey_test.dart index df7af5d..f6715a4 100644 --- a/test/backend/chaos_monkey_test.dart +++ b/test/backend/chaos_monkey_test.dart @@ -32,8 +32,13 @@ Future _imapConnectPlain( String username, String password, ) async { - final client = ImapClient(defaultResponseTimeout: const Duration(seconds: 20)); - await client.connectToServer(account.imapHost, account.imapPort, isSecure: false); + final client = + ImapClient(defaultResponseTimeout: const Duration(seconds: 20)); + await client.connectToServer( + account.imapHost, + account.imapPort, + isSecure: false, + ); await client.login(username, password); return client; } @@ -47,7 +52,11 @@ Future _smtpConnectPlain( final domain = atIndex != -1 ? account.email.substring(atIndex + 1) : account.smtpHost; final client = SmtpClient(domain); - await client.connectToServer(account.smtpHost, account.smtpPort, isSecure: false); + await client.connectToServer( + account.smtpHost, + account.smtpPort, + isSecure: false, + ); await client.ehlo(); await client.authenticate(username, password); return client; @@ -122,15 +131,16 @@ void main() { tearDown(() => db.close()); - test('chaos monkey — random operations do not crash the repository', () async { - final seedStr = _env('CHAOS_SEED', ''); + test('chaos monkey — random operations do not crash the repository', + () async { + final seedStr = _env('CHAOS_SEED'); final seed = seedStr.isEmpty ? DateTime.now().millisecondsSinceEpoch : int.parse(seedStr); final rounds = int.parse(_env('CHAOS_ROUNDS', '30')); final rng = Random(seed); - print('chaos-monkey: seed=$seed rounds=$rounds'); + stdout.writeln('chaos-monkey: seed=$seed rounds=$rounds'); // Seed INBOX with a few messages so early rounds have something to act on. for (var i = 0; i < 3; i++) { @@ -149,7 +159,7 @@ void main() { for (var round = 0; round < rounds; round++) { final action = rng.nextInt(8); - print('chaos-monkey: round=$round action=$action'); + stdout.writeln('chaos-monkey: round=$round action=$action'); switch (action) { case 0: // sync INBOX @@ -190,8 +200,9 @@ void main() { await emails.setFlag(e.id, flagged: !e.isFlagged); case 6: // flush pending changes to server - final flushed = await emails.flushPendingChanges(account.id, userPass); - print('chaos-monkey: flushed $flushed pending changes'); + final flushed = + await emails.flushPendingChanges(account.id, userPass); + stdout.writeln('chaos-monkey: flushed $flushed pending changes'); case 7: // delete random email final inbox = await emails.observeEmails(account.id, 'INBOX').first; @@ -203,8 +214,8 @@ void main() { // Final flush and sync to confirm the server is in a consistent state. final flushed = await emails.flushPendingChanges(account.id, userPass); - print('chaos-monkey: final flush flushed=$flushed'); + stdout.writeln('chaos-monkey: final flush flushed=$flushed'); final result = await emails.syncEmails(account.id, 'INBOX'); - print('chaos-monkey: final sync fetched=${result.fetched}'); + stdout.writeln('chaos-monkey: final sync fetched=${result.fetched}'); }); }