import type { JwtPayload } from '@supabase/supabase-js' import type { NextApiRequest, NextApiResponse } from 'next' import { IS_PLATFORM } from '../constants' import { apiAuthenticate } from './apiAuthenticate' import { ResponseError, ResponseFailure } from '@/types' export function isResponseOk(response: T | ResponseFailure | undefined): response is T { if (response === undefined || response === null) { return false } if (response instanceof ResponseError) { return false } if (typeof response === 'object' && 'error' in response && Boolean(response.error)) { return false } return true } // Purpose of this apiWrapper is to function like a global catchall for ANY errors // It's a safety net as the API service should never drop, nor fail async function apiWrapper( req: NextApiRequest, res: NextApiResponse, handler: ( req: NextApiRequest, res: NextApiResponse, claims?: JwtPayload ) => Promise, options?: { withAuth: boolean } ): Promise { try { const { withAuth } = options || {} let claims: JwtPayload | undefined if (IS_PLATFORM && withAuth) { const response = await apiAuthenticate(req, res) if (!isResponseOk(response)) { return res.status(401).json({ error: { message: `Unauthorized: ${response.error.message}`, }, }) } claims = response } return handler(req, res, claims) } catch (error) { return res.status(500).json({ error }) } } export { apiWrapper } export default apiWrapper