List Messages (Inbox)

# fan inbox (sent messages)
curl 'https://api.bio.re/api/v1/messages?role=fan&page=1&limit=20' \
  -H "Authorization: Bearer $ACCESS_TOKEN"

# creator inbox (received messages, scoped to one session)
curl 'https://api.bio.re/api/v1/messages?role=creator&sessionId=s1a2b3c4-d5e6-7890-abcd-ef1234567890' \
  -H "Authorization: Bearer $ACCESS_TOKEN"

type MessageStatus =
  | 'PENDING' | 'ESCROWED' | 'DELIVERED' | 'READ'
  | 'REPLIED' | 'COMPLETED' | 'EXPIRED'
  | 'REFUNDED' | 'REJECTED' | 'QUARANTINED';

type DmType = 'FREE' | 'SINGLE_PAY' | 'PER_MESSAGE';

type MessageInboxItem = {
  id: string;
  content: string;
  status: MessageStatus;
  dmType: DmType;
  priceSnapshot: string | null;
  senderId: string;
  receiverId: string;
  createdAt: string;
  expiresAt: string | null;
};

type Paginated<T> = {
  items: T[];
  total: number;
  page: number;
  limit: number;
  totalPages: number;
};

async function listMessages(
  accessToken: string,
  filter: { role?: 'fan' | 'creator'; sessionId?: string; page?: number; limit?: number } = {},
): Promise<Paginated<MessageInboxItem>> {
  const url = new URL('https://api.bio.re/api/v1/messages');
  if (filter.role) url.searchParams.set('role', filter.role);
  if (filter.sessionId) url.searchParams.set('sessionId', filter.sessionId);
  if (filter.page) url.searchParams.set('page', String(filter.page));
  if (filter.limit) url.searchParams.set('limit', String(filter.limit));
  const res = await fetch(url, {
    headers: { Authorization: `Bearer ${accessToken}` },
  });
  const json = await res.json();
  if (!res.ok || !json.success) {
    throw Object.assign(new Error(json?.error?.message ?? 'Inbox fetch failed'), {
      code: json?.error?.code,
    });
  }
  return json.data;
}

import { useQuery, keepPreviousData } from '@tanstack/react-query';

export const messageKeys = {
  list: (filter: { role?: string; sessionId?: string; page?: number; limit?: number }) =>
    ['messages', 'list', filter] as const,
};

export function useMessageList(filter: {
  role?: 'fan' | 'creator';
  sessionId?: string;
  page?: number;
  limit?: number;
} = {}) {
  return useQuery({
    queryKey: messageKeys.list(filter),
    queryFn: async () => {
      const url = new URL('/api/v1/messages', window.location.origin);
      if (filter.role) url.searchParams.set('role', filter.role);
      if (filter.sessionId) url.searchParams.set('sessionId', filter.sessionId);
      if (filter.page) url.searchParams.set('page', String(filter.page));
      if (filter.limit) url.searchParams.set('limit', String(filter.limit));
      const res = await fetch(url);
      const json = await res.json();
      if (!res.ok || !json.success) {
        throw Object.assign(new Error(json?.error?.message ?? 'Inbox fetch failed'), {
          code: json?.error?.code,
          i18nKey: json?.error?.i18nKey,
        });
      }
      return json.data as Paginated<MessageInboxItem>;
    },
    placeholderData: keepPreviousData, // smooth pagination
    staleTime: 10_000, // refetch frequently — DM status flips on webhook events
  });
}