examples/typescript/websocket-server-pool/ws-hybrid/src/request-handler-worker.ts

   1 import { ThreadWorker } from 'poolifier'
   2
   3 import type {
   4   DataPayload,
   5   ThreadWorkerData,
   6   ThreadWorkerResponse,
   7 } from './types.js'
   8
   9 class RequestHandlerWorker<
  10   Data extends ThreadWorkerData<DataPayload>,
  11   Response extends ThreadWorkerResponse<DataPayload>
  12 > extends ThreadWorker<Data, Response> {
  13   private static readonly factorial = (n: number | bigint): bigint => {
  14     if (n === 0 || n === 1) {
  15       return 1n
  16     } else {
  17       n = BigInt(n)
  18       let factorial = 1n
  19       for (let i = 1n; i <= n; i++) {
  20         factorial *= i
  21       }
  22       return factorial
  23     }
  24   }
  25
  26   public constructor () {
  27     super({
  28       echo: (workerData?: Data) => {
  29         return workerData as unknown as Response
  30       },
  31       factorial: (workerData?: Data) => {
  32         return {
  33           data: {
  34             // eslint-disable-next-line @typescript-eslint/no-non-null-assertion
  35             number: RequestHandlerWorker.factorial(workerData!.data.number!),
  36           },
  37         } as unknown as Response
  38       },
  39     })
  40   }
  41 }
  42
  43 export const requestHandlerWorker = new RequestHandlerWorker<
  44   ThreadWorkerData<DataPayload>,
  45   ThreadWorkerResponse<DataPayload>
  46 >()