Supabase backend + UI dropdown updates

src/app/api/admin/requests/[type]/[id]/comments/route.ts

@@ -19,7 +19,7 @@ export async function POST(
             return NextResponse.json({ error: "Invalid request type" }, { status: 400 });
         }
 
-        const existing = getRequest(type, params.id);
+        const existing = await getRequest(type, params.id);
         if (!existing) {
             return NextResponse.json({ error: "Request not found" }, { status: 404 });
         }
@@ -30,7 +30,7 @@ export async function POST(
             return NextResponse.json({ error: "Comment body is required" }, { status: 400 });
         }
 
-        const comment = addAdminComment(type, params.id, text, userId);
+        const comment = await addAdminComment(type, params.id, text, userId);
         const response = NextResponse.json({ ok: true, comment });
         if (shouldSetCookie) {
             response.cookies.set({ ...userCookieOptions(), value: userId });

src/app/api/admin/requests/[type]/[id]/route.ts

@@ -23,7 +23,7 @@ export async function PATCH(
             return NextResponse.json({ error: "Invalid status" }, { status: 400 });
         }
 
-        const ok = updateRequestStatus(type, params.id, status);
+        const ok = await updateRequestStatus(type, params.id, status);
         if (!ok) {
             return NextResponse.json({ error: "Request not found" }, { status: 404 });
         }
@@ -50,7 +50,7 @@ export async function DELETE(
             return NextResponse.json({ error: "Invalid request type" }, { status: 400 });
         }
 
-        const ok = deleteRequest(type, params.id);
+        const ok = await deleteRequest(type, params.id);
         if (!ok) {
             return NextResponse.json({ error: "Request not found" }, { status: 404 });
         }

src/app/api/dataset/route.ts

@@ -8,7 +8,7 @@ import { getOrCreateUserId, userCookieOptions } from "@/lib/userIdentity";
 
 export async function GET() {
     try {
-        const requests = getDatasetRequests();
+        const requests = await getDatasetRequests();
         return NextResponse.json(requests);
     } catch (error) {
         console.error("Error fetching dataset requests:", error);
@@ -29,7 +29,7 @@ export async function POST(request: NextRequest) {
             );
         }
 
-        const newRequest = addDatasetRequest({
+        const newRequest = await addDatasetRequest({
             sourceModel,
             datasetSize: datasetSize || "250x",
             reasoningDepth: reasoningDepth || "high",
@@ -62,7 +62,7 @@ export async function PATCH(request: NextRequest) {
             request.headers.get("x-real-ip") ||
             "anonymous";
 
-        const result = upvoteDataset(id, ip);
+        const result = await upvoteDataset(id, ip);
 
         if (!result.success) {
             return NextResponse.json(

src/app/api/distillation/route.ts

@@ -8,7 +8,7 @@ import { getOrCreateUserId, userCookieOptions } from "@/lib/userIdentity";
 
 export async function GET() {
     try {
-        const requests = getDistillationRequests();
+        const requests = await getDistillationRequests();
         return NextResponse.json(requests);
     } catch (error) {
         console.error("Error fetching distillation requests:", error);
@@ -29,7 +29,7 @@ export async function POST(request: NextRequest) {
             );
         }
 
-        const newRequest = addDistillationRequest({
+        const newRequest = await addDistillationRequest({
             sourceDataset,
             studentModel,
             additionalNotes: additionalNotes || "",
@@ -60,7 +60,7 @@ export async function PATCH(request: NextRequest) {
             request.headers.get("x-real-ip") ||
             "anonymous";
 
-        const result = upvoteDistillation(id, ip);
+        const result = await upvoteDistillation(id, ip);
 
         if (!result.success) {
             return NextResponse.json(

src/app/api/requests/[type]/[id]/comments/[commentId]/route.ts

@@ -22,7 +22,7 @@ export async function PATCH(
             return NextResponse.json({ error: "Invalid request type" }, { status: 400 });
         }
 
-        const thread = getThread(type, params.id);
+        const thread = await getThread(type, params.id);
         const comment = thread.comments.find((c) => c.id === params.commentId);
         if (!comment) {
             return NextResponse.json({ error: "Comment not found" }, { status: 404 });
@@ -40,7 +40,7 @@ export async function PATCH(
             return NextResponse.json({ error: "Comment body is required" }, { status: 400 });
         }
 
-        const updated = updateComment(type, params.id, params.commentId, text);
+        const updated = await updateComment(type, params.id, params.commentId, text);
         if (!updated) {
             return NextResponse.json({ error: "Comment not found" }, { status: 404 });
         }
@@ -75,7 +75,7 @@ export async function DELETE(
             return NextResponse.json({ error: "Invalid request type" }, { status: 400 });
         }
 
-        const thread = getThread(type, params.id);
+        const thread = await getThread(type, params.id);
         const comment = thread.comments.find((c) => c.id === params.commentId);
         if (!comment) {
             return NextResponse.json({ error: "Comment not found" }, { status: 404 });
@@ -89,7 +89,7 @@ export async function DELETE(
             return NextResponse.json({ error: "Forbidden" }, { status: 403 });
         }
 
-        const ok = deleteComment(type, params.id, params.commentId);
+        const ok = await deleteComment(type, params.id, params.commentId);
         if (!ok) {
             return NextResponse.json({ error: "Comment not found" }, { status: 404 });
         }

src/app/api/requests/[type]/[id]/comments/route.ts

@@ -20,7 +20,7 @@ export async function POST(
             return NextResponse.json({ error: "Invalid request type" }, { status: 400 });
         }
 
-        const existing = getRequest(type, params.id);
+        const existing = await getRequest(type, params.id);
         if (!existing) {
             return NextResponse.json({ error: "Request not found" }, { status: 404 });
         }
@@ -33,7 +33,7 @@ export async function POST(
             return NextResponse.json({ error: "Comment body is required" }, { status: 400 });
         }
 
-        const comment = addUserComment(type, params.id, text, author, userId);
+        const comment = await addUserComment(type, params.id, text, author, userId);
         const response = NextResponse.json({ ok: true, comment });
         if (shouldSetCookie) {
             response.cookies.set({ ...userCookieOptions(), value: userId });

src/app/api/requests/[type]/[id]/route.ts

@@ -20,7 +20,7 @@ export async function GET(
         return NextResponse.json({ error: "Invalid request type" }, { status: 400 });
     }
 
-    const requestItem = getRequest(type, params.id);
+    const requestItem = await getRequest(type, params.id);
     if (!requestItem) {
         return NextResponse.json({ error: "Request not found" }, { status: 404 });
     }
@@ -30,7 +30,7 @@ export async function GET(
     const canEditRequest = admin || (Boolean(ownerId) && ownerId === userId);
     const canDeleteRequest = canEditRequest;
 
-    const thread = getThread(type, params.id);
+    const thread = await getThread(type, params.id);
     const threadWithPerms = {
         ...thread,
         comments: thread.comments.map((c) => {
@@ -72,7 +72,7 @@ export async function PATCH(
             return NextResponse.json({ error: "Invalid request type" }, { status: 400 });
         }
 
-        const existing = getRequest(type, params.id);
+        const existing = await getRequest(type, params.id);
         if (!existing) {
             return NextResponse.json({ error: "Request not found" }, { status: 404 });
         }
@@ -87,12 +87,12 @@ export async function PATCH(
         const body = await request.json();
         const updated =
             type === "distillation"
-                ? updateDistillationRequest(params.id, {
+                ? await updateDistillationRequest(params.id, {
                     sourceDataset: typeof body?.sourceDataset === "string" ? body.sourceDataset : undefined,
                     studentModel: typeof body?.studentModel === "string" ? body.studentModel : undefined,
                     additionalNotes: typeof body?.additionalNotes === "string" ? body.additionalNotes : undefined,
                 })
-                : updateDatasetRequest(params.id, {
+                : await updateDatasetRequest(params.id, {
                     sourceModel: typeof body?.sourceModel === "string" ? body.sourceModel : undefined,
                     datasetSize: typeof body?.datasetSize === "string" ? body.datasetSize : undefined,
                     reasoningDepth: typeof body?.reasoningDepth === "string" ? body.reasoningDepth : undefined,
@@ -127,7 +127,7 @@ export async function DELETE(
             return NextResponse.json({ error: "Invalid request type" }, { status: 400 });
         }
 
-        const existing = getRequest(type, params.id);
+        const existing = await getRequest(type, params.id);
         if (!existing) {
             return NextResponse.json({ error: "Request not found" }, { status: 404 });
         }
@@ -139,7 +139,7 @@ export async function DELETE(
             return NextResponse.json({ error: "Forbidden" }, { status: 403 });
         }
 
-        const ok = deleteRequest(type, params.id);
+        const ok = await deleteRequest(type, params.id);
         if (!ok) {
             return NextResponse.json({ error: "Request not found" }, { status: 404 });
         }

src/app/page.tsx

@@ -53,6 +53,11 @@ interface OpenRouterModel {
     name: string;
 }
 
+interface HuggingFaceModel {
+    id: string;
+    name: string;
+}
+
 const STUDENT_MODELS = [
     "Qwen3-4B",
     "Qwen3-8B",
@@ -64,6 +69,17 @@ const STUDENT_MODELS = [
     "Other",
 ];
 
+const SOURCE_MODELS = [
+    "google/gemini-3-flash-preview",
+    "openai/gpt-4o-mini",
+    "openai/gpt-4o",
+    "anthropic/claude-3-5-sonnet",
+    "deepseek/deepseek-r1",
+    "Qwen/Qwen2.5-72B-Instruct",
+    "meta-llama/Llama-3.1-8B-Instruct",
+    "Other",
+];
+
 const REASONING_DEPTHS = ["low", "medium", "high"];
 const DATASET_SIZES = ["100x", "250x", "500x", "1000x", "3000x", "11000x"];
 const TOPICS = [
@@ -94,6 +110,10 @@ export default function Home() {
     const [loadingDatasets, setLoadingDatasets] = useState(false);
     const [loadingModels, setLoadingModels] = useState(false);
 
+    const [huggingfaceModels, setHuggingfaceModels] = useState<HuggingFaceModel[]>([]);
+    const [hfModelQuery, setHfModelQuery] = useState("");
+    const [loadingHfModels, setLoadingHfModels] = useState(false);
+
     // Distillation form state
     const [sourceDataset, setSourceDataset] = useState("");
     const [sourceDatasetOther, setSourceDatasetOther] = useState("");
@@ -115,6 +135,36 @@ export default function Home() {
         fetchOpenrouterModels();
     }, []);
 
+    useEffect(() => {
+        let cancelled = false;
+        const q = hfModelQuery.trim();
+
+        const timer = setTimeout(async () => {
+            setLoadingHfModels(true);
+            try {
+                const res = await fetch(`/api/huggingface-models?q=${encodeURIComponent(q)}&limit=20`);
+                const data = await res.json();
+                if (!cancelled) {
+                    setHuggingfaceModels(Array.isArray(data) ? data : []);
+                }
+            } catch (error) {
+                console.error("Error fetching Hugging Face models:", error);
+                if (!cancelled) {
+                    setHuggingfaceModels([]);
+                }
+            } finally {
+                if (!cancelled) {
+                    setLoadingHfModels(false);
+                }
+            }
+        }, 250);
+
+        return () => {
+            cancelled = true;
+            clearTimeout(timer);
+        };
+    }, [hfModelQuery]);
+
     async function fetchRequests() {
         try {
             const [distillRes, datasetRes] = await Promise.all([
@@ -530,16 +580,19 @@ export default function Home() {
                                                 <div className="space-y-2">
                                                     <Label htmlFor="sourceModel">Source Model *</Label>
                                                     <Combobox
-                                                        options={[...openrouterModels, { id: "Other", name: "Other" }]}
+                                                        options={SOURCE_MODELS.map((m) => ({ id: m, name: m }))}
                                                         value={sourceModel}
                                                         onValueChange={(v) => {
                                                             setSourceModel(v);
-                                                            if (v !== "Other") setSourceModelOther("");
+                                                            if (v !== "Other") {
+                                                                setSourceModelOther("");
+                                                                setHfModelQuery("");
+                                                                setHuggingfaceModels([]);
+                                                            }
                                                         }}
-                                                        placeholder="Select an OpenRouter model"
+                                                        placeholder="Select a model"
                                                         searchPlaceholder="Search models..."
                                                         emptyMessage="No models found"
-                                                        loading={loadingModels}
                                                     />
                                                 </div>
                                                 <div className="space-y-2">
@@ -560,13 +613,18 @@ export default function Home() {
                                             </div>
                                             {sourceModel === "Other" && (
                                                 <div className="space-y-2">
-                                                    <Label htmlFor="sourceModelOther">Source Model (Other) *</Label>
-                                                    <input
-                                                        id="sourceModelOther"
-                                                        className="flex h-10 w-full rounded-md border border-input bg-background px-3 py-2 text-sm ring-offset-background placeholder:text-muted-foreground focus:outline-none focus:ring-2 focus:ring-ring focus:ring-offset-2"
+                                                    <Label htmlFor="sourceModelOther">Hugging Face Model *</Label>
+                                                    <Combobox
+                                                        options={huggingfaceModels}
                                                         value={sourceModelOther}
-                                                        onChange={(e) => setSourceModelOther(e.target.value)}
-                                                        placeholder="Type the model name"
+                                                        onValueChange={setSourceModelOther}
+                                                        placeholder="Search safetensors models"
+                                                        searchPlaceholder="Type to search models..."
+                                                        emptyMessage={hfModelQuery.trim() ? "No models found" : "Start typing to search"}
+                                                        loading={loadingHfModels}
+                                                        searchValue={hfModelQuery}
+                                                        onSearchValueChange={setHfModelQuery}
+                                                        disableLocalFilter
                                                     />
                                                 </div>
                                             )}

src/components/ui/combobox.tsx

@@ -19,6 +19,9 @@ interface ComboboxProps {
     searchPlaceholder?: string;
     emptyMessage?: string;
     loading?: boolean;
+    searchValue?: string;
+    onSearchValueChange?: (value: string) => void;
+    disableLocalFilter?: boolean;
 }
 
 export function Combobox({
@@ -29,11 +32,17 @@ export function Combobox({
     searchPlaceholder = "Search...",
     emptyMessage = "No results found.",
     loading = false,
+    searchValue,
+    onSearchValueChange,
+    disableLocalFilter = false,
 }: ComboboxProps) {
     const [open, setOpen] = React.useState(false);
-    const [search, setSearch] = React.useState("");
+    const [internalSearch, setInternalSearch] = React.useState("");
+
+    const search = searchValue ?? internalSearch;
 
     const filteredOptions = React.useMemo(() => {
+        if (disableLocalFilter) return options;
         if (!search) return options;
         const lower = search.toLowerCase();
         return options.filter(
@@ -41,7 +50,7 @@ export function Combobox({
                 option.name.toLowerCase().includes(lower) ||
                 option.id.toLowerCase().includes(lower)
         );
-    }, [options, search]);
+    }, [disableLocalFilter, options, search]);
 
     const selectedOption = options.find((opt) => opt.id === value);
 
@@ -65,7 +74,14 @@ export function Combobox({
                     <Input
                         placeholder={searchPlaceholder}
                         value={search}
-                        onChange={(e) => setSearch(e.target.value)}
+                        onChange={(e) => {
+                            const next = e.target.value;
+                            if (onSearchValueChange) {
+                                onSearchValueChange(next);
+                            } else {
+                                setInternalSearch(next);
+                            }
+                        }}
                         className="h-9"
                     />
                 </div>
@@ -86,7 +102,11 @@ export function Combobox({
                                     onClick={() => {
                                         onValueChange(option.id === value ? "" : option.id);
                                         setOpen(false);
-                                        setSearch("");
+                                        if (onSearchValueChange) {
+                                            onSearchValueChange("");
+                                        } else {
+                                            setInternalSearch("");
+                                        }
                                     }}
                                     className={cn(
                                         "relative flex w-full cursor-pointer select-none items-center rounded-sm py-1.5 pl-8 pr-2 text-sm outline-none hover:bg-accent hover:text-accent-foreground",

src/lib/store.ts

@@ -1,6 +1,4 @@
-import { v4 as uuidv4 } from "uuid";
-import fs from "fs";
-import path from "path";
+import { supabaseRest } from "@/lib/supabaseRest";
 
 export interface DistillationRequest {
     id: string;
@@ -53,357 +51,428 @@ interface Store {
     threads: Record<string, DiscussionThread>;
 }
 
-const DATA_DIR = process.env.NODE_ENV === "production" ? "/data" : "./data";
-const DATA_FILE = path.join(DATA_DIR, "requests.json");
+function normalizeStatus(value: unknown): "pending" | "in_progress" | "completed" {
+    return value === "in_progress" || value === "completed" ? value : "pending";
+}
 
-function ensureDataDir() {
-    if (!fs.existsSync(DATA_DIR)) {
-        fs.mkdirSync(DATA_DIR, { recursive: true });
-    }
+function mapDistillationRow(row: any): DistillationRequest {
+    return {
+        id: String(row?.id ?? ""),
+        sourceDataset: String(row?.source_dataset ?? ""),
+        studentModel: String(row?.student_model ?? ""),
+        additionalNotes: String(row?.additional_notes ?? ""),
+        upvotes: typeof row?.upvotes === "number" ? row.upvotes : 0,
+        votedIps: Array.isArray(row?.voted_ips) ? row.voted_ips.map(String) : [],
+        ownerId: String(row?.owner_id ?? ""),
+        createdAt: String(row?.created_at ?? new Date().toISOString()),
+        status: normalizeStatus(row?.status),
+    };
 }
 
-function loadStore(): Store {
-    ensureDataDir();
-    try {
-        if (fs.existsSync(DATA_FILE)) {
-            const data = fs.readFileSync(DATA_FILE, "utf-8");
-            const parsed = JSON.parse(data) as Partial<Store>;
-            const parsedThreads = (parsed as any).threads;
-            const threads: Record<string, DiscussionThread> =
-                parsedThreads && typeof parsedThreads === "object" && !Array.isArray(parsedThreads)
-                    ? Object.fromEntries(
-                        Object.entries(parsedThreads as Record<string, any>).map(([key, t]) => {
-                            const requestType: RequestType = t?.requestType === "dataset" ? "dataset" : "distillation";
-                            const thread: DiscussionThread = {
-                                key: String(t?.key ?? key),
-                                requestType,
-                                requestId: String(t?.requestId ?? ""),
-                                comments: Array.isArray(t?.comments)
-                                    ? t.comments.map((c: any) => ({
-                                        id: String(c?.id ?? uuidv4()),
-                                        body: String(c?.body ?? ""),
-                                        author: String(c?.author ?? (c?.role === "user" ? "Anonymous" : "TeichAI")),
-                                        role: c?.role === "user" ? "user" : "admin",
-                                        ownerId: String(c?.ownerId ?? ""),
-                                        createdAt: String(c?.createdAt ?? new Date().toISOString()),
-                                        editedAt: c?.editedAt ? String(c.editedAt) : undefined,
-                                    }))
-                                    : [],
-                            };
-                            return [key, thread] as const;
-                        })
-                    )
-                    : {};
-            const store: Store = {
-                distillationRequests: Array.isArray(parsed.distillationRequests)
-                    ? (parsed.distillationRequests as any[]).map((r) => ({
-                        id: String(r.id ?? uuidv4()),
-                        sourceDataset: String(r.sourceDataset ?? r.teacherModel ?? ""),
-                        studentModel: String(r.studentModel ?? ""),
-                        additionalNotes: String(r.additionalNotes ?? ""),
-                        upvotes: typeof r.upvotes === "number" ? r.upvotes : 0,
-                        votedIps: Array.isArray(r.votedIps) ? r.votedIps.map(String) : [],
-                        ownerId: String(r.ownerId ?? ""),
-                        createdAt: String(r.createdAt ?? new Date().toISOString()),
-                        status: (r.status === "in_progress" || r.status === "completed") ? r.status : "pending",
-                    }))
-                    : [],
-                datasetRequests: Array.isArray(parsed.datasetRequests)
-                    ? (parsed.datasetRequests as any[]).map((r) => ({
-                        id: String(r.id ?? uuidv4()),
-                        sourceModel: String(r.sourceModel ?? ""),
-                        datasetSize: String(r.datasetSize ?? "250x"),
-                        reasoningDepth: String(r.reasoningDepth ?? "high"),
-                        topics: Array.isArray(r.topics) ? r.topics.map(String) : [],
-                        additionalNotes: String(r.additionalNotes ?? ""),
-                        upvotes: typeof r.upvotes === "number" ? r.upvotes : 0,
-                        votedIps: Array.isArray(r.votedIps) ? r.votedIps.map(String) : [],
-                        ownerId: String(r.ownerId ?? ""),
-                        createdAt: String(r.createdAt ?? new Date().toISOString()),
-                        status: (r.status === "in_progress" || r.status === "completed") ? r.status : "pending",
-                    }))
-                    : [],
-                threads,
-            };
-            return store;
-        }
-    } catch (error) {
-        console.error("Error loading store:", error);
-    }
-    return { distillationRequests: [], datasetRequests: [], threads: {} };
+function mapDatasetRow(row: any): DatasetRequest {
+    return {
+        id: String(row?.id ?? ""),
+        sourceModel: String(row?.source_model ?? ""),
+        datasetSize: String(row?.dataset_size ?? "250x"),
+        reasoningDepth: String(row?.reasoning_depth ?? "high"),
+        topics: Array.isArray(row?.topics) ? row.topics.map(String) : [],
+        additionalNotes: String(row?.additional_notes ?? ""),
+        upvotes: typeof row?.upvotes === "number" ? row.upvotes : 0,
+        votedIps: Array.isArray(row?.voted_ips) ? row.voted_ips.map(String) : [],
+        ownerId: String(row?.owner_id ?? ""),
+        createdAt: String(row?.created_at ?? new Date().toISOString()),
+        status: normalizeStatus(row?.status),
+    };
 }
 
-function saveStore(store: Store) {
-    ensureDataDir();
-    fs.writeFileSync(DATA_FILE, JSON.stringify(store, null, 2));
+function mapCommentRow(row: any): DiscussionComment {
+    return {
+        id: String(row?.id ?? ""),
+        body: String(row?.body ?? ""),
+        author: String(row?.author ?? (row?.role === "user" ? "Anonymous" : "TeichAI")),
+        role: row?.role === "user" ? "user" : "admin",
+        ownerId: String(row?.owner_id ?? ""),
+        createdAt: String(row?.created_at ?? new Date().toISOString()),
+        editedAt: row?.edited_at ? String(row.edited_at) : undefined,
+    };
 }
 
-export function getDistillationRequests(): DistillationRequest[] {
-    const store = loadStore();
-    return store.distillationRequests.sort((a, b) => b.upvotes - a.upvotes);
+export async function getDistillationRequests(): Promise<DistillationRequest[]> {
+    const { data, error } = await supabaseRest<any[]>("/rest/v1/distillation_requests", {
+        query: {
+            select: "*",
+            order: "upvotes.desc,created_at.desc",
+        },
+    });
+
+    if (error) {
+        throw new Error(error.message);
+    }
+
+    return Array.isArray(data) ? data.map(mapDistillationRow) : [];
 }
 
-export function getDatasetRequests(): DatasetRequest[] {
-    const store = loadStore();
-    return store.datasetRequests.sort((a, b) => b.upvotes - a.upvotes);
+export async function getDatasetRequests(): Promise<DatasetRequest[]> {
+    const { data, error } = await supabaseRest<any[]>("/rest/v1/dataset_requests", {
+        query: {
+            select: "*",
+            order: "upvotes.desc,created_at.desc",
+        },
+    });
+
+    if (error) {
+        throw new Error(error.message);
+    }
+
+    return Array.isArray(data) ? data.map(mapDatasetRow) : [];
 }
 
-export function getRequest(type: RequestType, id: string): DistillationRequest | DatasetRequest | null {
-    const store = loadStore();
-    if (type === "distillation") {
-        return store.distillationRequests.find((r) => r.id === id) ?? null;
+export async function getRequest(type: RequestType, id: string): Promise<DistillationRequest | DatasetRequest | null> {
+    const table = type === "distillation" ? "distillation_requests" : "dataset_requests";
+    const { data, error } = await supabaseRest<any>(`/rest/v1/${table}`, {
+        query: {
+            select: "*",
+            id: `eq.${id}`,
+        },
+        acceptObject: true,
+    });
+
+    if (error) {
+        throw new Error(error.message);
     }
-    return store.datasetRequests.find((r) => r.id === id) ?? null;
+
+    if (!data) return null;
+    return type === "distillation" ? mapDistillationRow(data) : mapDatasetRow(data);
 }
 
-export function updateDistillationRequest(
+export async function updateDistillationRequest(
     id: string,
     updates: Partial<Pick<DistillationRequest, "sourceDataset" | "studentModel" | "additionalNotes">>
-): DistillationRequest | null {
-    const store = loadStore();
-    const request = store.distillationRequests.find((r) => r.id === id);
-    if (!request) return null;
-    if (typeof updates.sourceDataset === "string") request.sourceDataset = updates.sourceDataset;
-    if (typeof updates.studentModel === "string") request.studentModel = updates.studentModel;
-    if (typeof updates.additionalNotes === "string") request.additionalNotes = updates.additionalNotes;
-    saveStore(store);
-    return request;
+): Promise<DistillationRequest | null> {
+    const body: Record<string, any> = {};
+    if (typeof updates.sourceDataset === "string") body.source_dataset = updates.sourceDataset;
+    if (typeof updates.studentModel === "string") body.student_model = updates.studentModel;
+    if (typeof updates.additionalNotes === "string") body.additional_notes = updates.additionalNotes;
+
+    const { data, error } = await supabaseRest<any>("/rest/v1/distillation_requests", {
+        method: "PATCH",
+        body: JSON.stringify(body),
+        query: { select: "*", id: `eq.${id}` },
+        preferReturn: "representation",
+        acceptObject: true,
+    });
+
+    if (error) {
+        throw new Error(error.message);
+    }
+
+    return data ? mapDistillationRow(data) : null;
 }
 
-export function updateDatasetRequest(
+export async function updateDatasetRequest(
     id: string,
     updates: Partial<Pick<DatasetRequest, "sourceModel" | "datasetSize" | "reasoningDepth" | "topics" | "additionalNotes">>
-): DatasetRequest | null {
-    const store = loadStore();
-    const request = store.datasetRequests.find((r) => r.id === id);
-    if (!request) return null;
-    if (typeof updates.sourceModel === "string") request.sourceModel = updates.sourceModel;
-    if (typeof updates.datasetSize === "string") request.datasetSize = updates.datasetSize;
-    if (typeof updates.reasoningDepth === "string") request.reasoningDepth = updates.reasoningDepth;
-    if (Array.isArray(updates.topics)) request.topics = updates.topics.map(String);
-    if (typeof updates.additionalNotes === "string") request.additionalNotes = updates.additionalNotes;
-    saveStore(store);
-    return request;
+): Promise<DatasetRequest | null> {
+    const body: Record<string, any> = {};
+    if (typeof updates.sourceModel === "string") body.source_model = updates.sourceModel;
+    if (typeof updates.datasetSize === "string") body.dataset_size = updates.datasetSize;
+    if (typeof updates.reasoningDepth === "string") body.reasoning_depth = updates.reasoningDepth;
+    if (Array.isArray(updates.topics)) body.topics = updates.topics.map(String);
+    if (typeof updates.additionalNotes === "string") body.additional_notes = updates.additionalNotes;
+
+    const { data, error } = await supabaseRest<any>("/rest/v1/dataset_requests", {
+        method: "PATCH",
+        body: JSON.stringify(body),
+        query: { select: "*", id: `eq.${id}` },
+        preferReturn: "representation",
+        acceptObject: true,
+    });
+
+    if (error) {
+        throw new Error(error.message);
+    }
+
+    return data ? mapDatasetRow(data) : null;
 }
 
-export function updateRequestStatus(
+export async function updateRequestStatus(
     type: RequestType,
     id: string,
     status: "pending" | "in_progress" | "completed"
-): boolean {
-    const store = loadStore();
-    if (type === "distillation") {
-        const request = store.distillationRequests.find((r) => r.id === id);
-        if (!request) return false;
-        request.status = status;
-        saveStore(store);
-        return true;
+): Promise<boolean> {
+    const table = type === "distillation" ? "distillation_requests" : "dataset_requests";
+    const { data, error } = await supabaseRest<any>(`/rest/v1/${table}`, {
+        method: "PATCH",
+        body: JSON.stringify({ status }),
+        query: { select: "id", id: `eq.${id}` },
+        preferReturn: "representation",
+        acceptObject: true,
+    });
+
+    if (error) {
+        throw new Error(error.message);
     }
 
-    const request = store.datasetRequests.find((r) => r.id === id);
-    if (!request) return false;
-    request.status = status;
-    saveStore(store);
-    return true;
+    return Boolean(data?.id);
 }
 
-export function deleteRequest(type: RequestType, id: string): boolean {
-    const store = loadStore();
-    if (type === "distillation") {
-        const before = store.distillationRequests.length;
-        store.distillationRequests = store.distillationRequests.filter((r) => r.id !== id);
-        if (store.distillationRequests.length === before) return false;
-    } else {
-        const before = store.datasetRequests.length;
-        store.datasetRequests = store.datasetRequests.filter((r) => r.id !== id);
-        if (store.datasetRequests.length === before) return false;
-    }
+export async function deleteRequest(type: RequestType, id: string): Promise<boolean> {
+    await supabaseRest("/rest/v1/request_comments", {
+        method: "DELETE",
+        query: {
+            request_type: `eq.${type}`,
+            request_id: `eq.${id}`,
+        },
+    });
 
-    const key = `${type}:${id}`;
-    if (store.threads[key]) {
-        delete store.threads[key];
+    const table = type === "distillation" ? "distillation_requests" : "dataset_requests";
+    const { data, error } = await supabaseRest<any>(`/rest/v1/${table}`, {
+        method: "DELETE",
+        body: null,
+        query: { select: "id", id: `eq.${id}` },
+        preferReturn: "representation",
+        acceptObject: true,
+    });
+
+    if (error) {
+        throw new Error(error.message);
     }
-    saveStore(store);
-    return true;
+
+    return Boolean(data?.id);
 }
 
-export function getThread(type: RequestType, id: string): DiscussionThread {
-    const store = loadStore();
+export async function getThread(type: RequestType, id: string): Promise<DiscussionThread> {
     const key = `${type}:${id}`;
-    const existing = store.threads[key];
-    if (existing && existing.requestType === type && existing.requestId === id) {
-        return existing;
+    const { data, error } = await supabaseRest<any[]>("/rest/v1/request_comments", {
+        query: {
+            select: "*",
+            request_type: `eq.${type}`,
+            request_id: `eq.${id}`,
+            order: "created_at.asc",
+        },
+    });
+
+    if (error) {
+        throw new Error(error.message);
     }
-    const thread: DiscussionThread = {
+
+    return {
         key,
         requestType: type,
         requestId: id,
-        comments: [],
+        comments: Array.isArray(data) ? data.map(mapCommentRow) : [],
     };
-    store.threads[key] = thread;
-    saveStore(store);
-    return thread;
 }
 
-export function addAdminComment(type: RequestType, id: string, body: string, ownerId: string): DiscussionComment {
-    const store = loadStore();
-    const key = `${type}:${id}`;
-    const thread = store.threads[key] ?? {
-        key,
-        requestType: type,
-        requestId: id,
-        comments: [],
-    };
-    const comment: DiscussionComment = {
-        id: uuidv4(),
-        body,
-        author: "TeichAI",
-        role: "admin",
-        ownerId,
-        createdAt: new Date().toISOString(),
-    };
-    thread.comments.push(comment);
-    store.threads[key] = thread;
-    saveStore(store);
-    return comment;
+export async function addAdminComment(type: RequestType, id: string, body: string, ownerId: string): Promise<DiscussionComment> {
+    const { data, error } = await supabaseRest<any>("/rest/v1/request_comments", {
+        method: "POST",
+        body: JSON.stringify({
+            request_type: type,
+            request_id: id,
+            body,
+            author: "TeichAI",
+            role: "admin",
+            owner_id: ownerId,
+        }),
+        query: { select: "*" },
+        preferReturn: "representation",
+        acceptObject: true,
+    });
+
+    if (error) {
+        throw new Error(error.message);
+    }
+
+    if (!data) {
+        throw new Error("Failed to create comment");
+    }
+
+    return mapCommentRow(data);
 }
 
-export function addUserComment(
+export async function addUserComment(
     type: RequestType,
     id: string,
     body: string,
     author: string | undefined,
     ownerId: string
-): DiscussionComment {
-    const store = loadStore();
-    const key = `${type}:${id}`;
-    const thread = store.threads[key] ?? {
-        key,
-        requestType: type,
-        requestId: id,
-        comments: [],
-    };
-    const comment: DiscussionComment = {
-        id: uuidv4(),
-        body,
-        author: author?.trim() ? author.trim() : "Anonymous",
-        role: "user",
-        ownerId,
-        createdAt: new Date().toISOString(),
-    };
-    thread.comments.push(comment);
-    store.threads[key] = thread;
-    saveStore(store);
-    return comment;
+): Promise<DiscussionComment> {
+    const { data, error } = await supabaseRest<any>("/rest/v1/request_comments", {
+        method: "POST",
+        body: JSON.stringify({
+            request_type: type,
+            request_id: id,
+            body,
+            author: author?.trim() ? author.trim() : "Anonymous",
+            role: "user",
+            owner_id: ownerId,
+        }),
+        query: { select: "*" },
+        preferReturn: "representation",
+        acceptObject: true,
+    });
+
+    if (error) {
+        throw new Error(error.message);
+    }
+
+    if (!data) {
+        throw new Error("Failed to create comment");
+    }
+
+    return mapCommentRow(data);
 }
 
-export function updateComment(
+export async function updateComment(
     type: RequestType,
     requestId: string,
     commentId: string,
     body: string
-): DiscussionComment | null {
-    const store = loadStore();
-    const key = `${type}:${requestId}`;
-    const thread = store.threads[key];
-    if (!thread) return null;
-    const comment = thread.comments.find((c) => c.id === commentId);
-    if (!comment) return null;
-    comment.body = body;
-    comment.editedAt = new Date().toISOString();
-    saveStore(store);
-    return comment;
+): Promise<DiscussionComment | null> {
+    const { data, error } = await supabaseRest<any>("/rest/v1/request_comments", {
+        method: "PATCH",
+        body: JSON.stringify({ body, edited_at: new Date().toISOString() }),
+        query: {
+            select: "*",
+            id: `eq.${commentId}`,
+            request_type: `eq.${type}`,
+            request_id: `eq.${requestId}`,
+        },
+        preferReturn: "representation",
+        acceptObject: true,
+    });
+
+    if (error) {
+        throw new Error(error.message);
+    }
+
+    return data ? mapCommentRow(data) : null;
 }
 
-export function deleteComment(
+export async function deleteComment(
     type: RequestType,
     requestId: string,
     commentId: string
-): boolean {
-    const store = loadStore();
-    const key = `${type}:${requestId}`;
-    const thread = store.threads[key];
-    if (!thread) return false;
-    const before = thread.comments.length;
-    thread.comments = thread.comments.filter((c) => c.id !== commentId);
-    if (thread.comments.length === before) return false;
-    store.threads[key] = thread;
-    saveStore(store);
-    return true;
+): Promise<boolean> {
+    const { data, error } = await supabaseRest<any>("/rest/v1/request_comments", {
+        method: "DELETE",
+        body: null,
+        query: {
+            select: "id",
+            id: `eq.${commentId}`,
+            request_type: `eq.${type}`,
+            request_id: `eq.${requestId}`,
+        },
+        preferReturn: "representation",
+        acceptObject: true,
+    });
+
+    if (error) {
+        throw new Error(error.message);
+    }
+
+    return Boolean(data?.id);
 }
 
-export function addDistillationRequest(
+export async function addDistillationRequest(
     request: Omit<DistillationRequest, "id" | "upvotes" | "votedIps" | "createdAt" | "status">
-): DistillationRequest {
-    const store = loadStore();
-    const newRequest: DistillationRequest = {
-        ...request,
-        id: uuidv4(),
-        upvotes: 0,
-        votedIps: [],
-        createdAt: new Date().toISOString(),
-        status: "pending",
-    };
-    store.distillationRequests.push(newRequest);
-    saveStore(store);
-    return newRequest;
+): Promise<DistillationRequest> {
+    const { data, error } = await supabaseRest<any>("/rest/v1/distillation_requests", {
+        method: "POST",
+        body: JSON.stringify({
+            source_dataset: request.sourceDataset,
+            student_model: request.studentModel,
+            additional_notes: request.additionalNotes,
+            owner_id: request.ownerId,
+        }),
+        query: { select: "*" },
+        preferReturn: "representation",
+        acceptObject: true,
+    });
+
+    if (error) {
+        throw new Error(error.message);
+    }
+    if (!data) {
+        throw new Error("Failed to create request");
+    }
+    return mapDistillationRow(data);
 }
 
-export function addDatasetRequest(
+export async function addDatasetRequest(
     request: Omit<DatasetRequest, "id" | "upvotes" | "votedIps" | "createdAt" | "status">
-): DatasetRequest {
-    const store = loadStore();
-    const newRequest: DatasetRequest = {
-        ...request,
-        id: uuidv4(),
-        upvotes: 0,
-        votedIps: [],
-        createdAt: new Date().toISOString(),
-        status: "pending",
-    };
-    store.datasetRequests.push(newRequest);
-    saveStore(store);
-    return newRequest;
+): Promise<DatasetRequest> {
+    const { data, error } = await supabaseRest<any>("/rest/v1/dataset_requests", {
+        method: "POST",
+        body: JSON.stringify({
+            source_model: request.sourceModel,
+            dataset_size: request.datasetSize,
+            reasoning_depth: request.reasoningDepth,
+            topics: request.topics,
+            additional_notes: request.additionalNotes,
+            owner_id: request.ownerId,
+        }),
+        query: { select: "*" },
+        preferReturn: "representation",
+        acceptObject: true,
+    });
+
+    if (error) {
+        throw new Error(error.message);
+    }
+    if (!data) {
+        throw new Error("Failed to create request");
+    }
+    return mapDatasetRow(data);
 }
 
-export function upvoteDistillation(
+export async function upvoteDistillation(
     id: string,
     ip: string
-): { success: boolean; upvotes: number; action?: "upvoted" | "unvoted" } {
-    const store = loadStore();
-    const request = store.distillationRequests.find((r) => r.id === id);
-    if (!request) {
-        return { success: false, upvotes: 0 };
+): Promise<{ success: boolean; upvotes: number; action?: "upvoted" | "unvoted" }> {
+    const { data, error } = await supabaseRest<any[]>("/rest/v1/rpc/toggle_upvote_distillation", {
+        method: "POST",
+        body: JSON.stringify({ request_id: id, voter_ip: ip }),
+    });
+
+    if (error) {
+        throw new Error(error.message);
     }
-    if (request.votedIps.includes(ip)) {
-        request.votedIps = request.votedIps.filter((v) => v !== ip);
-        request.upvotes = Math.max(0, request.upvotes - 1);
-        saveStore(store);
-        return { success: true, upvotes: request.upvotes, action: "unvoted" };
+
+    const row = Array.isArray(data) ? data[0] : null;
+    if (!row) {
+        return { success: false, upvotes: 0 };
     }
-    request.upvotes += 1;
-    request.votedIps.push(ip);
-    saveStore(store);
-    return { success: true, upvotes: request.upvotes, action: "upvoted" };
+
+    return {
+        success: Boolean(row.success),
+        upvotes: typeof row.upvotes === "number" ? row.upvotes : 0,
+        action: row.action === "upvoted" || row.action === "unvoted" ? row.action : undefined,
+    };
 }
 
-export function upvoteDataset(
+export async function upvoteDataset(
     id: string,
     ip: string
-): { success: boolean; upvotes: number; action?: "upvoted" | "unvoted" } {
-    const store = loadStore();
-    const request = store.datasetRequests.find((r) => r.id === id);
-    if (!request) {
-        return { success: false, upvotes: 0 };
+): Promise<{ success: boolean; upvotes: number; action?: "upvoted" | "unvoted" }> {
+    const { data, error } = await supabaseRest<any[]>("/rest/v1/rpc/toggle_upvote_dataset", {
+        method: "POST",
+        body: JSON.stringify({ request_id: id, voter_ip: ip }),
+    });
+
+    if (error) {
+        throw new Error(error.message);
     }
-    if (request.votedIps.includes(ip)) {
-        request.votedIps = request.votedIps.filter((v) => v !== ip);
-        request.upvotes = Math.max(0, request.upvotes - 1);
-        saveStore(store);
-        return { success: true, upvotes: request.upvotes, action: "unvoted" };
+
+    const row = Array.isArray(data) ? data[0] : null;
+    if (!row) {
+        return { success: false, upvotes: 0 };
     }
-    request.upvotes += 1;
-    request.votedIps.push(ip);
-    saveStore(store);
-    return { success: true, upvotes: request.upvotes, action: "upvoted" };
+
+    return {
+        success: Boolean(row.success),
+        upvotes: typeof row.upvotes === "number" ? row.upvotes : 0,
+        action: row.action === "upvoted" || row.action === "unvoted" ? row.action : undefined,
+    };
 }