feat: add HTTP server pool example: express request handler pool

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

import { ThreadWorker } from 'poolifier'
import nodeFetch from 'node-fetch'
import {
  type RequestInfo as NodeFetchRequestInfo,
  type ResponseInit as NodeFetchRequestInit
} from 'node-fetch'
import axios from 'axios'
import { type WorkerData, type WorkerResponse } from './types.js'

class HttpClientWorker extends ThreadWorker<WorkerData, WorkerResponse> {
  public constructor () {
    super({
      node_fetch: async (workerData?: WorkerData) => {
        const response = await nodeFetch(
          (workerData as WorkerData).input as URL | NodeFetchRequestInfo,
          workerData?.init as NodeFetchRequestInit
        )
        // The response is not structured-cloneable, so we return the response text body instead.
        return {
          text: await response.text()
        }
      },
      fetch: async (workerData?: WorkerData) => {
        const response = await fetch(
          (workerData as WorkerData).input as URL | RequestInfo,
          workerData?.init as RequestInit
        )
        // The response is not structured-cloneable, so we return the response text body instead.
        return {
          text: await response.text()
        }
      },
      axios: async (workerData?: WorkerData) => {
        const response = await axios({
          method: 'get',
          url: (workerData as WorkerData).input as string,
          ...workerData?.axiosRequestConfig
        })
        return {
          text: response.data
        }
      }
    })
  }
}

export const httpClientWorker = new HttpClientWorker()