[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_152":153,"_154":155},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_103":85,"_27":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":58,"_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":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",2,"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","main.tsx","latestPath","fileId","e68fc940-55b9-11f1-a446-ee650bb23af1","name","fileType","http","content","import { Hono } from \"npm:hono\";\nimport { cors } from \"npm:hono/cors\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst MOCK_BASE = \"https://vlduy123--5a73622e559a11f1a2c7ee650bb23af1.web.val.run\";\nconst MOCK_KEY = Deno.env.get(\"API_KEY\") ?? \"ewm-demo-key-aihive-2025\";\n\nconst ENTITIES = [\n \"WarehouseOrders\",\n \"TransferOrders\",\n \"StockPositions\",\n \"InboundDeliveries\",\n \"OutboundDeliveries\",\n \"Waves\",\n];\n\nconst STRATEGIES = [\"per-record\", \"group-warehouse\", \"token-budget\", \"field-window\"] as const;\ntype Strategy = typeof STRATEGIES[number];\n\nasync function initDb() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ingest_runs (\n run_id TEXT PRIMARY KEY,\n entity TEXT NOT NULL,\n strategy TEXT NOT NULL,\n warehouse_id TEXT,\n token_budget INTEGER,\n field_window INTEGER,\n record_limit INTEGER,\n status TEXT NOT NULL,\n total_chunks INTEGER DEFAULT 0,\n total_records INTEGER DEFAULT 0,\n total_tokens INTEGER DEFAULT 0,\n started_at TEXT DEFAULT (datetime('now')),\n finished_at TEXT,\n error TEXT\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS chunks (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n run_id TEXT NOT NULL,\n entity TEXT NOT NULL,\n strategy TEXT NOT NULL,\n warehouse_id TEXT,\n chunk_index INTEGER NOT NULL,\n record_count INTEGER NOT NULL,\n tokens INTEGER NOT NULL,\n payload TEXT NOT NULL,\n created_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_chunks_run ON chunks(run_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_chunks_entity ON chunks(entity)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_runs_started ON ingest_runs(started_at DESC)`);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS plants (\n id TEXT PRIMARY KEY, name TEXT, country TEXT, region TEXT, currency TEXT,\n data TEXT NOT NULL, updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS warehouses (\n id TEXT PRIMARY KEY, plant_id TEXT, plant_name TEXT, type TEXT, country TEXT, region TEXT,\n data TEXT NOT NULL, updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS entity_records (\n entity TEXT NOT NULL, record_id TEXT NOT NULL,\n warehouse_id TEXT, plant_id TEXT, status TEXT,\n data TEXT NOT NULL, updated_at TEXT DEFAULT (datetime('now')),\n PRIMARY KEY (entity, record_id)\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_entity_records_wh ON entity_records(entity, warehouse_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_entity_records_status ON entity_records(entity, status)`);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS seed_runs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n entity TEXT NOT NULL, warehouse_id TEXT, limit_param INTEGER,\n inserted INTEGER DEFAULT 0, status TEXT NOT NULL,\n started_at TEXT DEFAULT (datetime('now')), finished_at TEXT, error TEXT\n )\n `);\n}\n\nconst ID_FIELDS: Record = {\n WarehouseOrders: [\"WarehouseOrderID\"],\n TransferOrders: [\"TransferOrderID\"],\n InboundDeliveries: [\"InboundDeliveryID\"],\n OutboundDeliveries: [\"OutboundDeliveryID\"],\n Waves: [\"WaveID\"],\n StockPositions: [\"PositionID\", \"id\", \"ID\"],\n};\nfunction pickField(r: any, candidates: string[]): string | null {\n for (const k of candidates) if (r[k] != null) return String(r[k]);\n return null;\n}\nconst getRecordId = (entity: string, r: any, idx: number) =>\n pickField(r, ID_FIELDS[entity] || []) ?? `${entity}-${idx}`;\nconst getWarehouseId = (r: any) => pickField(r, [\"WarehouseNo\", \"warehouseId\", \"WarehouseID\", \"warehouse_id\"]);\nconst getPlantId = (r: any) => pickField(r, [\"PlantID\", \"plantId\", \"plant_id\"]);\nconst getStatus = (r: any) => pickField(r, [\"Status\", \"status\"]);\n\nfunction approxTokens(text: string): number { return Math.ceil(text.length / 4); }\n\nasync function fetchMockPage(entity: string, opts: { warehouseId?: string; skip?: number; top?: number }) {\n const params = new URLSearchParams();\n if (opts.warehouseId) params.set(\"warehouseId\", opts.warehouseId);\n if (opts.skip !== undefined) params.set(\"$skip\", String(opts.skip));\n if (opts.top !== undefined) params.set(\"$top\", String(opts.top));\n const url = `${MOCK_BASE}/api/ewm/${entity}?${params.toString()}`;\n const res = await fetch(url, { headers: { \"X-API-Key\": MOCK_KEY } });\n if (!res.ok) throw new Error(`mock ${res.status}: ${await res.text()}`);\n return res.json();\n}\n\nasync function* iterateRecords(entity: string, opts: { warehouseId?: string; limit: number }) {\n const PAGE = 500;\n let offset = 0, yielded = 0;\n while (yielded < opts.limit) {\n const top = Math.min(PAGE, opts.limit - yielded);\n const args: any[] = [entity];\n let where = \"entity = ?\";\n if (opts.warehouseId) { where += \" AND warehouse_id = ?\"; args.push(opts.warehouseId); }\n args.push(top, offset);\n const res = await sqlite.execute({\n sql: `SELECT data FROM entity_records WHERE ${where} ORDER BY record_id LIMIT ? OFFSET ?`,\n args,\n });\n if (!res.rows.length) return;\n for (const row of res.rows as any[]) {\n yield JSON.parse(row[0]);\n yielded++;\n if (yielded >= opts.limit) return;\n }\n if (res.rows.length < top) return;\n offset += res.rows.length;\n }\n}\n\ntype ChunkRow = {\n warehouseId: string | null; chunkIndex: number;\n recordCount: number; tokens: number; payload: string;\n};\n\nasync function chunkPerRecord(entity: string, opts: { warehouseId?: string; limit: number }): Promise {\n const out: ChunkRow[] = [];\n let idx = 0;\n for await (const r of iterateRecords(entity, opts)) {\n const payload = JSON.stringify(r);\n out.push({ warehouseId: r.warehouseId ?? null, chunkIndex: idx++, recordCount: 1, tokens: approxTokens(payload), payload });\n }\n return out;\n}\nasync function chunkGroupWarehouse(entity: string, opts: { warehouseId?: string; limit: number }): Promise {\n const groups = new Map();\n for await (const r of iterateRecords(entity, opts)) {\n const wh = getWarehouseId(r) ?? \"_unknown\";\n if (!groups.has(wh)) groups.set(wh, []);\n groups.get(wh)!.push(r);\n }\n const out: ChunkRow[] = [];\n let idx = 0;\n for (const [wh, recs] of groups) {\n const payload = JSON.stringify({ warehouseId: wh, entity, records: recs });\n out.push({ warehouseId: wh, chunkIndex: idx++, recordCount: recs.length, tokens: approxTokens(payload), payload });\n }\n return out;\n}\nasync function chunkTokenBudget(entity: string, opts: { warehouseId?: string; limit: number; tokenBudget: number }): Promise {\n const out: ChunkRow[] = [];\n let buf: any[] = [], bufTokens = 0, idx = 0, bufWh: string | null = null;\n const flush = () => {\n if (!buf.length) return;\n const payload = JSON.stringify({ entity, records: buf });\n out.push({ warehouseId: bufWh, chunkIndex: idx++, recordCount: buf.length, tokens: approxTokens(payload), payload });\n buf = []; bufTokens = 0; bufWh = null;\n };\n for await (const r of iterateRecords(entity, opts)) {\n const t = approxTokens(JSON.stringify(r));\n if (bufTokens + t > opts.tokenBudget && buf.length) flush();\n const wh = getWarehouseId(r);\n if (bufWh === null) bufWh = wh;\n else if (bufWh !== wh) bufWh = null;\n buf.push(r); bufTokens += t;\n }\n flush();\n return out;\n}\nasync function chunkFieldWindow(entity: string, opts: { warehouseId?: string; limit: number; windowSize: number }): Promise {\n const out: ChunkRow[] = [];\n let idx = 0;\n for await (const r of iterateRecords(entity, opts)) {\n const subArrays: [string, any[]][] = [];\n for (const [k, v] of Object.entries(r)) if (Array.isArray(v) && v.length > opts.windowSize) subArrays.push([k, v]);\n if (!subArrays.length) {\n const payload = JSON.stringify(r);\n out.push({ warehouseId: getWarehouseId(r), chunkIndex: idx++, recordCount: 1, tokens: approxTokens(payload), payload });\n continue;\n }\n for (const [field, arr] of subArrays) {\n for (let i = 0; i < arr.length; i += opts.windowSize) {\n const slice = arr.slice(i, i + opts.windowSize);\n const head = { ...r };\n for (const [f] of subArrays) delete (head as any)[f];\n const payload = JSON.stringify({ parent: head, field, window: { offset: i, size: slice.length, total: arr.length }, items: slice });\n out.push({ warehouseId: getWarehouseId(r), chunkIndex: idx++, recordCount: slice.length, tokens: approxTokens(payload), payload });\n }\n }\n }\n return out;\n}\n\nasync function runIngest(p: { runId: string; entity: string; strategy: Strategy; warehouseId?: string; limit: number; tokenBudget: number; windowSize: number; }) {\n try {\n let rows: ChunkRow[];\n if (p.strategy === \"per-record\") rows = await chunkPerRecord(p.entity, p);\n else if (p.strategy === \"group-warehouse\") rows = await chunkGroupWarehouse(p.entity, p);\n else if (p.strategy === \"token-budget\") rows = await chunkTokenBudget(p.entity, p);\n else rows = await chunkFieldWindow(p.entity, p);\n for (const row of rows) {\n await sqlite.execute({\n sql: `INSERT INTO chunks (run_id, entity, strategy, warehouse_id, chunk_index, record_count, tokens, payload)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [p.runId, p.entity, p.strategy, row.warehouseId, row.chunkIndex, row.recordCount, row.tokens, row.payload],\n });\n }\n const totalRecords = rows.reduce((a, r) => a + r.recordCount, 0);\n const totalTokens = rows.reduce((a, r) => a + r.tokens, 0);\n await sqlite.execute({\n sql: `UPDATE ingest_runs SET status='done', total_chunks=?, total_records=?, total_tokens=?, finished_at=datetime('now') WHERE run_id=?`,\n args: [rows.length, totalRecords, totalTokens, p.runId],\n });\n } catch (e: any) {\n await sqlite.execute({\n sql: `UPDATE ingest_runs SET status='failed', error=?, finished_at=datetime('now') WHERE run_id=?`,\n args: [String(e?.message ?? e), p.runId],\n });\n }\n}\n\nfunction rowsToObjects(res: any): any[] {\n const cols: string[] = res.columns;\n return (res.rows as any[]).map((row) => {\n const o: any = {};\n cols.forEach((col, i) => { o[col] = row[i]; });\n return o;\n });\n}\nconst rowToObject = (res: any) => rowsToObjects(res)[0];\n\nconst app = new Hono();\napp.use(\"*\", cors());\n\napp.get(\"/\", (c) => c.json({\n service: \"ewmBackend\",\n description: \"SAP EWM data + chunking API, SQLite-backed, sources from ewmMockServer\",\n endpoints: [\n \"GET /api/health\", \"GET /api/entities\", \"GET /api/warehouses\",\n \"POST /api/seed/master\", \"POST /api/seed\", \"GET /api/seed/stats\",\n \"GET /api/data/:entity\",\n \"POST /api/ingest\", \"GET /api/runs\", \"DELETE /api/runs/:id\",\n \"GET /api/chunks\", \"GET /api/chunks/:id\", \"GET /api/stats\",\n ],\n}));\n\napp.get(\"/api/health\", (c) => c.json({ ok: true, mock: MOCK_BASE }));\napp.get(\"/api/entities\", (c) => c.json({ entities: ENTITIES, strategies: STRATEGIES }));\n\napp.get(\"/api/warehouses\", async (c) => {\n await initDb();\n const res = await sqlite.execute(`SELECT data FROM warehouses ORDER BY id`);\n const value = (res.rows as any[]).map((r) => JSON.parse(r[0]));\n return c.json({ \"@odata.count\": value.length, value });\n});\n\napp.post(\"/api/seed/master\", async (c) => {\n await initDb();\n let plants = 0, warehouses = 0;\n try {\n const pData = await (await fetch(`${MOCK_BASE}/api/ewm/plants`, { headers: { \"X-API-Key\": MOCK_KEY } })).json();\n for (const p of pData.value || []) {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO plants (id, name, country, region, currency, data, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, datetime('now'))`,\n args: [String(p.id), p.name ?? null, p.country ?? null, p.region ?? null, p.currency ?? null, JSON.stringify(p)],\n });\n plants++;\n }\n const wData = await (await fetch(`${MOCK_BASE}/api/ewm/warehouses`, { headers: { \"X-API-Key\": MOCK_KEY } })).json();\n for (const w of wData.value || []) {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO warehouses (id, plant_id, plant_name, type, country, region, data, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, datetime('now'))`,\n args: [String(w.id), w.plantId ?? null, w.plantName ?? null, w.type ?? null, w.country ?? null, w.region ?? null, JSON.stringify(w)],\n });\n warehouses++;\n }\n return c.json({ ok: true, plants, warehouses });\n } catch (e: any) {\n return c.json({ ok: false, plants, warehouses, error: String(e?.message ?? e) }, 500);\n }\n});\n\napp.post(\"/api/seed\", async (c) => {\n await initDb();\n const body = await c.req.json();\n const entity = String(body.entity);\n const warehouseId = body.warehouseId ? String(body.warehouseId) : undefined;\n const limit = Math.min(Math.max(parseInt(body.limit ?? \"1000\"), 1), 100000);\n if (!ENTITIES.includes(entity)) return c.json({ error: \"invalid entity\" }, 400);\n\n const seedRes = await sqlite.execute({\n sql: `INSERT INTO seed_runs (entity, warehouse_id, limit_param, status) VALUES (?, ?, ?, 'running')`,\n args: [entity, warehouseId ?? null, limit],\n });\n const seedId = (seedRes as any).lastInsertRowid ?? (seedRes as any).rowsAffected;\n\n let inserted = 0, idx = 0;\n try {\n const PAGE = 500;\n let skip = 0;\n while (inserted < limit) {\n const top = Math.min(PAGE, limit - inserted);\n const page = await fetchMockPage(entity, { warehouseId, skip, top });\n const value = (page.value as any[]) || [];\n if (!value.length) break;\n for (const r of value) {\n const id = getRecordId(entity, r, idx++);\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO entity_records (entity, record_id, warehouse_id, plant_id, status, data, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, datetime('now'))`,\n args: [entity, id, getWarehouseId(r), getPlantId(r), getStatus(r), JSON.stringify(r)],\n });\n inserted++;\n if (inserted >= limit) break;\n }\n if (value.length < top) break;\n skip += value.length;\n }\n await sqlite.execute({\n sql: `UPDATE seed_runs SET status='done', inserted=?, finished_at=datetime('now') WHERE id=?`,\n args: [inserted, seedId],\n });\n return c.json({ ok: true, entity, warehouseId, inserted, seedId });\n } catch (e: any) {\n await sqlite.execute({\n sql: `UPDATE seed_runs SET status='failed', inserted=?, error=?, finished_at=datetime('now') WHERE id=?`,\n args: [inserted, String(e?.message ?? e), seedId],\n });\n return c.json({ ok: false, entity, warehouseId, inserted, error: String(e?.message ?? e) }, 500);\n }\n});\n\napp.get(\"/api/seed/stats\", async (c) => {\n await initDb();\n const counts = await sqlite.execute(`SELECT entity, COUNT(*) as n, MAX(updated_at) as latest FROM entity_records GROUP BY entity`);\n const whCount = await sqlite.execute(`SELECT COUNT(*) as n FROM warehouses`);\n const plantCount = await sqlite.execute(`SELECT COUNT(*) as n FROM plants`);\n const runs = await sqlite.execute(`SELECT id, entity, warehouse_id, limit_param, inserted, status, started_at, finished_at, error FROM seed_runs ORDER BY started_at DESC LIMIT 20`);\n return c.json({\n byEntity: rowsToObjects(counts),\n warehouses: (whCount.rows[0] as any)[0],\n plants: (plantCount.rows[0] as any)[0],\n runs: rowsToObjects(runs),\n });\n});\n\napp.get(\"/api/data/:entity\", async (c) => {\n await initDb();\n const entity = c.req.param(\"entity\");\n if (!ENTITIES.includes(entity)) return c.json({ error: \"invalid entity\" }, 400);\n const warehouseId = c.req.query(\"warehouseId\");\n const top = Math.min(parseInt(c.req.query(\"$top\") ?? \"25\"), 500);\n const skip = parseInt(c.req.query(\"$skip\") ?? \"0\");\n\n const args: any[] = [entity];\n let where = \"entity = ?\";\n if (warehouseId) { where += \" AND warehouse_id = ?\"; args.push(warehouseId); }\n\n const total = await sqlite.execute({ sql: `SELECT COUNT(*) FROM entity_records WHERE ${where}`, args });\n const rows = await sqlite.execute({\n sql: `SELECT data FROM entity_records WHERE ${where} ORDER BY record_id LIMIT ? OFFSET ?`,\n args: [...args, top, skip],\n });\n return c.json({\n \"@odata.context\": `$metadata#${entity}`,\n \"@odata.count\": (total.rows[0] as any)[0],\n value: (rows.rows as any[]).map((r) => JSON.parse(r[0])),\n });\n});\n\napp.post(\"/api/ingest\", async (c) => {\n await initDb();\n const body = await c.req.json();\n const entity = String(body.entity);\n const strategy = String(body.strategy) as Strategy;\n const warehouseId = body.warehouseId ? String(body.warehouseId) : undefined;\n const limit = Math.min(Math.max(parseInt(body.limit ?? \"1000\"), 1), 50000);\n const tokenBudget = Math.max(parseInt(body.tokenBudget ?? \"2000\"), 100);\n const windowSize = Math.max(parseInt(body.windowSize ?? \"50\"), 1);\n if (!ENTITIES.includes(entity)) return c.json({ error: \"invalid entity\" }, 400);\n if (!STRATEGIES.includes(strategy)) return c.json({ error: \"invalid strategy\" }, 400);\n\n const runId = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO ingest_runs (run_id, entity, strategy, warehouse_id, token_budget, field_window, record_limit, status)\n VALUES (?, ?, ?, ?, ?, ?, ?, 'running')`,\n args: [runId, entity, strategy, warehouseId ?? null, tokenBudget, windowSize, limit],\n });\n await runIngest({ runId, entity, strategy, warehouseId, limit, tokenBudget, windowSize });\n const out = await sqlite.execute({ sql: `SELECT * FROM ingest_runs WHERE run_id=?`, args: [runId] });\n return c.json({ run: rowToObject(out) });\n});\n\napp.get(\"/api/runs\", async (c) => {\n await initDb();\n const limit = Math.min(parseInt(c.req.query(\"limit\") ?? \"50\"), 200);\n const res = await sqlite.execute({ sql: `SELECT * FROM ingest_runs ORDER BY started_at DESC LIMIT ?`, args: [limit] });\n return c.json({ runs: rowsToObjects(res) });\n});\n\napp.get(\"/api/chunks\", async (c) => {\n await initDb();\n const runId = c.req.query(\"run_id\");\n const entity = c.req.query(\"entity\");\n const strategy = c.req.query(\"strategy\");\n const limit = Math.min(parseInt(c.req.query(\"limit\") ?? \"100\"), 500);\n const offset = parseInt(c.req.query(\"offset\") ?? \"0\");\n const includePayload = c.req.query(\"payload\") === \"1\";\n\n const wheres: string[] = [];\n const args: any[] = [];\n if (runId) { wheres.push(\"run_id = ?\"); args.push(runId); }\n if (entity) { wheres.push(\"entity = ?\"); args.push(entity); }\n if (strategy) { wheres.push(\"strategy = ?\"); args.push(strategy); }\n const where = wheres.length ? `WHERE ${wheres.join(\" AND \")}` : \"\";\n\n const fields = includePayload\n ? \"id, run_id, entity, strategy, warehouse_id, chunk_index, record_count, tokens, payload, created_at\"\n : \"id, run_id, entity, strategy, warehouse_id, chunk_index, record_count, tokens, created_at\";\n\n const res = await sqlite.execute({\n sql: `SELECT ${fields} FROM chunks ${where} ORDER BY id DESC LIMIT ? OFFSET ?`,\n args: [...args, limit, offset],\n });\n const countRes = await sqlite.execute({ sql: `SELECT COUNT(*) as n FROM chunks ${where}`, args });\n return c.json({ chunks: rowsToObjects(res), total: (countRes.rows[0] as any)[0] });\n});\n\napp.get(\"/api/chunks/:id\", async (c) => {\n await initDb();\n const id = parseInt(c.req.param(\"id\"));\n const res = await sqlite.execute({ sql: `SELECT * FROM chunks WHERE id = ?`, args: [id] });\n if (!res.rows.length) return c.json({ error: \"not found\" }, 404);\n return c.json({ chunk: rowToObject(res) });\n});\n\napp.get(\"/api/stats\", async (c) => {\n await initDb();\n const totals = await sqlite.execute(`SELECT COUNT(*) as total_chunks, COALESCE(SUM(record_count),0) as total_records, COALESCE(SUM(tokens),0) as total_tokens FROM chunks`);\n const byEntity = await sqlite.execute(`SELECT entity, COUNT(*) as chunks, SUM(record_count) as records, SUM(tokens) as tokens FROM chunks GROUP BY entity ORDER BY chunks DESC`);\n const byStrategy = await sqlite.execute(`SELECT strategy, COUNT(*) as chunks, SUM(record_count) as records, SUM(tokens) as tokens FROM chunks GROUP BY strategy ORDER BY chunks DESC`);\n const runStats = await sqlite.execute(`SELECT status, COUNT(*) as n FROM ingest_runs GROUP BY status`);\n return c.json({\n totals: rowsToObjects(totals)[0],\n byEntity: rowsToObjects(byEntity),\n byStrategy: rowsToObjects(byStrategy),\n runStats: rowsToObjects(runStats),\n });\n});\n\napp.delete(\"/api/runs/:id\", async (c) => {\n await initDb();\n const runId = c.req.param(\"id\");\n await sqlite.execute({ sql: `DELETE FROM chunks WHERE run_id = ?`, args: [runId] });\n await sqlite.execute({ sql: `DELETE FROM ingest_runs WHERE run_id = ?`, args: [runId] });\n return c.json({ deleted: runId });\n});\n\nexport default app.fetch;\n","import { Hono } from \"npm:hono\";\nimport { cors } from \"npm:hono/cors\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst MOCK_BASE = \"https://vlduy123--5a73622e559a11f1a2c7ee650bb23af1.web.val.run\";\nconst MOCK_KEY = Deno.env.get(\"API_KEY\") ?? \"ewm-demo-key-aihive-2025\";\n\nconst ENTITIES = [\n \"WarehouseOrders\",\n \"TransferOrders\",\n \"StockPositions\",\n \"InboundDeliveries\",\n \"OutboundDeliveries\",\n \"Waves\",\n];\n\nconst STRATEGIES = [\"per-record\", \"group-warehouse\", \"token-budget\", \"field-window\"] as const;\ntype Strategy = typeof STRATEGIES[number];\n\nasync function initDb() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ingest_runs (\n run_id TEXT PRIMARY KEY,\n entity TEXT NOT NULL,\n strategy TEXT NOT NULL,\n warehouse_id TEXT,\n token_budget INTEGER,\n field_window INTEGER,\n record_limit INTEGER,\n status TEXT NOT NULL,\n total_chunks INTEGER DEFAULT 0,\n total_records INTEGER DEFAULT 0,\n total_tokens INTEGER DEFAULT 0,\n started_at TEXT DEFAULT (datetime('now')),\n finished_at TEXT,\n error TEXT\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS chunks (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n run_id TEXT NOT NULL,\n entity TEXT NOT NULL,\n strategy TEXT NOT NULL,\n warehouse_id TEXT,\n chunk_index INTEGER NOT NULL,\n record_count INTEGER NOT NULL,\n tokens INTEGER NOT NULL,\n payload TEXT NOT NULL,\n created_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_chunks_run ON chunks(run_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_chunks_entity ON chunks(entity)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_runs_started ON ingest_runs(started_at DESC)`);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS plants (\n id TEXT PRIMARY KEY, name TEXT, country TEXT, region TEXT, currency TEXT,\n data TEXT NOT NULL, updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS warehouses (\n id TEXT PRIMARY KEY, plant_id TEXT, plant_name TEXT, type TEXT, country TEXT, region TEXT,\n data TEXT NOT NULL, updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS entity_records (\n entity TEXT NOT NULL, record_id TEXT NOT NULL,\n warehouse_id TEXT, plant_id TEXT, status TEXT,\n data TEXT NOT NULL, updated_at TEXT DEFAULT (datetime('now')),\n PRIMARY KEY (entity, record_id)\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_entity_records_wh ON entity_records(entity, warehouse_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_entity_records_status ON entity_records(entity, status)`);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS seed_runs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n entity TEXT NOT NULL, warehouse_id TEXT, limit_param INTEGER,\n inserted INTEGER DEFAULT 0, status TEXT NOT NULL,\n started_at TEXT DEFAULT (datetime('now')), finished_at TEXT, error TEXT\n )\n `);\n}\n\nconst ID_FIELDS: Record = {\n WarehouseOrders: [\"WarehouseOrderID\"],\n TransferOrders: [\"TransferOrderID\"],\n InboundDeliveries: [\"InboundDeliveryID\"],\n OutboundDeliveries: [\"OutboundDeliveryID\"],\n Waves: [\"WaveID\"],\n StockPositions: [\"PositionID\", \"id\", \"ID\"],\n};\nfunction pickField(r: any, candidates: string[]): string | null {\n for (const k of candidates) if (r[k] != null) return String(r[k]);\n return null;\n}\nconst getRecordId = (entity: string, r: any, idx: number) =>\n pickField(r, ID_FIELDS[entity] || []) ?? `${entity}-${idx}`;\nconst getWarehouseId = (r: any) => pickField(r, [\"WarehouseNo\", \"warehouseId\", \"WarehouseID\", \"warehouse_id\"]);\nconst getPlantId = (r: any) => pickField(r, [\"PlantID\", \"plantId\", \"plant_id\"]);\nconst getStatus = (r: any) => pickField(r, [\"Status\", \"status\"]);\n\nfunction approxTokens(text: string): number { return Math.ceil(text.length / 4); }\n\nasync function fetchMockPage(entity: string, opts: { warehouseId?: string; skip?: number; top?: number }) {\n const params = new URLSearchParams();\n if (opts.warehouseId) params.set(\"warehouseId\", opts.warehouseId);\n if (opts.skip !== undefined) params.set(\"$skip\", String(opts.skip));\n if (opts.top !== undefined) params.set(\"$top\", String(opts.top));\n const url = `${MOCK_BASE}/api/ewm/${entity}?${params.toString()}`;\n const res = await fetch(url, { headers: { \"X-API-Key\": MOCK_KEY } });\n if (!res.ok) throw new Error(`mock ${res.status}: ${await res.text()}`);\n return res.json();\n}\n\nasync function* iterateRecords(entity: string, opts: { warehouseId?: string; limit: number }) {\n const PAGE = 500;\n let offset = 0, yielded = 0;\n while (yielded < opts.limit) {\n const top = Math.min(PAGE, opts.limit - yielded);\n const args: any[] = [entity];\n let where = \"entity = ?\";\n if (opts.warehouseId) { where += \" AND warehouse_id = ?\"; args.push(opts.warehouseId); }\n args.push(top, offset);\n const res = await sqlite.execute({\n sql: `SELECT data FROM entity_records WHERE ${where} ORDER BY record_id LIMIT ? OFFSET ?`,\n args,\n });\n if (!res.rows.length) return;\n for (const row of res.rows as any[]) {\n yield JSON.parse(row[0]);\n yielded++;\n if (yielded >= opts.limit) return;\n }\n if (res.rows.length < top) return;\n offset += res.rows.length;\n }\n}\n\ntype ChunkRow = {\n warehouseId: string | null; chunkIndex: number;\n recordCount: number; tokens: number; payload: string;\n};\n\nasync function chunkPerRecord(entity: string, opts: { warehouseId?: string; limit: number }): Promise {\n const out: ChunkRow[] = [];\n let idx = 0;\n for await (const r of iterateRecords(entity, opts)) {\n const payload = JSON.stringify(r);\n out.push({ warehouseId: r.warehouseId ?? null, chunkIndex: idx++, recordCount: 1, tokens: approxTokens(payload), payload });\n }\n return out;\n}\nasync function chunkGroupWarehouse(entity: string, opts: { warehouseId?: string; limit: number }): Promise {\n const groups = new Map();\n for await (const r of iterateRecords(entity, opts)) {\n const wh = getWarehouseId(r) ?? \"_unknown\";\n if (!groups.has(wh)) groups.set(wh, []);\n groups.get(wh)!.push(r);\n }\n const out: ChunkRow[] = [];\n let idx = 0;\n for (const [wh, recs] of groups) {\n const payload = JSON.stringify({ warehouseId: wh, entity, records: recs });\n out.push({ warehouseId: wh, chunkIndex: idx++, recordCount: recs.length, tokens: approxTokens(payload), payload });\n }\n return out;\n}\nasync function chunkTokenBudget(entity: string, opts: { warehouseId?: string; limit: number; tokenBudget: number }): Promise {\n const out: ChunkRow[] = [];\n let buf: any[] = [], bufTokens = 0, idx = 0, bufWh: string | null = null;\n const flush = () => {\n if (!buf.length) return;\n const payload = JSON.stringify({ entity, records: buf });\n out.push({ warehouseId: bufWh, chunkIndex: idx++, recordCount: buf.length, tokens: approxTokens(payload), payload });\n buf = []; bufTokens = 0; bufWh = null;\n };\n for await (const r of iterateRecords(entity, opts)) {\n const t = approxTokens(JSON.stringify(r));\n if (bufTokens + t > opts.tokenBudget && buf.length) flush();\n const wh = getWarehouseId(r);\n if (bufWh === null) bufWh = wh;\n else if (bufWh !== wh) bufWh = null;\n buf.push(r); bufTokens += t;\n }\n flush();\n return out;\n}\nasync function chunkFieldWindow(entity: string, opts: { warehouseId?: string; limit: number; windowSize: number }): Promise {\n const out: ChunkRow[] = [];\n let idx = 0;\n for await (const r of iterateRecords(entity, opts)) {\n const subArrays: [string, any[]][] = [];\n for (const [k, v] of Object.entries(r)) if (Array.isArray(v) && v.length > opts.windowSize) subArrays.push([k, v]);\n if (!subArrays.length) {\n const payload = JSON.stringify(r);\n out.push({ warehouseId: getWarehouseId(r), chunkIndex: idx++, recordCount: 1, tokens: approxTokens(payload), payload });\n continue;\n }\n for (const [field, arr] of subArrays) {\n for (let i = 0; i < arr.length; i += opts.windowSize) {\n const slice = arr.slice(i, i + opts.windowSize);\n const head = { ...r };\n for (const [f] of subArrays) delete (head as any)[f];\n const payload = JSON.stringify({ parent: head, field, window: { offset: i, size: slice.length, total: arr.length }, items: slice });\n out.push({ warehouseId: getWarehouseId(r), chunkIndex: idx++, recordCount: slice.length, tokens: approxTokens(payload), payload });\n }\n }\n }\n return out;\n}\n\nasync function runIngest(p: { runId: string; entity: string; strategy: Strategy; warehouseId?: string; limit: number; tokenBudget: number; windowSize: number; }) {\n try {\n let rows: ChunkRow[];\n if (p.strategy === \"per-record\") rows = await chunkPerRecord(p.entity, p);\n else if (p.strategy === \"group-warehouse\") rows = await chunkGroupWarehouse(p.entity, p);\n else if (p.strategy === \"token-budget\") rows = await chunkTokenBudget(p.entity, p);\n else rows = await chunkFieldWindow(p.entity, p);\n for (const row of rows) {\n await sqlite.execute({\n sql: `INSERT INTO chunks (run_id, entity, strategy, warehouse_id, chunk_index, record_count, tokens, payload)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [p.runId, p.entity, p.strategy, row.warehouseId, row.chunkIndex, row.recordCount, row.tokens, row.payload],\n });\n }\n const totalRecords = rows.reduce((a, r) => a + r.recordCount, 0);\n const totalTokens = rows.reduce((a, r) => a + r.tokens, 0);\n await sqlite.execute({\n sql: `UPDATE ingest_runs SET status='done', total_chunks=?, total_records=?, total_tokens=?, finished_at=datetime('now') WHERE run_id=?`,\n args: [rows.length, totalRecords, totalTokens, p.runId],\n });\n } catch (e: any) {\n await sqlite.execute({\n sql: `UPDATE ingest_runs SET status='failed', error=?, finished_at=datetime('now') WHERE run_id=?`,\n args: [String(e?.message ?? e), p.runId],\n });\n }\n}\n\nfunction rowsToObjects(res: any): any[] {\n const cols: string[] = res.columns;\n return (res.rows as any[]).map((row) => {\n const o: any = {};\n cols.forEach((col, i) => { o[col] = row[i]; });\n return o;\n });\n}\nconst rowToObject = (res: any) => rowsToObjects(res)[0];\n\nconst app = new Hono();\napp.use(\"*\", cors());\n\napp.get(\"/\", (c) => c.json({\n service: \"ewmBackend\",\n description: \"SAP EWM data + chunking API, SQLite-backed, sources from ewmMockServer\",\n endpoints: [\n \"GET /api/health\", \"GET /api/entities\",\n \"GET /api/warehouses\", \"GET /api/plants\", \"GET /api/products\",\n \"POST /api/seed/master\", \"POST /api/seed\", \"GET /api/seed/stats\",\n \"GET /api/data/:entity\",\n \"POST /api/ingest\", \"GET /api/runs\", \"DELETE /api/runs/:id\",\n \"GET /api/chunks\", \"GET /api/chunks/:id\", \"GET /api/stats\",\n \"GET /api/inbox\",\n ],\n}));\n\napp.get(\"/api/health\", (c) => c.json({ ok: true, mock: MOCK_BASE }));\napp.get(\"/api/entities\", (c) => c.json({ entities: ENTITIES, strategies: STRATEGIES }));\n\napp.get(\"/api/warehouses\", async (c) => {\n await initDb();\n const res = await sqlite.execute(`SELECT data FROM warehouses ORDER BY id`);\n const value = (res.rows as any[]).map((r) => JSON.parse(r[0]));\n return c.json({ \"@odata.count\": value.length, value });\n});\n\napp.get(\"/api/plants\", async (c) => {\n await initDb();\n const res = await sqlite.execute(`SELECT data FROM plants ORDER BY id`);\n const value = (res.rows as any[]).map((r) => JSON.parse(r[0]));\n return c.json({ \"@odata.count\": value.length, value });\n});\n\napp.get(\"/api/products\", async (c) => {\n await initDb();\n const res = await sqlite.execute(`\n SELECT\n json_extract(data, '$.Product') as id,\n json_extract(data, '$.ProductDesc') as name,\n json_extract(data, '$.ProductCategory') as category,\n COUNT(*) as occurrences\n FROM entity_records\n WHERE entity = 'WarehouseOrders' AND json_extract(data, '$.Product') IS NOT NULL\n GROUP BY id, name, category\n ORDER BY occurrences DESC\n LIMIT 500\n `);\n const value = rowsToObjects(res);\n return c.json({ \"@odata.count\": value.length, value });\n});\n\napp.get(\"/api/inbox\", async (c) => {\n await initDb();\n const ingests = await sqlite.execute(`\n SELECT 'ingest' as kind, run_id as id, entity, strategy as detail, status,\n total_chunks as count, started_at, finished_at\n FROM ingest_runs ORDER BY started_at DESC LIMIT 25\n `);\n const seeds = await sqlite.execute(`\n SELECT 'seed' as kind, CAST(id AS TEXT) as id, entity,\n COALESCE(warehouse_id, '(all)') as detail, status,\n inserted as count, started_at, finished_at\n FROM seed_runs ORDER BY started_at DESC LIMIT 25\n `);\n const items = [...rowsToObjects(ingests), ...rowsToObjects(seeds)]\n .sort((a, b) => String(b.started_at || \"\").localeCompare(String(a.started_at || \"\")));\n return c.json({ items: items.slice(0, 50) });\n});\n\napp.post(\"/api/seed/master\", async (c) => {\n await initDb();\n let plants = 0, warehouses = 0;\n try {\n const pData = await (await fetch(`${MOCK_BASE}/api/ewm/plants`, { headers: { \"X-API-Key\": MOCK_KEY } })).json();\n for (const p of pData.value || []) {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO plants (id, name, country, region, currency, data, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, datetime('now'))`,\n args: [String(p.id), p.name ?? null, p.country ?? null, p.region ?? null, p.currency ?? null, JSON.stringify(p)],\n });\n plants++;\n }\n const wData = await (await fetch(`${MOCK_BASE}/api/ewm/warehouses`, { headers: { \"X-API-Key\": MOCK_KEY } })).json();\n for (const w of wData.value || []) {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO warehouses (id, plant_id, plant_name, type, country, region, data, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, datetime('now'))`,\n args: [String(w.id), w.plantId ?? null, w.plantName ?? null, w.type ?? null, w.country ?? null, w.region ?? null, JSON.stringify(w)],\n });\n warehouses++;\n }\n return c.json({ ok: true, plants, warehouses });\n } catch (e: any) {\n return c.json({ ok: false, plants, warehouses, error: String(e?.message ?? e) }, 500);\n }\n});\n\napp.post(\"/api/seed\", async (c) => {\n await initDb();\n const body = await c.req.json();\n const entity = String(body.entity);\n const warehouseId = body.warehouseId ? String(body.warehouseId) : undefined;\n const limit = Math.min(Math.max(parseInt(body.limit ?? \"1000\"), 1), 100000);\n if (!ENTITIES.includes(entity)) return c.json({ error: \"invalid entity\" }, 400);\n\n const seedRes = await sqlite.execute({\n sql: `INSERT INTO seed_runs (entity, warehouse_id, limit_param, status) VALUES (?, ?, ?, 'running')`,\n args: [entity, warehouseId ?? null, limit],\n });\n const seedId = (seedRes as any).lastInsertRowid ?? (seedRes as any).rowsAffected;\n\n let inserted = 0, idx = 0;\n try {\n const PAGE = 500;\n let skip = 0;\n while (inserted < limit) {\n const top = Math.min(PAGE, limit - inserted);\n const page = await fetchMockPage(entity, { warehouseId, skip, top });\n const value = (page.value as any[]) || [];\n if (!value.length) break;\n for (const r of value) {\n const id = getRecordId(entity, r, idx++);\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO entity_records (entity, record_id, warehouse_id, plant_id, status, data, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, datetime('now'))`,\n args: [entity, id, getWarehouseId(r), getPlantId(r), getStatus(r), JSON.stringify(r)],\n });\n inserted++;\n if (inserted >= limit) break;\n }\n if (value.length < top) break;\n skip += value.length;\n }\n await sqlite.execute({\n sql: `UPDATE seed_runs SET status='done', inserted=?, finished_at=datetime('now') WHERE id=?`,\n args: [inserted, seedId],\n });\n return c.json({ ok: true, entity, warehouseId, inserted, seedId });\n } catch (e: any) {\n await sqlite.execute({\n sql: `UPDATE seed_runs SET status='failed', inserted=?, error=?, finished_at=datetime('now') WHERE id=?`,\n args: [inserted, String(e?.message ?? e), seedId],\n });\n return c.json({ ok: false, entity, warehouseId, inserted, error: String(e?.message ?? e) }, 500);\n }\n});\n\napp.get(\"/api/seed/stats\", async (c) => {\n await initDb();\n const counts = await sqlite.execute(`SELECT entity, COUNT(*) as n, MAX(updated_at) as latest FROM entity_records GROUP BY entity`);\n const whCount = await sqlite.execute(`SELECT COUNT(*) as n FROM warehouses`);\n const plantCount = await sqlite.execute(`SELECT COUNT(*) as n FROM plants`);\n const runs = await sqlite.execute(`SELECT id, entity, warehouse_id, limit_param, inserted, status, started_at, finished_at, error FROM seed_runs ORDER BY started_at DESC LIMIT 20`);\n return c.json({\n byEntity: rowsToObjects(counts),\n warehouses: (whCount.rows[0] as any)[0],\n plants: (plantCount.rows[0] as any)[0],\n runs: rowsToObjects(runs),\n });\n});\n\napp.get(\"/api/data/:entity\", async (c) => {\n await initDb();\n const entity = c.req.param(\"entity\");\n if (!ENTITIES.includes(entity)) return c.json({ error: \"invalid entity\" }, 400);\n const warehouseId = c.req.query(\"warehouseId\");\n const top = Math.min(parseInt(c.req.query(\"$top\") ?? \"25\"), 500);\n const skip = parseInt(c.req.query(\"$skip\") ?? \"0\");\n\n const args: any[] = [entity];\n let where = \"entity = ?\";\n if (warehouseId) { where += \" AND warehouse_id = ?\"; args.push(warehouseId); }\n\n const total = await sqlite.execute({ sql: `SELECT COUNT(*) FROM entity_records WHERE ${where}`, args });\n const rows = await sqlite.execute({\n sql: `SELECT data FROM entity_records WHERE ${where} ORDER BY record_id LIMIT ? OFFSET ?`,\n args: [...args, top, skip],\n });\n return c.json({\n \"@odata.context\": `$metadata#${entity}`,\n \"@odata.count\": (total.rows[0] as any)[0],\n value: (rows.rows as any[]).map((r) => JSON.parse(r[0])),\n });\n});\n\napp.post(\"/api/ingest\", async (c) => {\n await initDb();\n const body = await c.req.json();\n const entity = String(body.entity);\n const strategy = String(body.strategy) as Strategy;\n const warehouseId = body.warehouseId ? String(body.warehouseId) : undefined;\n const limit = Math.min(Math.max(parseInt(body.limit ?? \"1000\"), 1), 50000);\n const tokenBudget = Math.max(parseInt(body.tokenBudget ?? \"2000\"), 100);\n const windowSize = Math.max(parseInt(body.windowSize ?? \"50\"), 1);\n if (!ENTITIES.includes(entity)) return c.json({ error: \"invalid entity\" }, 400);\n if (!STRATEGIES.includes(strategy)) return c.json({ error: \"invalid strategy\" }, 400);\n\n const runId = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO ingest_runs (run_id, entity, strategy, warehouse_id, token_budget, field_window, record_limit, status)\n VALUES (?, ?, ?, ?, ?, ?, ?, 'running')`,\n args: [runId, entity, strategy, warehouseId ?? null, tokenBudget, windowSize, limit],\n });\n await runIngest({ runId, entity, strategy, warehouseId, limit, tokenBudget, windowSize });\n const out = await sqlite.execute({ sql: `SELECT * FROM ingest_runs WHERE run_id=?`, args: [runId] });\n return c.json({ run: rowToObject(out) });\n});\n\napp.get(\"/api/runs\", async (c) => {\n await initDb();\n const limit = Math.min(parseInt(c.req.query(\"limit\") ?? \"50\"), 200);\n const res = await sqlite.execute({ sql: `SELECT * FROM ingest_runs ORDER BY started_at DESC LIMIT ?`, args: [limit] });\n return c.json({ runs: rowsToObjects(res) });\n});\n\napp.get(\"/api/chunks\", async (c) => {\n await initDb();\n const runId = c.req.query(\"run_id\");\n const entity = c.req.query(\"entity\");\n const strategy = c.req.query(\"strategy\");\n const limit = Math.min(parseInt(c.req.query(\"limit\") ?? \"100\"), 500);\n const offset = parseInt(c.req.query(\"offset\") ?? \"0\");\n const includePayload = c.req.query(\"payload\") === \"1\";\n\n const wheres: string[] = [];\n const args: any[] = [];\n if (runId) { wheres.push(\"run_id = ?\"); args.push(runId); }\n if (entity) { wheres.push(\"entity = ?\"); args.push(entity); }\n if (strategy) { wheres.push(\"strategy = ?\"); args.push(strategy); }\n const where = wheres.length ? `WHERE ${wheres.join(\" AND \")}` : \"\";\n\n const fields = includePayload\n ? \"id, run_id, entity, strategy, warehouse_id, chunk_index, record_count, tokens, payload, created_at\"\n : \"id, run_id, entity, strategy, warehouse_id, chunk_index, record_count, tokens, created_at\";\n\n const res = await sqlite.execute({\n sql: `SELECT ${fields} FROM chunks ${where} ORDER BY id DESC LIMIT ? OFFSET ?`,\n args: [...args, limit, offset],\n });\n const countRes = await sqlite.execute({ sql: `SELECT COUNT(*) as n FROM chunks ${where}`, args });\n return c.json({ chunks: rowsToObjects(res), total: (countRes.rows[0] as any)[0] });\n});\n\napp.get(\"/api/chunks/:id\", async (c) => {\n await initDb();\n const id = parseInt(c.req.param(\"id\"));\n const res = await sqlite.execute({ sql: `SELECT * FROM chunks WHERE id = ?`, args: [id] });\n if (!res.rows.length) return c.json({ error: \"not found\" }, 404);\n return c.json({ chunk: rowToObject(res) });\n});\n\napp.get(\"/api/stats\", async (c) => {\n await initDb();\n const totals = await sqlite.execute(`SELECT COUNT(*) as total_chunks, COALESCE(SUM(record_count),0) as total_records, COALESCE(SUM(tokens),0) as total_tokens FROM chunks`);\n const byEntity = await sqlite.execute(`SELECT entity, COUNT(*) as chunks, SUM(record_count) as records, SUM(tokens) as tokens FROM chunks GROUP BY entity ORDER BY chunks DESC`);\n const byStrategy = await sqlite.execute(`SELECT strategy, COUNT(*) as chunks, SUM(record_count) as records, SUM(tokens) as tokens FROM chunks GROUP BY strategy ORDER BY chunks DESC`);\n const runStats = await sqlite.execute(`SELECT status, COUNT(*) as n FROM ingest_runs GROUP BY status`);\n return c.json({\n totals: rowsToObjects(totals)[0],\n byEntity: rowsToObjects(byEntity),\n byStrategy: rowsToObjects(byStrategy),\n runStats: rowsToObjects(runStats),\n });\n});\n\napp.delete(\"/api/runs/:id\", async (c) => {\n await initDb();\n const runId = c.req.param(\"id\");\n await sqlite.execute({ sql: `DELETE FROM chunks WHERE run_id = ?`, args: [runId] });\n await sqlite.execute({ sql: `DELETE FROM ingest_runs WHERE run_id = ?`, args: [runId] });\n return c.json({ deleted: runId });\n});\n\nexport default app.fetch;\n","createdAt",["D",1779440140208],"branchVersion","branchId","e282339c-55b9-11f1-8a6a-ee650bb23af1","id","e2816890-55b9-11f1-8a6a-ee650bb23af1","ewmBackend",["D",1779439228263],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","SAP EWM backend: Hono + SQLite + chunking","imageUrl","e8c17657-6210-4c45-bd2b-dbcf2e020293","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019e4de5-f6b1-7488-a017-a3a028bc2ba8","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_102":98},"org",{"_95":94,"_96":94,"_97":98,"_18":55,"_99":100,"_101":25},"branch",{"_13":14,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","vlduy123","handle","displayName","avatar","https://avatars.githubusercontent.com/u/208025931?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":148,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":149,"_80":150,"_82":151,"_84":25},"tree",[143],"files",[143],"counts",{"_133":62,"_134":130,"_135":62,"_136":137,"_138":139},"contents",[125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":58,"_38":129,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_27":132},"0212b43c-55bc-11f1-9f08-ee650bb23af1","parentId","latest",["D",1779440140208],1,"label",[28],"pulls","branches","forks","envVars",{"_140":130,"_142":62},"connections",{"_140":62,"_141":62},"count","unfilledCount","emptyCount",{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":58,"_38":144,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_145":146,"_27":147},["D",1779440140208],"children",[],[28],["D",1779439228263],{"_95":94,"_102":98},{"_95":94,"_96":94,"_97":98,"_18":55,"_99":100,"_101":25},{"_13":14,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_78":-5,"_122":185,"_186":187,"_188":189,"_190":25,"_191":25,"_192":25,"_193":58,"_194":-5,"_195":-7,"_196":-7,"_197":62,"_198":25,"_199":25,"_200":-5,"_201":25,"_202":25,"_203":25,"_204":-5},"ENV",{"_156":157,"_158":159,"_160":85,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184},"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 · v2