refactor: null -> undefined where appropriate
[poolifier.git] / examples / typescript / websocket-server-pool / ws-cluster / src / main.ts
CommitLineData
72855e92
JB
1import { dirname, extname, join } from 'node:path'
2import { fileURLToPath } from 'node:url'
3import { FixedClusterPool, availableParallelism } from 'poolifier'
ef083f7b 4import type { WorkerData, WorkerResponse } from './types.js'
72855e92
JB
5
6const workerFile = join(
7 dirname(fileURLToPath(import.meta.url)),
8 `worker${extname(fileURLToPath(import.meta.url))}`
9)
10
11const pool = new FixedClusterPool<WorkerData, WorkerResponse>(
12 availableParallelism(),
13 workerFile,
14 {
8a199a0a
JB
15 onlineHandler: () => {
16 pool
17 .execute({ port: 8080 })
041dc05b 18 .then(response => {
8a199a0a
JB
19 if (response.status) {
20 console.info(
21 // eslint-disable-next-line @typescript-eslint/restrict-template-expressions
80ccdab6 22 `WebSocket server is listening in cluster worker on port ${response.port}`
8a199a0a 23 )
8a199a0a 24 }
fefd3cef 25 return undefined
8a199a0a 26 })
041dc05b 27 .catch(error => {
02999424 28 console.error(
80ccdab6 29 'WebSocket server failed to start in cluster worker:',
02999424
JB
30 error
31 )
8a199a0a
JB
32 })
33 },
72855e92 34 errorHandler: (e: Error) => {
3b311539 35 console.error('Cluster worker error', e)
72855e92
JB
36 }
37 }
38)