[{"_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",27,"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\nexport const TURSO = {\n url: \"https://neon-anime-db-lupinarashi.aws-ap-south-1.turso.io\",\n authToken: \"eyJhbGciOiJFZERTQSIsInR5cCI6IkpXVCJ9.eyJhIjoicnciLCJpYXQiOjE3NzIzNTg3NTEsImlkIjoiZGY1MzQ0OWEtZmNlNi00YzIwLTlhNWMtODdlY2JkZjZkNjA0IiwicmlkIjoiODcwYzBmZDUtNWM4Ny00MGYwLWFhZTYtYTE0YTUyZmEwZDk1In0.hHOmuljVz91S7bveKE02E_6-lsGAt0dU1VNTgfw9cyJhBvJGu6oa8O8nz8Af5-qqqWy_PAL-3lsJopEopPhEAw\",\n};\n\nexport const MANGA_TURSO = {\n url: \"https://neon-manga-db-lupinarashi.turso.io\",\n authToken: \"eyJhbGciOiJFZERTQSIsInR5cCI6IkpXVCJ9.eyJhIjoicnciLCJpYXQiOjE3ODM5MjY0NDQsImlkIjoiMDE5ZjVhNGMtMWEwMS03NmM1LWEzZGItNmVjOTZhZTFkOWNjIiwia2lkIjoibTRxTWl4ZVRaM0xGelBSc3AyVnFYMTRQLVRKSllNOWVkUmxNQWllQ3c2TSIsInJpZCI6ImM1N2Q0NThjLWU3MmMtNGM4OC1iYmIxLTE2YjkyOWYzNzk3ZSJ9.tfdqmDSy2ndG9jGp3l4CLuJ_JRXkeZAEfoUKBRUPIgvEijXtfuzytZFGeXMjnS6fmNFN3ZQDaTLs7DRhZGwUCg\",\n};\n\nexport const UPSTASH = {\n url: \"https://magical-giraffe-89191.upstash.io\",\n token: \"gQAAAAAAAVxnAAIncDJmY2MwNTdiZDAyNDQ0OTY3ODhkMjJjMWFkNDlkZGExMnAyODkxOTE\",\n};\n\nexport const KV_PREFIX = \"anime_admin\";\n\nexport const ALLOWED_TABLES = [\n \"anime_info\",\n \"cdn_extracted\",\n \"neonsprivatedata\",\n \"neon_manga_library\",\n \"neon_manga_official\",\n];\n\nexport const TABLE_SOURCES = {\n anime_info: \"primary\",\n cdn_extracted: \"primary\",\n neonsprivatedata: \"primary\",\n neon_manga_official: \"primary\",\n neon_manga_library: \"manga\",\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: [\"int_id\", \"id\", \"title\", \"season\", \"episode\", \"stream\", \"sha\"],\n neon_manga_library: [\n \"key\",\n \"title\",\n \"type\",\n \"year\",\n \"banner_1\",\n \"banner_2\",\n \"author\",\n \"tags\",\n \"status\",\n \"created_at\",\n ],\n neon_manga_official: [\n \"id\",\n \"mngakey\",\n \"title\",\n \"type\",\n \"year\",\n \"banner_1\",\n \"banner_2\",\n \"author\",\n \"tags\",\n \"status\",\n \"sha\",\n ],\n};\n\nexport const INTEGRATION = {\n sourceTable: \"cdn_extracted\",\n targetTable: \"anime_info\",\n bridgeTable: \"neonsprivatedata\",\n mangaTable: \"neon_manga_library\",\n officialTable: \"neon_manga_official\",\n sourceKey: \"int_id\",\n targetKey: \"id\",\n mangaKey: \"key\",\n};","export const APP_NAME = \"Neon Admin Integration API\";\n\nexport const HEALTH_MESSAGE = \"use the admin panel to access this API\";\n\nexport const TURSO = {\n url: \"https://neon-anime-db-lupinarashi.aws-ap-south-1.turso.io\",\n authToken: \"eyJhbGciOiJFZERTQSIsInR5cCI6IkpXVCJ9.eyJhIjoicnciLCJpYXQiOjE3NzIzNTg3NTEsImlkIjoiZGY1MzQ0OWEtZmNlNi00YzIwLTlhNWMtODdlY2JkZjZkNjA0IiwicmlkIjoiODcwYzBmZDUtNWM4Ny00MGYwLWFhZTYtYTE0YTUyZmEwZDk1In0.hHOmuljVz91S7bveKE02E_6-lsGAt0dU1VNTgfw9cyJhBvJGu6oa8O8nz8Af5-qqqWy_PAL-3lsJopEopPhEAw\",\n};\n\nexport const MANGA_TURSO = {\n url: \"https://neon-manga-db-lupinarashi.turso.io\",\n authToken: \"eyJhbGciOiJFZERTQSIsInR5cCI6IkpXVCJ9.eyJhIjoicnciLCJpYXQiOjE3ODM5MjY0NDQsImlkIjoiMDE5ZjVhNGMtMWEwMS03NmM1LWEzZGItNmVjOTZhZTFkOWNjIiwia2lkIjoibTRxTWl4ZVRaM0xGelBSc3AyVnFYMTRQLVRKSllNOWVkUmxNQWllQ3c2TSIsInJpZCI6ImM1N2Q0NThjLWU3MmMtNGM4OC1iYmIxLTE2YjkyOWYzNzk3ZSJ9.tfdqmDSy2ndG9jGp3l4CLuJ_JRXkeZAEfoUKBRUPIgvEijXtfuzytZFGeXMjnS6fmNFN3ZQDaTLs7DRhZGwUCg\",\n};\n\nexport const UPSTASH = {\n url: \"https://magical-giraffe-89191.upstash.io\",\n token: \"gQAAAAAAAVxnAAIncDJmY2MwNTdiZDAyNDQ0OTY3ODhkMjJjMWFkNDlkZGExMnAyODkxOTE\",\n};\n\nexport const KV_PREFIX = \"anime_admin\";\n\nexport const ALLOWED_TABLES = [\n \"anime_info\",\n \"cdn_extracted\",\n \"neonsprivatedata\",\n \"neon_manga_library\",\n \"neon_manga_official\",\n];\n\nexport const TABLE_SOURCES = {\n anime_info: \"primary\",\n cdn_extracted: \"primary\",\n neonsprivatedata: \"primary\",\n neon_manga_library: \"manga\",\n // FIXED: Routed to primary database\n neon_manga_official: \"primary\",\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: [\"int_id\", \"id\", \"title\", \"season\", \"episode\", \"stream\", \"sha\"],\n neon_manga_library: [\n \"key\",\n \"title\",\n \"type\",\n \"year\",\n \"banner_1\",\n \"banner_2\",\n \"author\",\n \"tags\",\n \"status\",\n \"created_at\",\n ],\n neon_manga_official: [\n \"id\",\n \"mngakey\",\n \"title\",\n \"type\",\n \"year\",\n \"banner_1\",\n \"banner_2\",\n \"author\",\n \"tags\",\n \"status\",\n \"sha\",\n ],\n};\n\nexport const INTEGRATION = {\n sourceTable: \"cdn_extracted\",\n targetTable: \"anime_info\",\n bridgeTable: \"neonsprivatedata\",\n mangaTable: \"neon_manga_library\",\n officialTable: \"neon_manga_official\",\n sourceKey: \"int_id\",\n targetKey: \"id\",\n mangaKey: \"key\",\n};","createdAt",["D",1783999072389],"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":134,"_32":135,"_30":136,"_128":-5,"_41":42,"_40":137,"_129":25,"_38":138,"_13":139,"_33":140,"_35":141,"_24":25,"_132":-5,"_27":142},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":120,"_38":130,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_27":133},"b6f258c9-8116-4092-90d2-5b334675ee1f","parentId","latest",["D",1783999072389],13,"label",[28],"aad136bf-c19e-4423-9ded-d91b19954e0b","Ruler-Hand.ts","d32af79a-64f4-11f1-941a-1607ee4eb77e",26,["D",1783964914494],12,"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 APP_NAME,\n HEALTH_MESSAGE,\n TURSO,\n MANGA_TURSO,\n UPSTASH,\n KV_PREFIX,\n ALLOWED_TABLES,\n TABLE_FIELDS,\n TABLE_SOURCES,\n INTEGRATION,\n} from \"./customize.js\";\n\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\ntype CachedTableManifest = {\n kind: \"chunked-table\";\n version: 2;\n table: string;\n chunkCount: number;\n totalRows: number;\n totalBytes: number;\n createdAt: string;\n};\n\nconst sql = createClient({ url: TURSO.url, authToken: TURSO.authToken });\nconst mangaSql = createClient({ url: MANGA_TURSO.url, authToken: MANGA_TURSO.authToken });\nconst redis = new Redis({ url: UPSTASH.url, token: UPSTASH.token });\n\nconst ALLOWED_TABLE_SET = new Set(ALLOWED_TABLES);\nconst MAX_UPSTASH_CHUNK_BYTES = 9_000_000;\nconst CHUNK_KEY_SUFFIX = \"part\";\nconst CHUNK_MANIFEST_KIND = \"chunked-table\" as const;\nconst CHUNK_MANIFEST_VERSION = 2 as const;\n\nconst trace = (...args: unknown[]) => console.log(\"[AnimeAdmin]\", ...args);\n\nfunction isPlainObject(value: unknown): value is JsonObject {\n return typeof value === \"object\" && value !== null && !Array.isArray(value);\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 readJson(req: Request): Promise {\n try {\n return await req.json();\n } catch {\n const txt = await req.text();\n if (!txt.trim()) return null;\n try {\n return JSON.parse(txt);\n } catch {\n return null;\n }\n }\n}\n\nfunction escapeSqlIdentifier(identifier: string): string {\n return `\"${String(identifier).replaceAll('\"', '\"\"')}\"`;\n}\n\nfunction normalizePrimitive(value: unknown): string | number | boolean | null {\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.split(\",\").map((part) => part.trim()).filter(Boolean);\n return pieces.length > 1 ? pieces : [value.trim()];\n }\n const primitive = normalizePrimitive(value);\n return primitive === null ? [] : [primitive as string | number | boolean];\n}\n\nfunction uniqueStrings(values: Array): string[] {\n return [...new Set(values.map((value) => String(value).trim()).filter(Boolean))];\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) chunks.push(items.slice(i, i + chunkSize));\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 tableClient(table: string) {\n return TABLE_SOURCES[table as keyof typeof TABLE_SOURCES] === \"manga\" ? mangaSql : sql;\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) => a.pk - b.pk).map((column) => column.name);\n if (pkFields.length) return pkFields;\n }\n const allowed = getAllowedFields(table);\n if (allowed.includes(\"key\")) return [\"key\"];\n if (allowed.includes(\"id\") && allowed.includes(\"int_id\")) return [\"int_id\", \"id\"];\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 parseStoredValue(value: unknown): unknown {\n if (typeof value !== \"string\") return value;\n const text = value.trim();\n if (!text) return value;\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 if (Array.isArray(parsed)) return parsed as Row[];\n if (isPlainObject(parsed)) {\n if (Array.isArray((parsed as any).rows)) return (parsed as any).rows as Row[];\n if (Array.isArray((parsed as any).data)) return (parsed as any).data as Row[];\n if (Array.isArray((parsed as any).items)) return (parsed as any).items as Row[];\n }\n return [];\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}\n\nfunction normalizeStoredManifest(value: unknown): CachedTableManifest | null {\n const parsed = parseStoredValue(value);\n return isCachedTableManifest(parsed) ? parsed : null;\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\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\")).join(\"\");\n}\n\nasync function selectAllRows(table: string): Promise {\n const client = tableClient(table);\n const result = await client.execute({ sql: `SELECT * FROM ${escapeSqlIdentifier(table)}` });\n return (result.rows ?? []) as Row[];\n}\n\nasync function readSchema(table: string): Promise<{ columns: SchemaColumn[]; primaryKeyFields: string[] }> {\n const client = tableClient(table);\n const result = await client.execute({ sql: `PRAGMA table_info(${escapeSqlIdentifier(table)})` });\n const columns = (result.rows ?? []) as SchemaColumn[];\n const primaryKeyFields = columns.filter((column) => Number(column.pk) > 0).sort((a, b) => Number(a.pk) - Number(b.pk)).map((column) => String(column.name));\n return { columns, primaryKeyFields };\n}\n\nfunction splitRowsByByteSize(rows: Row[], maxBytes = MAX_UPSTASH_CHUNK_BYTES): 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 ? 2 + rowBytes : currentBytes + 1 + rowBytes;\n if (nextBytes <= maxBytes || current.length === 0) {\n current.push(row);\n currentBytes = nextBytes;\n continue;\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 const rows = normalizeStoredRows(raw);\n if (rows.length) return { kind: \"legacy\", rows };\n const manifest = normalizeStoredManifest(raw);\n if (manifest) return { kind: \"manifest\", manifest };\n return { kind: \"missing\" };\n}\n\nasync function loadChunk(table: string, index: number): Promise {\n return normalizeStoredRows(await redis.get(getChunkKey(table, index)));\n}\n\nasync function loadChunkedTable(table: string, manifest: CachedTableManifest): Promise {\n const chunkCount = Math.max(0, Math.trunc(manifest.chunkCount));\n if (chunkCount === 0) return [];\n const chunkKeys = Array.from({ length: chunkCount }, (_, index) => getChunkKey(table, index));\n const chunks = await Promise.all(chunkKeys.map(async (key) => normalizeStoredRows(await redis.get(key))));\n return chunks.flat();\n}\n\nasync function deleteChunkedTableArtifacts(table: string, manifest: CachedTableManifest | null): Promise {\n if (!manifest) {\n await redis.del(getManifestKey(table));\n return;\n }\n const chunkKeys = Array.from({ length: Math.max(0, Math.trunc(manifest.chunkCount)) }, (_, index) => getChunkKey(table, index));\n for (const key of chunkKeys) await redis.del(key);\n await redis.del(getManifestKey(table));\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 await redis.del(getManifestKey(table));\n}\n\nasync function saveCachedTable(table: string, rows: Row[]): Promise {\n const previous = await readLegacyOrManifest(table);\n const chunks = splitRowsByByteSize(rows);\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: chunks.reduce((sum, chunk) => sum + utf8ByteLength(JSON.stringify(chunk)), 0),\n createdAt: new Date().toISOString(),\n };\n\n const pipeline = redis.pipeline();\n for (const [index, chunk] of chunks.entries()) pipeline.set(getChunkKey(table, index), chunk);\n pipeline.set(getManifestKey(table), manifest);\n if (previous.kind === \"manifest\" && previous.manifest.chunkCount > chunks.length) {\n for (let index = chunks.length; index < previous.manifest.chunkCount; index += 1) pipeline.del(getChunkKey(table, index));\n }\n await pipeline.exec();\n return manifest;\n}\n\nasync function loadCachedTable(table: string): Promise {\n const storage = await readLegacyOrManifest(table);\n if (storage.kind === \"legacy\") return storage.rows;\n if (storage.kind === \"manifest\") return await loadChunkedTable(table, storage.manifest);\n return [];\n}\n\nasync function refreshCacheFromSql(table: string): 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 ensureTableMeta(table: string) {\n const schema = await readSchema(table);\n let storage = await readLegacyOrManifest(table);\n if (storage.kind === \"missing\") {\n await refreshCacheFromSql(table);\n storage = await readLegacyOrManifest(table);\n }\n const manifest = storage.kind === \"manifest\"\n ? storage.manifest\n : {\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\" ? utf8ByteLength(JSON.stringify(storage.rows)) : 0,\n createdAt: new Date().toISOString(),\n };\n\n return {\n table,\n source: TABLE_SOURCES[table as keyof typeof TABLE_SOURCES] ?? \"primary\",\n schema: { columns: schema.columns },\n keyFields: schema.primaryKeyFields.length ? schema.primaryKeyFields : getTableKeyFields(table, schema.columns),\n manifest,\n };\n}\n\nasync function readAllTableMeta() {\n const out: Record = {};\n for (const table of ALLOWED_TABLES) out[table] = await ensureTableMeta(table);\n return out;\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)) return { ok: false, error: \"invalid table requested\" };\n const schema = await readSchema(table);\n let storage = await readLegacyOrManifest(table);\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 =\n 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 (rows.length === 0 && storage.kind === \"manifest\" && storage.manifest.totalRows > 0) {\n await refreshCacheFromSql(table);\n storage = await readLegacyOrManifest(table);\n rows =\n 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\"\n ? storage.manifest\n : {\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\" ? utf8ByteLength(JSON.stringify(storage.rows)) : 0,\n createdAt: new Date().toISOString(),\n };\n\n return { ok: true, source: TABLE_SOURCES[table as keyof typeof TABLE_SOURCES] ?? \"primary\", table, part: Math.max(0, Math.trunc(part)), schema, manifest, rows };\n }\n\n const manifest = storage.kind === \"manifest\"\n ? storage.manifest\n : {\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\" ? utf8ByteLength(JSON.stringify(storage.rows)) : 0,\n createdAt: new Date().toISOString(),\n };\n\n return { ok: true, source: TABLE_SOURCES[table as keyof typeof TABLE_SOURCES] ?? \"primary\", table, schema, manifest };\n }\n\n return { ok: true, api: APP_NAME, message: HEALTH_MESSAGE, tables: await readAllTableMeta() };\n}\n\nfunction buildWhereFromObject(where: JsonObject, allowedFields: Set) {\n const parts: string[] = [];\n const args: Array = [];\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((value): value is string | number | boolean | null => true);\n const actual = normalized.filter((value): value is string | number | boolean => value !== null);\n if (!actual.length) continue;\n if (actual.length === 1) {\n parts.push(`${escapeSqlIdentifier(field)} = ?`);\n args.push(actual[0]);\n } else {\n parts.push(`${escapeSqlIdentifier(field)} IN (${actual.map(() => \"?\").join(\", \")})`);\n args.push(...actual);\n }\n }\n if (!parts.length) return null;\n return { sql: parts.join(\" AND \"), args };\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 ${escapeSqlIdentifier(INTEGRATION.sourceTable)} WHERE ${escapeSqlIdentifier(INTEGRATION.sourceKey)} IN (${placeholders})`,\n args: chunk,\n });\n for (const row of (result.rows ?? []) as Row[]) {\n const key = Number(row[INTEGRATION.sourceKey]);\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 ${escapeSqlIdentifier(INTEGRATION.targetTable)} WHERE ${escapeSqlIdentifier(INTEGRATION.targetKey)} IN (${placeholders})`,\n args: chunk,\n });\n for (const row of (result.rows ?? []) as Row[]) {\n const key = String(row[INTEGRATION.targetKey] ?? \"\").trim();\n if (key) out.set(key, row);\n }\n }\n return out;\n}\n\nasync function fetchRowsByMangaKeys(keys: string[]): Promise> {\n const out = new Map();\n for (const chunk of splitIntoChunks(keys, 400)) {\n const placeholders = chunk.map(() => \"?\").join(\", \");\n const result = await mangaSql.execute({\n sql: `SELECT * FROM ${escapeSqlIdentifier(INTEGRATION.mangaTable)} WHERE ${escapeSqlIdentifier(INTEGRATION.mangaKey)} IN (${placeholders})`,\n args: chunk,\n });\n for (const row of (result.rows ?? []) as Row[]) {\n const key = String(row[INTEGRATION.mangaKey] ?? \"\").trim();\n if (key) out.set(key, row);\n }\n }\n return out;\n}\n\nfunction normalizeConnectorRows(rows: Row[]): Row[] {\n const seen = new Set();\n const out: Row[] = [];\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 const key = `${Math.trunc(intId)}::${id}`;\n if (seen.has(key)) continue;\n seen.add(key);\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 return out;\n}\n\nasync function upsertConnectorRows(rows: Row[]) {\n const uniqueRows = normalizeConnectorRows(rows);\n if (uniqueRows.length === 0) return { inserted: 0 };\n const statements: Array<{ sql: string; args: unknown[] }> = [];\n for (const row of uniqueRows) {\n statements.push({\n sql: `DELETE FROM ${escapeSqlIdentifier(INTEGRATION.bridgeTable)} WHERE ${escapeSqlIdentifier(\"int_id\")} = ? AND ${escapeSqlIdentifier(\"id\")} = ?`,\n args: [row.int_id, row.id],\n });\n statements.push({\n sql: `INSERT INTO ${escapeSqlIdentifier(INTEGRATION.bridgeTable)} (int_id, id, title, season, episode, stream, sha) VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [row.int_id, row.id, row.title, row.season, row.episode, row.stream, row.sha],\n });\n }\n await sql.batch(statements as any, \"write\");\n return { inserted: uniqueRows.length };\n}\n\nfunction normalizeMangaOfficialRows(rows: Row[]): Row[] {\n const seen = new Set();\n const out: Row[] = [];\n for (const row of rows) {\n const id = String(row.id ?? \"\").trim();\n const mngakey = String(row.mngakey ?? \"\").trim();\n if (!id || !mngakey) continue;\n const key = `${id}::${mngakey}`;\n if (seen.has(key)) continue;\n seen.add(key);\n out.push({\n id,\n mngakey,\n title: row.title ?? null,\n type: row.type ?? null,\n year: row.year ?? null,\n banner_1: row.banner_1 ?? null,\n banner_2: row.banner_2 ?? null,\n author: row.author ?? null,\n tags: row.tags ?? null,\n status: row.status ?? null,\n sha: row.sha ?? null,\n });\n }\n return out;\n}\n\nasync function upsertMangaOfficialRows(rows: Row[]) {\n const uniqueRows = normalizeMangaOfficialRows(rows);\n if (uniqueRows.length === 0) return { inserted: 0 };\n const statements: Array<{ sql: string; args: unknown[] }> = [];\n for (const row of uniqueRows) {\n statements.push({\n sql: `DELETE FROM ${escapeSqlIdentifier(INTEGRATION.officialTable)} WHERE ${escapeSqlIdentifier(\"id\")} = ?`,\n args: [row.id],\n });\n statements.push({\n sql: `INSERT INTO ${escapeSqlIdentifier(INTEGRATION.officialTable)} (id, mngakey, title, type, year, banner_1, banner_2, author, tags, status, sha) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [row.id, row.mngakey, row.title, row.type, row.year, row.banner_1, row.banner_2, row.author, row.tags, row.status, row.sha],\n });\n }\n await sql.batch(statements as any, \"write\");\n return { inserted: uniqueRows.length };\n}\n\nfunction parseIntegrationRecords(body: JsonObject): Array<{ int_id: number; id: string; key?: string }> {\n const records: Array<{ int_id: number; id: string; key?: string }> = [];\n const directArrays = [body.records, body.pairs, body.batch, body.items, body.connect];\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 const key = item.length >= 3 ? String(item[2] ?? \"\").trim() : \"\";\n if (Number.isFinite(intId) && id) records.push({ int_id: Math.trunc(intId), id, key: key || undefined });\n continue;\n }\n if (isPlainObject(item)) {\n const intIdValue = item.int_id ?? item.intId ?? item.source_id ?? item.from_int_id;\n const idValue = item.id ?? item.anime_id ?? item.target_id ?? item.to_id;\n const keyValue = item.key ?? item.manga_key ?? item.mangaKey ?? item.mngakey;\n const intId = Number(intIdValue);\n const id = String(idValue ?? \"\").trim();\n const key = String(keyValue ?? \"\").trim();\n if (Number.isFinite(intId) && id) records.push({ int_id: Math.trunc(intId), id, key: key || undefined });\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) records.push({ int_id: intId, id: animeId });\n }\n }\n\n if (records.length === 0 && isPlainObject(body)) {\n for (const [id, raw] of Object.entries(body)) {\n if ([\n \"relation\", \"relate\", \"pairs\", \"records\", \"batch\", \"items\", \"connect\", \"mapping\", \"map\",\n \"execute\", \"provider\", \"table\", \"sourceTable\", \"targetTable\", \"bridgeTable\", \"mangaTable\", \"officialTable\",\n ].includes(id)) continue;\n if (Array.isArray(raw) || typeof raw === \"string\" || typeof raw === \"number\") {\n const animeId = String(id).trim();\n const intIds = uniqueNumbers(flattenValues(raw));\n for (const intId of intIds) records.push({ int_id: intId, id: animeId });\n }\n }\n }\n\n return [...new Map(records.map((record) => [`${record.int_id}:${record.id}:${record.key ?? \"\"}`, record] as const)).values()];\n}\n\nasync function handleIntegrateSqlData(body: JsonObject) {\n const relation = isPlainObject(body.relation) ? body.relation : {};\n const fromTable = String(relation.from ?? body.from ?? INTEGRATION.sourceTable).trim();\n const toTable = String(relation.to ?? body.to ?? INTEGRATION.targetTable).trim();\n const bridgeTable = String(relation.using ?? body.using ?? INTEGRATION.bridgeTable).trim();\n\n if (fromTable !== INTEGRATION.sourceTable || toTable !== INTEGRATION.targetTable || bridgeTable !== INTEGRATION.bridgeTable) {\n return { status: \"failed\", error: `this endpoint is wired for ${INTEGRATION.sourceTable} -> ${INTEGRATION.targetTable} using ${INTEGRATION.bridgeTable}` };\n }\n\n const records = parseIntegrationRecords(body);\n if (records.length === 0) return { status: \"failed\", error: \"no integration pairs supplied\" };\n\n const intIds = [...new Set(records.map((record) => record.int_id))];\n const animeIds = [...new Set(records.map((record) => record.id))];\n const mangaKeys = [...new Set(records.map((record) => record.key).filter((value): value is string => typeof value === \"string\" && value.trim().length > 0))];\n\n const [episodeRows, animeRows, mangaRows] = await Promise.all([\n fetchRowsByIntIds(intIds),\n fetchRowsByAnimeIds(animeIds),\n mangaKeys.length ? fetchRowsByMangaKeys(mangaKeys) : Promise.resolve(new Map()),\n ]);\n\n const connectorRows: Row[] = [];\n const officialRows: Row[] = [];\n const missing: Array> = [];\n\n for (const record of records) {\n const episode = episodeRows.get(record.int_id);\n const anime = animeRows.get(record.id);\n const manga = record.key ? mangaRows.get(record.key) : null;\n\n if (!episode || !anime) {\n missing.push({\n int_id: record.int_id,\n id: record.id,\n key: record.key ?? null,\n reason: !episode && !anime ? \"missing source and target rows\" : !episode ? \"missing source row\" : \"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 if (manga) {\n officialRows.push({\n id: String(anime.id),\n mngakey: String(manga.key ?? record.key ?? \"\").trim(),\n title: manga.title ?? null,\n type: manga.type ?? null,\n year: manga.year ?? null,\n banner_1: manga.banner_1 ?? null,\n banner_2: manga.banner_2 ?? null,\n author: manga.author ?? null,\n tags: manga.tags ?? null,\n status: manga.status ?? null,\n sha,\n });\n }\n }\n\n const [connectorWrite, mangaWrite] = await Promise.all([\n upsertConnectorRows(connectorRows),\n officialRows.length ? upsertMangaOfficialRows(officialRows) : Promise.resolve({ inserted: 0 }),\n ]);\n\n const refreshedBridge = await refreshCacheFromSql(INTEGRATION.bridgeTable);\n try { await refreshCacheFromSql(INTEGRATION.mangaTable); } catch {}\n try { await refreshCacheFromSql(INTEGRATION.officialTable); } catch {}\n\n return {\n status: \"ok\",\n relation: {\n from: fromTable,\n to: toTable,\n using: bridgeTable,\n manga: INTEGRATION.mangaTable,\n official: INTEGRATION.officialTable,\n source_key: INTEGRATION.sourceKey,\n target_key: INTEGRATION.targetKey,\n manga_key: INTEGRATION.mangaKey,\n },\n requested_pairs: records.length,\n written_pairs: connectorWrite.inserted,\n written_manga_rows: mangaWrite.inserted,\n skipped_pairs: missing.length,\n missing,\n refreshed: {\n rows: refreshedBridge.rows,\n manifest: refreshedBridge.manifest,\n },\n };\n}\n\nfunction parseTableList(value: unknown): string[] {\n return uniqueStrings(flattenValues(value)).filter((table) => isAllowedTable(table));\n}\n\nasync function handleRestoreTables(tables: string[]) {\n const results: Array> = [];\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({ table, status: \"restored\", sql_rows: rows.length, cache_rows: manifest.totalRows, kv_key: toTableKey(table) });\n } catch (error) {\n results.push({ table, status: \"failed\", error: error instanceof Error ? error.message : String(error) });\n }\n }\n return results;\n}\n\nasync function handleDeleteTables(tables: string[]) {\n const results: Array> = [];\n for (const table of tables) {\n try {\n await deleteCachedTable(table);\n results.push({ table, status: \"deleted\", kv_key: toTableKey(table) });\n } catch (error) {\n results.push({ table, status: \"failed\", error: error instanceof Error ? error.message : String(error) });\n }\n }\n return results;\n}\n\nasync function executeKvRowRemoval(table: string, filters: Record>) {\n const rows = await loadCachedTable(table);\n if (!rows.length) return { table, status: \"empty\", removed: 0, kept: 0 };\n const kept = rows.filter((row) => !Object.entries(filters).every(([field, values]) => values.some((value) => String(row[field] ?? \"\").trim() === String(value).trim())));\n const removed = rows.length - kept.length;\n await saveCachedTable(table, kept);\n return { table, status: \"ok\", removed, kept: kept.length, key: toTableKey(table) };\n}\n\nasync function executeSqlRowRemoval(table: string, filters: Record>) {\n const allowedFields = new Set(getAllowedFields(table));\n const fieldEntries = Object.entries(filters).filter(([field]) => allowedFields.has(field));\n if (fieldEntries.length === 0) return { table, status: \"skipped\", reason: \"no valid fields supplied for this table\" };\n\n const whereParts: string[] = [];\n const args: Array = [];\n for (const [field, values] of fieldEntries) {\n const unique = [...new Set(values.map((v) => normalizePrimitive(v)).filter((v): v is string | number | boolean => v !== null))];\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) return { table, status: \"skipped\", reason: \"no valid values supplied\" };\n const query = `DELETE FROM ${escapeSqlIdentifier(table)} WHERE ${whereParts.join(\" AND \")}`;\n const client = tableClient(table);\n const result = await client.execute({ sql: query, args });\n if ((result.rowsAffected ?? 0) > 0) {\n const refreshed = await refreshCacheFromSql(table);\n return { table, status: \"ok\", removed: result.rowsAffected ?? 0, refreshed: { rows: refreshed.rows, manifest: refreshed.manifest } };\n }\n return { table, status: \"ok\", removed: 0, refreshed: null };\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(body.lnrmv ?? body.remove ?? body.filters ?? body.where);\n if (!table || !isAllowedTable(table)) return { status: \"failed\", error: \"invalid or unsupported table\" };\n if (provider === \"KV\") return await executeKvRowRemoval(table, filters);\n if (provider === \"SQL\") return await executeSqlRowRemoval(table, filters);\n return { status: \"failed\", error: \"execute must be KV or SQL\" };\n}\n\nfunction normalizeFilterMap(value: unknown): 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 buildSchemaWhere(table: string, where: JsonObject | null) {\n if (!where) return null;\n const schema = await readSchema(table);\n const allowedFields = new Set(schema.columns.map((column) => String(column.name)));\n return buildWhereFromObject(where, allowedFields);\n}\n\nasync function updateRows(table: string, where: JsonObject | null, patch: JsonObject) {\n const whereClause = await buildSchemaWhere(table, where);\n if (!whereClause) return { updated: 0, reason: \"missing where clause\" };\n const schema = await readSchema(table);\n const allowedFields = new Set(schema.columns.map((column) => String(column.name)));\n const updateEntries = Object.entries(patch).filter(([field, value]) => allowedFields.has(field) && value !== undefined);\n if (updateEntries.length === 0) return { updated: 0, reason: \"no updatable fields supplied\" };\n const setSql = updateEntries.map(([field]) => `${escapeSqlIdentifier(field)} = ?`).join(\", \");\n const setArgs = updateEntries.map(([, value]) => normalizePrimitive(value));\n const client = tableClient(table);\n const result = await client.execute({ sql: `UPDATE ${escapeSqlIdentifier(table)} SET ${setSql} WHERE ${whereClause.sql}`, args: [...setArgs, ...whereClause.args] });\n return { updated: result.rowsAffected ?? 0 };\n}\n\nasync function deleteRows(table: string, body: JsonObject) {\n const schema = await readSchema(table);\n const allowedFields = new Set(schema.columns.map((column) => String(column.name)));\n const keyFields = getTableKeyFields(table, schema.columns);\n const keys = Array.isArray(body.keys) ? body.keys : [];\n\n if (keys.length > 0 && keyFields.length > 0) {\n const clauses: string[] = [];\n const args: Array = [];\n for (const item of keys) {\n if (isPlainObject(item)) {\n const fields = keyFields.map((field) => ({ field, value: normalizePrimitive(item[field]) })).filter((entry) => entry.value !== null);\n if (fields.length !== keyFields.length) continue;\n clauses.push(`(${fields.map((entry) => `${escapeSqlIdentifier(entry.field)} = ?`).join(\" AND \")})`);\n args.push(...fields.map((entry) => entry.value as string | number | boolean));\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 client = tableClient(table);\n const result = await client.execute({ sql: `DELETE FROM ${escapeSqlIdentifier(table)} WHERE ${clauses.join(\" OR \")}`, args });\n return { removed: result.rowsAffected ?? 0 };\n }\n }\n\n const filters = normalizeFilterMap(body.where ?? body.filters ?? body.lnrmv ?? body.remove);\n const whereClause = buildWhereFromObject(filters, allowedFields);\n if (!whereClause) return { removed: 0, reason: \"no valid filters supplied\" };\n const client = tableClient(table);\n const result = await client.execute({ sql: `DELETE FROM ${escapeSqlIdentifier(table)} WHERE ${whereClause.sql}`, args: whereClause.args });\n return { removed: result.rowsAffected ?? 0 };\n}\n\nasync function addField(table: string, field: string, type = \"TEXT\", defaultValue: unknown = null) {\n const client = tableClient(table);\n const sanitizedType = String(type || \"TEXT\").trim() || \"TEXT\";\n const defaultSql = defaultValue === null || defaultValue === undefined\n ? \"\"\n : ` DEFAULT ${typeof defaultValue === \"number\" ? defaultValue : `'${String(defaultValue).replaceAll(\"'\", \"''\")}'`}`;\n await client.execute({ sql: `ALTER TABLE ${escapeSqlIdentifier(table)} ADD COLUMN ${escapeSqlIdentifier(field)} ${sanitizedType}${defaultSql}` });\n return { added: field, type: sanitizedType };\n}\n\nasync function renameField(table: string, fromField: string, toField: string) {\n const client = tableClient(table);\n await client.execute({ sql: `ALTER TABLE ${escapeSqlIdentifier(table)} RENAME COLUMN ${escapeSqlIdentifier(fromField)} TO ${escapeSqlIdentifier(toField)}` });\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) => String(column.name) !== removeField);\n if (remaining.length === schema.columns.length) return { removed: 0, reason: \"field not found\" };\n const tempTable = `${table}__rebuild_tmp_${Date.now()}`;\n const columnDefs = remaining.map((column) => {\n const pieces = [escapeSqlIdentifier(String(column.name)), column.type ? String(column.type) : \"TEXT\"];\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\" ? String(column.dflt_value) : 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 const columnNames = remaining.map((column) => escapeSqlIdentifier(String(column.name)));\n const copyColumns = columnNames.join(\", \");\n const client = tableClient(table);\n await client.batch(\n [\n { sql: `CREATE TABLE ${escapeSqlIdentifier(tempTable)} (${columnDefs.join(\", \")})`, args: [] },\n { sql: `INSERT INTO ${escapeSqlIdentifier(tempTable)} (${copyColumns}) SELECT ${copyColumns} FROM ${escapeSqlIdentifier(table)}`, args: [] },\n { sql: `DROP TABLE ${escapeSqlIdentifier(table)}`, args: [] },\n { sql: `ALTER TABLE ${escapeSqlIdentifier(tempTable)} RENAME TO ${escapeSqlIdentifier(table)}`, args: [] },\n ],\n \"write\",\n );\n return { removed: 1, rebuilt: true };\n}\n\nasync function removeField(table: string, field: string) {\n const client = tableClient(table);\n try {\n await client.execute({ sql: `ALTER TABLE ${escapeSqlIdentifier(table)} DROP COLUMN ${escapeSqlIdentifier(field)}` });\n return { removed: 1, mode: \"native\" };\n } catch {\n return await rebuildTableWithoutField(table, field);\n }\n}\n\nasync function insertRows(table: string, rows: Row[]) {\n const schema = await readSchema(table);\n const allowedColumns = new Set(schema.columns.map((column) => String(column.name)));\n const statements: Array<{ sql: string; args: unknown[] }> = [];\n for (const row of rows) {\n const entries = Object.entries(row).filter(([field, value]) => allowedColumns.has(field) && value !== undefined);\n if (entries.length === 0) continue;\n statements.push({\n sql: `INSERT INTO ${escapeSqlIdentifier(table)} (${entries.map(([field]) => escapeSqlIdentifier(field)).join(\", \")}) VALUES (${entries.map(() => \"?\").join(\", \")})`,\n args: entries.map(([, value]) => normalizePrimitive(value)),\n });\n }\n if (!statements.length) return { inserted: 0, skipped: rows.length };\n const client = tableClient(table);\n await client.batch(statements as any, \"write\");\n return { inserted: statements.length, skipped: rows.length - statements.length };\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\nasync function handleTableAdmin(body: JsonObject) {\n const action = String(body.action ?? body.op ?? \"\").trim().toLowerCase();\n const table = String(body.table ?? \"\").trim();\n if (!table || !isAllowedTable(table)) return { ok: false, error: \"invalid or unsupported table\" };\n\n try {\n let result: Record | null = null;\n let refreshed: { rows: number; manifest: CachedTableManifest } | null = null;\n if (action === \"insert-row\" || action === \"insert\" || action === \"create-row\" || action === \"add-row\") {\n const rows = Array.isArray(body.rows) ? body.rows.filter(isPlainObject) : isPlainObject(body.row) ? [body.row] : [];\n result = await insertRows(table, rows);\n } else if (action === \"update-row\" || action === \"update\" || action === \"edit-row\") {\n const patch = isPlainObject(body.patch) ? body.patch : isPlainObject(body.row) ? body.row : {};\n const where = isPlainObject(body.where) ? body.where : isPlainObject(body.keys) ? body.keys : null;\n result = await updateRows(table, where, patch);\n } else if (action === \"delete-rows\" || action === \"delete\" || action === \"remove-rows\" || action === \"remove\") {\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(table, field, String(body.type ?? \"TEXT\"), body.defaultValue ?? null);\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) return { ok: false, error: \"both from and to field names are required\" };\n result = await renameField(table, from, to);\n } else if (action === \"remove-field\" || action === \"field-remove\" || action === \"drop-field\") {\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 { ok: true, table, action, result: { rows: refreshed.rows, manifest: refreshed.manifest }, refreshed };\n } else {\n return { ok: false, error: \"invalid action\" };\n }\n\n refreshed = await refreshCacheFromSql(table);\n return { ok: true, table, action, result, refreshed: { rows: refreshed.rows, manifest: refreshed.manifest } };\n } catch (error) {\n return { ok: false, table, action, error: error instanceof Error ? error.message : String(error) };\n }\n}\n\nasync function handleBootrootData(body: JsonObject) {\n const results: Array> = [];\n for (const command of normalizeCommands(body)) {\n try {\n const restoreTables = parseTableList(command.restore);\n const deleteTables = parseTableList(command.delete);\n const executeResult = command.execute || command.provider || command.lnrmv ? await handleExecuteCommand(command) : null;\n if (restoreTables.length) results.push({ action: \"restore\", tables: restoreTables, results: await handleRestoreTables(restoreTables) });\n if (deleteTables.length) results.push({ action: \"delete\", tables: deleteTables, results: await handleDeleteTables(deleteTables) });\n if (executeResult) results.push({ action: \"execute\", result: executeResult });\n if (!restoreTables.length && !deleteTables.length && !executeResult) results.push({ action: \"noop\", command });\n } catch (error) {\n results.push({ action: \"failed\", error: error instanceof Error ? error.message : String(error), command });\n }\n }\n return { ok: true, results };\n}\n\nasync function handleRequest(req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/+$/, \"\") || \"/\";\n\n if (req.method === \"OPTIONS\") return new Response(null, { status: 204, headers: CORS_HEADERS });\n\n if (req.method === \"GET\" && path === \"/\") {\n return jsonResponse({\n ok: true,\n api: APP_NAME,\n message: HEALTH_MESSAGE,\n routes: [\"GET /\", \"GET /ignite-engine\", \"POST /bootroot-data\", \"POST /integrate-sqldata\", \"POST /table-admin\"],\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({ ok: false, error: error instanceof Error ? error.message : String(error) }, 500);\n }\n }\n\n if (req.method !== \"POST\") return jsonResponse({ ok: false, error: \"method not allowed\" }, 405);\n\n const body = await readJson(req);\n const objectBody = isPlainObject(body) ? body : {};\n\n if (path === \"/bootroot-data\") return jsonResponse(await handleBootrootData(objectBody));\n if (path === \"/integrate-sqldata\") return jsonResponse(await handleIntegrateSqlData(objectBody));\n if (path === \"/table-admin\") return jsonResponse(await handleTableAdmin(objectBody));\n\n return jsonResponse({ ok: false, error: \"not found\" }, 404);\n}\n\nexport default async function handler(req: Request): Promise {\n try {\n return await handleRequest(req);\n } catch (error) {\n trace(\"fatal\", error);\n return jsonResponse({ ok: false, error: error instanceof Error ? error.message : String(error) }, 500);\n }\n}",[135],"pulls","branches",1,"forks","envVars",{"_151":61,"_153":61},"connections",{"_151":61,"_152":61},"count","unfilledCount","emptyCount",{"_43":134,"_32":135,"_30":136,"_128":-5,"_41":42,"_40":137,"_129":25,"_38":160,"_13":139,"_33":140,"_35":141,"_24":25,"_132":-5,"_157":161,"_27":162},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":120,"_38":156,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_157":158,"_27":159},["D",1783999072389],"children",[],[28],["D",1783964914494],[],[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":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 · v27