diff --git a/server/src/controllers/queueController.ts b/server/src/controllers/queueController.ts index 9ae2b494a..52762f42b 100755 --- a/server/src/controllers/queueController.ts +++ b/server/src/controllers/queueController.ts @@ -3,7 +3,14 @@ import { Request, Response, NextFunction } from "express"; const SERVICE_NAME = "JobQueueController"; -class JobQueueController { +export interface IJobQueueController { + getMetrics(req: Request, res: Response, next: NextFunction): Promise; + getJobs(req: Request, res: Response, next: NextFunction): Promise; + getAllMetrics(req: Request, res: Response, next: NextFunction): Promise; + flushQueue(req: Request, res: Response, next: NextFunction): Promise; +} + +class JobQueueController implements IJobQueueController { static SERVICE_NAME = SERVICE_NAME; private jobQueue: ISuperSimpleQueue; constructor(jobQueue: ISuperSimpleQueue) { diff --git a/server/src/routes/queueRoute.ts b/server/src/routes/queueRoute.ts index dd3b27999..d5d35147c 100755 --- a/server/src/routes/queueRoute.ts +++ b/server/src/routes/queueRoute.ts @@ -1,10 +1,11 @@ import { Router } from "express"; -import { isAllowed } from "../middleware/isAllowed.js"; +import { isAllowed } from "@/middleware/isAllowed.js"; +import { IJobQueueController } from "@/controllers/queueController.js"; class QueueRoutes { private router: Router; - private queueController: any; + private queueController: IJobQueueController; - constructor(queueController: any) { + constructor(queueController: IJobQueueController) { this.router = Router(); this.queueController = queueController; this.initRoutes();