[{"_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","network_controls.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/network_controls.ts","extension","id","36ba1026-2d53-40f3-8a30-5314b44f43c4","fileId","38af9720-b279-11f1-9fc0-1607ee4eb77e","parentId","branchId","6de82370-98e9-41cd-add4-480bf35c921b","branchVersion",57,"latest",true,"createdAt",["D",1789640485246],"version",1,"fileType","script","content","import { cities, clean, escape, validateTranslation, type Translation } from './core.ts';\nimport { previewFeed, translateJob } from './network_content.ts';\nimport { activateFeed, dispatchFeed, enqueueFeed } from './network_delivery.ts';\nimport { getFeed, saveFeed, type Feed, type Job } from './network_store.ts';\nimport { type Store } from './store.ts';\nimport { area, checkbox, hidden, input } from './ui.ts';\nconst form=(csrf:string,action:string,feed:string,body:string)=>``;\nexport async function feedControls(f:Feed,csrf:string,db:Store):Promise{\n const draft=await previewFeed(f.id,true,db),ready=await previewFeed(f.id,false,db);\n let html=`

Telegram preview

${escape(draft.text||'No current draft items.')}

Public-ready now: ${ready.items.length}. Draft preview can show original titles while translation is pending. Nothing is sent by opening this page.

`;\n if(!f.external)html+=`

Connect this feed

${form(csrf,'feed_settings',f.id,`${input('title','Channel title',f.title,'text','maxlength=\"160\" required')}${input('destination','Telegram channel @username or numeric ID',f.destination,'text','maxlength=\"80\"')}${input('publishTime','Daily digest time (Asia/Almaty)',f.publishTime,'time','step=\"900\" required')}`)}${form(csrf,'feed_pause',f.id,'')}${form(csrf,'feed_activate',f.id,`${checkbox('confirm','Activate this feed for public Telegram delivery',true)}${f.reviewRequired?checkbox('native','I reviewed the channel title and content language',true):'

Automatic mode: no individual post approvals. Valid translated events are published on schedule; incomplete items are skipped.

'}`)}

${f.reviewRequired?'This feed uses manual review.':'This channel posts automatically without manual approval.'} Valid translations, source access and safe event details are still checked. The global sending switch remains separate. This app never creates Telegram user accounts or channels.

${form(csrf,'private_test',f.id,`${checkbox('confirm','Send this preview only to CITY_TEST_CHAT_ID, a private test chat',true)}`)}

Required bindings: CITY_TELEGRAM_BOT_TOKEN and, for a private test, CITY_TEST_CHAT_ID. Store them in the Val Town environment editor, not in this form.

`;\n if(f.type==='jobs'){\n const records=(await db.q('SELECT * FROM ccn_jobs WHERE city=? ORDER BY last_seen DESC LIMIT 40',[f.city])).rows;\n html+='

Job review

Employer metadata only. No applicant records or contact lists are collected. An absent vacancy is held, not assumed filled.

';\n for(const r of records){const job=JSON.parse(String(r.json)) as Job,t=r.translation?JSON.parse(String(r.translation)) as Translation:null;\n html+=`

${escape(job.title)}

${escape(r.status)} · ${escape(r.review)}

${escape(t?JSON.stringify(t,null,2):'Translation pending')}

${form(csrf,'job_translate',f.id,`${hidden('id',r.id)}`)}${form(csrf,'job_review',f.id,`${hidden('id',r.id)}${hidden('hash',r.hash)}${input('title','Reviewed translated title',t?.title||'','text','maxlength=\"260\"')}${area('description','Short job label in channel language',t?.description||'','maxlength=\"280\"')}${input('note','Review evidence / reason','','text','maxlength=\"1000\" required')}${checkbox('facts','I checked the current employer posting and factual details')}${checkbox('native','I reviewed the translation with native-level competence')} `)}

`;\n }\n html+=`${form(csrf,'jobs_reuse',f.id,`${area('basis','Document actual public-reuse permission / basis','','maxlength=\"2000\" required')}${checkbox('confirm','I verified the intended public use is permitted')}`)}

Public API access is not by itself a commercial redistribution licence. With no confirmed decision, jobs stay private.

`;\n }\n const deliveries=(await db.q('SELECT key,mode,state,message_id,reason,items FROM ccn_feed_deliveries WHERE feed_id=? ORDER BY created DESC LIMIT 20',[f.id])).rows;\n html+='

Delivery history

';\n for(const r of deliveries){html+=`

${escape(r.mode)} · ${escape(r.state)} · message ${escape(r.message_id||'not confirmed')}

${escape(r.reason||'')}

`;\n if(r.state==='delivery_unknown')html+=form(csrf,'reconcile',f.id,`${hidden('key',r.key)}${input('messageId','Observed Telegram message ID','','number','min=\"1\"')}${input('note','What you verified in the destination','','text','maxlength=\"1000\" required')}${checkbox('confirm','I checked the actual Telegram destination',true)} `);\n }\n return html+(deliveries.length?'':'

No messages queued or sent for this feed.

')+'

';\n}\nexport async function controlAction(data:URLSearchParams,db:Store):Promise{\n const value=(name:string)=>clean(data.get(name)),yes=(name:string)=>value(name)==='yes',action=value('action');\n const supported=['feed_settings','feed_pause','feed_activate','private_test','job_translate','job_review','jobs_reuse','reconcile','kill'];if(!supported.includes(action))return false;\n if(action==='kill'){if(!yes('confirm')||!['0','1'].includes(value('value')))throw new Error('Explicit switch confirmation required');await db.set('kill',value('value'));await db.audit(null,'network_kill_switch',value('value'));return true;}\n const {feed:f}=await getFeed(value('feed'),db);const lock=await db.lease('network:configuration',60000);if(!lock)throw new Error('Configuration busy; retry');\n try{\n if(action==='feed_settings'){await saveFeed({...f,title:value('title'),destination:value('destination'),publishTime:value('publishTime'),enabled:false},db);await db.audit(null,'feed_settings',f.id);}\n else if(action==='feed_pause'){await saveFeed({...f,enabled:false},db);}\n else if(action==='feed_activate'){if(!yes('confirm')||(f.reviewRequired&&!yes('native')))throw new Error('Explicit channel activation confirmation required');await activateFeed(f.id,db);}\n else if(action==='private_test'){if(!yes('confirm'))throw new Error('Private test confirmation required');if(await db.setting('kill','1')!=='0')throw new Error('Global kill switch is ON');const key=await enqueueFeed(f.id,'private',db);if(!key)throw new Error('No deliverable private draft');await dispatchFeed(key,db);}\n else if(action==='jobs_reuse'){if(f.type!=='jobs'||value('basis').length<30)throw new Error('Job feed and documented basis required');await db.q(\"UPDATE ccn_collectors SET reuse=?,basis=? WHERE id='jobs:accor'\",[yes('confirm')?'approved':'pending',value('basis').slice(0,2000)]);await db.audit(null,'job_reuse_decision',yes('confirm')?'owner-approved':'pending');}\n else if(action==='job_translate'||action==='job_review'){\n if(f.type!=='jobs')throw new Error('Select a jobs feed');const r=(await db.q('SELECT * FROM ccn_jobs WHERE id=? AND city=?',[value('id'),f.city])).rows[0];if(!r)throw new Error('Job not found');\n if(action==='job_translate'){if(!await translateJob(value('id'),db))throw new Error('Translation failed or daily cap reached');}\n else{if(r.hash!==value('hash')||!value('note'))throw new Error('Job changed or review evidence missing');\n if(value('decision')==='reject')await db.q(\"UPDATE ccn_jobs SET review='rejected',approved_hash=NULL WHERE id=? AND hash=?\",[value('id'),value('hash')]);\n else if(value('decision')==='approve'){\n if(!yes('facts')||!yes('native')||r.status!=='active'||Number(r.last_seen)(s.match(/\\d+/g)||[]).sort().join('|');if(digits(t.title)!==digits(original.title))throw new Error('Title numbers changed');\n const result=await db.q(\"UPDATE ccn_jobs SET translation=?,translation_hash=hash,review='approved',approved_hash=hash WHERE id=? AND hash=?\",[JSON.stringify(t),value('id'),value('hash')]);if(!result.rowsAffected)throw new Error('Job changed during approval');\n }else throw new Error('Invalid review decision');await db.audit(value('id'),'job_'+value('decision'),value('note'));}\n }\n else if(action==='reconcile'){const decision=value('decision');if(!yes('confirm')||!value('note')||!['sent','abandoned'].includes(decision)||(decision==='sent'&&!/^[1-9]\\d{0,15}$/.test(value('messageId'))))throw new Error('Observed evidence and valid decision required');const result=await db.q(\"UPDATE ccn_feed_deliveries SET state=?,message_id=?,reason=? WHERE key=? AND feed_id=? AND state='delivery_unknown'\",[decision,decision==='sent'?value('messageId'):null,'Owner reconciliation: '+value('note'),value('key'),f.id]);if(!result.rowsAffected)throw new Error('Unresolved delivery not found');await db.audit(null,'feed_delivery_reconciled',value('key'));}\n return true;\n }finally{await db.release('network:configuration',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"]