| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960 |
- 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<T>(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<NextApiResponse | Response | void>,
- options?: { withAuth: boolean }
- ): Promise<NextApiResponse | Response | void> {
- 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
|