X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2Ftypescript%2Fhttp-server-pool%2Ffastify-cluster%2Fsrc%2Fworker.ts;h=ee64ee2ec3911257f86e90a48702116676692afa;hb=6c05d445368a6e7b692578e7d74375dc69357617;hp=3f7b3661f99cd2f51082366eadfc8cbe17ba804a;hpb=8ad621cc1d32ed396fca3ef2ec48337e42d2dcc2;p=poolifier.git diff --git a/examples/typescript/http-server-pool/fastify-cluster/src/worker.ts b/examples/typescript/http-server-pool/fastify-cluster/src/worker.ts index 3f7b3661..ee64ee2e 100644 --- a/examples/typescript/http-server-pool/fastify-cluster/src/worker.ts +++ b/examples/typescript/http-server-pool/fastify-cluster/src/worker.ts @@ -3,7 +3,7 @@ import { ClusterWorker } from 'poolifier' import Fastify, { type FastifyInstance } from 'fastify' import type { WorkerData, WorkerResponse } from './types.js' -const factorial: (n: number) => number = (n) => { +const factorial: (n: number) => number = n => { if (n === 0) { return 1 } @@ -17,17 +17,18 @@ class FastifyWorker extends ClusterWorker { workerData?: WorkerData ): Promise => { const { port } = workerData as WorkerData + FastifyWorker.fastify = Fastify({ logger: true }) - FastifyWorker.fastify.all('/api/echo', (request) => { + FastifyWorker.fastify.all('/api/echo', request => { return request.body }) FastifyWorker.fastify.get<{ Params: { number: number } - }>('/api/factorial/:number', (request) => { + }>('/api/factorial/:number', request => { const { number } = request.params return { number: factorial(number) } }) @@ -35,12 +36,16 @@ class FastifyWorker extends ClusterWorker { await FastifyWorker.fastify.listen({ port }) return { status: true, - port: (FastifyWorker.fastify.server.address() as AddressInfo).port + port: (FastifyWorker.fastify.server.address() as AddressInfo)?.port } } public constructor () { - super(FastifyWorker.startFastify) + super(FastifyWorker.startFastify, { + killHandler: async () => { + await FastifyWorker.fastify.close() + } + }) } }