import { type ServerContext, type ServiceResult, now } from "../context.js";
import { readConversationCached } from "./conversations.js";

export async function setIndicator(ctx: ServerContext, participantId: string, conversationId: string): Promise<ServiceResult<void>> {
    // Participation gate, indicators only live for participants of the conversation
    const conversation = await readConversationCached(ctx, conversationId);
    if (!conversation || !conversation.participantIds.includes(participantId)) throw new Error("Not a participant of this conversation");

    ctx.indicators.set(conversationId, participantId, now());
    ctx.subscriptions.emit(ctx.subscriptions.prepareIndicators(conversationId));
    return { result: undefined, hooks: [] };
}

export async function removeIndicator(ctx: ServerContext, participantId: string, conversationId: string): Promise<ServiceResult<void>> {
    // Skip the broadcast when nothing was actually removed, otherwise every sendMessage from a non-typing participant fans out an unchanged snapshot
    if (ctx.indicators.delete(conversationId, participantId)) {
        ctx.subscriptions.emit(ctx.subscriptions.prepareIndicators(conversationId));
    }
    return { result: undefined, hooks: [] };
}