supabase/apps/studio/data/notifications/notifications-v2-query.ts

import { useInfiniteQuery } from '@tanstack/react-query'
import { get, handleError } from 'data/fetchers'

import type { components } from 'data/api'
import type { ResponseError, UseCustomInfiniteQueryOptions } from 'types'
import { notificationKeys } from './keys'

const NOTIFICATIONS_PAGE_LIMIT = 10

export type NotificationVariables = {
  page: number
  limit?: number
  status?: 'new' | 'seen' | 'archived'
  filters: {
    priority: readonly string[]
    organizations: readonly string[]
    projects: readonly string[]
  }
}

export type Notification = components['schemas']['NotificationResponse']

/**
 * Notification Data - This is not typed from the API end as it's meant to be open-ended
 * @param title: Title of the notification
 * @param message: Rendered as Markdown to support inline links. Should be capped to n characters
 * @param project_id: (Optional) Only available if notification is specifically for a project (e.g exhaustion notification)
 * @param actions: (Optional) Any sort of actions that we want to provide users, could be external link, could be something that needs to be handled on FE
 */
export type NotificationData = {
  title: string
  message: string
  org_slug?: string
  project_ref?: string
  actions: { label: string; url?: string; action_type?: string }[]
}

export async function getNotifications(options: NotificationVariables, signal?: AbortSignal) {
  const { status, filters, page = 0, limit = NOTIFICATIONS_PAGE_LIMIT } = options
  const { data, error } = await get('/platform/notifications', {
    params: {
      query: {
        offset: page * limit,
        limit,
        // [Alaister]: 'as any' is needed because the API types don't reflect an array of strings
        ...(status !== undefined ? { status } : { status: ['new', 'seen'].join(',') as any }),
        ...(filters.priority.length > 0 ? { priority: filters.priority.join(',') as any } : {}),
        ...(filters.organizations.length > 0 ? { org_slug: filters.organizations.join(',') } : {}),
        ...(filters.projects.length > 0 ? { project_ref: filters.projects.join(',') } : {}),
      },
    },
    headers: { Version: '2' },
    signal,
  })

  if (error) handleError(error)

  return data
}

export type NotificationsData = Awaited<ReturnType<typeof getNotifications>>
export type NotificationsError = ResponseError

export const useNotificationsV2Query = <TData = NotificationsData>(
  { status, filters, limit = NOTIFICATIONS_PAGE_LIMIT }: Omit<NotificationVariables, 'page'>,
  {
    enabled = true,
    ...options
  }: UseCustomInfiniteQueryOptions<NotificationsData, NotificationsError, TData> = {}
) => {
  return useInfiniteQuery<NotificationsData, NotificationsError, TData>({
    queryKey: notificationKeys.listV2({ status, filters, limit }),
    queryFn: ({ signal, pageParam }) =>
      getNotifications({ status, filters, limit, page: pageParam }, signal),
    enabled: enabled,
    getNextPageParam(lastPage, pages) {
      const page = pages.length
      if ((lastPage ?? []).length < limit) return undefined
      return page
    },
    ...options,
  })
}