feat: add fastify poolifier integration example

[poolifier.git] / examples / typescript / http-server-pool / fastify / src / main.ts

import { dirname, extname, join } from 'node:path'
import { fileURLToPath } from 'node:url'
import Fastify from 'fastify'
import { availableParallelism } from 'poolifier'
import { fastifyPoolifier } from './fastify-poolifier.js'

const port = 8080
const fastify = Fastify({
  logger: true
})

const workerFile = join(
  dirname(fileURLToPath(import.meta.url)),
  `worker${extname(fileURLToPath(import.meta.url))}`
)

await fastify.register(fastifyPoolifier, {
  workerFile,
  minWorkers: 1,
  maxWorkers: availableParallelism(),
  enableTasksQueue: true,
  tasksQueueOptions: {
    concurrency: 8
  },
  errorHandler: (e: Error) => {
    console.error(e)
  }
})

fastify.all('/api/echo', async (request, reply) => {
  await reply.send((await fastify.execute({ body: request.body }, 'echo')).body)
})

// fastify.get('/api/factorial/:number', async (request, reply) => {
//   const { number } = request.params
//   await reply.send((await fastify.execute({ body: { number } }, 'factorial')).body)
// })

try {
  await fastify.listen({ port })
} catch (err) {
  fastify.log.error(err)
  process.exit(1)
}