X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2Ftypescript%2Fhttp-server-pool%2Ffastify-hybrid%2Fsrc%2Ffastify-worker.ts;h=4a697f3e255def59329478440f5f8d7ca205737e;hb=e69cc10a0b0e531f4bb7a33fc8728741d9a82533;hp=e21eb58c01294014fd9557f067c6544bcfcca18a;hpb=85d2a65ad4435211edf06c035f87425594044bd2;p=poolifier.git diff --git a/examples/typescript/http-server-pool/fastify-hybrid/src/fastify-worker.ts b/examples/typescript/http-server-pool/fastify-hybrid/src/fastify-worker.ts index e21eb58c..4a697f3e 100644 --- a/examples/typescript/http-server-pool/fastify-hybrid/src/fastify-worker.ts +++ b/examples/typescript/http-server-pool/fastify-hybrid/src/fastify-worker.ts @@ -1,22 +1,25 @@ import type { AddressInfo } from 'node:net' -import { ClusterWorker } from 'poolifier' + import Fastify, { type FastifyInstance } from 'fastify' -import type { ClusterWorkerData, ClusterWorkerResponse } from './types.js' +import { ClusterWorker } from 'poolifier' + import { fastifyPoolifier } from './fastify-poolifier.js' +import type { ClusterWorkerData, ClusterWorkerResponse } from './types.js' class FastifyWorker extends ClusterWorker< -ClusterWorkerData, -ClusterWorkerResponse + ClusterWorkerData, + ClusterWorkerResponse > { private static fastify: FastifyInstance private static readonly startFastify = async ( workerData?: ClusterWorkerData ): Promise => { - const { port, ...fastifyPoolifierOptions } = workerData as ClusterWorkerData + // eslint-disable-next-line @typescript-eslint/no-non-null-assertion + const { port, ...fastifyPoolifierOptions } = workerData! FastifyWorker.fastify = Fastify({ - logger: true + logger: true, }) await FastifyWorker.fastify.register( @@ -24,7 +27,7 @@ ClusterWorkerResponse fastifyPoolifierOptions ) - FastifyWorker.fastify.all('/api/echo', async (request) => { + FastifyWorker.fastify.all('/api/echo', async request => { return ( await FastifyWorker.fastify.execute({ data: request.body }, 'echo') ).data @@ -32,7 +35,7 @@ ClusterWorkerResponse FastifyWorker.fastify.get<{ Params: { number: number } - }>('/api/factorial/:number', async (request) => { + }>('/api/factorial/:number', async request => { const { number } = request.params return ( await FastifyWorker.fastify.execute({ data: { number } }, 'factorial') @@ -42,7 +45,7 @@ ClusterWorkerResponse await FastifyWorker.fastify.listen({ port }) return { status: true, - port: (FastifyWorker.fastify.server.address() as AddressInfo).port + port: (FastifyWorker.fastify.server.address() as AddressInfo).port, } } @@ -51,7 +54,7 @@ ClusterWorkerResponse killHandler: async () => { await FastifyWorker.fastify.pool.destroy() await FastifyWorker.fastify.close() - } + }, }) } }