[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_157":158,"_159":160},"routes/_app.x.$handle.$name",{"_16":17,"_20":21,"_82":65,"_83":31,"_63":-7,"_84":-5,"_13":85,"_86":87,"_11":88,"_89":90,"_91":92,"_93":-5,"_94":-5,"_95":-5,"_96":26,"_97":98,"_99":100,"_101":-5,"_102":-5,"_103":104},"routes/_app.x.$handle.$name.search.$(branch)",{"_11":12,"_13":14,"_15":-5,"_16":17},"files",[],"project",{"_18":19,"_20":21,"_22":23,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":31,"_32":-5,"_33":34,"_35":-5,"_36":26,"_37":-5,"_38":-5,"_39":40,"_41":42,"_43":-5,"_44":-5,"_45":-5,"_46":-5,"_47":48,"_49":48,"_50":51,"_52":51,"_53":51,"_54":48,"_55":48,"_56":57,"_58":59,"_60":61,"_62":26},"query","handle","lupinarashi","id","8d4756f5-19a1-49b6-a7d2-fafaf13094d0","name","Admin-API","createdAt",["D",1781113739528],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","","imageUrl","userId","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",{"_16":17,"_81":77},"org",{"_16":17,"_75":-5,"_76":77,"_33":34,"_78":79,"_80":26},"branch",{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"isOwned","version",36,"main","be9a3c7e-6537-466c-a008-fb2f5fb80bba","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzNCWndldUNFUURoY3B1Uzk1d2lQOVhDTE8xaCJ9","tier","free","canRestrictVals","profileImageUrl","branchName","path","adoptOrgId",{"_18":19,"_20":21,"_22":153,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":31,"_32":-5,"_33":34,"_35":-5,"_36":26,"_37":-5,"_38":-5,"_39":40,"_41":42,"_43":-5,"_44":-5,"_45":-5,"_46":-5,"_47":48,"_49":48,"_50":51,"_52":51,"_53":51,"_54":48,"_55":48,"_56":154,"_58":155,"_60":156,"_62":26},"tree",[144,145],[144,145],"counts",{"_133":40,"_134":135,"_136":40,"_137":138,"_139":140},"contents",[105,106],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_18":125,"_20":126,"_109":127,"_111":-5,"_112":66,"_113":64,"_115":100,"_22":128,"_63":129,"_118":130,"_120":131,"_122":26,"_123":-5,"_83":132},{"_18":107,"_20":108,"_109":110,"_111":-5,"_112":66,"_113":114,"_115":100,"_22":116,"_63":117,"_118":119,"_120":121,"_122":26,"_123":-5,"_83":124},"b6f258c9-8116-4092-90d2-5b334675ee1f","customize.js","fileId","a903be66-64f4-11f1-8eb9-1607ee4eb77e","parentId","branchId","branchVersion",27,"latest",["D",1783999072389],13,"fileType","script","content","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};","deleted","label",[108],"0c96c955-37be-4779-a555-f88313cf2da5","Ruler-Hand.ts","d32af79a-64f4-11f1-941a-1607ee4eb77e",["D",1784113785947],21,"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 MANGA_TURSO,\n TABLE_FIELDS,\n TABLE_SOURCES,\n TURSO,\n UPSTASH,\n} from \"./customize.js\";\n\ntype JsonObject = Record;\ntype Row = Record;\n\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({\n url: MANGA_TURSO.url,\n authToken: MANGA_TURSO.authToken,\n});\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 if (Array.isArray(value)) {\n return value.map((entry) => String(entry)).join(\", \");\n }\n if (typeof value === \"object\") {\n try {\n return JSON.stringify(value);\n } catch {\n return String(value);\n }\n }\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 [\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\n// Iron-clad router to ensure manga tables always hit the manga DB\nfunction getTableSource(table: string): \"primary\" | \"manga\" {\n if (table === \"neon_manga_library\" || table === \"neon_manga_official\") {\n return \"manga\";\n }\n const mappedSource = TABLE_SOURCES[table as keyof typeof TABLE_SOURCES];\n return mappedSource === \"manga\" ? \"manga\" : \"primary\";\n}\n\nfunction tableClient(table: string) {\n return getTableSource(table) === \"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\n .filter((column) => column.pk > 0)\n .sort((a, b) => a.pk - b.pk)\n .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\")) {\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 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)) {\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 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\"))\n .join(\"\");\n}\n\nasync function selectAllRows(table: string): Promise {\n const client = tableClient(table);\n const result = await client.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 client = tableClient(table);\n const result = await client.execute({\n sql: `PRAGMA table_info(${escapeSqlIdentifier(table)})`,\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 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 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(\n table: string,\n manifest: CachedTableManifest,\n): Promise {\n const chunkCount = Math.max(0, Math.trunc(manifest.chunkCount));\n if (chunkCount === 0) return [];\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 return chunks.flat();\n}\n\nasync function deleteChunkedTableArtifacts(\n table: string,\n manifest: CachedTableManifest | null,\n): Promise {\n if (!manifest) {\n await redis.del(getManifestKey(table));\n return;\n }\n const chunkKeys = Array.from({\n length: Math.max(0, Math.trunc(manifest.chunkCount)),\n }, (_, 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(\n table: string,\n rows: Row[],\n): 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(\n (sum, chunk) => sum + utf8ByteLength(JSON.stringify(chunk)),\n 0,\n ),\n createdAt: new Date().toISOString(),\n };\n\n const pipeline = redis.pipeline();\n for (const [index, chunk] of chunks.entries()) {\n pipeline.set(getChunkKey(table, index), chunk);\n }\n pipeline.set(getManifestKey(table), manifest);\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 ) 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\") {\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 ensureTableMeta(table: string) {\n try {\n const schema = await readSchema(table);\n let storage = await readLegacyOrManifest(table);\n\n if (storage.kind === \"missing\") {\n await refreshCacheFromSql(table);\n storage = await readLegacyOrManifest(table);\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 table,\n source: getTableSource(table),\n schema: { columns: schema.columns },\n keyFields: schema.primaryKeyFields.length\n ? schema.primaryKeyFields\n : getTableKeyFields(table, schema.columns),\n manifest,\n };\n } catch (error) {\n trace(`[ensureTableMeta] graceful fail for table ${table}:`, error);\n return {\n table,\n source: getTableSource(table),\n schema: { columns: [] },\n keyFields: getTableKeyFields(table),\n manifest: {\n kind: CHUNK_MANIFEST_KIND,\n version: CHUNK_MANIFEST_VERSION,\n table,\n chunkCount: 0,\n totalRows: 0,\n totalBytes: 0,\n createdAt: new Date().toISOString(),\n },\n error: error instanceof Error ? error.message : String(error),\n };\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)) {\n return { ok: false, error: \"invalid table requested\" };\n }\n\n try {\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 let rows: Row[] = [];\n if (part !== null && Number.isFinite(part)) {\n const normalizedPart = Math.max(0, Math.trunc(part));\n rows = storage.kind === \"manifest\"\n ? await loadChunk(table, normalizedPart)\n : storage.kind === \"legacy\" && normalizedPart === 0\n ? storage.rows\n : [];\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, normalizedPart)\n : storage.kind === \"legacy\" && normalizedPart === 0\n ? storage.rows\n : [];\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 api: APP_NAME,\n table,\n part: Number.isFinite(part as number)\n ? Math.max(0, Math.trunc(part as number))\n : null,\n rows,\n schema: { columns: schema.columns },\n keyFields: schema.primaryKeyFields.length\n ? schema.primaryKeyFields\n : getTableKeyFields(table, schema.columns),\n source: getTableSource(table),\n manifest,\n };\n } catch (error) {\n return {\n ok: false,\n table,\n error: error instanceof Error ? error.message : String(error),\n };\n }\n }\n\n return {\n ok: true,\n api: APP_NAME,\n message: HEALTH_MESSAGE,\n tables: await readAllTableMeta(),\n };\n}\n\nfunction normalizeFilterMap(\n value: unknown,\n): Record> {\n const out: Record> = {};\n if (!isPlainObject(value)) return out;\n\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\nfunction buildWhereFromObject(\n value: JsonObject | Record> | null,\n allowedFields: Set,\n) {\n if (!value) return null;\n const entries = Object.entries(value).filter(([field]) =>\n allowedFields.has(field)\n );\n if (entries.length === 0) return null;\n\n const parts: string[] = [];\n const args: Array = [];\n\n for (const [field, raw] of entries) {\n const values = Array.isArray(raw) ? raw : flattenValues(raw);\n const actual = values.filter((entry) =>\n entry !== null && entry !== undefined && String(entry).trim() !== \"\"\n );\n if (actual.length === 0) continue;\n if (actual.length === 1) {\n parts.push(`${escapeSqlIdentifier(field)} = ?`);\n args.push(actual[0] as string | number | boolean);\n } else {\n parts.push(\n `${escapeSqlIdentifier(field)} IN (${\n actual.map(() => \"?\").join(\", \")\n })`,\n );\n args.push(...actual);\n }\n }\n\n if (!parts.length) return null;\n return { sql: parts.join(\" AND \"), args };\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(\n schema.columns.map((column) => String(column.name)),\n );\n return buildWhereFromObject(where, allowedFields);\n}\n\nasync function updateRows(\n table: string,\n where: JsonObject | null,\n patch: JsonObject,\n) {\n const whereClause = await buildSchemaWhere(table, where);\n if (!whereClause) return { updated: 0, reason: \"missing where clause\" };\n\n const schema = await readSchema(table);\n const allowedFields = new Set(\n schema.columns.map((column) => String(column.name)),\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 const client = tableClient(table);\n const result = await client.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\nasync function insertRows(table: string, rows: Row[]) {\n const schema = await readSchema(table);\n const allowedColumns = new Set(\n schema.columns.map((column) => String(column.name)),\n );\n const statements: Array<{ sql: string; args: unknown[] }> = [];\n\n for (const row of rows) {\n const entries = Object.entries(row).filter(([field, value]) =>\n allowedColumns.has(field) && value !== undefined\n );\n if (entries.length === 0) continue;\n statements.push({\n sql: `INSERT INTO ${escapeSqlIdentifier(table)} (${\n entries.map(([field]) => escapeSqlIdentifier(field)).join(\", \")\n }) VALUES (${entries.map(() => \"?\").join(\", \")})`,\n args: entries.map(([, value]) => normalizePrimitive(value)),\n });\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 {\n inserted: statements.length,\n skipped: rows.length - statements.length,\n };\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 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\n for (const item of keys) {\n if (isPlainObject(item)) {\n const fields = keyFields.map((field) => ({\n field,\n value: normalizePrimitive(item[field]),\n })).filter((entry) => entry.value !== null);\n if (fields.length !== keyFields.length) continue;\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 client = tableClient(table);\n const result = await client.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) as unknown,\n );\n const whereClause = buildWhereFromObject(filters, allowedFields);\n if (!whereClause) return { removed: 0, reason: \"no valid filters supplied\" };\n\n const client = tableClient(table);\n const result = await client.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 client = tableClient(table);\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 await client.execute({\n sql: `ALTER TABLE ${escapeSqlIdentifier(table)} ADD COLUMN ${\n escapeSqlIdentifier(field)\n } ${sanitizedType}${defaultSql}`,\n });\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({\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 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 === \"string\"\n ? 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 client = tableClient(table);\n\n await client.batch(\n [\n {\n sql: `CREATE TABLE ${escapeSqlIdentifier(tempTable)} (${\n columnDefs.join(\", \")\n })`,\n args: [],\n },\n {\n sql: `INSERT INTO ${escapeSqlIdentifier(tempTable)} (${\n columnNames.join(\", \")\n }) SELECT ${columnNames.join(\", \")} FROM ${escapeSqlIdentifier(table)}`,\n args: [],\n },\n { sql: `DROP TABLE ${escapeSqlIdentifier(table)}`, args: [] },\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 const client = tableClient(table);\n try {\n await client.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\nfunction parseTableList(value: unknown): string[] {\n return uniqueStrings(flattenValues(value)).filter((table) =>\n isAllowedTable(table)\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\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({\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 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({\n table,\n status: \"failed\",\n error: error instanceof Error ? error.message : String(error),\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) return { table, status: \"empty\", removed: 0, kept: 0 };\n const kept = rows.filter((row) =>\n !Object.entries(filters).every(([field, values]) =>\n values.some((value) =>\n String(row[field] ?? \"\").trim() === String(value).trim()\n )\n )\n );\n const removed = rows.length - kept.length;\n await saveCachedTable(table, kept);\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 if (fieldEntries.length === 0) {\n return {\n table,\n status: \"skipped\",\n reason: \"no valid fields supplied for this table\",\n };\n }\n const whereClause = buildWhereFromObject(\n Object.fromEntries(fieldEntries),\n allowedFields,\n );\n if (!whereClause) {\n return { table, status: \"skipped\", reason: \"unable to build where clause\" };\n }\n const client = tableClient(table);\n const result = await client.execute({\n sql: `DELETE FROM ${escapeSqlIdentifier(table)} WHERE ${whereClause.sql}`,\n args: whereClause.args,\n });\n return {\n table,\n status: \"ok\",\n removed: result.rowsAffected ?? 0,\n key: toTableKey(table),\n };\n}\n\nasync function handleExecuteCommand(command: JsonObject) {\n const table = String(command.table ?? command.name ?? \"\").trim();\n if (!table || !isAllowedTable(table)) {\n return { ok: false, error: \"invalid table supplied for execute\" };\n }\n\n const filters = normalizeFilterMap(\n command.filters ?? command.where ?? command.lnrmv ?? command.remove,\n );\n const provider = String(\n command.provider ?? command.storage ?? command.source ?? \"\",\n ).trim().toLowerCase();\n const useKv = provider === \"redis\" || provider === \"kv\" ||\n provider === \"upstash\" || Boolean(command.lnrmv);\n\n if (useKv) return await executeKvRowRemoval(table, filters);\n return await executeSqlRowRemoval(table, filters);\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\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 if (deleteTables.length) {\n results.push({\n action: \"delete\",\n tables: deleteTables,\n results: await handleDeleteTables(deleteTables),\n });\n }\n if (executeResult) {\n results.push({ action: \"execute\", result: executeResult });\n }\n if (!restoreTables.length && !deleteTables.length && !executeResult) {\n results.push({ action: \"noop\", command });\n }\n } catch (error) {\n results.push({\n action: \"failed\",\n error: error instanceof Error ? error.message : String(error),\n command,\n });\n }\n }\n return { ok: true, results };\n}\n\nasync function readRowsByIds(\n client: {\n execute: (\n args: { sql: string; args?: unknown[] },\n ) => Promise<{ rows?: unknown[] }>;\n },\n table: string,\n field: string,\n values: Array,\n stringMode = false,\n): Promise> {\n const out = new Map();\n for (const chunk of splitIntoChunks(values, 400)) {\n const placeholders = chunk.map(() => \"?\").join(\", \");\n const result = await client.execute({\n sql: `SELECT * FROM ${escapeSqlIdentifier(table)} WHERE ${\n escapeSqlIdentifier(field)\n } IN (${placeholders})`,\n args: chunk,\n });\n for (const row of (result.rows ?? []) as Row[]) {\n const key = String(row[field] ?? \"\").trim();\n if (key) out.set(stringMode ? key : key, row);\n }\n }\n return out;\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 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 ${\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 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 ${\n escapeSqlIdentifier(INTEGRATION.mangaTable)\n } WHERE ${\n escapeSqlIdentifier(INTEGRATION.mangaKey)\n } 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 ?? row.link ?? null,\n sha: row.sha ?? null,\n });\n }\n return out;\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 if (!id) continue;\n const key = `${id}`;\n if (seen.has(key)) continue;\n seen.add(key);\n out.push({\n id,\n mngakey: String(row.mngakey ?? \"\").trim(),\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 replaceRowsByKey(\n table: string,\n keyFields: string[],\n rows: Row[],\n) {\n const uniqueRows = (() => {\n const seen = new Set();\n const out: Row[] = [];\n for (const row of rows) {\n const signature = keyFields.map((field) =>\n String(row[field] ?? \"\").trim()\n ).join(\"::\");\n if (!signature || seen.has(signature)) continue;\n seen.add(signature);\n out.push(row);\n }\n return out;\n })();\n\n if (uniqueRows.length === 0) return { inserted: 0 };\n\n const statements: Array<{ sql: string; args: unknown[] }> = [];\n for (const row of uniqueRows) {\n const deleteWhere = keyFields.map((field) =>\n `${escapeSqlIdentifier(field)} = ?`\n ).join(\" AND \");\n statements.push({\n sql: `DELETE FROM ${escapeSqlIdentifier(table)} WHERE ${deleteWhere}`,\n args: keyFields.map((field) => normalizePrimitive(row[field])),\n });\n const entries = Object.entries(row).filter(([_, value]) =>\n value !== undefined\n );\n statements.push({\n sql: `INSERT INTO ${escapeSqlIdentifier(table)} (${\n entries.map(([field]) => escapeSqlIdentifier(field)).join(\", \")\n }) VALUES (${entries.map(() => \"?\").join(\", \")})`,\n args: entries.map(([, value]) => normalizePrimitive(value)),\n });\n }\n\n const client = tableClient(table);\n await client.batch(statements as any, \"write\");\n return { inserted: uniqueRows.length };\n}\n\nfunction parseIntegrationRecords(body: JsonObject) {\n const records: Array<{ int_id: number; id: string; key?: string }> = [];\n const seen = new Set();\n\n const pushRecord = (raw: unknown) => {\n if (!isPlainObject(raw)) return;\n const intIdRaw = raw.int_id ?? raw.intId ?? raw.cdn_id ?? raw.source_id ??\n raw.episode_id;\n const animeIdRaw = raw.target_id ?? raw.anime_id ?? raw.id ?? raw.animeId;\n const keyRaw = raw.key ?? raw.manga_key ?? raw.mngakey ?? raw.mangaKey ??\n body.mangaKey ?? body.manga_key;\n\n const intId = Number(intIdRaw);\n const animeId = String(animeIdRaw ?? \"\").trim();\n const key = keyRaw === undefined || keyRaw === null\n ? \"\"\n : String(keyRaw).trim();\n\n if (!Number.isFinite(intId) || !animeId) return;\n const signature = `${Math.trunc(intId)}::${animeId}::${key}`;\n if (seen.has(signature)) return;\n seen.add(signature);\n records.push({\n int_id: Math.trunc(intId),\n id: animeId,\n key: key || undefined,\n });\n };\n\n if (Array.isArray(body.records)) {\n for (const item of body.records) pushRecord(item);\n }\n\n const animeIds = Array.isArray(body.anime_ids)\n ? body.anime_ids\n : Array.isArray(body.animeIds)\n ? body.animeIds\n : null;\n const cdnIds = Array.isArray(body.cdn_ids)\n ? body.cdn_ids\n : Array.isArray(body.cdnIds)\n ? body.cdnIds\n : null;\n const mangaKeys = Array.isArray(body.manga_keys)\n ? body.manga_keys\n : Array.isArray(body.mangaKeys)\n ? body.mangaKeys\n : null;\n\n if (animeIds && cdnIds) {\n for (const animeIdRaw of animeIds) {\n const animeId = String(animeIdRaw ?? \"\").trim();\n if (!animeId) continue;\n for (const cdnIdRaw of cdnIds) {\n const intId = Number(cdnIdRaw);\n if (!Number.isFinite(intId)) continue;\n if (mangaKeys && mangaKeys.length) {\n for (const mangaKeyRaw of mangaKeys) {\n const key = String(mangaKeyRaw ?? \"\").trim();\n if (!key) continue;\n pushRecord({ int_id: intId, target_id: animeId, key });\n }\n } else {\n pushRecord({ int_id: intId, target_id: animeId });\n }\n }\n }\n }\n\n if (\n !records.length && body.int_id !== undefined &&\n (body.target_id !== undefined || body.anime_id !== undefined ||\n body.id !== undefined)\n ) {\n pushRecord(body);\n }\n\n return records;\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 records = parseIntegrationRecords(body);\n if (records.length === 0) {\n return { status: \"failed\", error: \"no integration pairs supplied\" };\n }\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 = [\n ...new Set(\n records.map((record) => record.key).filter((value): value is string =>\n typeof value === \"string\" && value.trim().length > 0\n ),\n ),\n ];\n\n const [episodeRows, animeRows, mangaRows] = await Promise.all([\n fetchRowsByIntIds(intIds),\n fetchRowsByAnimeIds(animeIds),\n mangaKeys.length\n ? fetchRowsByMangaKeys(mangaKeys)\n : 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\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 ?? episode.title ?? null,\n season: episode.season ?? anime.season ?? null,\n episode: episode.episode ?? null,\n stream: episode.link ?? episode.stream ?? 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 replaceRowsByKey(\n INTEGRATION.bridgeTable,\n [\"int_id\", \"id\"],\n normalizeConnectorRows(connectorRows),\n ),\n officialRows.length\n ? replaceRowsByKey(\n INTEGRATION.officialTable,\n [\"id\"],\n normalizeMangaOfficialRows(officialRows),\n )\n : Promise.resolve({ inserted: 0 }),\n ]);\n\n // Target isolation tracking ensures we do not execute cache rebuild operations on Manga chunks unnecessarily\n const refreshTargets = [INTEGRATION.bridgeTable];\n if (officialRows.length > 0) {\n refreshTargets.push(INTEGRATION.mangaTable, INTEGRATION.officialTable);\n }\n\n const refreshed: Record = {};\n for (const table of refreshTargets) {\n try {\n refreshed[table] = await refreshCacheFromSql(table);\n } catch (error) {\n refreshed[table] = {\n error: error instanceof Error ? error.message : String(error),\n };\n }\n }\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 };\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)) {\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: { rows: refreshed.rows, manifest: refreshed.manifest },\n };\n } else if (action === \"restore-cache\" || action === \"restore\") {\n await deleteCachedTable(table);\n refreshed = await refreshCacheFromSql(table);\n return {\n ok: true,\n table,\n action,\n result: { rows: refreshed.rows, manifest: refreshed.manifest },\n };\n } else {\n return { ok: false, error: `unsupported action: ${action || \"(empty)\"}` };\n }\n\n refreshed = await refreshCacheFromSql(table);\n return {\n ok: true,\n table,\n action,\n result,\n refreshed: { rows: refreshed.rows, manifest: refreshed.manifest },\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}\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\") {\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 objectBody = isPlainObject(body) ? body : {};\n\n if (path === \"/bootroot-data\") {\n return jsonResponse(await handleBootrootData(objectBody));\n }\n if (path === \"/integrate-sqldata\") {\n return jsonResponse(await handleIntegrateSqlData(objectBody));\n }\n if (path === \"/table-admin\") {\n return jsonResponse(await handleTableAdmin(objectBody));\n }\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({\n ok: false,\n error: error instanceof Error ? error.message : String(error),\n }, 500);\n }\n}",[126],"pulls","branches",1,"forks","envVars",{"_141":40,"_143":40},"connections",{"_141":40,"_142":40},"count","unfilledCount","emptyCount",{"_18":125,"_20":126,"_109":127,"_111":-5,"_112":66,"_113":64,"_115":100,"_22":150,"_63":129,"_118":130,"_120":131,"_122":26,"_123":-5,"_147":151,"_83":152},{"_18":107,"_20":108,"_109":110,"_111":-5,"_112":66,"_113":114,"_115":100,"_22":146,"_63":117,"_118":119,"_120":121,"_122":26,"_123":-5,"_147":148,"_83":149},["D",1783999072389],"children",[],[108],["D",1784113785947],[],[126],["D",1781113739528],{"_16":17,"_81":77},{"_16":17,"_75":-5,"_76":77,"_33":34,"_78":79,"_80":26},{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"ctx",{"_56":-5,"_102":190,"_191":192,"_193":194,"_195":26,"_196":26,"_197":26,"_198":100,"_199":-5,"_200":-7,"_201":-7,"_202":40,"_203":26,"_204":26,"_205":-5,"_206":26,"_207":26,"_208":26,"_209":-5},"ENV",{"_161":162,"_163":164,"_165":65,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189},"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"]

Search