Merge branch 'master' of github.com:poolifier/poolifier

[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 { fastifyPoolifier } from './fastify-poolifier.js'

/**
 * The fastify server is still a single-threaded application, but the request handling can be multi-threaded.
 */

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,
  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<{
  Params: { number: number }
}>('/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)
}