[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_167":168,"_169":170},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_103":85,"_27":53,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":25,"_117":118,"_119":120,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",23,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","Ruler-Hand.ts","latestPath","fileId","d32af79a-64f4-11f1-941a-1607ee4eb77e","name","fileType","http","content","return rows\n .map((row) => {\n const entrs = Object.entries(row).filter(([field, value]) =>\n allowedColumns.has(field) && value !== undefined\n );\n if (entries.length === 0) return null;\n\n const columns = entries.map(([field]) => field);\n const values = entries.map(([, value]) => normalizePrimitive(value));\n return {\n columns,\n values,\n row,\n keyFields,\n };\n })\n .filter((item): item is NonNullable => Boolean(item));\n}\n\nfunction buildWhereFromObject(\n where: JsonObject,\n allowedFields: Set,\n): { sql: string; args: Array } | null {\n const parts: string[] = [];\n const args: Array = [];\n\n for (const [field, raw] of Object.entries(where)) {\n if (!allowedFields.has(field)) continue;\n const values = uniqueStrings(flattenValues(raw));\n const normalized = values.map((value) => normalizePrimitive(value)).filter((\n value,\n ): value is string | number | boolean | null => true);\n const actual = normalized.filter((\n value,\n ): value is string | number | boolean => value !== null);\n if (!actual.length) continue;\n\n if (actual.length === 1) {\n parts.push(`${escapeSqlIdentifier(field)} = ?`);\n args.push(actual[0]);\n } else {\n const placeholders = actual.map(() => \"?\").join(\", \");\n parts.push(`${escapeSqlIdentifier(field)} IN (${placeholders})`);\n args.push(...actual);\n }\n }\n\n if (!parts.length) return null;\n return { sql: parts.join(\" AND \"), args };\n}\n\nasync function insertRows(table: string, rows: Row[]) {\n const schema = await readSchema(table);\n const statements = buildInsertStatements(table, rows, schema.columns);\n if (statements.length === 0) {\n return { inserted: 0, skipped: rows.length };\n }\n\n const sqlStatements = statements.map((item) => ({\n sql: `INSERT INTO ${escapeSqlIdentifier(table)} (${\n item.columns.map(escapeSqlIdentifier).join(\", \")\n }) VALUES (${item.values.map(() => \"?\").join(\", \")})`,\n args: item.values,\n }));\n\n await sql.batch(sqlStatements, \"write\");\n return {\n inserted: statements.length,\n skipped: rows.length - statements.length,\n };\n}\n\nasync function updateRows(\n table: string,\n where: JsonObject | null,\n patch: JsonObject,\n) {\n const schema = await readSchema(table);\n const allowedFields = new Set(\n schema.columns.map((column) => String(column.name)),\n );\n const keyFields = getTableKeyFields(table, schema.columns);\n\n const whereClause = where && Object.keys(where).length\n ? buildWhereFromObject(where, allowedFields)\n : null;\n\n if (!whereClause && !keyFields.length) {\n return { updated: 0, reason: \"unable to infer key fields\" };\n }\n\n const updateEntries = Object.entries(patch).filter(([field, value]) =>\n allowedFields.has(field) && value !== undefined\n );\n if (updateEntries.length === 0) {\n return { updated: 0, reason: \"no updatable fields supplied\" };\n }\n\n const setSql = updateEntries.map(([field]) =>\n `${escapeSqlIdentifier(field)} = ?`\n ).join(\", \");\n const setArgs = updateEntries.map(([, value]) => normalizePrimitive(value));\n\n if (whereClause) {\n const result = await sql.execute({\n sql: `UPDATE ${\n escapeSqlIdentifier(table)\n } SET ${setSql} WHERE ${whereClause.sql}`,\n args: [...setArgs, ...whereClause.args],\n });\n return { updated: result.rowsAffected ?? 0 };\n }\n\n return { updated: 0, reason: \"missing where clause\" };\n}\n\nasync function deleteRows(table: string, body: JsonObject) {\n const schema = await readSchema(table);\n const allowedFields = new Set(\n schema.columns.map((column) => String(column.name)),\n );\n\n const keyFields = getTableKeyFields(table, schema.columns);\n const keys = Array.isArray(body.keys) ? body.keys : [];\n if (keys.length > 0 && keyFields.length > 0) {\n const clauses: string[] = [];\n const args: Array = [];\n\n for (const item of keys) {\n if (isPlainObject(item)) {\n const fields = keyFields\n .map((field) => ({ field, value: normalizePrimitive(item[field]) }))\n .filter((entry) => entry.value !== null);\n\n if (fields.length !== keyFields.length) continue;\n\n clauses.push(\n `(${\n fields.map((entry) => `${escapeSqlIdentifier(entry.field)} = ?`)\n .join(\" AND \")\n })`,\n );\n args.push(\n ...fields.map((entry) => entry.value as string | number | boolean),\n );\n } else if (keyFields.length === 1) {\n clauses.push(`(${escapeSqlIdentifier(keyFields[0])} = ?)`);\n args.push(normalizePrimitive(item) as string | number | boolean | null);\n }\n }\n\n if (clauses.length > 0) {\n const result = await sql.execute({\n sql: `DELETE FROM ${escapeSqlIdentifier(table)} WHERE ${\n clauses.join(\" OR \")\n }`,\n args,\n });\n return { removed: result.rowsAffected ?? 0 };\n }\n }\n\n const filters = normalizeFilterMap(\n body.where ?? body.filters ?? body.lnrmv ?? body.remove,\n );\n const whereClause = buildWhereFromObject(filters, allowedFields);\n if (!whereClause) return { removed: 0, reason: \"no valid filters supplied\" };\n\n const result = await sql.execute({\n sql: `DELETE FROM ${escapeSqlIdentifier(table)} WHERE ${whereClause.sql}`,\n args: whereClause.args,\n });\n return { removed: result.rowsAffected ?? 0 };\n}\n\nasync function addField(\n table: string,\n field: string,\n type = \"TEXT\",\n defaultValue: unknown = null,\n) {\n const sanitizedType = String(type || \"TEXT\").trim() || \"TEXT\";\n const defaultSql = defaultValue === null || defaultValue === undefined\n ? \"\"\n : ` DEFAULT ${\n typeof defaultValue === \"number\"\n ? defaultValue\n : `'${String(defaultValue).replaceAll(\"'\", \"''\")}'`\n }`;\n\n await sql.execute({\n sql: `ALTER TABLE ${escapeSqlIdentifier(table)} ADD COLUMN ${\n escapeSqlIdentifier(field)\n } ${sanitizedType}${defaultSql}`,\n });\n\n return { added: field, type: sanitizedType };\n}\n\nasync function renameField(table: string, fromField: string, toField: string) {\n await sql.execute({\n sql: `ALTER TABLE ${escapeSqlIdentifier(table)} RENAME COLUMN ${\n escapeSqlIdentifier(fromField)\n } TO ${escapeSqlIdentifier(toField)}`,\n });\n return { renamed: fromField, to: toField };\n}\n\nasync function rebuildTableWithoutField(table: string, removeField: string) {\n const schema = await readSchema(table);\n const remaining = schema.columns.filter((column) =>\n String(column.name) !== removeField\n );\n if (remaining.length === schema.columns.length) {\n return { removed: 0, reason: \"field not found\" };\n }\n\n const tempTable = `${table}__rebuild_tmp_${Date.now()}`;\n const columnDefs = remaining.map((column) => {\n const pieces = [\n escapeSqlIdentifier(String(column.name)),\n column.type ? String(column.type) : \"TEXT\",\n ];\n\n if (Number(column.notnull) === 1) pieces.push(\"NOT NULL\");\n if (column.dflt_value !== null && column.dflt_value !== undefined) {\n const raw = typeof column.dflt_value === \"number\"\n ? String(column.dflt_value)\n : String(column.dflt_value);\n pieces.push(`DEFAULT ${raw}`);\n }\n if (Number(column.pk) > 0) pieces.push(\"PRIMARY KEY\");\n return pieces.join(\" \");\n });\n\n const columnNames = remaining.map((column) =>\n escapeSqlIdentifier(String(column.name))\n );\n const copyColumns = columnNames.join(\", \");\n\n await sql.batch(\n [\n {\n sql: `CREATE TABLE ${escapeSqlIdentifier(tempTable)} (${\n columnDefs.join(\", \")\n })`,\n args: [],\n },\n {\n sql: `INSERT INTO ${\n escapeSqlIdentifier(tempTable)\n } (${copyColumns}) SELECT ${copyColumns} FROM ${\n escapeSqlIdentifier(table)\n }`,\n args: [],\n },\n {\n sql: `DROP TABLE ${escapeSqlIdentifier(table)}`,\n args: [],\n },\n {\n sql: `ALTER TABLE ${escapeSqlIdentifier(tempTable)} RENAME TO ${\n escapeSqlIdentifier(table)\n }`,\n args: [],\n },\n ],\n \"write\",\n );\n\n return { removed: 1, rebuilt: true };\n}\n\nasync function removeField(table: string, field: string) {\n try {\n await sql.execute({\n sql: `ALTER TABLE ${escapeSqlIdentifier(table)} DROP COLUMN ${\n escapeSqlIdentifier(field)\n }`,\n });\n return { removed: 1, mode: \"native\" };\n } catch {\n return await rebuildTableWithoutField(table, field);\n }\n}\n\nasync function handleIndexUpdate(body: JsonObject) {\n const rawIds = [\n body.ids,\n body.animeIds,\n body.selection,\n body.rows,\n body.items,\n body.records,\n ];\n\n const ids = [\n ...new Set(\n rawIds.flatMap((value) => {\n if (Array.isArray(value)) {\n return value.flatMap((item) => {\n if (isPlainObject(item)) {\n const candidate = item.id ?? item.anime_id ?? item.animeId ??\n item.target_id;\n const trimmed = String(candidate ?? \"\").trim();\n return trimmed ? [trimmed] : [];\n }\n const trimmed = String(item ?? \"\").trim();\n return trimmed ? [trimmed] : [];\n });\n }\n if (isPlainObject(value)) {\n return Object.keys(value).map((item) => String(item).trim()).filter(\n Boolean,\n );\n }\n return [];\n }).filter(Boolean),\n ),\n ];\n\n if (!ids.length) {\n return {\n status: \"failed\",\n error: \"no anime ids supplied for index update\",\n };\n }\n\n const animeRows = await fetchRowsByAnimeIds(ids);\n const connectorRows = await fetchConnectorRowsByAnimeIds(ids);\n\n if (connectorRows.length === 0) {\n return {\n status: \"ok\",\n requested_ids: ids.length,\n updated_pairs: 0,\n skipped_pairs: 0,\n missing: [],\n note: \"no connector rows matched the selected anime ids\",\n };\n }\n\n const intIds = [\n ...new Set(\n connectorRows.map((row) => Math.trunc(Number(row.int_id))).filter((\n value,\n ) => Number.isFinite(value)),\n ),\n ];\n const episodeRows = await fetchRowsByIntIds(intIds);\n\n const updatedRows: Row[] = [];\n const missing: Array<{ int_id: number; id: string; reason: string }> = [];\n\n for (const connectorRow of connectorRows) {\n const intId = Math.trunc(Number(connectorRow.int_id));\n const id = String(connectorRow.id ?? \"\").trim();\n if (!Number.isFinite(intId) || !id) continue;\n\n const episode = episodeRows.get(intId);\n const anime = animeRows.get(id);\n\n if (!episode || !anime) {\n missing.push({\n int_id: intId,\n id,\n reason: !episode && !anime\n ? \"missing source and target rows\"\n : !episode\n ? \"missing source row\"\n : \"missing target row\",\n });\n continue;\n }\n\n const password = anime.password == null ? \"\" : String(anime.password);\n const sha = await sha256Hex(password);\n\n updatedRows.push({\n int_id: intId,\n id,\n title: anime.title ?? null,\n season: episode.season ?? null,\n episode: episode.episode ?? null,\n stream: episode.link ?? null,\n sha,\n });\n }\n\n const writeResult = await upsertConnectorRows(updatedRows);\n const refreshed = await refreshCacheFromSql(INTEGRATION.bridgeTable);\n\n return {\n status: \"ok\",\n requested_ids: ids.length,\n requested_connections: connectorRows.length,\n written_pairs: writeResult.inserted,\n skipped_pairs: missing.length,\n missing,\n refreshed: {\n rows: refreshed.rows,\n manifest: refreshed.manifest,\n },\n };\n}\n\nasync function handleTableAdmin(body: JsonObject) {\n const action = String(body.action ?? body.op ?? \"\").trim().toLowerCase();\n const table = String(body.table ?? \"\").trim();\n\n if (action === \"index-update\") {\n if (table && table !== INTEGRATION.targetTable) {\n return {\n ok: false,\n error: `index update is wired for ${INTEGRATION.targetTable}`,\n };\n }\n try {\n const result = await handleIndexUpdate(body);\n return {\n ok: result.status === \"ok\",\n table: INTEGRATION.targetTable,\n action,\n result,\n refreshed: result.status === \"ok\" ? result.refreshed : null,\n };\n } catch (error) {\n return {\n ok: false,\n error: error instanceof Error ? error.message : String(error),\n };\n }\n }\n\n if (!table || !isAllowedTable(table)) {\n return { ok: false, error: \"invalid or unsupported table\" };\n }\n\n try {\n let result: Record | null = null;\n let refreshed: { rows: number; manifest: CachedTableManifest } | null =\n null;\n\n if (\n action === \"insert-row\" || action === \"insert\" ||\n action === \"create-row\" || action === \"add-row\"\n ) {\n const rows = Array.isArray(body.rows)\n ? body.rows.filter(isPlainObject)\n : isPlainObject(body.row)\n ? [body.row]\n : [];\n result = await insertRows(table, rows);\n } else if (\n action === \"update-row\" || action === \"update\" || action === \"edit-row\"\n ) {\n const patch = isPlainObject(body.patch)\n ? body.patch\n : isPlainObject(body.row)\n ? body.row\n : {};\n const where = isPlainObject(body.where)\n ? body.where\n : isPlainObject(body.keys)\n ? body.keys\n : null;\n result = await updateRows(table, where, patch);\n } else if (\n action === \"delete-rows\" || action === \"delete\" ||\n action === \"remove-rows\" || action === \"remove\"\n ) {\n result = await deleteRows(table, body);\n } else if (action === \"add-field\" || action === \"field-add\") {\n const field = String(body.field ?? body.name ?? \"\").trim();\n if (!field) return { ok: false, error: \"field name is required\" };\n result = await addField(\n table,\n field,\n String(body.type ?? \"TEXT\"),\n body.defaultValue ?? null,\n );\n } else if (action === \"rename-field\" || action === \"field-rename\") {\n const from = String(body.from ?? body.field ?? \"\").trim();\n const to = String(body.to ?? body.newField ?? body.renameTo ?? \"\").trim();\n if (!from || !to) {\n return {\n ok: false,\n error: \"both from and to field names are required\",\n };\n }\n result = await renameField(table, from, to);\n } else if (\n action === \"remove-field\" || action === \"field-remove\" ||\n action === \"drop-field\"\n ) {\n const field = String(body.field ?? body.name ?? \"\").trim();\n if (!field) return { ok: false, error: \"field name is required\" };\n result = await removeField(table, field);\n } else if (action === \"refresh-cache\") {\n refreshed = await refreshCacheFromSql(table);\n return {\n ok: true,\n table,\n action,\n result: {\n rows: refreshed.rows,\n manifest: refreshed.manifest,\n },\n refreshed,\n };\n } else {\n return { ok: false, error: \"invalid action\" };\n }\n\n refreshed = await refreshCacheFromSql(table);\n return {\n ok: true,\n table,\n action,\n result,\n refreshed: {\n rows: refreshed.rows,\n manifest: refreshed.manifest,\n },\n };\n } catch (error) {\n return {\n ok: false,\n table,\n action,\n error: error instanceof Error ? error.message : String(error),\n };\n }\n}\nexport default async function handler(req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/+$/, \"\") || \"/\";\n\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: CORS_HEADERS });\n }\n\n if (req.method === \"GET\" && path === \"/\") {\n return jsonResponse({\n ok: true,\n api: APP_NAME,\n message: HEALTH_MESSAGE,\n routes: [\n \"GET /\",\n \"GET /ignite-engine\",\n \"POST /bootroot-data\",\n \"POST /integrate-sqldata\",\n \"POST /table-admin\",\n ],\n });\n }\n\n if (req.method === \"GET\" && path === \"/ignite-engine\") {\n try {\n return jsonResponse(await handleIgniteEngine(url));\n } catch (error) {\n return jsonResponse({\n ok: false,\n error: error instanceof Error ? error.message : String(error),\n }, 500);\n }\n }\n\n if (req.method !== \"POST\") {\n return jsonResponse({ ok: false, error: \"method not allowed\" }, 405);\n }\n\n const body = await readJson(req);\n const commands = normalizeCommands(body);\n\n if (path === \"/bootroot-data\") {\n const results: Array> = [];\n\n for (const command of commands) {\n try {\n const restoreTables = parseTableList(command.restore);\n const deleteTables = parseTableList(command.delete);\n const executeResult =\n command.execute || command.provider || command.lnrmv\n ? await handleExecuteCommand(command)\n : null;\n\n if (restoreTables.length) {\n results.push({\n action: \"restore\",\n tables: restoreTables,\n results: await handleRestoreTables(restoreTables),\n });\n }\n\n if (deleteTables.length) {\n results.push({\n action: \"delete\",\n tables: deleteTables,\n results: await handleDeleteTables(deleteTables),\n });\n }\n\n if (executeResult) {\n results.push({\n action: \"execute\",\n result: executeResult,\n });\n }\n\n if (!restoreTables.length && !deleteTables.length && !executeResult) {\n results.push({\n action: \"noop\",\n status: \"ignored\",\n note: \"no recognized instruction found\",\n });\n }\n } catch (error) {\n results.push({\n action: \"error\",\n error: error instanceof Error ? error.message : String(error),\n });\n }\n }\n\n return jsonResponse({\n ok: true,\n endpoint: path,\n results,\n });\n }\n\n if (path === \"/integrate-sqldata\") {\n const payload = commands[0] ?? (isPlainObject(body) ? body : {});\n try {\n const result = await handleIntegrateSqlData(payload);\n return jsonResponse(\n {\n ok: result.status === \"ok\",\n endpoint: path,\n result,\n },\n result.status === \"ok\" ? 200 : 400,\n );\n } catch (error) {\n return jsonResponse(\n {\n ok: false,\n endpoint: path,\n error: error instanceof Error ? error.message : String(error),\n },\n 500,\n );\n }\n }\n\n if (path === \"/table-admin\") {\n const payload = commands[0] ?? (isPlainObject(body) ? body : {});\n try {\n return jsonResponse(await handleTableAdmin(payload));\n } catch (error) {\n return jsonResponse({\n ok: false,\n error: error instanceof Error ? error.message : String(error),\n }, 500);\n }\n }\n\n return jsonResponse({\n ok: false,\n error: \"not found\",\n path,\n }, 404);\n}","async function updateRows(\n table: string,\n where: JsonObject | null,\n patch: JsonObject,\n) {\n const schema = await readSchema(table);\n const allowedFields = new Set(\n schema.columns.map((column) => String(column.name)),\n );\n const keyFields = getTableKeyFields(table, schema.columns);\n\n const whereClause = where && Object.keys(where).length\n ? buildWhereFromObject(where, allowedFields)\n : null;\n\n if (!whereClause && !keyFields.length) {\n return { updated: 0, reason: \"unable to infer key fields\" };\n }\n\n const updateEntries = Object.entries(patch).filter(([field, value]) =>\n allowedFields.has(field) && value !== undefined\n );\n if (updateEntries.length === 0) {\n return { updated: 0, reason: \"no updatable fields supplied\" };\n }\n\n const setSql = updateEntries.map(([field]) =>\n `${escapeSqlIdentifier(field)} = ?`\n ).join(\", \");\n const setArgs = updateEntries.map(([, value]) => normalizePrimitive(value));\n\n if (whereClause) {\n const result = await sql.execute({\n sql: `UPDATE ${\n escapeSqlIdentifier(table)\n } SET ${setSql} WHERE ${whereClause.sql}`,\n args: [...setArgs, ...whereClause.args],\n });\n return { updated: result.rowsAffected ?? 0 };\n }\n\n return { updated: 0, reason: \"missing where clause\" };\n}\n\nasync function deleteRows(table: string, body: JsonObject) {\n const schema = await readSchema(table);\n const allowedFields = new Set(\n schema.columns.map((column) => String(column.name)),\n );\n\n const keyFields = getTableKeyFields(table, schema.columns);\n const keys = Array.isArray(body.keys) ? body.keys : [];\n if (keys.length > 0 && keyFields.length > 0) {\n const clauses: string[] = [];\n const args: Array = [];\n\n for (const item of keys) {\n if (isPlainObject(item)) {\n const fields = keyFields\n .map((field) => ({ field, value: normalizePrimitive(item[field]) }))\n .filter((entry) => entry.value !== null);\n\n if (fields.length !== keyFields.length) continue;\n\n clauses.push(\n `(${\n fields.map((entry) => `${escapeSqlIdentifier(entry.field)} = ?`)\n .join(\" AND \")\n })`,\n );\n args.push(\n ...fields.map((entry) => entry.value as string | number | boolean),\n );\n } else if (keyFields.length === 1) {\n clauses.push(`(${escapeSqlIdentifier(keyFields[0])} = ?)`);\n args.push(normalizePrimitive(item) as string | number | boolean | null);\n }\n }\n\n if (clauses.length > 0) {\n const result = await sql.execute({\n sql: `DELETE FROM ${escapeSqlIdentifier(table)} WHERE ${\n clauses.join(\" OR \")\n }`,\n args,\n });\n return { removed: result.rowsAffected ?? 0 };\n }\n }\n\n const filters = normalizeFilterMap(\n body.where ?? body.filters ?? body.lnrmv ?? body.remove,\n );\n const whereClause = buildWhereFromObject(filters, allowedFields);\n if (!whereClause) return { removed: 0, reason: \"no valid filters supplied\" };\n\n const result = await sql.execute({\n sql: `DELETE FROM ${escapeSqlIdentifier(table)} WHERE ${whereClause.sql}`,\n args: whereClause.args,\n });\n return { removed: result.rowsAffected ?? 0 };\n}\n\nasync function addField(\n table: string,\n field: string,\n type = \"TEXT\",\n defaultValue: unknown = null,\n) {\n const sanitizedType = String(type || \"TEXT\").trim() || \"TEXT\";\n const defaultSql = defaultValue === null || defaultValue === undefined\n ? \"\"\n : ` DEFAULT ${\n typeof defaultValue === \"number\"\n ? defaultValue\n : `'${String(defaultValue).replaceAll(\"'\", \"''\")}'`\n }`;\n\n await sql.execute({\n sql: `ALTER TABLE ${escapeSqlIdentifier(table)} ADD COLUMN ${\n escapeSqlIdentifier(field)\n } ${sanitizedType}${defaultSql}`,\n });\n\n return { added: field, type: sanitizedType };\n}\n\nasync function renameField(table: string, fromField: string, toField: string) {\n await sql.execute({\n sql: `ALTER TABLE ${escapeSqlIdentifier(table)} RENAME COLUMN ${\n escapeSqlIdentifier(fromField)\n } TO ${escapeSqlIdentifier(toField)}`,\n });\n return { renamed: fromField, to: toField };\n}\n\nasync function rebuildTableWithoutField(table: string, removeField: string) {\n const schema = await readSchema(table);\n const remaining = schema.columns.filter((column) =>\n String(column.name) !== removeField\n );\n if (remaining.length === schema.columns.length) {\n return { removed: 0, reason: \"field not found\" };\n }\n\n const tempTable = `${table}__rebuild_tmp_${Date.now()}`;\n const columnDefs = remaining.map((column) => {\n const pieces = [\n escapeSqlIdentifier(String(column.name)),\n column.type ? String(column.type) : \"TEXT\",\n ];\n\n if (Number(column.notnull) === 1) pieces.push(\"NOT NULL\");\n if (column.dflt_value !== null && column.dflt_value !== undefined) {\n const raw = typeof column.dflt_value === \"number\"\n ? String(column.dflt_value)\n : String(column.dflt_value);\n pieces.push(`DEFAULT ${raw}`);\n }\n if (Number(column.pk) > 0) pieces.push(\"PRIMARY KEY\");\n return pieces.join(\" \");\n });\n\n const columnNames = remaining.map((column) =>\n escapeSqlIdentifier(String(column.name))\n );\n const copyColumns = columnNames.join(\", \");\n\n await sql.batch(\n [\n {\n sql: `CREATE TABLE ${escapeSqlIdentifier(tempTable)} (${\n columnDefs.join(\", \")\n })`,\n args: [],\n },\n {\n sql: `INSERT INTO ${\n escapeSqlIdentifier(tempTable)\n } (${copyColumns}) SELECT ${copyColumns} FROM ${\n escapeSqlIdentifier(table)\n }`,\n args: [],\n },\n {\n sql: `DROP TABLE ${escapeSqlIdentifier(table)}`,\n args: [],\n },\n {\n sql: `ALTER TABLE ${escapeSqlIdentifier(tempTable)} RENAME TO ${\n escapeSqlIdentifier(table)\n }`,\n args: [],\n },\n ],\n \"write\",\n );\n\n return { removed: 1, rebuilt: true };\n}\n\nasync function removeField(table: string, field: string) {\n try {\n await sql.execute({\n sql: `ALTER TABLE ${escapeSqlIdentifier(table)} DROP COLUMN ${\n escapeSqlIdentifier(field)\n }`,\n });\n return { removed: 1, mode: \"native\" };\n } catch {\n return await rebuildTableWithoutField(table, field);\n }\n}\n\nasync function handleIndexUpdate(body: JsonObject) {\n const rawIds = [\n body.ids,\n body.animeIds,\n body.selection,\n body.rows,\n body.items,\n body.records,\n ];\n\n const ids = [\n ...new Set(\n rawIds.flatMap((value) => {\n if (Array.isArray(value)) {\n return value.flatMap((item) => {\n if (isPlainObject(item)) {\n const candidate = item.id ?? item.anime_id ?? item.animeId ??\n item.target_id;\n const trimmed = String(candidate ?? \"\").trim();\n return trimmed ? [trimmed] : [];\n }\n const trimmed = String(item ?? \"\").trim();\n return trimmed ? [trimmed] : [];\n });\n }\n if (isPlainObject(value)) {\n return Object.keys(value).map((item) => String(item).trim()).filter(\n Boolean,\n );\n }\n return [];\n }).filter(Boolean),\n ),\n ];\n\n if (!ids.length) {\n return {\n status: \"failed\",\n error: \"no anime ids supplied for index update\",\n };\n }\n\n const animeRows = await fetchRowsByAnimeIds(ids);\n const connectorRows = await fetchConnectorRowsByAnimeIds(ids);\n\n if (connectorRows.length === 0) {\n return {\n status: \"ok\",\n requested_ids: ids.length,\n updated_pairs: 0,\n skipped_pairs: 0,\n missing: [],\n note: \"no connector rows matched the selected anime ids\",\n };\n }\n\n const intIds = [\n ...new Set(\n connectorRows.map((row) => Math.trunc(Number(row.int_id))).filter((\n value,\n ) => Number.isFinite(value)),\n ),\n ];\n const episodeRows = await fetchRowsByIntIds(intIds);\n\n const updatedRows: Row[] = [];\n const missing: Array<{ int_id: number; id: string; reason: string }> = [];\n\n for (const connectorRow of connectorRows) {\n const intId = Math.trunc(Number(connectorRow.int_id));\n const id = String(connectorRow.id ?? \"\").trim();\n if (!Number.isFinite(intId) || !id) continue;\n\n const episode = episodeRows.get(intId);\n const anime = animeRows.get(id);\n\n if (!episode || !anime) {\n missing.push({\n int_id: intId,\n id,\n reason: !episode && !anime\n ? \"missing source and target rows\"\n : !episode\n ? \"missing source row\"\n : \"missing target row\",\n });\n continue;\n }\n\n const password = anime.password == null ? \"\" : String(anime.password);\n const sha = await sha256Hex(password);\n\n updatedRows.push({\n int_id: intId,\n id,\n title: anime.title ?? null,\n season: episode.season ?? null,\n episode: episode.episode ?? null,\n stream: episode.link ?? null,\n sha,\n });\n }\n\n const writeResult = await upsertConnectorRows(updatedRows);\n const refreshed = await refreshCacheFromSql(INTEGRATION.bridgeTable);\n\n return {\n status: \"ok\",\n requested_ids: ids.length,\n requested_connections: connectorRows.length,\n written_pairs: writeResult.inserted,\n skipped_pairs: missing.length,\n missing,\n refreshed: {\n rows: refreshed.rows,\n manifest: refreshed.manifest,\n },\n };\n}\n\nasync function handleTableAdmin(body: JsonObject) {\n const action = String(body.action ?? body.op ?? \"\").trim().toLowerCase();\n const table = String(body.table ?? \"\").trim();\n\n if (action === \"index-update\") {\n if (table && table !== INTEGRATION.targetTable) {\n return {\n ok: false,\n error: `index update is wired for ${INTEGRATION.targetTable}`,\n };\n }\n try {\n const result = await handleIndexUpdate(body);\n return {\n ok: result.status === \"ok\",\n table: INTEGRATION.targetTable,\n action,\n result,\n refreshed: result.status === \"ok\" ? result.refreshed : null,\n };\n } catch (error) {\n return {\n ok: false,\n error: error instanceof Error ? error.message : String(error),\n };\n }\n }\n\n if (!table || !isAllowedTable(table)) {\n return { ok: false, error: \"invalid or unsupported table\" };\n }\n\n try {\n let result: Record | null = null;\n let refreshed: { rows: number; manifest: CachedTableManifest } | null =\n null;\n\n if (\n action === \"insert-row\" || action === \"insert\" ||\n action === \"create-row\" || action === \"add-row\"\n ) {\n const rows = Array.isArray(body.rows)\n ? body.rows.filter(isPlainObject)\n : isPlainObject(body.row)\n ? [body.row]\n : [];\n result = await insertRows(table, rows);\n } else if (\n action === \"update-row\" || action === \"update\" || action === \"edit-row\"\n ) {\n const patch = isPlainObject(body.patch)\n ? body.patch\n : isPlainObject(body.row)\n ? body.row\n : {};\n const where = isPlainObject(body.where)\n ? body.where\n : isPlainObject(body.keys)\n ? body.keys\n : null;\n result = await updateRows(table, where, patch);\n } else if (\n action === \"delete-rows\" || action === \"delete\" ||\n action === \"remove-rows\" || action === \"remove\"\n ) {\n result = await deleteRows(table, body);\n } else if (action === \"add-field\" || action === \"field-add\") {\n const field = String(body.field ?? body.name ?? \"\").trim();\n if (!field) return { ok: false, error: \"field name is required\" };\n result = await addField(\n table,\n field,\n String(body.type ?? \"TEXT\"),\n body.defaultValue ?? null,\n );\n } else if (action === \"rename-field\" || action === \"field-rename\") {\n const from = String(body.from ?? body.field ?? \"\").trim();\n const to = String(body.to ?? body.newField ?? body.renameTo ?? \"\").trim();\n if (!from || !to) {\n return {\n ok: false,\n error: \"both from and to field names are required\",\n };\n }\n result = await renameField(table, from, to);\n } else if (\n action === \"remove-field\" || action === \"field-remove\" ||\n action === \"drop-field\"\n ) {\n const field = String(body.field ?? body.name ?? \"\").trim();\n if (!field) return { ok: false, error: \"field name is required\" };\n result = await removeField(table, field);\n } else if (action === \"refresh-cache\") {\n refreshed = await refreshCacheFromSql(table);\n return {\n ok: true,\n table,\n action,\n result: {\n rows: refreshed.rows,\n manifest: refreshed.manifest,\n },\n refreshed,\n };\n } else {\n return { ok: false, error: \"invalid action\" };\n }\n\n refreshed = await refreshCacheFromSql(table);\n return {\n ok: true,\n table,\n action,\n result,\n refreshed: {\n rows: refreshed.rows,\n manifest: refreshed.manifest,\n },\n };\n } catch (error) {\n return {\n ok: false,\n table,\n action,\n error: error instanceof Error ? error.message : String(error),\n };\n }\n}\nexport default async function handler(req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/+$/, \"\") || \"/\";\n\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: CORS_HEADERS });\n }\n\n if (req.method === \"GET\" && path === \"/\") {\n return jsonResponse({\n ok: true,\n api: APP_NAME,\n message: HEALTH_MESSAGE,\n routes: [\n \"GET /\",\n \"GET /ignite-engine\",\n \"POST /bootroot-data\",\n \"POST /integrate-sqldata\",\n \"POST /table-admin\",\n ],\n });\n }\n\n if (req.method === \"GET\" && path === \"/ignite-engine\") {\n try {\n return jsonResponse(await handleIgniteEngine(url));\n } catch (error) {\n return jsonResponse({\n ok: false,\n error: error instanceof Error ? error.message : String(error),\n }, 500);\n }\n }\n\n if (req.method !== \"POST\") {\n return jsonResponse({ ok: false, error: \"method not allowed\" }, 405);\n }\n\n const body = await readJson(req);\n const commands = normalizeCommands(body);\n\n if (path === \"/bootroot-data\") {\n const results: Array> = [];\n\n for (const command of commands) {\n try {\n const restoreTables = parseTableList(command.restore);\n const deleteTables = parseTableList(command.delete);\n const executeResult =\n command.execute || command.provider || command.lnrmv\n ? await handleExecuteCommand(command)\n : null;\n\n if (restoreTables.length) {\n results.push({\n action: \"restore\",\n tables: restoreTables,\n results: await handleRestoreTables(restoreTables),\n });\n }\n\n if (deleteTables.length) {\n results.push({\n action: \"delete\",\n tables: deleteTables,\n results: await handleDeleteTables(deleteTables),\n });\n }\n\n if (executeResult) {\n results.push({\n action: \"execute\",\n result: executeResult,\n });\n }\n\n if (!restoreTables.length && !deleteTables.length && !executeResult) {\n results.push({\n action: \"noop\",\n status: \"ignored\",\n note: \"no recognized instruction found\",\n });\n }\n } catch (error) {\n results.push({\n action: \"error\",\n error: error instanceof Error ? error.message : String(error),\n });\n }\n }\n\n return jsonResponse({\n ok: true,\n endpoint: path,\n results,\n });\n }\n\n if (path === \"/integrate-sqldata\") {\n const payload = commands[0] ?? (isPlainObject(body) ? body : {});\n try {\n const result = await handleIntegrateSqlData(payload);\n return jsonResponse(\n {\n ok: result.status === \"ok\",\n endpoint: path,\n result,\n },\n result.status === \"ok\" ? 200 : 400,\n );\n } catch (error) {\n return jsonResponse(\n {\n ok: false,\n endpoint: path,\n error: error instanceof Error ? error.message : String(error),\n },\n 500,\n );\n }\n }\n\n if (path === \"/table-admin\") {\n const payload = commands[0] ?? (isPlainObject(body) ? body : {});\n try {\n return jsonResponse(await handleTableAdmin(payload));\n } catch (error) {\n return jsonResponse({\n ok: false,\n error: error instanceof Error ? error.message : String(error),\n }, 500);\n }\n }\n\n return jsonResponse({\n ok: false,\n error: \"not found\",\n path,\n }, 404);\n}","createdAt",["D",1783964455507],"branchVersion","branchId","be9a3c7e-6537-466c-a008-fb2f5fb80bba","id","8d4756f5-19a1-49b6-a7d2-fafaf13094d0","Admin-API",["D",1781113739528],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","019d34f5-a118-71aa-86be-a3b05ce7b06e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019d34f5-a118-71aa-86be-a6dc6eeabba9","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_102":98},"org",{"_95":94,"_96":-5,"_97":98,"_18":55,"_99":100,"_101":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",36,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","lupinarashi","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzNCWndldUNFUURoY3B1Uzk1d2lQOVhDTE8xaCJ9","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":163,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":164,"_79":165,"_81":166,"_83":25},"tree",[154,155],"files",[154,155],"counts",{"_143":61,"_144":145,"_146":61,"_147":148,"_149":150},"contents",[125,126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":139,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_132":25,"_38":140,"_13":141,"_33":34,"_35":37,"_24":25,"_137":-5,"_27":142},{"_43":127,"_32":128,"_30":129,"_130":-5,"_41":42,"_40":131,"_132":25,"_38":133,"_13":134,"_33":135,"_35":136,"_24":25,"_137":-5,"_27":138},"0a62ba22-18f8-4dcd-bbc2-2580ca8e4609","customize.js","a903be66-64f4-11f1-8eb9-1607ee4eb77e","parentId",21,"latest",["D",1781895620168],11,"script","export const APP_NAME = \"Anime Database Admin API\";\n\nexport const HEALTH_MESSAGE = \"use neon,s admin panel to access this API\";\n\n// Fill these directly in the file. No environment variables are used.\nexport const TURSO = {\n url: \"https://neon-anime-db-lupinarashi.aws-ap-south-1.turso.io\",\n authToken:\n \"eyJhbGciOiJFZERTQSIsInR5cCI6IkpXVCJ9.eyJhIjoicnciLCJpYXQiOjE3NzIzNTg3NTEsImlkIjoiZGY1MzQ0OWEtZmNlNi00YzIwLTlhNWMtODdlY2JkZjZkNjA0IiwicmlkIjoiODcwYzBmZDUtNWM4Ny00MGYwLWFhZTYtYTE0YTUyZmEwZDk1In0.hHOmuljVz91S7bveKE02E_6-lsGAt0dU1VNTgfw9cyJhBvJGu6oa8O8nz8Af5-qqqWy_PAL-3lsJopEopPhEAw\",\n};\n\nexport const UPSTASH = {\n url: \"https://magical-giraffe-89191.upstash.io\",\n token:\n \"gQAAAAAAAVxnAAIncDJmY2MwNTdiZDAyNDQ0OTY3ODhkMjJjMWFkNDlkZGExMnAyODkxOTE\",\n};\n\nexport const KV_PREFIX = \"anime_admin\";\n\nexport const ALLOWED_TABLES = [\n \"anime_info\",\n \"cdn_extracted\",\n \"neonsprivatedata\",\n];\n\nexport const TABLE_FIELDS = {\n anime_info: [\n \"id\",\n \"type\",\n \"title\",\n \"title_japanese\",\n \"title_synonyms\",\n \"mal_id\",\n \"year\",\n \"season\",\n \"studio\",\n \"studios\",\n \"audio\",\n \"dubbed_languages\",\n \"duration\",\n \"episodes\",\n \"tags\",\n \"age_rating\",\n \"total_seasons\",\n \"airing_date\",\n \"ended_date\",\n \"airing_status\",\n \"image_url\",\n \"overview\",\n \"producers\",\n \"licensors\",\n \"themes\",\n \"demographics\",\n \"trailer\",\n \"source\",\n \"popularity\",\n \"rating\",\n \"scored_by\",\n \"favorites\",\n \"created_at\",\n \"updated_at\",\n \"aired_from_full\",\n \"aired_to_full\",\n \"broadcast\",\n \"background\",\n \"password\",\n ],\n cdn_extracted: [\"int_id\", \"title\", \"season\", \"episode\", \"link\"],\n neonsprivatedata: [\n \"int_id\",\n \"id\",\n \"title\",\n \"season\",\n \"episode\",\n \"stream\",\n \"sha\",\n ],\n};\n\nexport const INTEGRATION = {\n sourceTable: \"cdn_extracted\",\n targetTable: \"anime_info\",\n bridgeTable: \"neonsprivatedata\",\n sourceKey: \"int_id\",\n targetKey: \"id\",\n};","label",[128],"800ea3ad-b6c2-42db-ac11-b15171c02412",["D",1783964455507],10,[28],"pulls","branches",1,"forks","envVars",{"_151":61,"_153":61},"connections",{"_151":61,"_152":61},"count","unfilledCount","emptyCount",{"_43":139,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_132":25,"_38":160,"_13":141,"_33":34,"_35":37,"_24":25,"_137":-5,"_157":161,"_27":162},{"_43":127,"_32":128,"_30":129,"_130":-5,"_41":42,"_40":131,"_132":25,"_38":156,"_13":134,"_33":135,"_35":136,"_24":25,"_137":-5,"_157":158,"_27":159},["D",1781895620168],"children",[],[128],["D",1783964455507],[],[28],["D",1781113739528],{"_95":94,"_102":98},{"_95":94,"_96":-5,"_97":98,"_18":55,"_99":100,"_101":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_122":200,"_201":202,"_203":204,"_205":25,"_206":25,"_207":25,"_208":120,"_209":-5,"_210":-7,"_211":-7,"_212":61,"_213":25,"_214":25,"_215":-5,"_216":25,"_217":25,"_218":25,"_219":-5},"ENV",{"_171":172,"_173":174,"_175":85,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v23