X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2Ftypescript%2Fhttp-server-pool%2Ffastify-hybrid%2Fsrc%2Ffastify-worker.ts;h=0f4f6370b4c5249a2dfc8f2b4169d0245bbdda68;hb=efc4d37dd21d0c80e5fa2d58009e6298eefe5d48;hp=051be889250c57a97e8ea9af54e494e5c8e88a4b;hpb=93b097acefb8dfea7259bff4cb9f6c337d34db94;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 051be889..0f4f6370 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 @@ -13,26 +13,30 @@ ClusterWorkerResponse private static readonly startFastify = async ( workerData?: ClusterWorkerData ): Promise => { - const { port } = workerData as ClusterWorkerData + const { port, ...fastifyPoolifierOptions } = workerData! + FastifyWorker.fastify = Fastify({ logger: true }) - await FastifyWorker.fastify.register(fastifyPoolifier, workerData) + await FastifyWorker.fastify.register( + fastifyPoolifier, + fastifyPoolifierOptions + ) - FastifyWorker.fastify.all('/api/echo', async (request) => { + FastifyWorker.fastify.all('/api/echo', async request => { return ( - await FastifyWorker.fastify.execute({ body: request.body }, 'echo') - ).body + await FastifyWorker.fastify.execute({ data: request.body }, 'echo') + ).data }) 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({ body: { number } }, 'factorial') - ).body + await FastifyWorker.fastify.execute({ data: { number } }, 'factorial') + ).data }) await FastifyWorker.fastify.listen({ port })