[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","omriluz","name","telegram-city-network","path","admin.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/omriluz/telegram-city-network/code/admin.ts","extension","id","91fed134-e67d-45af-ae04-27092ed209b8","fileId","6880e91c-b257-11f1-bc02-1607ee4eb77e","parentId","branchId","6de82370-98e9-41cd-add4-480bf35c921b","branchVersion",44,"latest",true,"createdAt",["D",1789636913674],"version",1,"fileType","script","content","import { cities, clean, escape, hash, parseDate, validateEvent, validateTranslation, type EventData, type Translation } from \"./core.ts\";\nimport { approve, ingestCity, initialize, preview, publisher, translateEvent, verifyDestination } from \"./engine.ts\";\nimport { sources } from \"./sources.ts\";\nimport { type Store } from \"./store.ts\";\nimport { area, channelCopy, checkbox, editFields, form, input, layout } from \"./ui.ts\";\nexport const campaigns = [\"direct\", \"instagram-bio\", \"instagram-weekend\", \"instagram-free\", \"partner\", \"flyer\", \"other\"];\nconst rowsTable = (rows: Record[]) => rows.length ? `

${Object.keys(rows[0]).map((k) => ``).join(\"\")}${rows.map((row) => `${Object.values(row).map((v) => ``).join(\"\")}`).join(\"\")}

${escape(k)}
${escape(v ?? \"unavailable\")}

` : \"

No records yet.

\";\nexport async function adminPage(db: Store, csrf: string, tab: string, slug: string, origin: string): Promise {\n await initialize(db); const city = cities[slug] || cities.shymkent, flags = await db.flags(city.slug);\n const nav = ``;\n let content = \"\";\n if (tab === \"overview\") {\n const counts = (await db.q(\"SELECT review, COUNT(*) AS count FROM ccn_events WHERE city=? AND fixture=0 GROUP BY review\", [city.slug])).rows;\n const deliveries = (await db.q(\"SELECT mode,state,COUNT(*) AS count FROM ccn_publications GROUP BY mode,state\")).rows;\n const runs = (await db.q(\"SELECT kind,city,status,datetime(at/1000,'unixepoch') AS UTC,duration AS duration_ms,summary FROM ccn_runs ORDER BY at DESC LIMIT 12\")).rows;\n content = `

${counts.map((row) => `

${escape(row.count)}

${escape(row.review)}

`).join(\"\") || \"

No ingested events yet.

\"}

Deployment gates

Software deployment is not a channel launch. Source reuse review, native-language approval, bot permission and explicit public activation are separate gates.

Almaty: original publisher is outside this app. This configuration cannot send publicly. Astana: disabled and shadow-only.

${rowsTable(deliveries)}

Recent actual runs

${rowsTable(runs)}

`;\n } else if (tab === \"review\") {\n const rows = (await db.q(\"SELECT * FROM ccn_events WHERE city=? AND fixture=0 AND duplicate_of IS NULL ORDER BY json_extract(json,'$.date'),first_seen LIMIT 100\", [city.slug])).rows;\n for (const row of rows) {\n const e = JSON.parse(String(row.json)) as EventData, t = row.translation ? JSON.parse(String(row.translation)) as Translation : null;\n const provenance = (await db.q(\"SELECT source,url,json FROM ccn_records WHERE event_id=?\", [String(row.id)])).rows;\n content += `

${escape(row.review)}

${escape(e.title)}

${escape(e.date || \"DATE UNKNOWN\")} · ${escape(e.venue)} · ${e.cancelled ? \"CANCELLED\" : \"Cancellation not reported\"}

Original source facts

${escape(JSON.stringify(e, null, 2))}

${escape(city.locale.toUpperCase())} translation

${escape(t ? JSON.stringify(t, null, 2) : \"No valid translation. Public approval is blocked.\")}

Machine translation is not native-speaker approval. Venue/address, source facts and numbers are preserved separately.

${form(\"translate\", csrf, \"\", { id: row.id, city: city.slug })}${form(\"approve\", csrf, `${checkbox(\"native\", \"I have reviewed the channel-language text with native-level competence\", true)}${checkbox(\"facts\", \"I verified dates, place, price, event language and all unknown fields\", true)}${input(\"seconds\", \"Review effort in seconds (manual)\", 0, \"number\", 'min=\"0\" max=\"3600\"')}`, { id: row.id, hash: row.hash, city: city.slug })}${form(\"reject\", csrf, `${input(\"note\", \"Rejection reason\", \"\", \"text\", 'maxlength=\"1000\" required')}`, { id: row.id, hash: row.hash, city: city.slug })}

Edit facts / translation

${form(\"edit\", csrf, editFields(e, t), { id: row.id, hash: row.hash, city: city.slug })}

All source provenance

${rowsTable(provenance)}

`;\n }\n if (!rows.length) content = \"

No drafts yet. Inspect an accessible source from Sources.

\";\n } else if (tab === \"sources\") {\n for (const source of Object.values(sources)) {\n const configured = city.sources.includes(source.id); const row = (await db.q(\"SELECT * FROM ccn_sources WHERE id=?\", [`${city.slug}:${source.id}`])).rows[0];\n content += `

${escape(source.name)}

${escape(source.status)}

${escape(source.method)}

${escape(source.reuse)}

${row ? rowsTable([row]) : \"

Not configured for this city.

\"}${configured && source.enabledAdapter ? `${form(\"research\", csrf, \"

Manual bounded inspection only; this does not approve reuse or enable polling.

\", { city: city.slug, source: source.id })}${form(\"source\", csrf, `${area(\"basis\", \"Document actual reuse permission / applicable factual-metadata basis\", row?.basis || \"\", 'maxlength=\"2000\" required')}${checkbox(\"approved\", \"I have verified that this use and automated access are permitted\")}${checkbox(\"poll\", \"Enable hourly polling (only effective with permission above)\")}`, { city: city.slug, source: source.id })}` : \"\"}

`;\n }\n } else if (tab === \"duplicates\") {\n const rows = (await db.q(\"SELECT d.*,a.json AS left_event,b.json AS right_event FROM ccn_duplicates d JOIN ccn_events a ON a.id=d.left_id JOIN ccn_events b ON b.id=d.right_id WHERE a.city=? AND d.state='pending' LIMIT 50\", [city.slug])).rows;\n content = rows.map((row) => `

Uncertain match

${escape(row.reason)}

${escape(row.left_event)}

${escape(row.right_event)}

${form(\"duplicate\", csrf, `${checkbox(\"confirm\", \"I compared the actual occurrence dates, times and locations\", true)} `, { city: city.slug, pair: row.id })}

`).join(\"\") || \"

No unresolved duplicate candidates.

\";\n } else if (tab === \"preview\") {\n const ready = await preview(city.slug, false, Date.now(), db), draft = await preview(city.slug, true, Date.now(), db);\n content = `

Public-ready digest

${escape(ready.plan.edition)} · ${escape(ready.plan.from)}–${escape(ready.plan.to)}

${escape(ready.text || \"No approved, fresh, unpublished events in this digest window. Publishing skips.\")}

Draft preview — not public-ready

${escape(draft.text || \"No current translated drafts. Translate an event in Review.\")}

Preview does not create queue rows or consume delivery slots.

${form(\"private_test\", csrf, `${checkbox(\"confirm\", \"Send this draft only to the explicitly configured private test chat\", true)}

Requires CITY_TELEGRAM_BOT_TOKEN, CITY_TEST_CHAT_ID and kill switch off. Public city activation stays separate.

`, { city: city.slug })}

`;\n } else if (tab === \"queue\") {\n const rows = (await db.q(\"SELECT * FROM ccn_publications ORDER BY created DESC LIMIT 60\")).rows;\n content = rows.map((row) => `

${escape(row.state)} ${escape(row.mode)}

${escape(row.key)} · attempts ${escape(row.attempts)} · message ${escape(row.message_id || \"unknown/not sent\")}

${escape(row.reason)}

${row.needs_correction ? \"

Source changed after this post. Check and correct the Telegram message.

\" : \"\"}

Message body

${escape(row.text)}

${row.state === \"delivery_unknown\" ? form(\"reconcile\", csrf, `${input(\"messageId\", \"Observed Telegram message ID (required when confirming sent)\", \"\", \"number\", 'min=\"1\"')}${input(\"note\", \"Reconciliation evidence\", \"\", \"text\", 'required maxlength=\"1000\"')}${checkbox(\"confirm\", \"I checked the actual destination; this is not an assumption\", true)} `, { key: row.key, city: row.city }) : \"\"}${row.needs_correction ? form(\"correction\", csrf, `${checkbox(\"confirm\", \"I manually corrected/removed the affected Telegram post\", true)}`, { key: row.key, city: row.city }) : \"\"}

`).join(\"\") || \"

The queue is empty. Dry runs do not create fake deliveries.

\";\n } else if (tab === \"submissions\") {\n const rows = (await db.q(\"SELECT * FROM ccn_submissions ORDER BY at DESC LIMIT 60\")).rows;\n content = rows.map((row) => `

${escape(row.kind)} · ${escape(row.status)}

Private contact: ${escape(row.contact)}

${escape(row.json)}

${row.status === \"pending\" ? form(\"submission\", csrf, `${input(\"note\", \"Moderation note\", \"\", \"text\", 'maxlength=\"1000\" required')} ${row.kind === \"event\" ? \"\" : \"\"}`, { submission: row.id, city: \"shymkent\" }) : \"\"}

`).join(\"\") || \"

No organizer or advertising-interest submissions.

\";\n } else if (tab === \"growth\") {\n const clicks = (await db.q(\"SELECT * FROM ccn_clicks ORDER BY day DESC LIMIT 60\")).rows, subscribers = (await db.q(\"SELECT * FROM ccn_subscribers ORDER BY day DESC LIMIT 14\")).rows;\n const effort = (await db.q(\"SELECT action,COUNT(*) AS decisions,SUM(seconds) AS manually_reported_seconds FROM ccn_editorial GROUP BY action\")).rows;\n const usage = (await db.q(\"SELECT * FROM ccn_usage ORDER BY day DESC LIMIT 14\")).rows;\n content = `

Campaign links

${campaigns.filter((x) => ![\"other\", \"direct\"].includes(x)).map((name) => `

${escape(name)}
${escape(origin)}/shymkent?campaign=${escape(name)}
${escape(origin)}/join/shymkent?campaign=${escape(name)}

`).join(\"\")}

Counts are outbound clicks after basic preview-bot filtering. Not unique people, actual joins, ticket purchases or per-post views. Campaign retention and historical counts before installation are unavailable.

Observed clicks

${rowsTable(clicks)}

Daily subscriber snapshots

${rowsTable(subscribers)}

Translation usage

${rowsTable(usage)}

Editorial effort

${rowsTable(effort)}

`;\n const approvedRows = (await db.q(\"SELECT * FROM ccn_events WHERE city='shymkent' AND review='approved' AND approved_hash=hash AND translation_hash=hash AND fixture=0 AND duplicate_of IS NULL LIMIT 5\")).rows;\n const event = approvedRows[0]; const translated = event?.translation ? JSON.parse(String(event.translation)) as Translation : null; const e = event ? JSON.parse(String(event.json)) as EventData : null;\n content += `

Channel copy — native-language review required

${form(\"copy\", csrf, `${input(\"copyTitle\", \"Telegram title\", await db.setting(\"copy:title\", channelCopy.title), \"text\", 'maxlength=\"120\"')}${area(\"copyDescription\", \"Telegram description\", await db.setting(\"copy:description\", channelCopy.description), 'maxlength=\"400\"')}${area(\"copyWelcome\", \"Pinned welcome\", await db.setting(\"copy:welcome\", channelCopy.welcome), 'maxlength=\"3000\"')}`, { city: city.slug })}

Three editable Instagram captions

Language review required. Nothing is posted externally. Event-based drafts populate only after a real event is approved.

${form(\"captions\", csrf, await (async () => { let html = \"\"; for (let i = 1; i <= 3; i++) { const draft = translated && e ? `${i === 1 ? \"Шымкентте не бар?\" : i === 2 ? \"Демалыс жоспарыңыз дайын ба?\" : \"Жоспарды достарыңызбен бөлісіңіз.\"}\\n${translated.title}\\n${e.date || \"\"} · ${e.venue}\\nТолығырақ: ${origin}/event/${e.id}?campaign=instagram-bio\\n#Шымкент #ShymkentPlans` : \"\"; html += area(`caption${i}`, `Caption ${i}${!translated ? \" — waiting for approved real event\" : \"\"}`, await db.setting(`caption:${i}`, draft), 'maxlength=\"2000\"'); } return html; })() + \"\", { city: city.slug })}

`;\n } else if (tab === \"settings\") {\n content = `

Global kill switch

Stops new Telegram sends, including private tests. It cannot recall an in-flight request.

${form(\"kill\", csrf, ` `, { city: city.slug })}

${escape(city.brand)} controls

${escape(JSON.stringify({ ...flags, configurationEnabled: city.enabled, shadowOnly: city.shadowOnly }, null, 2))}

${form(\"pause\", csrf, \" \", { city: city.slug })}${city.slug === \"shymkent\" ? form(\"destination\", csrf, `${input(\"destination\", \"Shymkent channel @username or numeric ID\", await db.setting(\"shymkent:destination\"), \"text\", 'maxlength=\"80\"')}${input(\"join\", \"Public Telegram join URL\", await db.setting(\"shymkent:join\"), \"url\", 'maxlength=\"120\"')}${input(\"publishTime\", \"Primary daily digest time (Asia/Almaty)\", await db.setting(\"shymkent:publishTime\", \"10:00\"), \"time\", 'step=\"900\" required')}`, { city: city.slug }) : \"

This city cannot be activated in this release.

\"}

Translation cap

${form(\"cap\", csrf, `${input(\"cap\", \"Maximum attempted translations per UTC day (failed requests count)\", await db.setting(\"translation_daily_cap\", \"12\"), \"number\", 'min=\"0\" max=\"50\" required')}`, { city: city.slug })}

No paid provider subscription or billing limit is changed.

${city.slug === \"shymkent\" ? `

Explicit public activation

Only after source permission, language review, destination setup and successful bot access checks. Friday replaces the ordinary digest with a weekend edition.

${form(\"activate\", csrf, `${checkbox(\"native\", \"Native-language channel copy and approved events have been reviewed\", true)}${checkbox(\"confirm\", \"Enable Shymkent public posting; I understand this is a live action\", true)}`, { city: city.slug })}

` : \"\"}

Secure bindings

Set CITY_TELEGRAM_BOT_TOKEN and optional CITY_TEST_CHAT_ID in this val's encrypted environment-variable settings. Do not paste credentials into this dashboard, URLs or source files.

GitHub repository creation and automatic deployment credentials were unavailable to this connection. This app is currently deployed through the Val Town plugin, not a GitHub push.

`;\n }\n return layout(\"Owner workspace\", `

Editorial workspace

${escape(city.brand)}

Source facts → review → approved calendar → gated delivery

${Object.values(cities).map((item) => `${escape(item.brand)}${item.shadowOnly ? \" · shadow\" : \"\"}`).join(\"\")}

${flags.kill ? \"Global kill switch ON · no Telegram sends\" : \"Global kill switch OFF · city and destination gates still apply\"} · ${flags.enabled && !flags.dryRun && !flags.paused && !city.shadowOnly ? \"PUBLIC MODE ENABLED\" : \"Public publishing disabled/paused\"}

${nav}

${content}`, true);\n}\nexport async function adminAction(data: URLSearchParams, db: Store): Promise {\n await initialize(db); const value = (key: string) => clean(data.get(key)); const yes = (key: string) => value(key) === \"yes\";\n const action = value(\"action\"), slug = value(\"city\") || \"shymkent\", city = cities[slug]; if (!city) throw new Error(\"Unknown city\");\n if (action === \"research\") { const result = await ingestCity(slug, true, value(\"source\"), db); return JSON.stringify(result); }\n if (action === \"translate\") { const row = (await db.q(\"SELECT city FROM ccn_events WHERE id=?\", [value(\"id\")])).rows[0]; if (row?.city !== slug) throw new Error(\"City mismatch\"); return await translateEvent(value(\"id\"), db) ? \"Translation saved. Native-language approval is still required.\" : \"Translation blocked or daily cap reached; see logs.\"; }\n if (action === \"private_test\") { if (!yes(\"confirm\")) throw new Error(\"Explicit private-send confirmation required\"); return JSON.stringify(await publisher(slug, true, db)); }\n if (action === \"kill\") { if (![\"0\", \"1\"].includes(value(\"value\"))) throw new Error(\"Invalid switch\"); await db.set(\"kill\", value(\"value\")); await db.audit(null, \"kill_switch\", value(\"value\")); return \"Kill switch updated.\"; }\n if (action === \"cap\") { const cap = Number(value(\"cap\")); if (!Number.isInteger(cap) || cap < 0 || cap > 50) throw new Error(\"Cap must be 0–50\"); await db.set(\"translation_daily_cap\", String(cap)); return \"Application cap saved; no billing setting changed.\"; }\n if (action === \"copy\") { for (const [field, key] of [[\"copyTitle\", \"title\"], [\"copyDescription\", \"description\"], [\"copyWelcome\", \"welcome\"]]) await db.set(`copy:${key}`, data.get(field)?.slice(0, 3000) || \"\"); return \"Editable channel copy saved; not posted.\"; }\n if (action === \"captions\") { for (let i = 1; i <= 3; i++) await db.set(`caption:${i}`, (data.get(`caption${i}`) || \"\").slice(0, 2000)); return \"Captions saved; nothing posted externally.\"; }\n const lock = await db.lease(`city:${slug}`); if (!lock) throw new Error(\"City is busy; retry after the current run\");\n try {\n if ([\"approve\", \"edit\", \"reject\"].includes(action)) {\n const row = (await db.q(\"SELECT * FROM ccn_events WHERE id=? AND city=?\", [value(\"id\"), slug])).rows[0]; if (!row || row.hash !== value(\"hash\")) throw new Error(\"Event changed; reload review\"); const e = JSON.parse(String(row.json)) as EventData;\n if (action === \"approve\") { await approve(String(row.id), String(row.hash), yes(\"native\"), yes(\"facts\"), Number(value(\"seconds\")) || 0, db); return \"Current event version approved.\"; }\n if (!value(\"note\")) throw new Error(\"A review note is required\");\n if (action === \"reject\") { await db.invalidate(String(row.id), \"Editorial rejection/withdrawal\"); await db.q(\"UPDATE ccn_events SET review='rejected' WHERE id=?\", [String(row.id)]); await db.audit(String(row.id), \"rejected\", value(\"note\")); return \"Rejected; queued copies invalidated and existing posts flagged.\"; }\n const parsed = parseDate(value(\"date\") + (value(\"time\") ? \"T\" + value(\"time\") : \"\"), city.timezone);\n const edited: EventData = { ...e, title: value(\"title\"), venue: value(\"venue\"), address: value(\"address\") || null, date: parsed.date, start: parsed.ms, endDate: value(\"endDate\") || null, end: null, price: value(\"price\") === \"\" ? null : Number(value(\"price\")), priceText: null, currency: value(\"price\") === \"\" ? null : \"KZT\", category: value(\"category\"), eventLanguage: value(\"language\") || null, age: value(\"age\") || null, bookingUrl: value(\"bookingUrl\") || null, issues: parsed.issue ? [parsed.issue] : [] };\n validateEvent(edited); const text = JSON.stringify(edited), digest = await hash(text); let translation: Translation | null = null;\n if (value(\"translatedTitle\") || value(\"description\")) translation = validateTranslation({ title: value(\"translatedTitle\"), description: value(\"description\") }, city.locale, \"Owner edit; requires approval\");\n await db.invalidate(String(row.id), \"Editorial changes require reapproval\");\n await db.q(\"UPDATE ccn_events SET json=?,hash=?,translation=?,translation_hash=? WHERE id=?\", [text, digest, translation ? JSON.stringify(translation) : null, translation ? digest : null, String(row.id)]);\n await db.audit(String(row.id), \"edited\", value(\"note\"), Number(value(\"seconds\")) || 0); return \"Saved as draft. Original source records retained.\";\n }\n if (action === \"source\") {\n const id = value(\"source\"); if (!city.sources.includes(id) || !sources[id]?.enabledAdapter || value(\"basis\").length < 20) throw new Error(\"Configured source and documented basis required\");\n await db.q(\"UPDATE ccn_sources SET permission=?,poll_allowed=?,basis=? WHERE id=?\", [yes(\"approved\") ? \"approved\" : \"pending\", yes(\"approved\") && yes(\"poll\") ? 1 : 0, value(\"basis\").slice(0, 2000), `${slug}:${id}`]);\n if (!yes(\"approved\")) for (const row of (await db.q(\"SELECT DISTINCT event_id FROM ccn_records WHERE city=? AND source=?\", [slug, id])).rows) await db.invalidate(String(row.event_id), \"Source permission withdrawn\");\n await db.audit(null, \"source_decision\", `${slug}:${id}: ${yes(\"approved\") ? \"owner-approved basis\" : \"pending\"}`); return \"Source decision saved. Event and channel approvals remain separate.\";\n }\n if (action === \"duplicate\") {\n if (!yes(\"confirm\")) throw new Error(\"Occurrence comparison confirmation required\");\n const pair = (await db.q(\"SELECT d.* FROM ccn_duplicates d JOIN ccn_events e ON e.id=d.left_id WHERE d.id=? AND d.state='pending' AND e.city=?\", [value(\"pair\"), slug])).rows[0]; if (!pair) throw new Error(\"Duplicate review not found\");\n if (![\"merge\", \"separate\"].includes(value(\"decision\"))) throw new Error(\"Invalid duplicate decision\");\n await db.invalidate(String(pair.left_id), \"Duplicate decision\"); await db.invalidate(String(pair.right_id), \"Duplicate decision\");\n if (value(\"decision\") === \"merge\") await db.batch([{ sql: \"UPDATE ccn_events SET duplicate_of=?,review='duplicate' WHERE id=?\", args: [String(pair.right_id), String(pair.left_id)] }, { sql: \"UPDATE ccn_records SET event_id=? WHERE event_id=?\", args: [String(pair.right_id), String(pair.left_id)] }]);\n await db.q(\"UPDATE ccn_duplicates SET state=? WHERE id=?\", [value(\"decision\"), value(\"pair\")]); await db.audit(String(pair.right_id), \"duplicate_\" + value(\"decision\"), String(pair.id)); return \"Duplicate decision recorded; affected events require re-review.\";\n }\n if (action === \"pause\") { if (![\"0\", \"1\"].includes(value(\"value\"))) throw new Error(\"Invalid switch\"); await db.set(`${slug}:paused`, value(\"value\")); await db.audit(null, \"city_pause\", `${slug}:${value(\"value\")}`); return \"Pause state updated; this does not activate an unreleased city.\"; }\n if (action === \"destination\") {\n if (slug !== \"shymkent\") throw new Error(\"Only Shymkent destination is configurable\"); const chat = value(\"destination\"), join = value(\"join\"), time = value(\"publishTime\");\n if (chat && (!/^(@[A-Za-z][A-Za-z0-9_]{4,31}|-100\\d{6,16})$/.test(chat) || chat.toLowerCase() === \"@almaty_expats\")) throw new Error(\"Invalid/protected destination\");\n if (join && (!/^https:\\/\\/t\\.me\\/[A-Za-z][A-Za-z0-9_]{4,31}$/.test(join) || join.toLowerCase().endsWith(\"/almaty_expats\"))) throw new Error(\"Use the Shymkent channel's public t.me URL\");\n if (!/^(?:[01]\\d|2[0-3]):(?:00|15|30|45)$/.test(time)) throw new Error(\"Choose a quarter-hour publishing time\");\n await db.set(\"shymkent:destination\", chat); await db.set(\"shymkent:join\", join); await db.set(\"shymkent:publishTime\", time); await db.set(\"shymkent:enabled\", \"0\"); await db.set(\"shymkent:dryRun\", \"1\"); await db.set(\"shymkent:paused\", \"1\"); return \"Saved. Public publishing reset to disabled/dry-run.\";\n }\n if (action === \"activate\") {\n throw new Error(\"Use City Network > select feed > Verify channel and activate. The legacy Shymkent scheduler has been replaced.\");\n if (slug !== \"shymkent\" || !yes(\"confirm\") || !yes(\"native\")) throw new Error(\"Explicit Shymkent language/activation confirmations required\");\n if (!(await db.q(\"SELECT 1 FROM ccn_events WHERE city=? AND review='approved' AND approved_hash=hash AND fixture=0 LIMIT 1\", [slug])).rows.length) throw new Error(\"Approve at least one real event first\");\n await verifyDestination(city, \"public\", db); await db.set(`${slug}:enabled`, \"1\"); await db.set(`${slug}:dryRun`, \"0\"); await db.set(`${slug}:paused`, \"0\"); await db.audit(null, \"public_activation\", slug); return \"Shymkent activated. The separate global kill switch still applies.\";\n }\n if (action === \"reconcile\") {\n if (!yes(\"confirm\") || !value(\"note\")) throw new Error(\"Reconciliation evidence required\"); const decision = value(\"decision\");\n if (![\"sent\", \"abandoned\"].includes(decision) || (decision === \"sent\" && !/^[1-9]\\d{0,15}$/.test(value(\"messageId\")))) throw new Error(\"Valid reconciliation decision/message ID required\");\n const result = await db.q(\"UPDATE ccn_publications SET state=?,message_id=?,reason=? WHERE key=? AND city=? AND state='delivery_unknown'\", [decision, decision === \"sent\" ? value(\"messageId\") : null, \"Owner reconciliation: \" + value(\"note\").slice(0, 500), value(\"key\"), slug]); if (!result.rowsAffected) throw new Error(\"No unresolved delivery matched\"); await db.audit(null, \"delivery_reconciled\", value(\"key\")); return \"Reconciliation recorded. No resend performed.\";\n }\n if (action === \"correction\") { if (!yes(\"confirm\")) throw new Error(\"Manual correction confirmation required\"); await db.q(\"UPDATE ccn_publications SET needs_correction=0 WHERE key=? AND city=?\", [value(\"key\"), slug]); await db.audit(null, \"correction_confirmed\", value(\"key\")); return \"Manual Telegram correction recorded.\"; }\n if (action === \"submission\") {\n const row = (await db.q(\"SELECT * FROM ccn_submissions WHERE id=? AND status='pending'\", [value(\"submission\")])).rows[0]; if (!row || !value(\"note\")) throw new Error(\"Pending submission and moderation note required\"); const decision = value(\"decision\");\n if (![\"reject\", \"reviewed\", \"promote\"].includes(decision)) throw new Error(\"Invalid moderation decision\");\n if (decision === \"promote\") { if (row.kind !== \"event\") throw new Error(\"Advertising interest cannot become an event\"); const data = JSON.parse(String(row.json)) as Record; const parsed = parseDate(data.date + (data.time ? \"T\" + data.time : \"\"), cities.shymkent.timezone);\n const event: EventData = { id: \"\", source: \"organizer\", sourceItemId: String(row.id), city: \"shymkent\", url: data.url, bookingUrl: data.url, title: data.title, venue: data.venue, address: data.address || null, category: data.category || \"other\", date: parsed.date, start: parsed.ms, endDate: null, end: null, timezone: cities.shymkent.timezone, price: data.price === \"\" ? null : Number(data.price), priceText: null, currency: data.price === \"\" ? null : \"KZT\", eventLanguage: data.language || null, age: null, cancelled: false, issues: [\"Organizer submission; facts and language require independent editorial review\", ...(parsed.issue ? [parsed.issue] : [])] }; await db.ingest([event]);\n }\n await db.q(\"UPDATE ccn_submissions SET status=? WHERE id=?\", [decision, String(row.id)]); await db.audit(null, \"submission_\" + decision, value(\"note\")); return \"Moderation saved. No public approval or external message was sent.\";\n }\n throw new Error(\"Unknown admin action\");\n } finally { await db.release(`city:${slug}`, lock); }\n}\n","deleted",false,"label",[14],"47a79ebc-05ee-454e-983d-7f48a62bccc0",["D",1789621418009],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","City events: Shymkent review pilot, isolated from live Almaty","imageUrl","userId","f5be24e4-c798-4816-91e5-037b60b986f5","pinnedFileId","01a0adbf-b85c-735b-b5fd-9913cdd6d31f","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","7f67379d-2d38-49bd-81ac-2c7f92a739e2","tursoName","47a79ebc05ee454e983d7f48a62bccc0","tursoHostname","47a79ebc05ee454e983d7f48a62bccc0-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789710048837],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":101},"org",{"_9":10,"_99":-5,"_100":101,"_55":56,"_102":103,"_104":42},"branch",{"_35":89,"_11":90,"_22":28,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned",59,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ycWxkOWxiOE00SkVtZENmRWM4YWxLWTRVUFMifQ","tier","free","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":63,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":90,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","71c1b20804b3232a7e513be260cfffc1932a9e97","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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]