platform/packages/websocket/test/service/io_test.dart

import 'dart:io';
import 'package:angel3_container/mirrors.dart';
import 'package:angel3_framework/angel3_framework.dart' as srv;
import 'package:angel3_framework/http.dart' as srv;
import 'package:angel3_websocket/io.dart' as ws;
import 'package:angel3_websocket/server.dart' as srv;
import 'package:logging/logging.dart';
import 'package:test/test.dart';
import 'common.dart';

void main() {
  srv.Angel? app;
  late srv.AngelHttp http;
  ws.WebSockets? client;
  srv.AngelWebSocket websockets;
  HttpServer? server;
  String? url;

  setUp(() async {
    app = srv.Angel(reflector: MirrorsReflector())
      ..use('/api/todos', TodoService());
    http = srv.AngelHttp(app!, useZone: false);

    websockets = srv.AngelWebSocket(app)
      ..onData.listen((data) {
        print('Received by server: $data');
      });

    await app!.configure(websockets.configureServer);
    app!.all('/ws', websockets.handleRequest);
    app!.logger = Logger('angel_auth')..onRecord.listen(print);
    server = await http.startServer();
    url = 'ws://${server!.address.address}:${server!.port}/ws';

    client = ws.WebSockets(url);
    await client!.connect();

    client
      ?..onData.listen((data) {
        print('Received by client: $data');
      })
      ..onError.listen((error) {
        // Auto-fail tests on errors ;)
        stderr.writeln(error);
        error.errors.forEach(stderr.writeln);
        throw error;
      });
  });

  tearDown(() async {
    await client!.close();
    await http.server!.close(force: true);

    app = null;
    client = null;
    server = null;
    url = null;
    //exit(0);
  });

  group('service.io', () {
    test('index', () => testIndex(client!));
  });
}