add observability: EventBus logging, HTTP logging interceptor & structured GlobalErrorHandler

Author: Awakich

projects/core/src/lib/interceptors/index.ts

@@ -2,3 +2,4 @@
 
 export * from "./bearer-token.interceptor";
 export * from "./camelcase.interceptor";
+export * from "./logging.interceptor";

projects/core/src/lib/interceptors/logging.interceptor.ts

@@ -0,0 +1,42 @@
+/** @format */
+
+import { Injectable } from "@angular/core";
+import {
+  HttpErrorResponse,
+  HttpEvent,
+  HttpHandler,
+  HttpInterceptor,
+  HttpRequest,
+  HttpResponse,
+} from "@angular/common/http";
+import { Observable, tap } from "rxjs";
+import { LoggerService } from "../services";
+
+@Injectable()
+export class LoggingInterceptor implements HttpInterceptor {
+  constructor(private readonly logger: LoggerService) {}
+
+  intercept(request: HttpRequest<unknown>, next: HttpHandler): Observable<HttpEvent<unknown>> {
+    const started = Date.now();
+
+    return next.handle(request).pipe(
+      tap({
+        next: event => {
+          if (event instanceof HttpResponse) {
+            const elapsed = Date.now() - started;
+            this.logger.debug(
+              `[HTTP] ${request.method} ${request.urlWithParams} ${event.status} ${elapsed}ms`
+            );
+          }
+        },
+        error: (error: HttpErrorResponse) => {
+          const elapsed = Date.now() - started;
+          this.logger.error(
+            `[HTTP] ${request.method} ${request.urlWithParams} ${error.status} ${elapsed}ms`,
+            error.message
+          );
+        },
+      })
+    );
+  }
+}

projects/core/src/lib/services/error/global-error-handler.service.ts

@@ -1,7 +1,8 @@
 /** @format */
 
-import { ErrorHandler, Injectable, NgZone } from "@angular/core";
+import { ErrorHandler, inject, Injectable, NgZone } from "@angular/core";
 import { ErrorService } from "./error.service";
+import { LoggerService } from "../logger/logger.service";
 
 /**
  * Глобальный обработчик ошибок приложения
@@ -31,29 +32,17 @@ import { ErrorService } from "./error.service";
  */
 @Injectable()
 export class GlobalErrorHandlerService implements ErrorHandler {
+  private readonly logger = inject(LoggerService);
+
   constructor(private readonly errorService: ErrorService, private readonly zone: NgZone) {}
 
-  /**
-   * Обрабатывает глобальные ошибки приложения
-   * @param err - ошибка или Promise rejection
-   */
   handleError(err: any): void {
-    // Извлекаем фактическую ошибку из Promise rejection или используем как есть
     const error = err.rejection ? err.rejection : err;
 
-    // Закомментированный код для обработки HTTP ошибок:
-    // if(error instanceof HttpErrorResponse) {
-    //   switch(error.status) {
-    //     case 404: {
-    //       this.zone.run(() => this.errorService.throwNotFount())
-    //       break;
-    //     }
-    //   }
-    // }
-
-    // Логируем ошибки типа Error в консоль
     if (error instanceof Error) {
-      console.error(error);
+      this.logger.error(`[GlobalError] ${error.name}: ${error.message}`, error.stack);
+    } else {
+      this.logger.error("[GlobalError] Unknown error", error);
     }
   }
 }

projects/social_platform/src/app/app.config.ts

@@ -14,6 +14,7 @@ import {
   API_URL,
   BearerTokenInterceptor,
   CamelcaseInterceptor,
+  LoggingInterceptor,
   PRODUCTION,
   SKILLS_API_URL,
 } from "@corelib";
@@ -62,6 +63,11 @@ export const APP_CONFIG: ApplicationConfig = {
       useClass: BearerTokenInterceptor,
       multi: true,
     },
+    {
+      provide: HTTP_INTERCEPTORS,
+      useClass: LoggingInterceptor,
+      multi: true,
+    },
     {
       provide: API_URL,
       useValue: environment.apiUrl,

projects/social_platform/src/app/domain/shared/event-bus.ts

@@ -1,12 +1,20 @@
 /** @format */
 
-import { Injectable } from "@angular/core";
+import { inject, Injectable } from "@angular/core";
 import { filter, map, Observable, Subject } from "rxjs";
 import { DomainEvent } from "./domain-event";
+import { LoggerService } from "@corelib";
 
 @Injectable({ providedIn: "root" })
 export class EventBus {
   private readonly events$ = new Subject<DomainEvent>();
+  private readonly logger = inject(LoggerService);
+
+  constructor() {
+    this.events$.subscribe(event => {
+      this.logger.debug(`[EventBus] ${event.type}`, event.payload);
+    });
+  }
 
   emit<T extends DomainEvent>(event: T): void {
     this.events$.next(event);