feat: add multithreaded factorial endpoint to express example

[poolifier.git] / examples / typescript / http-server-pool / express / src / worker.ts

diff --git a/examples/typescript/http-server-pool/express/src/worker.ts b/examples/typescript/http-server-pool/express/src/worker.ts
index f006ad48217ba2a935498a9468a43a4ab5341bf4..7589aa6b6aaa9b37aa519d24c86bafc96d657b98 100644 (file)
--- a/examples/typescript/http-server-pool/express/src/worker.ts
+++ b/examples/typescript/http-server-pool/express/src/worker.ts
@@ -1,20 +1,36 @@
 import { ThreadWorker } from 'poolifier'
-import { type WorkerData, type WorkerResponse } from './types.js'
+import {
+  type BodyPayload,
+  type WorkerData,
+  type WorkerResponse
+} from './types.js'
+
+const factorial: (n: number) => number = n => {
+  if (n === 0) {
+    return 1
+  }
+  return factorial(n - 1) * n
+}
 
 class RequestHandlerWorker<
-  Data extends WorkerData,
-  Response extends WorkerResponse
+  Data extends WorkerData<BodyPayload>,
+  Response extends WorkerResponse<BodyPayload>
 > extends ThreadWorker<Data, Response> {
   public constructor () {
     super({
       echo: (workerData?: Data) => {
         return workerData as unknown as Response
+      },
+      factorial: (workerData?: Data) => {
+        return {
+          body: { number: factorial(workerData?.body?.number as number) }
+        } as unknown as Response
       }
     })
   }
 }
 
 export const requestHandlerWorker = new RequestHandlerWorker<
-WorkerData,
-WorkerResponse
+WorkerData<BodyPayload>,
+WorkerResponse<BodyPayload>
 >()