مسار بيع وخدمات يعمل من السحابة

حلول رقمية وإعلامية جاهزة للعمل

منتج رقمي جاهز للشراء، وخدمات علاقات عامة ومحتوى واتصال مؤسسي يمكن طلبها مباشرة. هذه الصفحة مستقلة عن جهاز المنزل.

${msg?`

${esc(msg)}

`:\"\"}

غرفة الأخبار الذكية

حزمة رقمية للإعلام وصناعة المحتوى وتسريع سير العمل.

الشراء من متجر سلة

خدمة إعلامية عاجلة

علاقات عامة، محتوى عربي، بيان صحفي، خطة إعلامية، تدقيق وصياغة واتصال مؤسسي.

اطلب عرض خدمة

استشارة PR للسوق السعودي

دعم للجهات التي تحتاج فهمًا للسياق الإعلامي السعودي، الرسائل، المحتوى، وأصحاب المصلحة.

ابدأ الطلب

طلب خدمة

لا يتم الدفع في هذا النموذج. يتم استخدام البيانات فقط للتواصل بشأن الطلب.

`;\n}\nexport default async function(req:Request){\n await init(); const u=new URL(req.url);\n if(u.pathname===\"/buy\"){\n await sqlite.execute({sql:\"INSERT INTO events(created_at,kind,source) VALUES(?,?,?)\",args:[new Date().toISOString(),\"buy_click\",u.searchParams.get(\"src\")||\"\"]});\n return Response.redirect(SALLA,302);\n }\n if(u.pathname===\"/lead\" && req.method===\"POST\"){\n const f=await req.formData(); if(String(f.get(\"website\")||\"\")) return new Response(page(\"تم استلام الطلب.\"),{headers:{\"content-type\":\"text/html; charset=utf-8\"}});\n const name=String(f.get(\"name\")||\"\").trim().slice(0,80), email=String(f.get(\"email\")||\"\").trim().slice(0,160), org=String(f.get(\"organization\")||\"\").trim().slice(0,120), need=String(f.get(\"need\")||\"\").trim().slice(0,1200), source=String(f.get(\"source\")||\"\").slice(0,80);\n if(!name||!email.includes(\"@\")||!need) return new Response(page(\"تحقق من الاسم والبريد ووصف الخدمة.\"),{status:400,headers:{\"content-type\":\"text/html; charset=utf-8\"}});\n await sqlite.execute({sql:\"INSERT INTO leads(created_at,name,email,organization,need,source) VALUES(?,?,?,?,?,?)\",args:[new Date().toISOString(),name,email,org,need,source]});\n return new Response(page(\"تم استلام طلبك بنجاح. سيتم مراجعته للتواصل بشأن نطاق الخدمة.\"),{headers:{\"content-type\":\"text/html; charset=utf-8\"}});\n }\n if(u.pathname===\"/api/opportunities\"){\n try{\n const rows=await sqlite.execute(`SELECT title,url,query,brain_score,category,money_signal,execution_signal,first_seen FROM radar_seen WHERE brain_score>=58 ORDER BY brain_score DESC, first_seen DESC LIMIT 30`);\n const leads=await sqlite.execute(`SELECT COUNT(*) AS n FROM leads`);\n const buys=await sqlite.execute(`SELECT COUNT(*) AS n FROM events WHERE kind='buy_click'`);\n return Response.json({\n ok:true,\n generated_at:new Date().toISOString(),\n rules:{minimum_brain_score:58,confirmed_income_sar:0,note:\"الفرص ليست إيراداً حتى القبول أو الاستحقاق أو التحصيل المؤكد\"},\n metrics:{qualified_opportunities:(rows.rows??[]).length,lead_requests:Number((leads.rows?.[0] as any)?.n||0),buy_clicks:Number((buys.rows?.[0] as any)?.n||0),confirmed_income_sar:0},\n opportunities:rows.rows??[]\n },{headers:{\"access-control-allow-origin\":\"*\",\"cache-control\":\"no-store\"}});\n }catch(e){ return Response.json({ok:false,error:String(e),opportunities:[]},{status:500,headers:{\"access-control-allow-origin\":\"*\",\"cache-control\":\"no-store\"}}); }\n }\n if(u.pathname===\"/health\") return Response.json({ok:true,service:\"Revenue Survival Hub\",time:new Date().toISOString()});\n return new Response(page(),{headers:{\"content-type\":\"text/html; charset=utf-8\",\"cache-control\":\"public, max-age=120\"}});\n}","label","survival-revenue",[18],"pulls","branches","forks","envVars",{"_177":26,"_179":26},"connections",{"_177":26,"_178":26},"count","unfilledCount","emptyCount",{"_34":252,"_13":253,"_64":254,"_44":-5,"_36":37,"_162":255,"_163":100,"_38":256,"_40":26,"_66":204,"_165":257,"_68":24,"_167":-5,"_196":258,"_17":259},{"_34":244,"_13":245,"_64":246,"_44":-5,"_36":37,"_162":247,"_163":100,"_38":248,"_40":26,"_66":204,"_165":249,"_68":24,"_167":-5,"_196":250,"_17":251},{"_34":161,"_13":18,"_64":65,"_44":-5,"_36":37,"_162":81,"_163":100,"_38":241,"_40":74,"_66":67,"_165":166,"_68":24,"_167":168,"_196":242,"_17":243},{"_34":233,"_13":234,"_64":235,"_44":-5,"_36":37,"_162":236,"_163":100,"_38":237,"_40":81,"_66":204,"_165":238,"_68":24,"_167":-5,"_196":239,"_17":240},{"_34":225,"_13":226,"_64":227,"_44":-5,"_36":37,"_162":228,"_163":100,"_38":229,"_40":26,"_66":204,"_165":230,"_68":24,"_167":-5,"_196":231,"_17":232},{"_34":217,"_13":218,"_64":219,"_44":-5,"_36":37,"_162":220,"_163":100,"_38":221,"_40":26,"_66":204,"_165":222,"_68":24,"_167":-5,"_196":223,"_17":224},{"_34":208,"_13":209,"_64":210,"_44":-5,"_36":37,"_162":211,"_163":100,"_38":212,"_40":26,"_66":67,"_165":213,"_68":24,"_167":214,"_196":215,"_17":216},{"_34":199,"_13":200,"_64":201,"_44":-5,"_36":37,"_162":202,"_163":100,"_38":203,"_40":26,"_66":204,"_165":205,"_68":24,"_167":-5,"_196":206,"_17":207},{"_34":189,"_13":190,"_64":191,"_44":-5,"_36":37,"_162":192,"_163":100,"_38":193,"_40":26,"_66":194,"_165":195,"_68":24,"_167":-5,"_196":197,"_17":198},"bc0080e2-b0d6-4921-a851-3a1cd2bb3c01","verify_hot_links.ts","f0003856-9fcf-11f1-bef9-1607ee4eb77e",18,["D",1787585085863],"script","const links=[\n['Senior Management Consultant','https://www.opentrain.ai/jobs/senior-management-consultant-ai-strategy--cmt2ts2vl00050aje09v3wzcs/'],\n['AI Research Question Writer','https://www.opentrain.ai/jobs/ai-research-question-writer-and-evaluator--cmt3gfxdv001r04jr4b93yiqq/'],\n['Enterprise Marketing Content Expert','https://www.opentrain.ai/jobs/enterprise-marketing-and-content-expert--cmt3gfx6q001h04jrw2u0aq77/'],\n['CrowdGen Speech Evaluator','https://jobs.lever.co/appen/de5356d9-cc88-4a20-a09c-c2a1e8f7a3b6']\n];\nexport default async function(){\n const out=[];\n for(const [name,url] of links){\n try{\n const r=await fetch(url,{redirect:'follow',headers:{'user-agent':'Mozilla/5.0 LinkVerifier/1.0'},signal:AbortSignal.timeout(10000)});\n out.push({name,status:r.status,ok:r.ok,final:r.url,contentType:r.headers.get('content-type')});\n }catch(e){out.push({name,status:'ERROR',ok:false,error:String(e)});}\n }\n console.log(JSON.stringify(out,null,2));\n return out;\n}","children",[],[190],"ba1519a4-ce43-42d5-add8-9ac7efe9b07d","timeout_guard.ts","e2a330fc-9fcd-11f1-887b-1607ee4eb77e",15,["D",1787584204457],"interval","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nconst FEEDS = [\n 'https://remotive.com/api/remote-jobs?search=arabic',\n 'https://remotive.com/api/remote-jobs?search=communications',\n 'https://remotive.com/api/remote-jobs?search=content'\n];\nconst KEEP = ['arabic','communications','public relations','media','content','copywriter','ai','evaluator','trainer','localization','marketing'];\nconst BLOCK = ['bank','banking','loan','mortgage'];\n\nasync function sleep(ms:number){ await new Promise(r=>setTimeout(r,ms)); }\nasync function getJson(url:string){\n let last:any;\n for(let i=1;i<=3;i++){\n try{\n const r=await fetch(url,{headers:{'user-agent':'Mozilla/5.0 RevenueTimeoutGuard/1.0'},signal:AbortSignal.timeout(8000)});\n if(!r.ok) throw new Error(`HTTP ${r.status}`);\n return await r.json();\n }catch(e){ last=e; console.log(`Fallback attempt ${i}/3 failed: ${e}`); if(i<3) await sleep(500*Math.pow(2,i-1)); }\n }\n throw last ?? new Error('fallback fetch failed');\n}\n\nexport default async function(_interval: Interval){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS radar_state(key TEXT PRIMARY KEY, value TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS radar_seen(url TEXT PRIMARY KEY, title TEXT, query TEXT, score INTEGER, first_seen TEXT NOT NULL, notified INTEGER NOT NULL DEFAULT 0, brain_score INTEGER NOT NULL DEFAULT 0, category TEXT NOT NULL DEFAULT '', money_signal INTEGER NOT NULL DEFAULT 0, execution_signal INTEGER NOT NULL DEFAULT 0)`);\n const r=await sqlite.execute(`SELECT value FROM radar_state WHERE key='last_success'`);\n const last=String((r.rows?.[0] as any)?.value ?? '');\n const age=last ? Date.now()-Date.parse(last) : Number.POSITIVE_INFINITY;\n if(age < 75*60*1000){ console.log(`Primary radar healthy; age=${Math.round(age/60000)}m`); return; }\n\n console.log('Primary radar stale; activating fallback source.');\n const now=new Date();\n let inserted=0, failures=0;\n for(const feed of FEEDS){\n try{\n const data:any=await getJson(feed);\n for(const j of (data?.jobs ?? []).slice(0,50)){\n const title=String(j?.title ?? '').trim();\n const desc=String(j?.description ?? '').replace(/<[^>]+>/g,' ').replace(/\\s+/g,' ').trim();\n const url=String(j?.url ?? '').trim();\n const s=(title+' '+desc).toLowerCase();\n if(!url || BLOCK.some(k=>s.includes(k)) || !KEEP.some(k=>s.includes(k))) continue;\n const strong=(s.includes('arabic')?20:0)+(s.includes('communications')||s.includes('public relations')?15:0)+(s.includes('content')||s.includes('media')?10:0)+(s.includes('remote')?5:0);\n const brain=Math.min(90,60+strong);\n const ex=await sqlite.execute({sql:`SELECT 1 FROM radar_seen WHERE url=? LIMIT 1`,args:[url]});\n if(ex.rows?.length) continue;\n await sqlite.execute({sql:`INSERT OR IGNORE INTO radar_seen(url,title,query,score,first_seen,notified,brain_score,category,money_signal,execution_signal) VALUES(?,?,?,?,?,0,?,?,?,?)`,args:[url,title,'Fallback Remotive',8,now.toISOString(),brain,'وظائف عن بعد',2,2]});\n inserted++;\n }\n }catch(e){ failures++; console.log(`Fallback feed error: ${e}`); }\n }\n\n await sqlite.execute({sql:`INSERT OR REPLACE INTO radar_state(key,value) VALUES('fallback_last_run',?)`,args:[now.toISOString()]});\n await sqlite.execute({sql:`INSERT OR REPLACE INTO radar_state(key,value) VALUES('fallback_last_status',?)`,args:[failures0 && hour>=7 && hour<21){\n const q=await sqlite.execute(`SELECT url,title,brain_score FROM radar_seen WHERE notified=0 AND query='Fallback Remotive' ORDER BY brain_score DESC LIMIT 6`);\n const rows:any[]=(q.rows ?? []) as any[];\n if(rows.length){\n const body=rows.map((x:any,i:number)=>`${i+1}) ${x.title}\\nScore: ${x.brain_score}/100\\n${x.url}`).join('\\n\\n---\\n\\n');\n await email({subject:`Timeout Guard — ${rows.length} فرص من المسار الاحتياطي`,text:`تعطل/تأخر الرادار الأساسي، فاشتغلت طبقة البنك الاحتياطية تلقائياً. هذه فرص وليست إيراداً حتى القبول والتحصيل.\\n\\n${body}`});\n for(const x of rows){ await sqlite.execute({sql:`UPDATE radar_seen SET notified=1 WHERE url=?`,args:[x.url]}); }\n }\n }\n console.log(`Timeout Guard complete: inserted=${inserted}, failures=${failures}`);\n}",[],[200],"325fbb0e-8b95-4f46-8ebb-8fe2ac79af19","status_public.ts","da0f5fe4-9fd0-11f1-92ef-1607ee4eb77e",20,["D",1787585478534],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport default async function(_req:Request){\n const one=async(sql:string)=>{try{return await sqlite.execute(sql);}catch{return {rows:[] as any[]};}};\n const leads=await one(`SELECT COUNT(*) c FROM leads`);\n const outreach=await one(`SELECT COUNT(*) c FROM outreach_ledger`);\n const platforms=await one(`SELECT COUNT(*) c FROM platform_jobs`);\n const radar=await one(`SELECT COUNT(*) c FROM radar_seen WHERE brain_score>=68`);\n const hot=await one(`SELECT name,http_status,alive,last_checked FROM hot_link_health ORDER BY name`);\n const state=await one(`SELECT key,value FROM radar_state WHERE key IN ('last_success','last_status','fallback_last_run','fallback_last_status') ORDER BY key`);\n const pstate=await one(`SELECT key,value FROM platform_watch_state WHERE key IN ('last_run','last_status') ORDER BY key`);\n const value=(x:any)=>Number((x.rows?.[0] as any)?.c??0);\n const data={service:'Revenue Survival Status',generatedAt:new Date().toISOString(),counts:{leads:value(leads),outreachEntities:value(outreach),platformLinks:value(platforms),highPriorityRadar:value(radar)},hotLinks:hot.rows??[],radarState:state.rows??[],platformState:pstate.rows??[],privacy:'aggregate status only; no lead names or emails exposed'};\n return new Response(JSON.stringify(data,null,2),{headers:{'content-type':'application/json; charset=utf-8','cache-control':'no-store'}});\n}","revenue-survival-status",[],[209],"0f07753b-b535-4e69-9db3-d7eb43f431e5","platform_jobs_watch.ts","e2ae6ea8-9fce-11f1-b7e1-1607ee4eb77e",16,["D",1787584634023],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\nimport { load } from \"npm:cheerio\";\n\nconst SOURCES = [\n {name:'OpenTrain Saudi', url:'https://www.opentrain.ai/jobs/country/saudi-arabia/', base:'https://www.opentrain.ai'},\n {name:'CrowdGen Appen Saudi', url:'https://jobs.lever.co/appen?location=Saudi+Arabia', base:'https://jobs.lever.co'}\n];\nconst WANT = ['arabic','saudi','ksa','communications','public relations','media','content','writer','editor','ai','evaluator','trainer','speech','localization','marketing'];\nconst REJECT = ['bank','banking','loan','mortgage'];\n\nasync function sleep(ms:number){ await new Promise(r=>setTimeout(r,ms)); }\nasync function fetchText(url:string, label:string){\n let last:any;\n for(let i=1;i<=3;i++){\n try{\n const r=await fetch(url,{headers:{'user-agent':'Mozilla/5.0 PlatformJobsWatch/1.0'},signal:AbortSignal.timeout(9000)});\n if(!r.ok) throw new Error(`HTTP ${r.status}`);\n return await r.text();\n }catch(e){ last=e; console.log(`${label} attempt ${i}/3 failed: ${e}`); if(i<3) await sleep(500*Math.pow(2,i-1)); }\n }\n throw last;\n}\nfunction abs(href:string, base:string){ try{return new URL(href,base).href;}catch{return '';} }\nfunction clean(s:string){return s.replace(/\\s+/g,' ').trim();}\nfunction relevant(title:string, context:string){\n const s=(title+' '+context).toLowerCase();\n if(REJECT.some(k=>s.includes(k))) return false;\n return WANT.some(k=>s.includes(k));\n}\n\nexport default async function(_interval: Interval){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS platform_jobs(url TEXT PRIMARY KEY, source TEXT NOT NULL, title TEXT NOT NULL, first_seen TEXT NOT NULL, notified INTEGER NOT NULL DEFAULT 0)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS platform_watch_state(key TEXT PRIMARY KEY, value TEXT NOT NULL)`);\n const init=await sqlite.execute(`SELECT value FROM platform_watch_state WHERE key='initialized'`);\n const initialized=Boolean(init.rows?.length);\n const now=new Date();\n let added=0, failures=0;\n\n for(const src of SOURCES){\n try{\n const html=await fetchText(src.url,src.name);\n const $=load(html);\n const candidates:any[]=[];\n $('a').each((_i,el)=>{\n const a=$(el); const title=clean(a.text()); const href=abs(String(a.attr('href')||''),src.base);\n if(!title || !href) return;\n const parent=clean(a.parent().text()).slice(0,500);\n const h=href.toLowerCase();\n const looksJob = src.name.startsWith('OpenTrain') ? (h.includes('/jobs/') || h.includes('app.opentrain.ai')) : h.includes('jobs.lever.co/appen/');\n if(!looksJob || !relevant(title,parent)) return;\n candidates.push({title,href});\n });\n const unique=new Map(candidates.map(x=>[x.href,x]));\n for(const x of unique.values()){\n const ex=await sqlite.execute({sql:`SELECT 1 FROM platform_jobs WHERE url=? LIMIT 1`,args:[x.href]});\n if(ex.rows?.length) continue;\n await sqlite.execute({sql:`INSERT INTO platform_jobs(url,source,title,first_seen,notified) VALUES(?,?,?,?,0)`,args:[x.href,src.name,x.title,now.toISOString()]});\n added++;\n }\n }catch(e){failures++; console.log(`${src.name} failed: ${e}`);}\n }\n\n await sqlite.execute({sql:`INSERT OR REPLACE INTO platform_watch_state(key,value) VALUES('last_run',?)`,args:[now.toISOString()]});\n await sqlite.execute({sql:`INSERT OR REPLACE INTO platform_watch_state(key,value) VALUES('last_status',?)`,args:[failures===0?'OK':failures=21){ console.log(`Quiet hours; added=${added}`); return; }\n const q=await sqlite.execute(`SELECT url,source,title FROM platform_jobs WHERE notified=0 ORDER BY first_seen ASC LIMIT 10`);\n const rows:any[]=(q.rows??[]) as any[];\n if(!rows.length){console.log(`No new platform jobs; added=${added}`); return;}\n const body=rows.map((x:any,i:number)=>`${i+1}) ${x.title}\\n${x.source}\\n${x.url}`).join('\\n\\n---\\n\\n');\n await email({subject:`وظائف سعودية جديدة — ${rows.length} من OpenTrain/Appen`,text:`رصد الحارس وظائف/مسارات جديدة فقط. لا تعتبر إيراداً حتى القبول والتحصيل.\\n\\n${body}`});\n for(const x of rows){await sqlite.execute({sql:`UPDATE platform_jobs SET notified=1 WHERE url=?`,args:[x.url]});}\n console.log(`Platform watcher alerted ${rows.length} job(s)`);\n}",[],[218],"954cb686-6a88-46bc-8a71-fee45f19be96","outreach_watch.ts","8fb5ad46-9fcf-11f1-ad5d-1607ee4eb77e",17,["D",1787584924257],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nexport default async function(_interval: Interval){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS outreach_ledger(id INTEGER PRIMARY KEY AUTOINCREMENT, entity TEXT NOT NULL, email TEXT NOT NULL, channel TEXT NOT NULL DEFAULT 'gmail', stage TEXT NOT NULL, last_action_at TEXT NOT NULL, followup_after TEXT, max_followups INTEGER NOT NULL DEFAULT 1, followups_sent INTEGER NOT NULL DEFAULT 0, status TEXT NOT NULL DEFAULT 'WAITING', notes TEXT, UNIQUE(entity,email))`);\n try { await sqlite.execute(`ALTER TABLE outreach_ledger ADD COLUMN reminded_at TEXT`); } catch (_) {}\n try { await sqlite.execute(`ALTER TABLE outreach_ledger ADD COLUMN reply_seen_at TEXT`); } catch (_) {}\n const now=new Date();\n const hour=(now.getUTCHours()+3)%24;\n const due=await sqlite.execute(`SELECT id,entity,email,stage,last_action_at,followup_after,followups_sent,max_followups,notes FROM outreach_ledger WHERE status='WAITING' AND followup_after IS NOT NULL AND datetime(followup_after)<=datetime('now') AND followups_sent=21){ console.log(`Quiet hours: ${rows.length} follow-up(s) due; deferred`); return; }\n const body=rows.map((x:any,i:number)=>`${i+1}) ${x.entity}\\n${x.email}\\nالمرحلة: ${x.stage}\\nآخر إجراء: ${x.last_action_at}\\nموعد المتابعة: ${x.followup_after}\\nالمتابعات: ${x.followups_sent}/${x.max_followups}\\nملاحظة: ${x.notes||'-'}`).join('\\n\\n---\\n\\n');\n await email({subject:`Revenue Follow-up Guard — ${rows.length} متابعة مستحقة`,text:`هذه تذكيرات داخلية فقط. لا ترسل المنظومة أي بريد للجهات تلقائيا. افحص الرد الوارد أولاً، ثم نفذ متابعة واحدة فقط إذا لم يوجد رد.\\n\\n${body}`});\n for(const x of rows){await sqlite.execute({sql:`UPDATE outreach_ledger SET reminded_at=? WHERE id=?`,args:[now.toISOString(),Number(x.id)]});}\n console.log(`Outreach guard reminded ${rows.length} due follow-up(s)`);\n}",[],[226],"dbd16b0d-76db-4c4f-a477-2b416a80f946","opportunity_radar.ts","a7ac598e-9fcc-11f1-b877-1607ee4eb77e",14,["D",1787584176326],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\nimport { XMLParser } from \"npm:fast-xml-parser\";\n\nconst QUERIES = [\n 'Saudi Arabia PR consultant freelance remote',\n 'KSA media relations consultant contract hiring',\n 'Saudi communications consultant freelance project hiring',\n 'Arabic PR consultant GCC remote freelance job',\n 'Arabic AI trainer Saudi remote freelance hiring',\n 'Arabic AI evaluator Saudi contract remote job',\n 'Arabic AI content reviewer remote Saudi Arabia hiring',\n 'Saudi Arabic prompt engineer freelance remote job',\n 'Arabic localization reviewer freelance remote hiring',\n 'Arabic copywriter Saudi freelance remote job',\n 'Arabic journalism freelance remote paid job',\n 'Saudi digital media consultant contract hiring',\n 'Saudi Arabia paid user research participant Arabic',\n 'Arabic usability testing paid participant Saudi Arabia',\n 'Saudi AI hackathon cash prize 2026 open registration',\n 'Gulf communications consultant Saudi freelance job'\n];\n\nconst POS = ['saudi','ksa','arabic','pr','public relations','communications','media','ai','evaluator','trainer','consultant','freelance','remote','contract','paid','hourly','project','hiring','job','opportunity','participant'];\nconst NEG = ['course','certificate','tuition','buy now','discount','restaurant','pizza','hotel deal','definition','history'];\nconst BLOCK = ['bank','banking','mortgage','loan'];\nconst BLOCK_DOMAINS = ['wikipedia.org','gnu.org','omniglot.com','britannica.com','worldpopulationreview.com','quora.com'];\nconst INTENT = ['job','jobs','hiring','career','careers','freelance','contract','consultant','opportunity','apply','application','vacancy','remote','project','paid','participant','prize','evaluator','reviewer','trainer'];\nconst MONEY = ['paid','hourly','salary','compensation','contract','freelance','project','consultant','cash prize'];\nconst EXEC = ['remote','freelance','contract','reviewer','evaluator','trainer','copywriter','consultant','participant'];\n\nfunction text(v:any){ return String(v ?? '').replace(/\\s+/g,' ').trim(); }\nfunction hostOf(link:string){ try { return new URL(link).hostname.toLowerCase(); } catch { return ''; } }\nfunction blockedHost(link:string){ const h=hostOf(link); return BLOCK_DOMAINS.some(d=>h===d||h.endsWith('.'+d)); }\nfunction hasIntent(s:string){ return INTENT.some(k=>s.includes(k)); }\nfunction baseScore(title:string, desc:string, link:string){\n const s=(title+' '+desc).toLowerCase();\n if (blockedHost(link) || BLOCK.some(k=>s.includes(k)) || !hasIntent(s)) return -99;\n let n=0;\n for(const k of POS) if(s.includes(k)) n++;\n for(const k of NEG) if(s.includes(k)) n-=4;\n return n;\n}\nfunction countHits(s:string, terms:string[]){ return terms.reduce((n,k)=>n+(s.includes(k)?1:0),0); }\nfunction category(s:string){\n if(/user research|usability|participant|interview/.test(s)) return 'بحث مدفوع';\n if(/hackathon|cash prize|prize/.test(s)) return 'مسابقة/جائزة';\n if(/ai|prompt|evaluator|trainer|reviewer/.test(s)) return 'ذكاء اصطناعي';\n if(/pr|public relations|communications|media|journalism/.test(s)) return 'إعلام وعلاقات عامة';\n if(/copywriter|localization/.test(s)) return 'محتوى ولغة';\n return 'خدمة احترافية';\n}\nfunction extendedScore(title:string, desc:string, query:string, link:string, base:number){\n const content=(title+' '+desc).toLowerCase();\n const context=query.toLowerCase();\n if (blockedHost(link) || !hasIntent(content)) return {score:0,money:0,execution:0,category:'مرفوض'};\n const money=countHits(content,MONEY);\n const execution=countHits(content,EXEC);\n const direct=countHits(content,['hiring','apply','job','jobs','vacancy','opportunity','contract','freelance','paid','participant']);\n const geo=countHits(content+' '+context,['saudi','ksa','arabic','gulf']);\n const speculative=/hackathon|cash prize|prize/.test(content) ? 8 : 0;\n const score=Math.max(0,Math.min(100, 20 + Math.max(0,base)*5 + Math.min(4,money)*7 + Math.min(4,execution)*4 + Math.min(3,direct)*5 + Math.min(3,geo)*2 - speculative));\n return { score:Math.round(score), money, execution, category:category(content+' '+context) };\n}\nfunction arr(x:T|T[]|undefined):T[]{ return x==null?[]:Array.isArray(x)?x:[x]; }\nasync function sleep(ms:number){ await new Promise(r=>setTimeout(r,ms)); }\nasync function fetchWithRetry(url:string, q:string){\n let last:any;\n for(let attempt=1; attempt<=3; attempt++){\n try{\n const r=await fetch(url,{headers:{'user-agent':'Mozilla/5.0 RevenueRadar/2.2'},signal:AbortSignal.timeout(8000)});\n if(!r.ok) throw new Error(`HTTP ${r.status}`);\n return r;\n }catch(e){\n last=e;\n console.log(`Fetch attempt ${attempt}/3 failed for ${q}: ${e}`);\n if(attempt<3) await sleep(500*Math.pow(2,attempt-1));\n }\n }\n throw last ?? new Error('fetch failed');\n}\n\nexport default async function(_interval: Interval){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS radar_seen(url TEXT PRIMARY KEY, title TEXT, query TEXT, score INTEGER, first_seen TEXT NOT NULL, notified INTEGER NOT NULL DEFAULT 0)`);\n for (const alter of [\n `ALTER TABLE radar_seen ADD COLUMN notified INTEGER NOT NULL DEFAULT 0`,\n `ALTER TABLE radar_seen ADD COLUMN brain_score INTEGER NOT NULL DEFAULT 0`,\n `ALTER TABLE radar_seen ADD COLUMN category TEXT NOT NULL DEFAULT ''`,\n `ALTER TABLE radar_seen ADD COLUMN money_signal INTEGER NOT NULL DEFAULT 0`,\n `ALTER TABLE radar_seen ADD COLUMN execution_signal INTEGER NOT NULL DEFAULT 0`\n ]) { try { await sqlite.execute(alter); } catch (_) {} }\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS radar_state(key TEXT PRIMARY KEY, value TEXT NOT NULL)`);\n const st=await sqlite.execute(`SELECT value FROM radar_state WHERE key='initialized'`);\n const initialized=Boolean(st.rows?.length);\n\n // Re-score all existing records with strict content-based validation.\n const existing=await sqlite.execute(`SELECT url,title,query,score FROM radar_seen LIMIT 500`);\n for(const x of (existing.rows ?? []) as any[]){\n const brain=extendedScore(text(x.title),'',text(x.query),text(x.url),Number(x.score)||0);\n await sqlite.execute({sql:`UPDATE radar_seen SET brain_score=?,category=?,money_signal=?,execution_signal=? WHERE url=?`,args:[brain.score,brain.category,brain.money,brain.execution,x.url]});\n }\n\n const now=new Date();\n await sqlite.execute({sql:`INSERT OR REPLACE INTO radar_state(key,value) VALUES('last_started',?)`,args:[now.toISOString()]});\n const runIndex=Math.floor(now.getTime()/3600000);\n const batchSize=4;\n const start=(runIndex*batchSize)%QUERIES.length;\n const selected=Array.from({length:batchSize},(_,i)=>QUERIES[(start+i)%QUERIES.length]);\n const parser=new XMLParser({ignoreAttributes:false});\n let inserted=0;\n let sourceFailures=0;\n\n for(const q of selected){\n try{\n const url='https://www.bing.com/search?format=rss&q='+encodeURIComponent(q+' -wikipedia -gnu -omniglot -britannica');\n const r=await fetchWithRetry(url,q);\n if(!r.ok){ console.log(`Bing ${r.status} for ${q}`); continue; }\n const xml=await r.text();\n const obj=parser.parse(xml);\n const items=arr(obj?.rss?.channel?.item).slice(0,12);\n for(const it of items){\n const title=text(it?.title), link=text(it?.link), desc=text(it?.description);\n if(!link || !/^https?:\\/\\//i.test(link)) continue;\n const raw=baseScore(title,desc,link);\n if(raw<4) continue;\n const brain=extendedScore(title,desc,q,link,raw);\n if(brain.score<58) continue;\n const exists=await sqlite.execute({sql:`SELECT 1 FROM radar_seen WHERE url=? LIMIT 1`,args:[link]});\n if(exists.rows?.length) continue;\n await sqlite.execute({sql:`INSERT OR IGNORE INTO radar_seen(url,title,query,score,first_seen,notified,brain_score,category,money_signal,execution_signal) VALUES(?,?,?,?,?,0,?,?,?,?)`,args:[link,title,q,raw,now.toISOString(),brain.score,brain.category,brain.money,brain.execution]});\n inserted++;\n }\n }catch(e){ sourceFailures++; console.log(`Radar error ${q}: ${e}`); }\n }\n\n const health = sourceFailures===0 ? 'OK' : (sourceFailures=21){\n console.log(`Quiet hours: collected ${inserted} new result(s), alerts deferred.`);\n return;\n }\n\n const pending=await sqlite.execute(`SELECT url,title,query,score,brain_score,category,money_signal,execution_signal FROM radar_seen WHERE notified=0 AND brain_score>=68 ORDER BY brain_score DESC, first_seen ASC LIMIT 6`);\n const best:any[]=(pending.rows ?? []) as any[];\n if(!best.length){ console.log(`No new high-priority opportunities; inserted=${inserted}`); return; }\n\n const body=best.map((x:any,i:number)=>`${i+1}) ${x.title}\\nالعقل الممتد: ${x.brain_score}/100\\nالفئة: ${x.category}\\nإشارة المال: ${x.money_signal} | قابلية التنفيذ: ${x.execution_signal}\\n${x.url}`).join('\\n\\n---\\n\\n');\n await email({subject:`العقل الممتد — ${best.length} فرص عالية الأولوية`,text:`هذه فرص مصنفة وليست إيراداً. لا يُسجّل أي ريال إلا بعد قبول/استحقاق/تحصيل مؤكد.\\n\\n${body}\\n\\nمركز الدخل: https://survival-revenue.val.run/\\nالعقل الممتد: https://aql-mumtad.val.run/`});\n for(const x of best){ await sqlite.execute({sql:`UPDATE radar_seen SET notified=1 WHERE url=?`,args:[x.url]}); }\n console.log(`Extended Mind alerted ${best.length} high-priority opportunity(ies)`);\n}",[],[234],["D",1787583994697],[],[18],"833ab83a-5df9-4407-807a-3e4032f75474","lead_watch.ts","23660ef0-9fcb-11f1-9ea8-1607ee4eb77e",3,["D",1787583024616],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nexport default async function (_interval: Interval) {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS lead_watch_state(id INTEGER PRIMARY KEY CHECK(id=1), last_notified_id INTEGER NOT NULL DEFAULT 0)`);\n await sqlite.execute(`INSERT OR IGNORE INTO lead_watch_state(id,last_notified_id) VALUES(1,0)`);\n const state = await sqlite.execute(`SELECT last_notified_id FROM lead_watch_state WHERE id=1`);\n const last = Number(state.rows?.[0]?.last_notified_id ?? 0);\n const fresh = await sqlite.execute({sql:`SELECT id,created_at,name,email,organization,need FROM leads WHERE id>? ORDER BY id ASC LIMIT 20`,args:[last]});\n if (!fresh.rows?.length) { console.log(\"No new leads\"); return; }\n const rows:any[] = fresh.rows as any[];\n const text = rows.map((r:any)=>`#${r.id} | ${r.created_at}\\nالاسم: ${r.name}\\nالبريد: ${r.email}\\nالجهة: ${r.organization || '-'}\\nالطلب: ${r.need}`).join(\"\\n\\n---\\n\\n\");\n await email({subject:`طلب خدمة جديد — مركز الدخل (${rows.length})`,text:`وصلت طلبات جديدة عبر مركز الدخل السحابي:\\n\\n${text}\\n\\nرابط المركز: https://survival-revenue.val.run/`});\n const maxId = Math.max(...rows.map((r:any)=>Number(r.id)));\n await sqlite.execute({sql:`UPDATE lead_watch_state SET last_notified_id=? WHERE id=1`,args:[maxId]});\n console.log(`Notified ${rows.length} lead(s), through id ${maxId}`);\n}",[],[245],"3bc73e38-096e-4326-b2d1-58cf3f6de171","hot_link_health.ts","09e6d892-9fd0-11f1-9c2f-1607ee4eb77e",19,["D",1787585129313],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst HOT=[\n ['CrowdGen Speech Evaluator','https://jobs.lever.co/appen/de5356d9-cc88-4a20-a09c-c2a1e8f7a3b6'],\n ['OpenTrain AI Research Question Writer','https://www.opentrain.ai/jobs/ai-research-question-writer-and-evaluator--cmt3gfxdv001r04jr4b93yiqq/'],\n ['OpenTrain Enterprise Marketing Content Expert','https://www.opentrain.ai/jobs/enterprise-marketing-and-content-expert--cmt3gfx6q001h04jrw2u0aq77/'],\n ['OpenTrain Senior Management Consultant','https://www.opentrain.ai/jobs/senior-management-consultant-ai-strategy--cmt2ts2vl00050aje09v3wzcs/']\n];\n\nexport default async function(_interval: Interval){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS hot_link_health(url TEXT PRIMARY KEY,name TEXT NOT NULL,http_status INTEGER,last_checked TEXT NOT NULL,alive INTEGER NOT NULL,last_error TEXT)`);\n const now=new Date().toISOString();\n for(const [name,url] of HOT){\n let status=0,alive=0,error='';\n try{\n const r=await fetch(url,{redirect:'follow',headers:{'user-agent':'Mozilla/5.0 HotLinkHealth/1.0'},signal:AbortSignal.timeout(9000)});\n status=r.status; alive=r.ok?1:0;\n }catch(e){error=String(e);}\n await sqlite.execute({sql:`INSERT INTO hot_link_health(url,name,http_status,last_checked,alive,last_error) VALUES(?,?,?,?,?,?) ON CONFLICT(url) DO UPDATE SET name=excluded.name,http_status=excluded.http_status,last_checked=excluded.last_checked,alive=excluded.alive,last_error=excluded.last_error`,args:[url,name,status,now,alive,error]});\n console.log(`${name}: status=${status} alive=${alive}${error?' error='+error:''}`);\n }\n}",[],[253],["D",1787582853742],["D",1789494036282],{"_11":12,"_139":71},{"_11":12,"_135":12,"_70":71,"_30":69,"_136":137,"_138":24},{"_40":126,"_13":16,"_34":37,"_127":88,"_128":-5,"_129":-5,"_130":-5,"_131":-5,"_132":-5,"_133":14,"_134":12},"ctx",{"_54":-5,"_158":298,"_299":300,"_301":302,"_303":24,"_304":24,"_305":24,"_306":100,"_307":-5,"_308":-7,"_309":-7,"_310":26,"_311":24,"_312":24,"_313":-5,"_314":24,"_315":24,"_316":24,"_317":-5},"ENV",{"_269":270,"_271":272,"_273":16,"_274":275,"_276":277,"_278":279,"_280":281,"_282":283,"_284":285,"_286":287,"_288":289,"_290":291,"_292":293,"_294":295,"_296":297},"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"]

History · main.ts