feat: add logs endpoint

bin/main.dart

@@ -17,10 +17,6 @@ void main(List<String> args) async {
   Logger.root.level = Level.ALL;
   Logger.root.onRecord.listen(debugLogHandler);
 
-  if (kDebugMode) {
-    Logger.root.warning('Running in debug mode');
-  }
-
   try {
     await prisma.$connect();
 
@@ -32,6 +28,10 @@ void main(List<String> args) async {
       ],
     );
 
+    if (kDebugMode) {
+      Logger.root.warning('Running in debug mode');
+    }
+
     setPrintResolver((msg) {
       final logger = Logger('Modular');
       final parts = msg.split(' ');

lib/modules/admin/admin.dart

@@ -32,6 +32,13 @@ class AdminModule extends Module {
       ..resource(ProductsResource(), name: '/products')
       ..resource(FeaturesResource(), name: '/features')
       ..resource(PaymentsResource(), name: '/payments')
-      ..resource(ClientKeyResource(), name: '/client-keys');
+      ..resource(ClientKeyResource(), name: '/client-keys')
+      ..websocket(
+        '/logs',
+        websocket: LogsResource(),
+        middlewares: [
+          WebsocketMarkerMiddleware(),
+        ],
+      );
   }
 }

lib/modules/admin/presentation/resources/logs_resource.dart

@@ -0,0 +1,40 @@
+import 'dart:async';
+import 'dart:convert';
+
+import 'package:echidna_dto/echidna_dto.dart';
+import 'package:logging/logging.dart';
+import 'package:shelf_modular/shelf_modular.dart';
+
+/// Logs endpoint that broadcasts logs to connected clients.
+class LogsResource extends WebSocketResource {
+  final List<ServerLog> _logs = [];
+
+  /// Logs endpoint that broadcasts logs to connected clients.
+  LogsResource() {
+    Logger.root.onRecord.listen(listener);
+
+    Timer.periodic(
+      const Duration(hours: 1),
+      (_) {
+        _logs.removeWhere((log) => log.time.isBefore(DateTime.now().subtract(const Duration(days: 1))));
+      },
+    );
+  }
+
+  @override
+  void connect(WebSocket socket) {
+    socket.sink.add(jsonEncode(_logs));
+  }
+
+  @override
+  void disconnect(WebSocket socket) {}
+
+  @override
+  void onMessage(dynamic data, WebSocket socket) {}
+
+  void listener(LogRecord record) {
+    _logs.add(ServerLog.fromLogRecord(record));
+
+    broadcast(jsonEncode(_logs));
+  }
+}

lib/modules/admin/presentation/resources/resources.dart

@@ -2,5 +2,6 @@ export 'client_key_resource.dart';
 export 'customers_resource.dart';
 export 'features_resource.dart';
 export 'licenses_resource.dart';
+export 'logs_resource.dart';
 export 'payments_resource.dart';
-export 'products_resource.dart';
+export 'products_resource.dart';

lib/modules/auth/presentation/guards/auth_guard.dart

@@ -10,7 +10,13 @@ class AuthGuard extends RouteGuard {
   FutureOr<bool> canActivate(Request request, Route route) async {
     final auth = Modular.get<AuthService>();
 
-    final token = request.headers['Authorization']?.split('Bearer ').last;
+    String? token;
+
+    if (route.middlewares.any((element) => element is WebsocketMarkerMiddleware)) {
+      token = request.url.queryParameters['token'];
+    } else {
+      token = request.headers['Authorization']?.split('Bearer ').last;
+    }
 
     if (token == null) {
       return false;
@@ -23,3 +29,11 @@ class AuthGuard extends RouteGuard {
     }
   }
 }
+
+/// A [ModularMiddleware] that marks a route as a websocket route.
+class WebsocketMarkerMiddleware extends ModularMiddleware {
+  @override
+  Handler call(Handler handler, [ModularRoute? route]) {
+    return handler;
+  }
+}