examples/typescript/http-server-pool/express-cluster/src/worker.ts

   1 import type { Server } from 'node:http'
   2 import type { AddressInfo } from 'node:net'
   3
   4 import express, { type Express, type Request, type Response } from 'express'
   5 import { ClusterWorker } from 'poolifier'
   6
   7 import type { WorkerData, WorkerResponse } from './types.js'
   8
   9 class ExpressWorker extends ClusterWorker<WorkerData, WorkerResponse> {
  10   private static server: Server
  11
  12   private static readonly factorial = (n: number | bigint): bigint => {
  13     if (n === 0 || n === 1) {
  14       return 1n
  15     } else {
  16       n = BigInt(n)
  17       let factorial = 1n
  18       for (let i = 1n; i <= n; i++) {
  19         factorial *= i
  20       }
  21       return factorial
  22     }
  23   }
  24
  25   private static readonly startExpress = (
  26     workerData?: WorkerData
  27   ): WorkerResponse => {
  28     const { port } = workerData!
  29
  30     const application: Express = express()
  31
  32     // Parse only JSON requests body
  33     application.use(express.json())
  34
  35     application.all('/api/echo', (req: Request, res: Response) => {
  36       res.send(req.body).end()
  37     })
  38
  39     application.get('/api/factorial/:number', (req: Request, res: Response) => {
  40       const { number } = req.params
  41       res
  42         .send({ number: ExpressWorker.factorial(parseInt(number)).toString() })
  43         .end()
  44     })
  45
  46     ExpressWorker.server = application.listen(port, () => {
  47       console.info(
  48         `⚡️[express server]: Express server is started in cluster worker at http://localhost:${port}/`
  49       )
  50     })
  51     return {
  52       status: true,
  53       port: (ExpressWorker.server.address() as AddressInfo).port
  54     }
  55   }
  56
  57   public constructor () {
  58     super(ExpressWorker.startExpress, {
  59       killHandler: () => {
  60         ExpressWorker.server.close()
  61       }
  62     })
  63   }
  64 }
  65
  66 export const expressWorker = new ExpressWorker()