source: server/telefunc/ctx.ts@ cc841a5

import { Abort, getContext } from "telefunc";
import * as drizzleQueries from "../../database/drizzle/queries";

export function ctx() {
    return getContext();
}

export function parseSessionUserId(sessionUserId: unknown): number | undefined {
    if (typeof sessionUserId !== "string" && typeof sessionUserId !== "number") return undefined;
    const n = Number(sessionUserId);
    return Number.isInteger(n) && n > 0 ? n : undefined;
}

export function requireUser() {
    const c = ctx();
    const userId = parseSessionUserId(c.session?.user?.id);
    if (!userId) throw Abort();
    return { c, userId };
}

export function getAuthState() {
    const c = ctx();
    const userId = parseSessionUserId(c.session?.user?.id);
    return {
        isLoggedIn: Boolean(userId),
        userId: userId ?? null,
        username: c.session?.user?.name ?? null,
        isAdmin: c.session?.user?.isAdmin,
        session: c.session,
    };
}

export async function requireAdmin() {
    const { c, userId } = requireUser();


    if(!!c.session?.user?.isAdmin) throw Abort();

    const isAdmin = await drizzleQueries.isAdmin(c.db, userId);
    if (!isAdmin) throw Abort();

    return { c, userId };
}