List Conversations

curl 'https://api.bio.re/api/v1/messages/conversations?page=1&limit=20' \
  -H "Authorization: Bearer $ACCESS_TOKEN"

type ConversationOtherParty = {
  id: string;
  username: string | null;
  displayName: string | null;
};

type ConversationLastMessage = {
  id: string;
  content: string; // always '[encrypted]' here
  dmType: 'FREE' | 'SINGLE_PAY' | 'PER_MESSAGE';
  status: string;
  createdAt: string;
  senderId: string;
};

type ConversationItem = {
  sessionId: string;
  otherParty: ConversationOtherParty;
  lastMessage: ConversationLastMessage | null;
  unreadCount: number;
  lastMessageAt: string | null;
  isBlocked: boolean;
  isBlockedBy: boolean;
};

type ConversationList = {
  items: ConversationItem[];
  total: number;
};

async function listConversations(
  accessToken: string,
  page = 1,
  limit = 20,
): Promise<ConversationList> {
  const url = new URL('https://api.bio.re/api/v1/messages/conversations');
  url.searchParams.set('page', String(page));
  url.searchParams.set('limit', String(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 ?? 'Conversations fetch failed'), {
      code: json?.error?.code,
    });
  }
  return json.data;
}

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

export const messageKeys = {
  conversations: (page: number, limit: number) =>
    ['messages', 'conversations', page, limit] as const,
};

export function useConversations(page = 1, limit = 20) {
  return useQuery({
    queryKey: messageKeys.conversations(page, limit),
    queryFn: async () => {
      const url = new URL('/api/v1/messages/conversations', window.location.origin);
      url.searchParams.set('page', String(page));
      url.searchParams.set('limit', String(limit));
      const res = await fetch(url);
      const json = await res.json();
      if (!res.ok || !json.success) {
        throw Object.assign(new Error(json?.error?.message ?? 'Conversations fetch failed'), {
          code: json?.error?.code,
          i18nKey: json?.error?.i18nKey,
        });
      }
      return json.data as ConversationList;
    },
    placeholderData: keepPreviousData,
    staleTime: 10_000, // refresh frequently — new messages flip unreadCount
  });
}