[{"_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_collect.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_collect.ts","extension","id","18717bc9-26ed-496d-82d3-4419a4c87c69","fileId","38af3fbe-b279-11f1-9fc0-1607ee4eb77e","parentId","branchId","6de82370-98e9-41cd-add4-480bf35c921b","branchVersion",51,"latest",true,"createdAt",["D",1789637840898],"version",1,"fileType","script","content","import { cities, clean, eligible, hash, safeUrl, type EventData } from './core.ts';\nimport { collectSource, readBounded } from './sources.ts';\nimport { store, type Store } from './store.ts';\nimport { cityNames, initNetwork, type Job } from './network_store.ts';\nconst API='https://api.smartrecruiters.com/v1/companies/AccorHotel/postings';\nexport function jobFromDetail(value:unknown):Omit|null {\n if(!value||typeof value!=='object')return null;const x=value as Record;\n const loc=x.location as Record|undefined,company=x.company as Record|undefined;\n if(x.active!==true||x.visibility!=='PUBLIC'||loc?.country!=='kz'||company?.identifier!=='AccorHotel')return null;\n const city=Object.keys(cityNames).find(k=>cityNames[k].toLowerCase()===clean(loc.city).toLowerCase());if(!city||!/^\\d{5,20}$/.test(String(x.id)))return null;\n const title=clean(x.name);if(!title||title.length>260)return null;\n let url:string;try{url=safeUrl(clean(x.postingUrl),['jobs.smartrecruiters.com']);if(!new URL(url).pathname.startsWith(`/AccorHotel/${x.id}-`))return null;}catch{return null;}\n const released=clean(x.releasedDate),employment=x.typeOfEmployment as Record|undefined;\n return {source:'smartrecruiters:AccorHotel',sourceId:String(x.id),city,title,employer:clean(company.name),location:clean(loc.fullLocation)||clean(loc.city),url,published:released&&Number.isFinite(Date.parse(released))?released:null,employment:clean(employment?.label)||null,salary:null};\n}\nasync function jobGet(url:string,db:Store,fetcher:typeof fetch):Promise{\n const u=new URL(url);if(u.origin!=='https://api.smartrecruiters.com'||!/^\\/v1\\/companies\\/AccorHotel\\/postings(?:\\/\\d{5,20})?$/.test(u.pathname))throw new Error('Job API URL refused');\n const cached=(await db.q('SELECT body,expires FROM ccn_cache WHERE url=?',[url])).rows[0];if(cached&&Number(cached.expires)>Date.now())return JSON.parse(String(cached.body));\n const r=await fetcher(url,{headers:{'User-Agent':'CityEventsReview/0.3 (+https://www.val.town/x/omriluz/telegram-city-network)','Accept':'application/json'},signal:AbortSignal.timeout(6500),redirect:'error'});\n if(!r.ok){await r.body?.cancel();throw new Error(`Job API HTTP ${r.status}`);}const body=await readBounded(r,1500000),data=JSON.parse(body);\n await db.q('INSERT INTO ccn_cache(url,body,expires) VALUES (?,?,?) ON CONFLICT(url) DO UPDATE SET body=excluded.body,expires=excluded.expires',[url,body,Date.now()+3600000]);return data;\n}\nexport async function ingestJobs(jobs:Omit[],db:Store=store){\n let inserted=0,unchanged=0,changed=0;for(const raw of jobs){const id=await hash(`${raw.source}|${raw.sourceId}|${raw.city}`),job={...raw,id},text=JSON.stringify(job),digest=await hash(text);const old=(await db.q('SELECT hash FROM ccn_jobs WHERE id=?',[id])).rows[0];\n if(!old){await db.q('INSERT INTO ccn_jobs(id,city,source,json,hash,first_seen,last_seen) VALUES (?,?,?,?,?,?,?)',[id,job.city,job.source,text,digest,Date.now(),Date.now()]);inserted++;}\n else if(old.hash===digest){await db.q(\"UPDATE ccn_jobs SET last_seen=?,status='active' WHERE id=?\",[Date.now(),id]);unchanged++;}\n else{await db.invalidate(id,'Employer job details changed; check affected Telegram posts');await db.q(\"UPDATE ccn_jobs SET json=?,hash=?,last_seen=?,status='active',review='draft',approved_hash=NULL,translation=NULL,translation_hash=NULL WHERE id=?\",[text,digest,Date.now(),id]);changed++;}\n }return {inserted,unchanged,changed};\n}\nexport async function collectJobs(db:Store=store,fetcher:typeof fetch=fetch){\n const data=await jobGet(API+'?country=kz&limit=100&destination=PUBLIC',db,fetcher) as {content?:{id?:string}[];totalFound?:number};if(!Array.isArray(data.content)||typeof data.totalFound!=='number')throw new Error('Job API schema changed');\n const list=data.content.filter(x=>/^\\d{5,20}$/.test(String(x.id)));const jobs:Omit[]=[];const prior=(await db.q(\"SELECT json,last_seen FROM ccn_jobs WHERE source='smartrecruiters:AccorHotel'\")).rows;\n const checks=new Map(prior.map(r=>[JSON.parse(String(r.json)).sourceId,Number(r.last_seen)]));\n const selected=[...list].sort((a,b)=>(checks.get(String(a.id))||0)-(checks.get(String(b.id))||0)).slice(0,4);\n for(const item of selected){const raw=await jobGet(API+'/'+item.id,db,fetcher);const job=jobFromDetail(raw);if(job)jobs.push(job);else if(raw&&typeof raw==='object'&&((raw as Record).active===false))await db.q(\"UPDATE ccn_jobs SET status='closed',review='draft',approved_hash=NULL WHERE source='smartrecruiters:AccorHotel' AND json_extract(json,'$.sourceId')=?\",[String(item.id)]);}\n const stats=await ingestJobs(jobs,db);\n if(data.totalFound===data.content.length){const ids=new Set(list.map(x=>String(x.id)));for(const row of prior){const j=JSON.parse(String(row.json)) as Job;if(!ids.has(j.sourceId))await db.q(\"UPDATE ccn_jobs SET status='not_listed',review='draft',approved_hash=NULL WHERE id=?\",[j.id]);}}\n return {...stats,observed:jobs.length,available:data.totalFound,cities:[...new Set(jobs.map(j=>j.city))],note:'Employer API only; no resumes/contact collection. Missing jobs held, not assumed filled.'};\n}\nexport type Collector = (row:Record,db:Store)=>Promise>;\nexport const liveCollector:Collector=async(row,db)=>{\n if(row.source==='smartrecruiters:AccorHotel')return collectJobs(db);\n const c=cities[String(row.city)];if(!c||row.source!=='sxodim')throw new Error('Collector not configured');\n const lock=await db.lease(`city:${c.slug}`);if(!lock)throw new Error('City busy');\n try{const events=await collectSource('sxodim',c,db);const stats=await db.ingest(events);return {...stats,observed:events.length,current:events.filter(e=>eligible(e)).length};}finally{await db.release(`city:${c.slug}`,lock);}\n};\nexport async function collectNetwork(db:Store=store,collector:Collector=liveCollector,maxTasks=2){\n await initNetwork(db);if(await db.setting('network:collection','0')!=='1')return {status:'disabled',results:[]};\n const lock=await db.lease('network:collection',120000);if(!lock)return {status:'busy',results:[]};const results:Record[]=[],started=Date.now();\n try{const rows=(await db.q(\"SELECT * FROM ccn_collectors WHERE enabled=1 AND next_due<=? ORDER BY next_due,id LIMIT ?\",[Date.now(),Math.min(6,Math.max(1,maxTasks))])).rows;\n for(const row of rows){if(results.length&&Date.now()-started>22000)break;const id=String(row.id);await db.q('UPDATE ccn_collectors SET next_due=? WHERE id=?',[Date.now()+3600000,id]);\n try{const summary=await collector(row,db);await db.q(\"UPDATE ccn_collectors SET last_run=?,status='ok',summary=? WHERE id=?\",[Date.now(),JSON.stringify(summary),id]);await db.log('network_collection',row.city?String(row.city):null,'ok',{collector:id,...summary});results.push({collector:id,status:'ok',...summary});}\n catch(error){const reason=error instanceof Error?error.message.replace(/https?:\\/\\/\\S+/g,'[source]').slice(0,160):'Collector failed';await db.q(\"UPDATE ccn_collectors SET last_run=?,status='failed',summary=? WHERE id=?\",[Date.now(),JSON.stringify({reason}),id]);await db.log('network_collection',row.city?String(row.city):null,'failed',{collector:id,reason});results.push({collector:id,status:'failed',reason});}\n }\n return {status:'finished',results};}finally{await db.release('network:collection',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"]