[{"_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_content.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_content.ts","extension","id","0cb52b7b-ccfa-4550-b5e4-875827ebdd14","fileId","38af6a02-b279-11f1-9fc0-1607ee4eb77e","parentId","branchId","6de82370-98e9-41cd-add4-480bf35c921b","branchVersion",57,"latest",true,"createdAt",["D",1789640485246],"version",1,"fileType","script","content","import { automaticEventSafe, automaticLabel } from './automatic_policy.ts';\nimport { cities, eligible, escape, localParts, renderEvent, schedule, validateTranslation, type EventData, type Translation } from './core.ts';\nimport { translateEvent, translationProvider, type TranslationProvider } from './engine.ts';\nimport { store, type Store } from './store.ts';\nimport { getFeed, initNetwork, matchesFeed, type Feed, type Job } from './network_store.ts';\nexport interface FeedItem {id:string;kind:'event'|'job';hash:string;text:string;source:string;review:string;}\nexport async function feedItems(f:Feed,draft:boolean,db:Store=store,now=Date.now()):Promise{\n await initNetwork(db);const jobs=f.type==='jobs';const rows=(await db.q(jobs?\"SELECT * FROM ccn_jobs WHERE city=? AND status='active' ORDER BY last_seen DESC LIMIT 200\":\"SELECT * FROM ccn_events WHERE city=? AND fixture=0 AND duplicate_of IS NULL ORDER BY json_extract(json,'$.date'),first_seen LIMIT 300\",[f.city])).rows;\n const out:FeedItem[]=[],plan=schedule({...cities[f.city],publishTime:f.publishTime},now);\n const auto = !jobs && f.reviewRequired === false;\n const conflicts = auto ? (await db.q(\"SELECT left_id,right_id FROM ccn_duplicates WHERE state='pending'\")).rows : [];\n const unresolved = new Set(conflicts.flatMap(r=>[String(r.left_id),String(r.right_id)]));\n const autoUntil = localParts(now + 14 * 86400000,cities[f.city].timezone).date;\n for(const r of rows){if(['rejected','source_review','duplicate_review'].includes(String(r.review)))continue;const data=JSON.parse(String(r.json)) as Job&EventData;\n if(jobs?Number(r.last_seen)autoUntil)continue;\n }else if(r.review!=='approved'||r.approved_hash!==r.hash||(!jobs&&(Number(r.verified)plan.to||(data.endDate||data.date)${escape(display.title)}`,escape(labels.job),`🏢 ${escape(data.employer)}`,`📍 ${escape(data.location)}`,`💰 ${escape(data.salary||labels.salary)}`,data.employment?escape(data.employment):'',`${labels.link} · ${escape(data.source)}`].filter(Boolean).join('\\n'):renderEvent(data,auto&&t?{...display,description:automaticLabel(data.category,f.locale)}:display,f.locale);\n out.push({id:String(r.id),kind:jobs?'job':'event',hash:String(r.hash),text,source:String(r.source),review:String(r.review)});\n }return out;\n}\nexport async function previewFeed(id:string,draft=true,db:Store=store,now=Date.now()){\n const {feed:f}=await getFeed(id,db);let available=await feedItems(f,draft,db,now);\n if(!draft){const prior=(await db.q(\"SELECT items FROM ccn_feed_deliveries WHERE feed_id=? AND mode='public' AND state IN ('sent','sending','delivery_unknown')\",[id])).rows;const seen=new Set(prior.flatMap(r=>(JSON.parse(String(r.items)) as FeedItem[]).map(x=>x.id)));available=available.filter(x=>!seen.has(x.id));}\n const header=`${escape(f.title)}${draft?'\\nPRIVATE DRAFT — NOT FOR PUBLICATION':''}`,items:FeedItem[]=[];let text=header;\n for(const item of available){if(items.length>=5)break;if((text+'\\n\\n'+item.text).length>3800)continue;text+='\\n\\n'+item.text;items.push(item);}\n return {feed:f,items,text:items.length?text:'',available:available.length,draft,date:localParts(now,cities[f.city].timezone).date};\n}\nexport async function translateJob(id:string,db:Store=store,provider:TranslationProvider=translationProvider):Promise{\n await initNetwork(db);const r=(await db.q(\"SELECT * FROM ccn_jobs WHERE id=? AND status='active' AND review!='rejected'\",[id])).rows[0];if(!r)return false;const j=JSON.parse(String(r.json)) as Job,c=cities[j.city],key=`job:${r.hash}:${c.locale}`;\n const cached=(await db.q(\"SELECT json FROM ccn_translations WHERE key=? AND status='ready'\",[key])).rows[0];if(cached){await db.q('UPDATE ccn_jobs SET translation=?,translation_hash=? WHERE id=? AND hash=?',[String(cached.json),String(r.hash),id,String(r.hash)]);return true;}\n const lock=await db.lease(key,45000);if(!lock)return false;\n try{const cap=Number(await db.setting('translation_daily_cap','12'));if(!(await db.budget(Math.min(50,Math.max(0,cap)))))return false;\n try{const result=await provider.translate({title:j.title,category:'job vacancy'},c),t=validateTranslation(result.value,c.locale,provider.name);const digits=(s:string)=>(s.match(/\\d+/g)||[]).sort().join('|');if(digits(t.title)!==digits(j.title))throw new Error('Changed numbers');\n const text=JSON.stringify(t);await db.batch([{sql:\"INSERT INTO ccn_translations(key,status,json,provider,tokens,created) VALUES (?,'ready',?,?,?,?) ON CONFLICT(key) DO UPDATE SET status='ready',json=excluded.json,tokens=excluded.tokens\",args:[key,text,provider.name,result.tokens,Date.now()]},{sql:'UPDATE ccn_jobs SET translation=?,translation_hash=? WHERE id=? AND hash=?',args:[text,String(r.hash),id,String(r.hash)]},{sql:'UPDATE ccn_usage SET tokens=tokens+? WHERE day=?',args:[result.tokens,new Date().toISOString().slice(0,10)]}]);return true;\n }catch{await db.log('job_translation',j.city,'blocked',{id,reason:'Provider or output validation failed'});return false;}\n }finally{await db.release(key,lock);}\n}\nexport async function translateNetwork(db:Store=store){\n await initNetwork(db);if(await db.setting('network:collection','0')!=='1')return {status:'disabled'};\n const automaticFeeds=(await db.q(\"SELECT json FROM ccn_feeds WHERE json_extract(json,'$.enabled')=1 AND json_extract(json,'$.reviewRequired')=0 AND json_extract(json,'$.external')=0 ORDER BY id\")).rows.map(r=>JSON.parse(String(r.json)) as Feed);\n if(automaticFeeds.length){\n const cursor=Number(await db.setting('network:auto_translation_cursor','0'))%automaticFeeds.length;\n for(let i=0;i? AND (e.translation IS NULL OR e.translation_hash!=e.hash) AND json_extract(e.json,'$.date')<=? AND NOT EXISTS (SELECT 1 FROM ccn_translations t WHERE t.key=e.hash||':'||? AND t.status='blocked' AND t.created>?) ORDER BY json_extract(e.json,'$.date'),e.first_seen LIMIT 40\",[f.city,Date.now()-86400000,until,f.locale,Date.now()-3600000])).rows;\n const r=rows.find(row=>{const e=JSON.parse(String(row.json)) as EventData;return eligible(e)&&e.start!==null&&!!e.venue&&e.issues.length===0&&matchesFeed(f,e);});\n if(!r)continue;\n await db.set('network:auto_translation_cursor',String((cursor+i+1)%automaticFeeds.length));\n const ok=!!await translateEvent(String(r.id),db);\n await db.log('network_translation',f.city,ok?'ready':'blocked',{id:r.id,mode:'automatic',kind:'event'});\n return {status:ok?'ready':'blocked',city:f.city,kind:'event'};\n }\n return {status:'idle'};\n }\n const order=Object.keys(cities),cursor=Number(await db.setting('network:translation_cursor','0'))%order.length;\n for(let i=0;ieligible(JSON.parse(String(r.json))));\n const job=(await db.q(\"SELECT id FROM ccn_jobs WHERE city=? AND status='active' AND review='draft' AND last_seen>? AND (translation IS NULL OR translation_hash!=hash) ORDER BY first_seen LIMIT 1\",[city,Date.now()-86400000])).rows[0];\n if(!event&&!job)continue;\n const useJob=!!job&&(!event||await db.setting('network:translation_kind','event')==='job');\n const item=useJob?job!:event!;await db.set('network:translation_cursor',String((cursor+i+1)%order.length));await db.set('network:translation_kind',useJob?'event':'job');\n const ok=useJob?await translateJob(String(item.id),db):!!await translateEvent(String(item.id),db);await db.log('network_translation',city,ok?'ready':'blocked',{kind:useJob?'job':'event',id:item.id});return {status:ok?'ready':'blocked',city,kind:useJob?'job':'event'};\n }return {status:'idle'};\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"]