[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_166":167,"_168":169},"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",18,"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","customize.js","latestPath","fileId","a903be66-64f4-11f1-8eb9-1607ee4eb77e","name","fileType","script","content","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 \"connector\",\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 connector: [\"int_id\", \"id\", \"title\", \"season\", \"episode\", \"stream\", \"sha\"],\n};\n\nexport const INTEGRATION = {\n sourceTable: \"cdn_extracted\",\n targetTable: \"anime_info\",\n bridgeTable: \"connector\",\n sourceKey: \"int_id\",\n targetKey: \"id\",\n};","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 connector: [\"int_id\", \"id\", \"title\", \"season\", \"episode\", \"stream\", \"sha\"],\n};\n\nexport const INTEGRATION = {\n sourceTable: \"cdn_extracted\",\n targetTable: \"anime_info\",\n bridgeTable: \"connector\",\n sourceKey: \"int_id\",\n targetKey: \"id\",\n};","createdAt",["D",1781895327713],"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":162,"_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":163,"_79":164,"_81":165,"_83":25},"tree",[153,154],"files",[153,154],"counts",{"_142":61,"_143":144,"_145":61,"_146":147,"_148":149},"contents",[125,126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":134,"_32":135,"_30":136,"_128":-5,"_41":42,"_40":137,"_129":25,"_38":138,"_13":131,"_33":139,"_35":140,"_24":25,"_132":-5,"_27":141},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":130,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_27":133},"b6dd0018-0dcd-45db-900e-7efd38ccee00","parentId","latest",["D",1781895327713],8,"label",[28],"22aae817-16f8-4109-b312-dfe65732617d","Ruler-Hand.ts","d32af79a-64f4-11f1-941a-1607ee4eb77e",17,["D",1781592591062],"http","const CORS_HEADERS = {\n \"access-control-allow-origin\": \"*\",\n \"access-control-allow-methods\": \"GET,POST,OPTIONS\",\n \"access-control-allow-headers\": \"content-type\",\n \"access-control-max-age\": \"86400\",\n};\n\nimport { createClient } from \"npm:@libsql/client/web\";\nimport { Redis } from \"npm:@upstash/redis\";\nimport {\n ALLOWED_TABLES,\n APP_NAME,\n HEALTH_MESSAGE,\n INTEGRATION,\n KV_PREFIX,\n TABLE_FIELDS,\n TURSO,\n UPSTASH,\n} from \"./customize.js\";\n\nconst trace = (...args: unknown[]) => console.log(\"[Ruler-Hand]\", ...args);\n\ntype JsonPrimitive = string | number | boolean | null;\ntype JsonValue = JsonPrimitive | JsonValue[] | { [key: string]: JsonValue };\ntype JsonObject = Record;\ntype Row = Record;\ntype SchemaColumn = {\n cid: number;\n name: string;\n type: string | null;\n notnull: number;\n dflt_value: unknown;\n pk: number;\n};\n\nconst sql = createClient({\n url: TURSO.url,\n authToken: TURSO.authToken,\n});\n\nconst redis = new Redis({\n url: UPSTASH.url,\n token: UPSTASH.token,\n});\n\nconst ALLOWED_TABLE_SET = new Set(ALLOWED_TABLES);\n\nconst MAX_UPSTASH_CHUNK_BYTES = 9_000_000;\nconst CHUNK_KEY_SUFFIX = \"part\";\nconst CHUNK_MANIFEST_KIND = \"chunked-table\";\nconst CHUNK_MANIFEST_VERSION = 2;\n\ntype CachedTableManifest = {\n kind: typeof CHUNK_MANIFEST_KIND;\n version: typeof CHUNK_MANIFEST_VERSION;\n table: string;\n chunkCount: number;\n totalRows: number;\n totalBytes: number;\n createdAt: string;\n};\n\nfunction isPlainObject(value: unknown): value is JsonObject {\n return typeof value === \"object\" && value !== null && !Array.isArray(value);\n}\n\nfunction toTableKey(table: string): string {\n return `${KV_PREFIX}:${table}`;\n}\n\nfunction getManifestKey(table: string): string {\n return toTableKey(table);\n}\n\nfunction getChunkKey(table: string, index: number): string {\n return `${toTableKey(table)}:${CHUNK_KEY_SUFFIX}:${index}`;\n}\n\nfunction escapeSqlIdentifier(identifier: string): string {\n return `\"${String(identifier).replaceAll('\"', '\"\"')}\"`;\n}\n\nfunction normalizePrimitive(value: unknown): JsonPrimitive {\n if (value === null || value === undefined) return null;\n if (typeof value === \"string\") return value.trim();\n if (typeof value === \"number\" || typeof value === \"boolean\") return value;\n if (typeof value === \"bigint\") return Number(value);\n return String(value).trim();\n}\n\nfunction flattenValues(value: unknown): Array {\n if (Array.isArray(value)) return value.flatMap(flattenValues);\n if (value === null || value === undefined) return [];\n if (typeof value === \"string\") {\n const pieces = value\n .split(\",\")\n .map((part) => part.trim())\n .filter(Boolean);\n return pieces.length > 1 ? pieces : [value.trim()];\n }\n\n const primitive = normalizePrimitive(value);\n return primitive === null ? [] : [primitive as string | number | boolean];\n}\n\nfunction uniqueStrings(values: Array): string[] {\n return [\n ...new Set(values.map((value) => String(value).trim()).filter(Boolean)),\n ];\n}\n\nfunction uniqueNumbers(values: Array): number[] {\n const out = new Set();\n for (const value of values) {\n const n = Number(value);\n if (Number.isFinite(n)) out.add(Math.trunc(n));\n }\n return [...out];\n}\n\nfunction splitIntoChunks(items: T[], size: number): T[][] {\n const chunkSize = Math.max(1, Math.trunc(size));\n const chunks: T[][] = [];\n for (let i = 0; i < items.length; i += chunkSize) {\n chunks.push(items.slice(i, i + chunkSize));\n }\n return chunks;\n}\n\nfunction utf8ByteLength(value: string): number {\n return new TextEncoder().encode(value).byteLength;\n}\n\nfunction isAllowedTable(table: string): table is string {\n return ALLOWED_TABLE_SET.has(table);\n}\n\nfunction getAllowedFields(table: string): string[] {\n const fields = (TABLE_FIELDS as Record)[table];\n return Array.isArray(fields) ? fields : [];\n}\n\nfunction getTableKeyFields(table: string, schema?: SchemaColumn[]): string[] {\n if (schema?.length) {\n const pkFields = schema.filter((column) => column.pk > 0).sort((a, b) =>\n a.pk - b.pk\n ).map((column) => column.name);\n if (pkFields.length) return pkFields;\n }\n\n const allowed = getAllowedFields(table);\n if (allowed.includes(\"id\") && allowed.includes(\"int_id\")) {\n return [\"int_id\", \"id\"];\n }\n if (allowed.includes(\"id\")) return [\"id\"];\n if (allowed.includes(\"int_id\")) return [\"int_id\"];\n return allowed[0] ? [allowed[0]] : [];\n}\n\nfunction rowKeyFromFields(row: Row, fields: string[]): string {\n return fields.map((field) => String(row[field] ?? \"\").trim()).join(\"::\");\n}\n\nfunction rowMatchesFilters(\n row: Row,\n filters: Record>,\n): boolean {\n const entries = Object.entries(filters);\n if (entries.length === 0) return false;\n return entries.every(([field, allowedValues]) => {\n const current = row[field];\n if (current === undefined || current === null) return false;\n const currentNormalized = String(current).trim();\n return allowedValues.some((candidate) =>\n String(candidate).trim() === currentNormalized\n );\n });\n}\n\nfunction normalizeFilterMap(\n value: unknown,\n): Record> {\n if (!isPlainObject(value)) return {};\n const out: Record> = {};\n for (const [field, raw] of Object.entries(value)) {\n const normalized = flattenValues(raw);\n if (normalized.length > 0) out[field] = normalized;\n }\n return out;\n}\n\nasync function readJson(req: Request): Promise {\n const contentType = req.headers.get(\"content-type\") ?? \"\";\n trace(\"readJson:start\", { contentType });\n\n if (!contentType.toLowerCase().includes(\"application/json\")) {\n const text = await req.text();\n if (!text.trim()) return null;\n try {\n return JSON.parse(text);\n } catch {\n return null;\n }\n }\n\n try {\n return await req.json();\n } catch {\n return null;\n }\n}\n\nfunction jsonResponse(payload: unknown, status = 200): Response {\n return new Response(JSON.stringify(payload, null, 2), {\n status,\n headers: {\n ...CORS_HEADERS,\n \"content-type\": \"application/json; charset=utf-8\",\n \"cache-control\": \"no-store\",\n },\n });\n}\n\nasync function sha256Hex(input: string): Promise {\n const bytes = new TextEncoder().encode(input);\n const hash = await crypto.subtle.digest(\"SHA-256\", bytes);\n return [...new Uint8Array(hash)].map((b) => b.toString(16).padStart(2, \"0\"))\n .join(\"\");\n}\n\nfunction isCachedTableManifest(value: unknown): value is CachedTableManifest {\n return (\n isPlainObject(value) &&\n value.kind === CHUNK_MANIFEST_KIND &&\n value.version === CHUNK_MANIFEST_VERSION &&\n typeof value.table === \"string\" &&\n typeof value.chunkCount === \"number\" &&\n typeof value.totalRows === \"number\" &&\n typeof value.totalBytes === \"number\" &&\n typeof value.createdAt === \"string\"\n );\n}\nfunction parseStoredValue(value: unknown): unknown {\n if (typeof value !== \"string\") return value;\n\n const text = value.trim();\n if (!text) return value;\n\n try {\n return JSON.parse(text);\n } catch {\n return value;\n }\n}\n\nfunction normalizeStoredRows(value: unknown): Row[] {\n const parsed = parseStoredValue(value);\n\n if (Array.isArray(parsed)) return parsed as Row[];\n\n if (isPlainObject(parsed)) {\n if (Array.isArray((parsed as any).rows)) {\n return (parsed as any).rows as Row[];\n }\n if (Array.isArray((parsed as any).data)) {\n return (parsed as any).data as Row[];\n }\n if (Array.isArray((parsed as any).items)) {\n return (parsed as any).items as Row[];\n }\n }\n\n return [];\n}\nfunction normalizeStoredManifest(value: unknown): CachedTableManifest | null {\n const parsed = parseStoredValue(value);\n return isCachedTableManifest(parsed) ? parsed : null;\n}\nasync function selectAllRows(table: string): Promise {\n const result = await sql.execute({\n sql: `SELECT * FROM ${escapeSqlIdentifier(table)}`,\n });\n return (result.rows ?? []) as Row[];\n}\n\nasync function readSchema(\n table: string,\n): Promise<{ columns: SchemaColumn[]; primaryKeyFields: string[] }> {\n const result = await sql.execute({\n sql: `PRAGMA table_info(${escapeSqlIdentifier(table)})`,\n });\n\n const columns = (result.rows ?? []) as SchemaColumn[];\n const primaryKeyFields = columns\n .filter((column) => Number(column.pk) > 0)\n .sort((a, b) => Number(a.pk) - Number(b.pk))\n .map((column) => String(column.name));\n\n return { columns, primaryKeyFields };\n}\n\nfunction splitRowsByByteSize(\n rows: Row[],\n maxBytes = MAX_UPSTASH_CHUNK_BYTES,\n): Row[][] {\n const chunks: Row[][] = [];\n let current: Row[] = [];\n let currentBytes = 2;\n\n for (const row of rows) {\n const rowBytes = utf8ByteLength(JSON.stringify(row));\n const nextBytes = current.length === 0\n ? 2 + rowBytes\n : currentBytes + 1 + rowBytes;\n\n if (nextBytes <= maxBytes || current.length === 0) {\n current.push(row);\n currentBytes = nextBytes;\n continue;\n }\n\n chunks.push(current);\n current = [row];\n currentBytes = 2 + rowBytes;\n }\n\n if (current.length > 0) chunks.push(current);\n return chunks;\n}\n\nasync function readLegacyOrManifest(table: string): Promise<\n | { kind: \"legacy\"; rows: Row[] }\n | { kind: \"manifest\"; manifest: CachedTableManifest }\n | { kind: \"missing\" }\n> {\n const raw = await redis.get(getManifestKey(table));\n\n const rows = normalizeStoredRows(raw);\n if (rows.length) return { kind: \"legacy\", rows };\n\n const manifest = normalizeStoredManifest(raw);\n if (manifest) return { kind: \"manifest\", manifest };\n\n return { kind: \"missing\" };\n}\n\nasync function loadChunkedTable(\n table: string,\n manifest: CachedTableManifest,\n): Promise {\n const chunkCount = Math.max(0, Math.trunc(manifest.chunkCount));\n if (chunkCount === 0) return [];\n\n const chunkKeys = Array.from(\n { length: chunkCount },\n (_, index) => getChunkKey(table, index),\n );\n const chunks = await Promise.all(\n chunkKeys.map(async (key) => normalizeStoredRows(await redis.get(key))),\n );\n\n return chunks.flat();\n}\n\nasync function loadChunk(table: string, index: number): Promise {\n return normalizeStoredRows(await redis.get(getChunkKey(table, index)));\n}\nasync function deleteChunkedTableArtifacts(\n table: string,\n manifest: CachedTableManifest | null,\n): Promise {\n const manifestKey = getManifestKey(table);\n if (!manifest) {\n await redis.del(manifestKey);\n return;\n }\n\n const chunkKeys = Array.from({\n length: Math.max(0, Math.trunc(manifest.chunkCount)),\n }, (_, index) => getChunkKey(table, index));\n\n for (const key of chunkKeys) {\n await redis.del(key);\n }\n await redis.del(manifestKey);\n}\n\nasync function deleteCachedTable(table: string): Promise {\n const storage = await readLegacyOrManifest(table);\n if (storage.kind === \"manifest\") {\n await deleteChunkedTableArtifacts(table, storage.manifest);\n return;\n }\n\n await redis.del(getManifestKey(table));\n}\n\nasync function saveCachedTable(\n table: string,\n rows: Row[],\n): Promise {\n const previous = await readLegacyOrManifest(table);\n const chunks = splitRowsByByteSize(rows);\n const chunkBytes = chunks.map((chunk) =>\n utf8ByteLength(JSON.stringify(chunk))\n );\n\n const manifest: CachedTableManifest = {\n kind: CHUNK_MANIFEST_KIND,\n version: CHUNK_MANIFEST_VERSION,\n table,\n chunkCount: chunks.length,\n totalRows: rows.length,\n totalBytes: chunkBytes.reduce((sum, value) => sum + value, 0),\n createdAt: new Date().toISOString(),\n };\n\n const pipeline = redis.pipeline();\n\n for (const [index, chunk] of chunks.entries()) {\n pipeline.set(getChunkKey(table, index), chunk);\n }\n\n pipeline.set(getManifestKey(table), manifest);\n\n if (\n previous.kind === \"manifest\" && previous.manifest.chunkCount > chunks.length\n ) {\n for (\n let index = chunks.length;\n index < previous.manifest.chunkCount;\n index += 1\n ) {\n pipeline.del(getChunkKey(table, index));\n }\n }\n\n await pipeline.exec();\n return manifest;\n}\nasync function loadCachedTable(table: string): Promise {\n const storage = await readLegacyOrManifest(table);\n\n if (storage.kind === \"legacy\") return storage.rows;\n if (storage.kind === \"manifest\") {\n return await loadChunkedTable(table, storage.manifest);\n }\n return [];\n}\n\nasync function refreshCacheFromSql(\n table: string,\n): Promise<{ rows: number; manifest: CachedTableManifest }> {\n const rows = await selectAllRows(table);\n const manifest = await saveCachedTable(table, rows);\n return { rows: rows.length, manifest };\n}\n\nasync function handleIgniteEngine(url: URL) {\n const table = String(url.searchParams.get(\"table\") ?? \"\").trim();\n const partRaw = url.searchParams.get(\"part\");\n const part = partRaw === null || partRaw === \"\" ? null : Number(partRaw);\n\n if (table) {\n if (!isAllowedTable(table)) {\n return { ok: false, error: \"invalid table requested\" };\n }\n\n const schema = await readSchema(table);\n let storage = await readLegacyOrManifest(table);\n\n // Self-heal when the cache key is missing.\n if (storage.kind === \"missing\") {\n await refreshCacheFromSql(table);\n storage = await readLegacyOrManifest(table);\n }\n\n if (part !== null && Number.isFinite(part)) {\n let rows = storage.kind === \"manifest\"\n ? await loadChunk(table, Math.max(0, Math.trunc(part)))\n : storage.kind === \"legacy\" && Math.trunc(part) === 0\n ? storage.rows\n : [];\n\n // If chunks exist in the manifest but the chunk is missing/stale, rebuild once.\n if (\n rows.length === 0 && storage.kind === \"manifest\" &&\n storage.manifest.totalRows > 0\n ) {\n await refreshCacheFromSql(table);\n storage = await readLegacyOrManifest(table);\n rows = storage.kind === \"manifest\"\n ? await loadChunk(table, Math.max(0, Math.trunc(part)))\n : storage.kind === \"legacy\" && Math.trunc(part) === 0\n ? storage.rows\n : [];\n }\n\n const manifest = storage.kind === \"manifest\" ? storage.manifest : {\n kind: CHUNK_MANIFEST_KIND,\n version: CHUNK_MANIFEST_VERSION,\n table,\n chunkCount: storage.kind === \"legacy\" ? 1 : 0,\n totalRows: storage.kind === \"legacy\" ? storage.rows.length : 0,\n totalBytes: storage.kind === \"legacy\"\n ? utf8ByteLength(JSON.stringify(storage.rows))\n : 0,\n createdAt: new Date().toISOString(),\n };\n\n return {\n ok: true,\n source: \"upstash\",\n table,\n part: Math.max(0, Math.trunc(part)),\n schema,\n manifest,\n rows,\n };\n }\n\n const manifest = storage.kind === \"manifest\" ? storage.manifest : {\n kind: CHUNK_MANIFEST_KIND,\n version: CHUNK_MANIFEST_VERSION,\n table,\n chunkCount: storage.kind === \"legacy\" ? 1 : 0,\n totalRows: storage.kind === \"legacy\" ? storage.rows.length : 0,\n totalBytes: storage.kind === \"legacy\"\n ? utf8ByteLength(JSON.stringify(storage.rows))\n : 0,\n createdAt: new Date().toISOString(),\n };\n\n return {\n ok: true,\n source: \"upstash\",\n table,\n schema,\n manifest,\n columns: schema.columns.map((column) => column.name),\n keyFields: schema.primaryKeyFields.length\n ? schema.primaryKeyFields\n : getTableKeyFields(table, schema.columns),\n };\n }\n\n const tables = await Promise.all(\n ALLOWED_TABLES.map(async (name) => {\n const schema = await readSchema(name);\n let storage = await readLegacyOrManifest(name);\n\n if (storage.kind === \"missing\") {\n await refreshCacheFromSql(name);\n storage = await readLegacyOrManifest(name);\n }\n\n const manifest = storage.kind === \"manifest\" ? storage.manifest : {\n kind: CHUNK_MANIFEST_KIND,\n version: CHUNK_MANIFEST_VERSION,\n table: name,\n chunkCount: storage.kind === \"legacy\" ? 1 : 0,\n totalRows: storage.kind === \"legacy\" ? storage.rows.length : 0,\n totalBytes: storage.kind === \"legacy\"\n ? utf8ByteLength(JSON.stringify(storage.rows))\n : 0,\n createdAt: new Date().toISOString(),\n };\n\n return [\n name,\n {\n schema,\n manifest,\n columns: schema.columns.map((column) => column.name),\n keyFields: schema.primaryKeyFields.length\n ? schema.primaryKeyFields\n : getTableKeyFields(name, schema.columns),\n },\n ] as const;\n }),\n );\n\n return {\n ok: true,\n source: \"upstash\",\n tables: Object.fromEntries(tables),\n };\n}\nfunction parseTableList(value: unknown): string[] {\n return uniqueStrings(flattenValues(value)).filter((table) =>\n isAllowedTable(table)\n );\n}\n\nasync function handleRestoreTables(tables: string[]) {\n const results: Array> = [];\n\n for (const table of tables) {\n try {\n await deleteCachedTable(table);\n const rows = await selectAllRows(table);\n const manifest = await saveCachedTable(table, rows);\n results.push({\n table,\n status: \"restored\",\n sql_rows: rows.length,\n cache_rows: manifest.totalRows,\n kv_key: toTableKey(table),\n });\n } catch (error) {\n results.push({\n table,\n status: \"failed\",\n error: error instanceof Error ? error.message : String(error),\n });\n }\n }\n\n return results;\n}\n\nasync function handleDeleteTables(tables: string[]) {\n const results: Array> = [];\n\n for (const table of tables) {\n try {\n await deleteCachedTable(table);\n results.push({\n table,\n status: \"deleted\",\n kv_key: toTableKey(table),\n });\n } catch (error) {\n results.push({\n table,\n status: \"failed\",\n error: error instanceof Error ? error.message : String(error),\n });\n }\n }\n\n return results;\n}\n\nasync function executeKvRowRemoval(\n table: string,\n filters: Record>,\n) {\n const rows = await loadCachedTable(table);\n if (!rows.length) {\n return {\n table,\n status: \"empty\",\n removed: 0,\n kept: 0,\n };\n }\n\n const kept = rows.filter((row) => !rowMatchesFilters(row, filters));\n const removed = rows.length - kept.length;\n await saveCachedTable(table, kept);\n\n return {\n table,\n status: \"ok\",\n removed,\n kept: kept.length,\n key: toTableKey(table),\n };\n}\n\nasync function executeSqlRowRemoval(\n table: string,\n filters: Record>,\n) {\n const allowedFields = new Set(getAllowedFields(table));\n const fieldEntries = Object.entries(filters).filter(([field]) =>\n allowedFields.has(field)\n );\n\n if (fieldEntries.length === 0) {\n return {\n table,\n status: \"skipped\",\n reason: \"no valid fields supplied for this table\",\n };\n }\n\n const whereParts: string[] = [];\n const args: Array = [];\n\n for (const [field, values] of fieldEntries) {\n const unique = [\n ...new Set(\n values.map((v) => normalizePrimitive(v)).filter((\n v,\n ): v is string | number | boolean => v !== null),\n ),\n ];\n if (!unique.length) continue;\n const placeholders = unique.map(() => \"?\").join(\", \");\n whereParts.push(`${escapeSqlIdentifier(field)} IN (${placeholders})`);\n args.push(...unique);\n }\n\n if (!whereParts.length) {\n return {\n table,\n status: \"skipped\",\n reason: \"no valid values supplied\",\n };\n }\n\n const query = `DELETE FROM ${escapeSqlIdentifier(table)} WHERE ${\n whereParts.join(\" AND \")\n }`;\n const result = await sql.execute({ sql: query, args });\n\n if ((result.rowsAffected ?? 0) > 0) {\n const refreshed = await refreshCacheFromSql(table);\n return {\n table,\n status: \"ok\",\n removed: result.rowsAffected ?? 0,\n refreshed: {\n rows: refreshed.rows,\n manifest: refreshed.manifest,\n },\n };\n }\n\n return {\n table,\n status: \"ok\",\n removed: result.rowsAffected ?? 0,\n };\n}\nasync function handleExecuteCommand(body: JsonObject) {\n const provider = String(body.execute ?? body.provider ?? \"\").toUpperCase();\n const table = String(body.table ?? \"\").trim();\n const filters = normalizeFilterMap(\n body.lnrmv ?? body.remove ?? body.filters ?? body.where,\n );\n\n if (!table || !isAllowedTable(table)) {\n return {\n status: \"failed\",\n error: \"invalid or unsupported table\",\n };\n }\n\n if (provider === \"KV\") return await executeKvRowRemoval(table, filters);\n if (provider === \"SQL\") return await executeSqlRowRemoval(table, filters);\n\n return {\n status: \"failed\",\n error: \"execute must be KV or SQL\",\n };\n}\n\nfunction parseIntegrationPairs(\n body: JsonObject,\n): Array<{ int_id: number; id: string }> {\n const pairs: Array<{ int_id: number; id: string }> = [];\n\n const directArrays = [\n body.pairs,\n body.records,\n body.batch,\n body.items,\n body.connect,\n ];\n\n for (const source of directArrays) {\n if (!Array.isArray(source)) continue;\n for (const item of source) {\n if (Array.isArray(item) && item.length >= 2) {\n const intId = Number(item[0]);\n const id = String(item[1]).trim();\n if (Number.isFinite(intId) && id) {\n pairs.push({ int_id: Math.trunc(intId), id });\n }\n continue;\n }\n if (isPlainObject(item)) {\n const intIdValue = item.int_id ?? item.intId ?? item.source_id ??\n item.from_int_id;\n const idValue = item.id ?? item.anime_id ?? item.target_id ??\n item.to_id;\n const intId = Number(intIdValue);\n const id = String(idValue ?? \"\").trim();\n if (Number.isFinite(intId) && id) {\n pairs.push({ int_id: Math.trunc(intId), id });\n }\n }\n }\n }\n\n const mapping = body.mapping ?? body.map;\n if (isPlainObject(mapping)) {\n for (const [id, rawIntIds] of Object.entries(mapping)) {\n const animeId = String(id).trim();\n if (!animeId) continue;\n const intIds = uniqueNumbers(flattenValues(rawIntIds));\n for (const intId of intIds) pairs.push({ int_id: intId, id: animeId });\n }\n }\n\n if (pairs.length === 0 && isPlainObject(body)) {\n for (const [id, rawIntIds] of Object.entries(body)) {\n if (\n [\n \"relation\",\n \"relate\",\n \"pairs\",\n \"records\",\n \"batch\",\n \"items\",\n \"connect\",\n \"mapping\",\n \"map\",\n \"execute\",\n \"provider\",\n \"table\",\n \"sourceTable\",\n \"targetTable\",\n \"bridgeTable\",\n ].includes(id)\n ) {\n continue;\n }\n\n if (\n Array.isArray(rawIntIds) || typeof rawIntIds === \"string\" ||\n typeof rawIntIds === \"number\"\n ) {\n const animeId = String(id).trim();\n const intIds = uniqueNumbers(flattenValues(rawIntIds));\n for (const intId of intIds) pairs.push({ int_id: intId, id: animeId });\n }\n }\n }\n\n return [\n ...new Map(\n pairs.map((pair) => [`${pair.int_id}:${pair.id}`, pair] as const),\n ).values(),\n ];\n}\n\nasync function fetchRowsByIntIds(intIds: number[]): Promise> {\n const out = new Map();\n for (const chunk of splitIntoChunks(intIds, 400)) {\n const placeholders = chunk.map(() => \"?\").join(\", \");\n const result = await sql.execute({\n sql: `SELECT * FROM ${\n escapeSqlIdentifier(INTEGRATION.sourceTable)\n } WHERE ${\n escapeSqlIdentifier(INTEGRATION.sourceKey)\n } IN (${placeholders})`,\n args: chunk,\n });\n for (const row of (result.rows ?? []) as Row[]) {\n const raw = row[INTEGRATION.sourceKey];\n const key = Number(raw);\n if (Number.isFinite(key)) out.set(Math.trunc(key), row);\n }\n }\n return out;\n}\n\nasync function fetchRowsByAnimeIds(ids: string[]): Promise> {\n const out = new Map();\n for (const chunk of splitIntoChunks(ids, 400)) {\n const placeholders = chunk.map(() => \"?\").join(\", \");\n const result = await sql.execute({\n sql: `SELECT * FROM ${\n escapeSqlIdentifier(INTEGRATION.targetTable)\n } WHERE ${\n escapeSqlIdentifier(INTEGRATION.targetKey)\n } IN (${placeholders})`,\n args: chunk,\n });\n for (const row of (result.rows ?? []) as Row[]) {\n const raw = row[INTEGRATION.targetKey];\n const key = String(raw).trim();\n if (key) out.set(key, row);\n }\n }\n return out;\n}\n\nasync function fetchConnectorRowsByAnimeIds(ids: string[]): Promise {\n const out: Row[] = [];\n for (const chunk of splitIntoChunks(ids, 400)) {\n const placeholders = chunk.map(() => \"?\").join(\", \");\n const result = await sql.execute({\n sql: `SELECT * FROM ${\n escapeSqlIdentifier(INTEGRATION.bridgeTable)\n } WHERE ${\n escapeSqlIdentifier(INTEGRATION.targetKey)\n } IN (${placeholders})`,\n args: chunk,\n });\n out.push(...((result.rows ?? []) as Row[]));\n }\n return out;\n}\n\nfunction normalizeConnectorRows(rows: Row[]): Row[] {\n const seen = new Set();\n const out: Row[] = [];\n\n for (const row of rows) {\n const intId = Number(row.int_id);\n const id = String(row.id ?? \"\").trim();\n if (!Number.isFinite(intId) || !id) continue;\n\n const key = `${Math.trunc(intId)}::${id}`;\n if (seen.has(key)) continue;\n seen.add(key);\n\n out.push({\n int_id: Math.trunc(intId),\n id,\n title: row.title ?? null,\n season: row.season ?? null,\n episode: row.episode ?? null,\n stream: row.stream ?? null,\n sha: row.sha ?? null,\n });\n }\n\n return out;\n}\n\nasync function upsertConnectorRows(rows: Row[]) {\n const uniqueRows = normalizeConnectorRows(rows);\n if (uniqueRows.length === 0) return { inserted: 0 };\n\n const deleteStatements = uniqueRows.map((row) => ({\n sql: `\n DELETE FROM ${escapeSqlIdentifier(INTEGRATION.bridgeTable)}\n WHERE ${escapeSqlIdentifier(\"int_id\")} = ?\n AND ${escapeSqlIdentifier(\"id\")} = ?\n `,\n args: [row.int_id, row.id],\n }));\n\n const insertStatements = uniqueRows.map((row) => ({\n sql: `\n INSERT INTO ${escapeSqlIdentifier(INTEGRATION.bridgeTable)}\n (int_id, id, title, season, episode, stream, sha)\n VALUES (?, ?, ?, ?, ?, ?, ?)\n `,\n args: [\n row.int_id,\n row.id,\n row.title,\n row.season,\n row.episode,\n row.stream,\n row.sha,\n ],\n }));\n\n await sql.batch([...deleteStatements, ...insertStatements], \"write\");\n return { inserted: uniqueRows.length };\n}\n\nasync function handleIntegrateSqlData(body: JsonObject) {\n const relation = isPlainObject(body.relation) ? body.relation : {};\n const fromTable = String(\n relation.from ?? body.from ?? INTEGRATION.sourceTable,\n ).trim();\n const toTable = String(relation.to ?? body.to ?? INTEGRATION.targetTable)\n .trim();\n const bridgeTable = String(\n relation.using ?? body.using ?? INTEGRATION.bridgeTable,\n ).trim();\n\n if (\n fromTable !== INTEGRATION.sourceTable ||\n toTable !== INTEGRATION.targetTable ||\n bridgeTable !== INTEGRATION.bridgeTable\n ) {\n return {\n status: \"failed\",\n error:\n `this endpoint is wired for ${INTEGRATION.sourceTable} -> ${INTEGRATION.targetTable} using ${INTEGRATION.bridgeTable}`,\n };\n }\n\n const pairs = parseIntegrationPairs(body);\n if (pairs.length === 0) {\n return {\n status: \"failed\",\n error: \"no integration pairs supplied\",\n };\n }\n\n const intIds = [...new Set(pairs.map((pair) => pair.int_id))];\n const animeIds = [...new Set(pairs.map((pair) => pair.id))];\n\n const [episodeRows, animeRows] = await Promise.all([\n fetchRowsByIntIds(intIds),\n fetchRowsByAnimeIds(animeIds),\n ]);\n\n const connectorRows: Row[] = [];\n const missing: Array<{ int_id: number; id: string; reason: string }> = [];\n\n for (const pair of pairs) {\n const episode = episodeRows.get(pair.int_id);\n const anime = animeRows.get(pair.id);\n\n if (!episode || !anime) {\n missing.push({\n int_id: pair.int_id,\n id: pair.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 connectorRows.push({\n int_id: Number(episode.int_id),\n id: String(anime.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(connectorRows);\n const refreshed = await refreshCacheFromSql(INTEGRATION.bridgeTable);\n\n return {\n status: \"ok\",\n relation: {\n from: fromTable,\n to: toTable,\n using: bridgeTable,\n source_key: INTEGRATION.sourceKey,\n target_key: INTEGRATION.targetKey,\n },\n requested_pairs: pairs.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\nfunction normalizeCommands(body: unknown): JsonObject[] {\n if (Array.isArray(body)) return body.filter(isPlainObject);\n if (isPlainObject(body)) return [body];\n return [];\n}\n\nfunction buildInsertStatements(\n table: string,\n rows: Row[],\n schema: SchemaColumn[],\n) {\n const allowedColumns = new Set(schema.map((column) => String(column.name)));\n const keyFields = getTableKeyFields(table, schema);\n\n return rows\n .map((row) => {\n const entries = 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}",[135],"pulls","branches",1,"forks","envVars",{"_150":61,"_152":61},"connections",{"_150":61,"_151":61},"count","unfilledCount","emptyCount",{"_43":134,"_32":135,"_30":136,"_128":-5,"_41":42,"_40":137,"_129":25,"_38":159,"_13":131,"_33":139,"_35":140,"_24":25,"_132":-5,"_156":160,"_27":161},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":155,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_156":157,"_27":158},["D",1781895327713],"children",[],[28],["D",1781592591062],[],[135],["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":199,"_200":201,"_202":203,"_204":25,"_205":25,"_206":25,"_207":120,"_208":-5,"_209":-7,"_210":-7,"_211":61,"_212":25,"_213":25,"_214":-5,"_215":25,"_216":25,"_217":25,"_218":-5},"ENV",{"_170":171,"_172":173,"_174":85,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198},"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 · v18