import { readFile } from '@tauri-apps/plugin-fs';
import type { HttpResponse } from '@yaakapp-internal/models';
import type { ServerSentEvent } from '@yaakapp-internal/sse';
import { getCharsetFromContentType } from './model_util';
import { invokeCmd } from './tauri';

export async function getResponseBodyText(response: HttpResponse): Promise<string | null> {
  if (!response.bodyPath) {
    return null;
  }

  const bytes = await readFile(response.bodyPath);
  const charset = getCharsetFromContentType(response.headers);

  return new TextDecoder(charset ?? 'utf-8', { fatal: false }).decode(bytes);
}

export async function getResponseBodyBlob(response: HttpResponse): Promise<Uint8Array | null> {
  if (!response.bodyPath) return null;
  return readFile(response.bodyPath);
}

export async function getResponseBodyEventSource(
  response: HttpResponse,
): Promise<ServerSentEvent[]> {
  if (!response.bodyPath) return [];
  return invokeCmd<ServerSentEvent[]>('cmd_get_sse_events', {
    filePath: response.bodyPath,
  });
}