X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2Ftypescript%2Fhttp-server-pool%2Fexpress-cluster%2Fsrc%2Fworker.ts;h=98ca45deea0be0c1dab6bb92ff558555d9eee271;hb=5d9133ae9ef83c5f69e26daf8dcfea584884d9c4;hp=d575647375edca90297ee647d0c4c26395e288f1;hpb=c63a35a04c190989be80f9218d97e0aca739475e;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 d5756473..98ca45de 100644 --- a/examples/typescript/http-server-pool/express-cluster/src/worker.ts +++ b/examples/typescript/http-server-pool/express-cluster/src/worker.ts @@ -1,17 +1,25 @@ import type { Server } from 'node:http' import type { AddressInfo } from 'node:net' -import { ClusterWorker } from 'poolifier' + import express, { type Express, type Request, type Response } from 'express' +import { ClusterWorker } from 'poolifier' + import type { WorkerData, WorkerResponse } from './types.js' class ExpressWorker extends ClusterWorker { private static server: Server - private static readonly factorial = (n: number): number => { - if (n === 0) { - return 1 + private static readonly factorial = (n: number | bigint): bigint => { + if (n === 0 || n === 1) { + return 1n + } else { + n = BigInt(n) + let factorial = 1n + for (let i = 1n; i <= n; i++) { + factorial *= i + } + return factorial } - return ExpressWorker.factorial(n - 1) * n } private static readonly startExpress = ( @@ -30,17 +38,21 @@ class ExpressWorker extends ClusterWorker { application.get('/api/factorial/:number', (req: Request, res: Response) => { const { number } = req.params - res.send({ number: ExpressWorker.factorial(parseInt(number)) }).end() + res + .send({ number: ExpressWorker.factorial(parseInt(number)).toString() }) + .end() }) + let listenerPort: number | undefined ExpressWorker.server = application.listen(port, () => { + listenerPort = (ExpressWorker.server.address() as AddressInfo).port console.info( - `⚡️[express server]: Express server is started in cluster worker at http://localhost:${port}/` + `⚡️[express server]: Express server is started in cluster worker at http://localhost:${listenerPort}/` ) }) return { status: true, - port: (ExpressWorker.server.address() as AddressInfo).port + port: listenerPort ?? port } }