cluster-healthcheck.ts

import type { NextApiRequest, NextApiResponse } from 'next'
import { ElasticClusterHealthReport } from '@/models/diagnostics/ElasticClusterHealthReport'
import { ErrorResponseModel } from '@/models/ErrorResponseModel'
import { HttpMethod } from '@/models/RequestModel'

const handler = async (req: NextApiRequest, res: NextApiResponse<ElasticClusterHealthReport | ErrorResponseModel>) => {
	const response = await fetch(`${process.env.ELASTIC_URL}:9200/_cluster/health`, {
		method: HttpMethod.GET
	});

	try {
		const data: ElasticClusterHealthReport | undefined = await response.json()
		if (response.ok && data) {
			res.status(response.status).json(data)
		}
		else {
			res.status(response.status).json({
				Message: "Unknown error",
				ErrorCode: "ElasticClusterHealthError",
				StatusCode: response.status
			})
		}
	}
	catch (ex) {
		console.error(ex)

		let message: string
		if (ex instanceof Error) {
			message = ex.message
		}
		else {
			message = String(ex)
		}

		res.status(response.status).json({
			Message: message,
			ErrorCode: "ElasticClusterHealthError",
			StatusCode: response.status
		})
	}
}

export default handler;