alexrg/genesis-2
1
0
Fork 0
Code Issues 6 Pull Requests Actions Wiki Activity

fix: update database queries to use 'template' instead of 'template_id' and adjust related references in ai_generate_plan function

Browse Source
This commit is contained in:
Alejandro Rosales
2026-01-16 14:51:42 -06:00
parent 6c2faa97f1
commit 1d5d4b6a4e
3 changed files with 212 additions and 90 deletions
Download Patch File Download Diff File Expand all files Collapse all files
supabase/functions/ai-structured/index.ts
+155 -47
View File
@@ -126,12 +126,16 @@ function safePreview(val: unknown, maxLen = 1200) {
if (typeof v === "string") {
if (v.length > 500) return v.slice(0, 500) + "…[TRUNCATED]";
// evita imprimir base64/data URLs
if (v.startsWith("data:") && v.includes(";base64,")) return "[DATA_URL_REDACTED]";
if (v.startsWith("data:") && v.includes(";base64,")) {
return "[DATA_URL_REDACTED]";
}
}
return v;
});
if (!jsonStr) return String(val);
return jsonStr.length > maxLen ? jsonStr.slice(0, maxLen) + "…[TRUNCATED]" : jsonStr;
return jsonStr.length > maxLen
? jsonStr.slice(0, maxLen) + "…[TRUNCATED]"
: jsonStr;
} catch {
return String(val);
}
@@ -187,13 +191,17 @@ function toolsSummary(tools: any[]) {
return arr.map((t) => {
if (!t) return t;
const base: any = { type: t.type };
if (t.type === "file_search") base.vector_store_ids_count = (t.vector_store_ids ?? []).length;
if (t.type === "file_search") {
base.vector_store_ids_count = (t.vector_store_ids ?? []).length;
}
if (t.type === "mcp") {
base.server_label = t.server_label ?? null;
base.server_url = t.server_url ? "[SET]" : null;
base.require_approval = t.require_approval ?? null;
base.authorization = t.authorization ? "[REDACTED]" : null;
base.allowed_tools_count = Array.isArray(t.allowed_tools) ? t.allowed_tools.length : null;
base.allowed_tools_count = Array.isArray(t.allowed_tools)
? t.allowed_tools.length
: null;
}
return base;
});
@@ -207,7 +215,10 @@ Deno.serve(async (req) => {
const log = (msg: string, extra?: unknown) => {
if (extra !== undefined) {
console.log(`[${nowIso()}][ai-structured][${cid}] ${msg}`, safePreview(extra));
console.log(
`[${nowIso()}][ai-structured][${cid}] ${msg}`,
safePreview(extra),
);
} else {
console.log(`[${nowIso()}][ai-structured][${cid}] ${msg}`);
}
@@ -215,7 +226,10 @@ Deno.serve(async (req) => {
const warn = (msg: string, extra?: unknown) => {
if (extra !== undefined) {
console.warn(`[${nowIso()}][ai-structured][${cid}] ⚠️ ${msg}`, safePreview(extra));
console.warn(
`[${nowIso()}][ai-structured][${cid}] ⚠️ ${msg}`,
safePreview(extra),
);
} else {
console.warn(`[${nowIso()}][ai-structured][${cid}] ⚠️ ${msg}`);
}
@@ -223,7 +237,10 @@ Deno.serve(async (req) => {
const errlog = (msg: string, extra?: unknown) => {
if (extra !== undefined) {
console.error(`[${nowIso()}][ai-structured][${cid}] ❌ ${msg}`, safePreview(extra));
console.error(
`[${nowIso()}][ai-structured][${cid}] ❌ ${msg}`,
safePreview(extra),
);
} else {
console.error(`[${nowIso()}][ai-structured][${cid}] ❌ ${msg}`);
}
@@ -247,11 +264,17 @@ Deno.serve(async (req) => {
const authHeaderRaw = req.headers.get("Authorization") ??
req.headers.get("authorization");
log("Authorization header present?", { present: Boolean(authHeaderRaw), value: redactAuthHeader(authHeaderRaw) });
log("Authorization header present?", {
present: Boolean(authHeaderRaw),
value: redactAuthHeader(authHeaderRaw),
});
if (!authHeaderRaw) {
warn("Missing Authorization header");
return json({ ok: false, error: "Missing Authorization header", cid }, 401);
return json(
{ ok: false, error: "Missing Authorization header", cid },
401,
);
}
const SUPABASE_URL = Deno.env.get("SUPABASE_URL");
@@ -275,8 +298,11 @@ Deno.serve(async (req) => {
});
const tAuth = performance.now();
const { data: userData, error: userErr } = await supabaseUser.auth.getUser();
log("Supabase auth.getUser() done ⏱️", { ms: Math.round(performance.now() - tAuth) });
const { data: userData, error: userErr } = await supabaseUser.auth
.getUser();
log("Supabase auth.getUser() done ⏱️", {
ms: Math.round(performance.now() - tAuth),
});
if (userErr || !userData?.user) {
warn("Invalid token", { userErr: userErr?.message ?? userErr ?? null });
@@ -284,10 +310,15 @@ Deno.serve(async (req) => {
}
const user = userData.user;
log("Authenticated user ✅", { userId: user.id, email: user.email ?? null });
log("Authenticated user ✅", {
userId: user.id,
email: user.email ?? null,
});
const SERVICE_ROLE = Deno.env.get("SUPABASE_SERVICE_ROLE_KEY");
log("Env presence (service role) 🗝️", { hasSERVICE_ROLE: Boolean(SERVICE_ROLE) });
log("Env presence (service role) 🗝️", {
hasSERVICE_ROLE: Boolean(SERVICE_ROLE),
});
const supabaseAdmin = SERVICE_ROLE
? createClient(SUPABASE_URL, SERVICE_ROLE)
@@ -343,9 +374,13 @@ Deno.serve(async (req) => {
}, 400);
}
for (const key of ["files", "files[]", "archivos", "archivosTemporales"]) {
for (
const key of ["files", "files[]", "archivos", "archivosTemporales"]
) {
const vals = form.getAll(key);
if (vals?.length) log(`Found multipart field "${key}"`, { count: vals.length });
if (vals?.length) {
log(`Found multipart field "${key}"`, { count: vals.length });
}
for (const v of vals) {
if (v instanceof File) tempFiles.push(v);
}
@@ -361,19 +396,29 @@ Deno.serve(async (req) => {
log("Multipart files detected 📎", {
count: tempFiles.length,
files: tempFiles.map((f) => ({ name: f.name, type: f.type, size: f.size })),
files: tempFiles.map((f) => ({
name: f.name,
type: f.type,
size: f.size,
})),
});
} else {
log("Parsing JSON body 🧾");
try {
payload = await req.json();
} catch (e) {
errlog("Invalid JSON body", { error: (e as Error)?.message ?? String(e) });
errlog("Invalid JSON body", {
error: (e as Error)?.message ?? String(e),
});
return json({ ok: false, error: "Invalid JSON body", cid }, 400);
}
}
log("Body parsed ⏱️", { ms: Math.round(performance.now() - tParse) });
log("Payload top-level keys", { keys: Object.keys(payload ?? {}), hasOpenAI: Boolean(payload?.openai), hasResponse: Boolean(payload?.response) });
log("Payload top-level keys", {
keys: Object.keys(payload ?? {}),
hasOpenAI: Boolean(payload?.openai),
hasResponse: Boolean(payload?.response),
});
// 3) Construye config final para OpenAI (passthrough + overrides) 🧠
log("Step 3: Build responseCfg 🧠");
@@ -389,7 +434,10 @@ Deno.serve(async (req) => {
if (responseCfg.input !== undefined) {
responseCfg.input = normalizeInputUser(responseCfg.input);
log("responseCfg.input normalized ✅", summarizeInputShape(responseCfg.input));
log(
"responseCfg.input normalized ✅",
summarizeInputShape(responseCfg.input),
);
} else {
warn("responseCfg.input is undefined (is that expected?)");
}
@@ -406,7 +454,7 @@ Deno.serve(async (req) => {
responseCfg.reasoning = payload.reasoning;
}
responseCfg.model = responseCfg.model ?? "gpt-5";
responseCfg.model = responseCfg.model ?? "gpt-5-nano";
log("OpenAI config summary 🤖", {
model: responseCfg.model,
hasConversation: Boolean(responseCfg.conversation),
@@ -445,11 +493,15 @@ Deno.serve(async (req) => {
}
if (typeof structured === "string") {
log("Parsing structured from string 🧩", { preview: structured.slice(0, 200) });
log("Parsing structured from string 🧩", {
preview: structured.slice(0, 200),
});
try {
structured = JSON.parse(structured);
} catch (e) {
errlog("`structured` string is not valid JSON", { error: (e as Error)?.message ?? String(e) });
errlog("`structured` string is not valid JSON", {
error: (e as Error)?.message ?? String(e),
});
return json({
ok: false,
error: "`structured` is a string but not valid JSON.",
@@ -486,7 +538,9 @@ Deno.serve(async (req) => {
log("References summary", {
openaiFileIdsCount: openaiFileIds.length,
vectorStoreIdsCount: vectorStoreIds.length,
usarMCP: Boolean(payload.usarMCP ?? references.usarMCP ?? payload.mcp?.enabled),
usarMCP: Boolean(
payload.usarMCP ?? references.usarMCP ?? payload.mcp?.enabled,
),
});
// 5a) Vector stores => file_search tool
@@ -506,7 +560,10 @@ Deno.serve(async (req) => {
}
responseCfg.include = include;
log("Added file_search tool 🗂️", { vectorStoreIdsCount: vectorStoreIds.length, include: responseCfg.include });
log("Added file_search tool 🗂️", {
vectorStoreIdsCount: vectorStoreIds.length,
include: responseCfg.include,
});
}
// 5b) MCP opcional
@@ -518,8 +575,11 @@ Deno.serve(async (req) => {
const server_url = mcp.server_url ?? Deno.env.get("MCP_SERVER_URL");
log("MCP config presence", {
hasServerUrl: Boolean(server_url),
hasAuthorization: Boolean(mcp.authorization ?? Deno.env.get("MCP_AUTHORIZATION")),
server_label: mcp.server_label ?? Deno.env.get("MCP_SERVER_LABEL") ?? "supabase",
hasAuthorization: Boolean(
mcp.authorization ?? Deno.env.get("MCP_AUTHORIZATION"),
),
server_label: mcp.server_label ?? Deno.env.get("MCP_SERVER_LABEL") ??
"supabase",
});
if (!server_url) {
@@ -553,12 +613,17 @@ Deno.serve(async (req) => {
// 5c) OpenAI file IDs => se insertan al input como input_file
if (openaiFileIds.length) {
log("Injecting OpenAI file_ids into input 🧷", { count: openaiFileIds.length });
log("Injecting OpenAI file_ids into input 🧷", {
count: openaiFileIds.length,
});
responseCfg.input = normalizeInputWithOpenAIFileIds(
responseCfg.input,
openaiFileIds,
);
log("Input after OpenAI file_ids injection", summarizeInputShape(responseCfg.input));
log(
"Input after OpenAI file_ids injection",
summarizeInputShape(responseCfg.input),
);
}
// 6) Archivos temporales => subir a Supabase Storage (NO a OpenAI) ☁️
@@ -583,28 +648,43 @@ Deno.serve(async (req) => {
const safeName = (f.name ?? "file").replaceAll(/[^a-zA-Z0-9._-]/g, "_");
const path = `${prefix}/${user.id}/${crypto.randomUUID()}-${safeName}`;
log("Uploading file to storage ⬆️", { name: f.name, type: f.type, size: f.size, path });
log("Uploading file to storage ⬆️", {
name: f.name,
type: f.type,
size: f.size,
path,
});
const tUp = performance.now();
const bytes = new Uint8Array(await f.arrayBuffer());
// warning útil: btoa + spread puede tronarse con archivos grandes
if (bytes.length > 2 * MB) {
warn("Large file detected: base64 building might be heavy (btoa + spread) 🧨", {
name: f.name,
bytes: bytes.length,
approxBase64Chars: Math.ceil(bytes.length * 4 / 3),
});
warn(
"Large file detected: base64 building might be heavy (btoa + spread) 🧨",
{
name: f.name,
bytes: bytes.length,
approxBase64Chars: Math.ceil(bytes.length * 4 / 3),
},
);
}
const { data, error } = await supabaseAdmin.storage
.from(bucket)
.upload(path, bytes, { contentType: f.type, upsert: false });
log("Storage upload done ⏱️", { ms: Math.round(performance.now() - tUp) });
log("Storage upload done ⏱️", {
ms: Math.round(performance.now() - tUp),
});
if (error) {
errlog("Storage upload failed", { message: error.message, file: f.name, bucket, path });
errlog("Storage upload failed", {
message: error.message,
file: f.name,
bucket,
path,
});
return json({
ok: false,
error: `Storage upload failed: ${error.message}`,
@@ -616,7 +696,10 @@ Deno.serve(async (req) => {
// Add as an input_file base64 reference to the last user message content
const tB64 = performance.now();
const fileBase64 = btoa(String.fromCharCode(...bytes)); // ⚠️ potencialmente pesado
log("Base64 built ⏱️", { ms: Math.round(performance.now() - tB64), base64Chars: fileBase64.length });
log("Base64 built ⏱️", {
ms: Math.round(performance.now() - tB64),
base64Chars: fileBase64.length,
});
if (Array.isArray(responseCfg.input) && responseCfg.input.length > 0) {
const lastMsg = responseCfg.input[responseCfg.input.length - 1];
@@ -633,13 +716,19 @@ Deno.serve(async (req) => {
// no imprimimos file_data
});
} else {
warn("Could not append input_file: last message is not user/content array", {
lastRole: lastMsg?.role ?? null,
lastContentType: typeof lastMsg?.content,
});
warn(
"Could not append input_file: last message is not user/content array",
{
lastRole: lastMsg?.role ?? null,
lastContentType: typeof lastMsg?.content,
},
);
}
} else {
warn("responseCfg.input not array or empty; cannot append file_data", summarizeInputShape(responseCfg.input));
warn(
"responseCfg.input not array or empty; cannot append file_data",
summarizeInputShape(responseCfg.input),
);
}
uploadedToStorage.push({
@@ -657,7 +746,9 @@ Deno.serve(async (req) => {
// 7) Llamada a OpenAI Responses API 🚀
log("Step 7: OpenAI call 🚀");
const OPENAI_API_KEY = Deno.env.get("OPENAI_API_KEY");
log("Env presence (OpenAI) 🔑", { hasOPENAI_API_KEY: Boolean(OPENAI_API_KEY) });
log("Env presence (OpenAI) 🔑", {
hasOPENAI_API_KEY: Boolean(OPENAI_API_KEY),
});
if (!OPENAI_API_KEY) {
errlog("Missing OPENAI_API_KEY");
@@ -710,7 +801,9 @@ Deno.serve(async (req) => {
const tParseOut = performance.now();
try {
output = JSON.parse(outputText);
log("Output JSON parsed ✅", { ms: Math.round(performance.now() - tParseOut) });
log("Output JSON parsed ✅", {
ms: Math.round(performance.now() - tParseOut),
});
} catch (e) {
outputParseError = (e as Error)?.message ?? String(e);
warn("Output JSON parse FAILED 🧯", {
@@ -731,7 +824,7 @@ Deno.serve(async (req) => {
totalMs: Math.round(performance.now() - t0),
});
return json({
const response = json({
ok: outputParseError ? false : true,
cid, // 👈 útil para correlacionar logs
responseId: resp.id,
@@ -750,15 +843,30 @@ Deno.serve(async (req) => {
archivosReferenciaIds: references.archivosReferenciaIds ??
payload.archivosReferenciaIds ?? payload.archivosReferencia ?? [],
},
tools: sanitizeTools(responseCfg.tools),
});
// Log final response
log("Response payload preview:", {
references: {
uploadedToStorage,
openaiFileIds,
vectorStoreIds,
archivosReferenciaIds: references.archivosReferenciaIds ??
payload.archivosReferenciaIds ?? payload.archivosReferencia ?? [],
},
});
return response;
} catch (e) {
errlog("Unhandled error 💥", {
message: (e as Error)?.message ?? String(e),
stack: (e as Error)?.stack ?? null,
totalMs: Math.round(performance.now() - t0),
});
return json({ ok: false, error: (e as Error)?.message ?? String(e), cid }, 500);
return json(
{ ok: false, error: (e as Error)?.message ?? String(e), cid },
500,
);
}
});