configureServer method

@override Future configureServer(Angel app)

Applies routes, DI, and other configuration to an app.

Implementation

@override
Future configureServer(Angel app) async {
  if (findExpose(app.container!.reflector) != null) {
    await super.configureServer(app);
  }

  var instanceMirror = reflect(this);
  var classMirror = reflectClass(runtimeType);
  classMirror.instanceMembers.forEach((sym, mirror) {
    if (mirror.isRegularMethod) {
      var exposeMirror = mirror.metadata
          .firstWhereOrNull((mirror) => mirror.reflectee is ExposeWs);

      if (exposeMirror != null) {
        var exposeWs = exposeMirror.reflectee as ExposeWs;
        _handlers[exposeWs.eventName] = mirror;
        _handlerSymbols[exposeWs.eventName] = sym;
      }
    }
  });

  ws.onConnection.listen((socket) async {
    if (!socket.request.container!.has<WebSocketContext>()) {
      socket.request.container!.registerSingleton<WebSocketContext>(socket);
    }

    await onConnect(socket);

    socket.onData.listen((data) => onData(data, socket));

    socket.onAction.listen((WebSocketAction action) async {
      var container = socket.request.container!.createChild();
      container.registerSingleton<WebSocketAction>(action);

      try {
        await onAction(action, socket);

        if (_handlers.containsKey(action.eventName)) {
          var methodMirror = _handlers[action.eventName!]!;
          var fn = instanceMirror.getField(methodMirror.simpleName).reflectee;
          return app.runContained(
              fn as Function, socket.request, socket.response, container);
        }
      } catch (e, st) {
        ws.catchError(e, st, socket);
      }
    });
  });

  ws.onDisconnection.listen(onDisconnect);
}