malice

// Backend-agnostic API surface. Every call forwards to whichever transport

// this build was compiled for, hosted (fetch + SSE) or on-device (worker).

import type { MemberSummary, RoomSummary } from './types';

import { codeToHtml } from './code';

import { HttpTransport } from './transport-http';

import type { SessionInfo, Transport, VerifyAction } from './transport';

import { createDeviceTransport } from 'malice:device-transport';

export { ApiError } from './transport';

export type { SessionInfo, SoftLogout, VerifyAction } from './transport';

function createTransport(): Transport {

  if (import.meta.env.VITE_MALICE_TARGET === 'device') return createDeviceTransport();

  return new HttpTransport();

}

const transport: Transport = createTransport();

export function getSession(): Promise<SessionInfo> {

  return transport.getSession();

}

export function login(homeserver: string, username: string, password: string): Promise<{ user_id: string }> {

  return transport.login(homeserver, username, password);

}

export function logout(): Promise<void> {

  return transport.logout();

}

export function getRooms(): Promise<{ rooms: RoomSummary[] }> {

  return transport.getRooms();

}

export const openRoom = (room_id: string) => transport.openRoom(room_id);

export const closeRoom = (room_id: string) => transport.closeRoom(room_id);

export const sendMessage = (room_id: string, body: string, reply_to: string | null = null) =>

  transport.sendMessage(room_id, body, codeToHtml(body), reply_to);

export const paginateRoom = (room_id: string) => transport.paginateRoom(room_id);

export const setTyping = (room_id: string, typing: boolean) => transport.setTyping(room_id, typing);

export const getAccountData = (eventType: string) => transport.getAccountData(eventType);

export const getUrlPreview = (room_id: string, url: string) => transport.getUrlPreview(room_id, url);

export const setAccountData = (eventType: string, content: Record<string, unknown>) =>

  transport.setAccountData(eventType, content);

export function joinRoom(room: string): Promise<{ room_id: string }> {

  return transport.joinRoom(room);

}

export function createRoom(name: string, topic?: string): Promise<{ room_id: string }> {

  return transport.createRoom(name, topic);

}

export const leaveRoom = (room_id: string) => transport.leaveRoom(room_id);

export const reactToMessage = (room_id: string, event_id: string, key: string, shortcode?: string) =>

  transport.reactToMessage(room_id, event_id, key, shortcode);

export const markRead = (room_id: string, event_id: string) => transport.markRead(room_id, event_id);

export function getMembers(room_id: string): Promise<{ members: MemberSummary[] }> {

  return transport.getMembers(room_id);

}

/** Same URL shape in both builds: the hosted server and the device service worker both answer it. */

export function mediaUrl(mxc: string | null): string | null {

  if (!mxc) return null;

  return `/api/media?mxc=${encodeURIComponent(mxc)}`;

}

export function messageMediaUrl(mediaId: string, size: 'Thumbnail' | 'Full'): string {

  return `/api/message-media?media_id=${encodeURIComponent(mediaId)}&size=${size}`;

}

export function getProfile(): Promise<{ display_name: string | null; avatar_url: string | null }> {

  return transport.getProfile();

}

export function getSpaceChildren(room_id: string): Promise<{ room_ids: string[] }> {

  return transport.getSpaceChildren(room_id);

}

export function getEncryption(): Promise<{ state: unknown; verification: unknown }> {

  return transport.getEncryption();

}

export function recoverEncryption(recovery_key: string): Promise<void> {

  return transport.recoverEncryption(recovery_key);

}

export function startVerification(): Promise<void> {

  return transport.startVerification();

}

export function verifyEncryption(action: VerifyAction): Promise<void> {

  return transport.verifyEncryption(action);

}

export function uploadAttachment(room_id: string, file: File): Promise<void> {

  return transport.uploadAttachment(room_id, file);

}

export function subscribeEvents(onEvent: (data: string) => void, onDisconnect: () => void): () => void {

  return transport.subscribeEvents(onEvent, onDisconnect);

}