Function fetchMessages

packages/consortium-web/src/lib/api.ts:161–192

(
  credentials: Credentials,
  session: DecryptedSession,
)

}

export async function fetchMessages(
  credentials: Credentials,
  session: DecryptedSession,
): Promise<MessageContent[]> {
  const res = await fetch(
    `${SERVER_URL}/v1/sessions/${session.id}/messages`,
    { headers: authHeaders(credentials.token) },
  );
  if (!res.ok) throw new Error(`Failed to fetch messages: ${res.status}`);

  const data = await res.json();
  const messages: MessageContent[] = [];

  for (const raw of (data.messages as RawMessage[]).reverse()) {
    if (raw.content?.t === 'encrypted' && raw.content.c) {
      try {
        const decrypted = await decrypt(
          session.encryptionKey,
          session.encryptionVariant,
          decodeBase64(raw.content.c as string),
        );
        if (decrypted) {
          messages.push(decrypted as MessageContent);
        }
      } catch {
        // Skip undecryptable messages
      }
    }
  }

  return messages;
}

export async function deleteSession(
  credentials: Credentials,