error processing

src/app.ts

@@ -1,5 +1,6 @@
 import express, {Express} from 'express';
 import { Server} from 'http';
+import { ExeptionFilter } from './errors/exeption.filter';
 import { LoggerService } from './logger/logger.service';
 import { UserController } from './users/users.controller';
 
@@ -8,21 +9,28 @@ export class App {
     server: Server;
     port: number;
     logger: LoggerService;
-    userController: UserController
+    userController: UserController;
+    exeptionFilter: ExeptionFilter;
 
-    constructor(logger: LoggerService, userController: UserController) {
+    constructor(logger: LoggerService, userController: UserController, exeptionFilter: ExeptionFilter) {
         this.app = express();
         this.port = 8000;
         this.logger = logger;
         this.userController = userController;
+        this.exeptionFilter = exeptionFilter;
     }
 
     useRoutes() {
         this.app.use('/users', this.userController.router);
     }
 
+    useExeptionFilter() {
+        this.app.use(this.exeptionFilter.catch.bind(this.exeptionFilter))
+    }
+
     public async init() {
         this.useRoutes();
+        this.useExeptionFilter();
         this.server = this.app.listen(this.port);
         this.logger.log(`Сервер запущен на http://localhost:${this.port}`);
     }

src/errors/exeption.filter.interface.ts

@@ -0,0 +1,5 @@
+import { Request, Response, NextFunction } from "express";
+
+export interface IExeptionFilter {
+    catch: (err: Error, req: Request, res: Response, next: NextFunction) => void
+}

src/errors/exeption.filter.ts

@@ -0,0 +1,21 @@
+import { NextFunction, Request, Response } from "express";
+import { LoggerService } from "../logger/logger.service";
+import { IExeptionFilter } from "./exeption.filter.interface";
+import { HTTPError } from "./http-error.class";
+
+export class ExeptionFilter implements IExeptionFilter{
+    logger: LoggerService;
+    constructor(logger: LoggerService) {
+        this.logger = logger;
+    }
+
+    catch (err: Error | HTTPError, req: Request, res: Response, next: NextFunction) {
+        if (err instanceof HTTPError) {
+            this.logger.error(`[${err.context}] Ошибка ${err.statusCode}: ${err.message}`);
+            res.status(err.statusCode).send({err: err.message});
+        } else {
+            this.logger.error(`${err.message}`);
+            res.status(500).send({err: err.message});
+        }
+    }
+}

src/errors/http-error.class.ts

@@ -0,0 +1,13 @@
+export class HTTPError extends Error {
+    statusCode: number;
+    context?: string;
+
+    constructor(statusCode: number, message: string, context?: string) {
+        super(message);
+        this.statusCode = statusCode;
+        this.message = message;
+        this.context = context;
+    }
+
+
+}

src/main.ts

@@ -1,10 +1,11 @@
 import { App } from "./app";
+import { ExeptionFilter } from "./errors/exeption.filter";
 import { LoggerService } from "./logger/logger.service";
 import { UserController } from "./users/users.controller";
 
 async function bootstrap() {
     const logger = new LoggerService();
-    const app = new App(logger, new UserController(logger));
+    const app = new App(logger, new UserController(logger), new ExeptionFilter(logger));
     await app.init();
 }
 

src/users/users.controller.ts

@@ -1,5 +1,6 @@
 import { NextFunction, Request, Response } from "express";
 import { BaseController } from "../common/base.controller";
+import { HTTPError } from "../errors/http-error.class";
 import { LoggerService } from "../logger/logger.service";
 
 export class UserController extends BaseController{
@@ -12,7 +13,7 @@ export class UserController extends BaseController{
     }
 
     login (req: Request, res: Response, next: NextFunction) {
-        this.ok(res, 'login')
+        next(new HTTPError(401, 'Ошибка авторизации', 'login'))
     }
 
     register(req: Request, res: Response, next: NextFunction) {