feat: add fastify in cluster pool example

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

import { dirname, extname, join } from 'node:path'
import { fileURLToPath } from 'node:url'
import { FixedClusterPool, availableParallelism } from 'poolifier'
import type { WorkerData, WorkerResponse } from './types.js'

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

const pool = new FixedClusterPool<WorkerData, WorkerResponse>(
  availableParallelism(),
  workerFile,
  {
    errorHandler: (e: Error) => {
      console.error(e)
    }
  }
)

// Start one fastify instance per cluster worker in the pool
for (let i = 1; i <= pool.info.maxSize; i++) {
  pool
    .execute({ port: 8080 })
    .then(response => {
      if (response.status) {
        console.info(
          // eslint-disable-next-line @typescript-eslint/restrict-template-expressions
          `Fastify is listening on worker ${i} on port ${response.port}`
        )
      } else {
        console.error(`Fastify failed to start on worker ${i}:`, response.error)
      }
      return null
    })
    .catch(error => {
      console.error(error)
    })
}