import { API_BASE_URL } from "@/core/config";
import { getAuthHeaders } from "../user/auth";
import type { Message, Messages, SendMessageRequest } from "@/core/types";
import { request } from "@/core/websocket";

/**
 * Fetches public chat messages
 */
export async function fetchMessages(token: string, limit: number = 50, beforeId?: number): Promise<{ messages: Message[]; has_more: boolean }> {
    let url = `${API_BASE_URL}/get_messages?limit=${limit}`;
    if (beforeId) {
        url += `&before_id=${beforeId}`;
    }
    const response = await globalThis.fetch(url, {
        headers: getAuthHeaders(token, true)
    });
    if (!response.ok) return { messages: [], has_more: false };
    const data: Messages & { has_more?: boolean } = await response.json();
    return { messages: data.messages || [], has_more: data.has_more ?? false };
}

/**
 * Sends a public chat message via WebSocket
 */
export async function send(content: string, replyToId: number | null, authToken: string): Promise<void> {
    await request({
        data: {
            content: content.trim(),
            reply_to_id: replyToId ?? null
        },
        credentials: {
            scheme: "Bearer",
            credentials: authToken
        },
        type: "sendMessage"
    } satisfies SendMessageRequest);
}

/**
 * Sends a public chat message with files via HTTP
 */
export async function sendWithFiles(
    content: string,
    replyToId: number | null,
    files: File[],
    authToken: string
): Promise<void> {
    const form = new FormData();
    form.append("payload", JSON.stringify({
        content: content.trim(),
        reply_to_id: replyToId ?? null
    } satisfies SendMessageRequest["data"]));
    for (const f of files) form.append("files", f, f.name);
    const res = await globalThis.fetch(`${API_BASE_URL}/send_message`, {
        method: "POST",
        headers: getAuthHeaders(authToken, false),
        body: form
    });
    if (!res.ok) {
        const error = await res.text();
        throw new Error(error || "Failed to send message with files");
    }
}

/**
 * Edits a public chat message
 */
export async function edit(messageId: number, newContent: string, authToken: string): Promise<void> {
    const res = await globalThis.fetch(`${API_BASE_URL}/edit_message/${messageId}`, {
        method: "PUT",
        headers: getAuthHeaders(authToken, true),
        body: JSON.stringify({ content: newContent })
    });
    if (!res.ok) throw new Error("Failed to edit message");
}

/**
 * Deletes a public chat message
 */
export async function deleteMessage(messageId: number, authToken: string): Promise<void> {
    const res = await globalThis.fetch(`${API_BASE_URL}/delete_message/${messageId}`, {
        method: "DELETE",
        headers: getAuthHeaders(authToken, true)
    });
    if (!res.ok) throw new Error("Failed to delete message");
}

/**
 * Marks a message as read
 */
export async function markRead(messageId: number, authToken: string): Promise<void> {
    const res = await globalThis.fetch(`${API_BASE_URL}/messages/mark_read`, {
        method: "POST",
        headers: getAuthHeaders(authToken, true),
        body: JSON.stringify({ message_id: messageId })
    });
    if (!res.ok) throw new Error("Failed to mark message as read");
}