Alejandro Rosales
65a73ca99f
- Implemented subjects API with functions for creating, updating, and retrieving subjects, including history and bibliography. - Added tasks API for managing user tasks, including listing and marking tasks as completed. - Created hooks for managing AI interactions, authentication, subjects, tasks, and metadata queries. - Established query keys for caching and managing query states. - Introduced Supabase client and environment variable management for better configuration. - Defined types for database and domain models to ensure type safety across the application.
64 lines
2.1 KiB
TypeScript
64 lines
2.1 KiB
TypeScript
import { supabaseBrowser } from "../supabase/client";
|
|
import { throwIfError, requireData, getUserIdOrThrow } from "./_helpers";
|
|
import type { Archivo, UUID } from "../types/domain";
|
|
|
|
const DEFAULT_BUCKET = "archivos";
|
|
|
|
export type UploadFileInput = {
|
|
file: File;
|
|
bucket?: string;
|
|
pathPrefix?: string; // ej: "planes/<planId>" o "materias/<id>"
|
|
temporal?: boolean;
|
|
notas?: string | null;
|
|
};
|
|
|
|
export async function files_upload(input: UploadFileInput): Promise<Archivo> {
|
|
const supabase = supabaseBrowser();
|
|
const userId = await getUserIdOrThrow(supabase);
|
|
|
|
const bucket = input.bucket ?? DEFAULT_BUCKET;
|
|
const safeName = input.file.name.replace(/[^\w.\-() ]+/g, "_");
|
|
const pathPrefix = (input.pathPrefix ?? `usuarios/${userId}`).replace(/\/+$/g, "");
|
|
|
|
const storagePath = `${pathPrefix}/${crypto.randomUUID()}-${safeName}`;
|
|
|
|
const { data: upData, error: upErr } = await supabase.storage
|
|
.from(bucket)
|
|
.upload(storagePath, input.file, { upsert: false });
|
|
|
|
throwIfError(upErr);
|
|
requireData(upData, "No se pudo subir archivo.");
|
|
|
|
const { data: row, error: insErr } = await supabase
|
|
.from("archivos")
|
|
.insert({
|
|
ruta_storage: `${bucket}/${storagePath}`,
|
|
nombre: input.file.name,
|
|
mime_type: input.file.type || null,
|
|
bytes: input.file.size,
|
|
subido_por: userId as UUID,
|
|
temporal: Boolean(input.temporal),
|
|
notas: input.notas ?? null,
|
|
})
|
|
.select("id,ruta_storage,nombre,mime_type,bytes,subido_por,subido_en,temporal,openai_file_id,notas")
|
|
.single();
|
|
|
|
throwIfError(insErr);
|
|
return requireData(row, "No se pudo registrar metadata del archivo.");
|
|
}
|
|
|
|
export async function files_signed_url(params: {
|
|
ruta_storage: string; // "bucket/path/to/file"
|
|
expiresIn?: number; // segundos
|
|
}): Promise<string> {
|
|
const supabase = supabaseBrowser();
|
|
const expires = params.expiresIn ?? 60 * 10;
|
|
|
|
const [bucket, ...rest] = params.ruta_storage.split("/");
|
|
const path = rest.join("/");
|
|
|
|
const { data, error } = await supabase.storage.from(bucket).createSignedUrl(path, expires);
|
|
throwIfError(error);
|
|
return requireData(data?.signedUrl, "No se pudo generar URL firmada.");
|
|
}
|