X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2Ftypescript%2Fhttp-server-pool%2Fexpress-cluster%2Fsrc%2Fworker.ts;h=d575647375edca90297ee647d0c4c26395e288f1;hb=efc4d37dd21d0c80e5fa2d58009e6298eefe5d48;hp=7dd607b5b17cfd703d4dd75ae0c08d5aa6c5dd7b;hpb=ef083f7bb73616d1bd9d9069471edcf6dbaec0c7;p=poolifier.git diff --git a/examples/typescript/http-server-pool/express-cluster/src/worker.ts b/examples/typescript/http-server-pool/express-cluster/src/worker.ts index 7dd607b5..d5756473 100644 --- a/examples/typescript/http-server-pool/express-cluster/src/worker.ts +++ b/examples/typescript/http-server-pool/express-cluster/src/worker.ts @@ -4,20 +4,20 @@ import { ClusterWorker } from 'poolifier' import express, { type Express, type Request, type Response } from 'express' import type { WorkerData, WorkerResponse } from './types.js' -const factorial: (n: number) => number = n => { - if (n === 0) { - return 1 - } - return factorial(n - 1) * n -} - class ExpressWorker extends ClusterWorker { private static server: Server + private static readonly factorial = (n: number): number => { + if (n === 0) { + return 1 + } + return ExpressWorker.factorial(n - 1) * n + } + private static readonly startExpress = ( workerData?: WorkerData ): WorkerResponse => { - const { port } = workerData as WorkerData + const { port } = workerData! const application: Express = express() @@ -30,18 +30,17 @@ class ExpressWorker extends ClusterWorker { application.get('/api/factorial/:number', (req: Request, res: Response) => { const { number } = req.params - res.send({ number: factorial(parseInt(number)) }).end() + res.send({ number: ExpressWorker.factorial(parseInt(number)) }).end() }) ExpressWorker.server = application.listen(port, () => { console.info( - // eslint-disable-next-line @typescript-eslint/restrict-template-expressions `⚡️[express server]: Express server is started in cluster worker at http://localhost:${port}/` ) }) return { status: true, - port: (ExpressWorker.server.address() as AddressInfo)?.port ?? port + port: (ExpressWorker.server.address() as AddressInfo).port } }