duangsuse · November 15, 2025 01:33
diff --git a/1024.js b/1024.js
 tgTopic=(tme,sent,   m=/t\.me\/c\/(-?\d+)(?:\/(\d+))?/.exec(tme), id=+sent.B, SK=(this.$?.SK_TG?? location.href).replace(/getMe$/,''))=>
 fetch(SK+(sent['']?? (sent.B? 'editMessageText':'sendMessage')), {
  method: 'POST',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify({
    chat_id: m[1]>0? '-100'+m[1] : -m[1],
    message_thread_id: m[2],
    message_id: (sent.B=undefined, id),
    parse_mode: 'MarkdownV2',
    ...sent,
  })
 }).then(async(r)=>With((await r.json()).result??Error('-> Network Tab'), (u, c,mt)=>{
  u.valueOf=()=>u.message_id
  u.toJSON=()=>(c=('-'+u.chat.id).replace(/^--100/,''), {text:sent.text, A:u.from.id, B:u.message_id, C:(mt=u.message_thread_id)? `t.me/c/${c}/${mt}` : +c })
 }))

 LocalStorage=async(pre, T=JSON)=>{
  pre=pre.substr()+'.'
  let mem={}, st
  if(st=this.localStorage) return new Proxy(st, {get:(_,k)=>T.parse(_[k]??'null'), set(_,k,v){_[k]=T.stringify(v); return'dump!'} })
  st = globalThis.sharedStorage
  for (let {name:k} of (await st.list({prefix: pre})).keys) {
    mem[k.slice(pre.length)] = T.parse(await st.get(k)); 
  }
  return new Proxy(mem, {get:(_,k)=>k=='then'? Promise.all(LocalStorage.atexit):(_[k]), set(_,k,v){LocalStorage.atexit.push(st.put(pre+k, T.stringify(_[k]=v))); return'unfinish'} })
 }
 LocalStorage.atexit=[];

 fetchChat = (SK_AI, api='https://openrouter.ai/api/v1/chat/completions') => async (am,sys={}) => {
  /** Try: https://openrouter.ai/docs/api-reference/parameters#seed
    Use event.waitUntil(max=30s) or fastcron.com: https://developers.cloudflare.com/workers/platform/limits/#how-long-can-a-subrequest-take
    Learn more: Bref.sh, babel-preset-php */

  let[ai,tok] = SK_AI.split(':', 2), apai=api
  am = am.substr ? [{
    role: 'user',
    content: am
  }] : am
  if (sys.rule) {
    am.unshift({ role: 'system', content: sys.rule })
    if(/^JSON (example|示例)/.test(sys.rule)) sys.response_format={type:'json_object'}
    sys.rule=undefined
  }
  if(!/^http/.test(api)) { if(tok= api.find?.(r=>am[0].content.includes(r[0]))?.[1]) return {content:tok, valueOf:()=>tok};  apai='https://openrouter.ai/api/v1/chat/completions' } //MOCK
  const chat = {
    model: ai,
    messages: am, ...sys
  },
   response = await fetch(apai, {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${tok}`,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify(chat)
  }),
    data = await response.json(),
    res = With(data.choices?.[0]?.message, u=>u.toString=()=>u.content)
  return !res? Error(data.error.message) : (sys.response_format? JSON.parse(res+'') : res)
 }
 // aii= fetchChat('',[['鸡','太美']])


 With=(u,f)=>u!=null? (f(u),u) : u
 shuf=a=>a.sort(() => Math.random() - 0.5)
 md=(lit, ...val)=>val.reduce((A,B,i)=>A+String(B).replace(/([*_#`>\-![\.\]()|~+={}])/g, '\\$1')+lit[i+1], lit[0])

 function* listWeekAmPmDates(dt=new Date, apm=[[8, 0, 0, 0], [20, 0, 0, 0]]) {
  let week1 = With(dt, u=>new Date(u.setDate(u.getDate() - u.getDay() + 1)));
  // 遍历7天
  for (let i = 0; i < 7; i++) {
    const day = new Date(week1);
    day.setDate(week1.getDate() + i);
    for(hr of apm) { dt=new Date(day); dt.setHours(...hr); yield dt }
  }
 }
 /////
 let
 ai = fetchChat('google/gemini-2.5-pro:sk-or-v1-visitOpenRouter.ai')
    
 $=await LocalStorage('F12')

 function enableTouch(element, kRoll=-1) {
  if(!navigator.maxTouchPoints)return;
  let startY = 0;
  element.addEventListener('touchstart', e => startY = e.touches[0].clientY);
  element.addEventListener('touchmove', e => {
    e.preventDefault(); // å¯é€‰ï¼Œé˜»æ¢é»˜è®¤æ»šåŠ¨
    const deltaY = startY - e.touches[0].clientY;
    element.dispatchEvent(new WheelEvent('mousewheel', { bubbles: true, deltaY: deltaY * kRoll }));
    startY = e.touches[0].clientY;
  });
 }


 function forwardEvent(fromElement, toElement, eventType) {
  fromElement.addEventListener(eventType, e => {
    const newEvent = new e.constructor(e.type, e);
    toElement.dispatchEvent(newEvent);
    e.preventDefault()
  });
 }

 function serializeForm(e, st=localStorage, v) {
  addEventListener('unload', () => {
    v=JSON.stringify(Object.fromEntries(new FormData(e)))
    st[e.id]=v
  })
  jq(() => {
    v = JSON.parse(st[e.id] || '{}');
    Object.entries(v).forEach(([key, value]) => {
      const input = e.querySelector(`[name="${key}"]`);
      if (input) input.value = value; try{input.onchange(value)}catch{}
    });
  })
 } 

 const
 _404=(genkey,u={})=>new Proxy(u, {get:(u,k)=>u[k]?? (u[k]=genkey(k)) })
 ,setInterPoll=(f,n,dt_ms=500, dep=()=>((n.nodeType?n.isConnected : (n-->1))? setTimeout(dep, dt_ms) :0, f()))=>dep()
 ,useChanged=(find=()=>true, opt=[document, { attributes: true, childList: true, subtree: true }])=>new Promise(OK=>new MutationObserver((_, obs,e) =>{e=find(); e&&(obs.disconnect(),OK(e)) }).observe(...opt))

 ,useVisibleEventPair = (e, rw, percent = 10) => {
  // use IntersectionObserver(e)
  let opt = {
    root: null, // viewport
    rootMargin: '0px',
    threshold: percent / 100,
  },
    res = new IntersectionObserver((entries) => {
      entries.forEach(it => rw(!it.isIntersecting));
    }, opt);

  res.observe(e);
  return () => res.disconnect();
 }
 {
  let n = 1, _dispose = [];
  useHover = (rule, rw) => {
    let k = `--js_f${n}`, js_fn = app.appendChild(doc.createElement('span'))
    js_fn.style.cssText = `
      position: fixed;
      top: 0;
      display: var(${k});
    `;
    rule(qs => `:has(${qs}){${k}: none}`); n++
    _dispose.push(useVisibleEventPair(js_fn, rw, 100))
  }
 }
 {let 
 dsl=(tag,...cfg_ee)=>{
  tag=tag.substr? document.createElement(tag) : tag
  for(let i=0,e; e=cfg_ee[i];i++) e.call? e(tag)
    : e.nodeType? tag.append(e)
    : Object.entries(e).forEach(i==0? (([k,v])=>tag.setAttribute(k,v)) : ([k,f])=>tag.addEventListener(k,f))
  return tag
 }
 el=_404(k=>k=='As'? dsl : dsl.bind(0, k))
 }

 URL.svg=([W,H],s)=>`data:image/svg+xml,%3Csvg xmlns='http://www.w3.org/2000/svg' width='${W}' height='${H}'%3E${encodeURI(s)}%3C/svg%3E`
 CSS.href=s=>document.adoptedStyleSheets.push(With(new CSSStyleSheet(),c=>c.replaceSync(s)) )

 ////
 const CACHE = 'v1'
 const MAX_AGE = 60 * 60 * 1000; // 1小时
 const OFFLINE = `<!DOCTYPE html><head>
  <meta charset="utf-8"></head>
  <body style="font:sans-serif;text-align:center;margin:50px"><h1>离线</h1><button onclick="location.reload()">刷新</button></body>
 `;

 self.oninstall = self.skipWaiting;
 self.onfetch = (ev) => {
  const req = ev.request, url = new URL(req.url), DATE = 'Date';
  if (ev.request.method !== 'GET' || url.origin !== self.location.origin) {
    return;
  }
  const swr =
  caches.open(CACHE).then(cache =>
    cache.match(req).then(body => {
      const now = Date.now(), dt = body? Date.parse(body.headers.get(DATE)) : now,
      // headers要重克隆才可变，算了
        sets = async(k,res, u)=>(u=res.clone(), u.headers.set(k, (new Date).toUTCString()), await cache.put(req, u.clone()), res),
        age = body ? (now - dt) : Infinity;

      // 1. 有缓存且未过期 → 直接返回
      if (body && age < MAX_AGE) {
        return body;
      }

      // 发起网络请求（带 ETag 省流量），有更新&200 → 存新缓存
      let upd = fetch(req).then(body1 => {
        if (body1.status === 304) {
          // 服务端说“没变” → 一小时后更新旧缓存
          return sets(DATE, body);
        } 
       return body1.ok? sets(DATE, body1) : body1;
      })
      return (req.mode!='navigate')? upd :
        upd.catch(() => (body&&url.searchParams.get('swr')=='offline')? body 
        : new Response(OFFLINE, {status: 503, headers: { 'Content-Type': 'text/html' }}) );
    })
  )
  ev.respondWith(swr)
 };

 ////
 caches.open('v2').then(r=>{self.cache = r; addEventListener('fetch', main)})
 const HTM_OFFLINE = c=>`<!DOCTYPE html><html><head>
 <title>离线</title></head><body><h1>${c.ti}</h1>
 <pre>页游的其他域名（双击选中，右键访问）： 
 trtbf.ca
 bililibi.com
 squid4046.t.me
 🙏 感谢您的谅解！
 ${c.dur}秒后访问，将会显示缓存内的版本，直到重新连接或重启。
 </pre>
 <style>
  body{font-family:system-ui,sans-serif;margin:2rem;background:#fffbef;}
  h1{color:#d33;}
  pre{background:#f8f8f8;padding:1rem;border-radius:8px;font-size:0.9rem;}
 </style>
 </body></html>`,
 RE_OUR404=/nginx<\/center>/,
 RE_UNSAFE=/.*/,

 IPLAY_PAGE=`
 &mod=upgrade&act=index
 &mod=faction&act=index
 &mod=goods&act=index
 &mod=auction&act=index
 &mod=fairy&act=index
 &mod=breach&act=index
 &mod=mountain&act=index
 &mod=marry&act=index
 &mod=index&act=index
 `.replace(/(.+)/gm, '/plugin.php?id=iplay:front$1&server=1').split(/\n+/), //RegExp(s.trim().split(/\n+/).join('|'))

 WAF_HOST=new Set([
  "static.cloudflareinsights.com",
  "store.steampowered.com",
  "w.soundcloud.com",
  "www.googletagmanager.com",
 ]),
 WAF_IFWIN=`script-src ${[...WAF_HOST].join(' ')};`,
 WAF_CSP=`upgrade-insecure-requests; sandbox allow-scripts allow-same-origin;
    default-src 'self'; img-src * data:; media-src *; font-src *; style-src 'self' 'unsafe-inline';
    object-src 'none'; base-uri 'self'; frame-ancestors 'self'; form-action 'self';`+
    WAF_IFWIN .replace(/.*(-src) (.*);/, "script; connect; frame;".replaceAll(';', "$1 'self' $2;\n").replaceAll(' /', ' https://wojs.org/'))




 // 【可选】让新 SW 立即接管
 self.addEventListener('install', () => self.skipWaiting())
 self.addEventListener('activate', () => self.clients.claim())

 // sw.js
 function main(ev) {
  const { request: rq } = ev, u = new URL(rq.url)
  if (u.origin !== location.origin) return

  if (u.search.startsWith('?id=iplay:front')) { // 页游不兼容AJAX时清缓存
    if (/&mod=bag&act=index|&mod=upgrade&act=pking/.test(u.search)) IPLAY_PAGE.forEach(k=> cache.delete(k))
  }

  if (rq.destination === 'document') {
    let csp =  {
      'Content-Security-Policy': RE_UNSAFE.test(rq.url)? WAF_CSP.replace('script-src', "script-src 'unsafe-inline' 'unsafe-eval'") : WAF_CSP,
      'Permissions-Policy': `geolocation=(), camera=(), microphone=()`
    }
    return ev.respondWith(swr(rq).then(addHeader.bind(0, csp)))
  }
  ev.respondWith(swr(rq))
 }
 addHeader=(kv, r, MIME='text/html')=>{
  const contentType = r.headers.get('content-type');
  if (!contentType || !contentType.includes(MIME)) {
    return r;  // 非 HTML，直接返回
  }
  const kv1 = new Headers(r.headers); Object.keys(kv).forEach(k=>kv1.set(k, (''+kv[k]).replaceAll('\n','') ))
  return new Response(r.body, {
    headers: kv1,
    status: r.status,
    statusText: r.statusText,
  })
 }

 async function swr(req) {
  let net = (self.navigator?.onLine ?? true), r = await cache.match(req), dur
  try {
    if(!net) { if(!dtOff || (dur=Date.now()-dtOff)<10*1000) {dtOff=dtOff||Date.now(); throw ''} }
    else { dtOff = 0 }
    r = r?? await fetch(req)
    if(await verify(r)||verify.bad) throw ''
    F5(req)
    return r
  } catch (_) {
    r = new Response(HTM_OFFLINE({ti:net? (verify.bad|| "您似乎来到了没有知识的洼地"):"您已离线……", dur: Math.max(0, net?404: 10-dur/1000 >>0)}), {
      headers: { 'Content-Type': 'text/html; charset=utf-8' }
    })
    verify.bad=''; return r
  }
 }
 let
 dtOff=0,
 verify=async(r)=>{
  if(r.status==404||r.status==521) {
    let s=await r.clone().text()
    verify.bad=RE_OUR404.test(s)? '': '服务端正在打怪升级'; return true
  }
 },
 F5=(req)=>{
  fetch(req).then(r => {
    if (r && r.ok) cache.put(req, r.clone())
    else verify(r)
  }).catch(ex => { })
 }


 /*
 //   if(!WAF_HOST.has(u.hostname)) return ev.respondWith(new Response('Domain not whitelisted', { status: 403 }))
 <script>if (navigator.serviceWorker) {
 navigator.serviceWorker.register ('./sw.js')
 {
 // WARN: Run first & CSP deny iframe,worker-src. IPCs(sw.controller) are not hooked.
 let hook=(T,k,f, f0)=>{T=T.prototype?? T, f0=T[k], Object.defineProperty(T,k, {value: f(f0), writable:0,configurable:0})}
 hook(ServiceWorkerRegistration,'unregister', to=>async()=>{})
 hook(navigator.serviceWorker,'register', to=>async()=>{})
 }
 } </script>
 */
diff --git a/fortune.md b/fortune.md
	tgTopic=(tme,sent, m=/t\.me\/c\/(-?\d+)(?:\/(\d+))?/.exec(tme), id=+sent.B, SK=(this.$?.SK_TG?? location.href).replace(/getMe$/,''))=>
	fetch(SK+(sent['']?? (sent.B? 'editMessageText':'sendMessage')), {
	method: 'POST',
	headers: { 'Content-Type': 'application/json' },
	body: JSON.stringify({
	chat_id: m[1]>0? '-100'+m[1] : -m[1],
	message_thread_id: m[2],
	message_id: (sent.B=undefined, id),
	parse_mode: 'MarkdownV2',
	...sent,
	})
	}).then(async(r)=>With((await r.json()).result??Error('-> Network Tab'), (u, c,mt)=>{
	u.valueOf=()=>u.message_id
	u.toJSON=()=>(c=('-'+u.chat.id).replace(/^--100/,''), {text:sent.text, A:u.from.id, B:u.message_id, C:(mt=u.message_thread_id)? `t.me/c/${c}/${mt}` : +c })
	}))

	LocalStorage=async(pre, T=JSON)=>{
	pre=pre.substr()+'.'
	let mem={}, st
	if(st=this.localStorage) return new Proxy(st, {get:(_,k)=>T.parse(_[k]??'null'), set(_,k,v){_[k]=T.stringify(v); return'dump!'} })
	st = globalThis.sharedStorage
	for (let {name:k} of (await st.list({prefix: pre})).keys) {
	mem[k.slice(pre.length)] = T.parse(await st.get(k));
	}
	return new Proxy(mem, {get:(_,k)=>k=='then'? Promise.all(LocalStorage.atexit):(_[k]), set(_,k,v){LocalStorage.atexit.push(st.put(pre+k, T.stringify(_[k]=v))); return'unfinish'} })
	}
	LocalStorage.atexit=[];

	fetchChat = (SK_AI, api='https://openrouter.ai/api/v1/chat/completions') => async (am,sys={}) => {
	/** Try: https://openrouter.ai/docs/api-reference/parameters#seed
	Use event.waitUntil(max=30s) or fastcron.com: https://developers.cloudflare.com/workers/platform/limits/#how-long-can-a-subrequest-take
	Learn more: Bref.sh, babel-preset-php */

	let[ai,tok] = SK_AI.split(':', 2), apai=api
	am = am.substr ? [{
	role: 'user',
	content: am
	}] : am
	if (sys.rule) {
	am.unshift({ role: 'system', content: sys.rule })
	if(/^JSON (example\|示例)/.test(sys.rule)) sys.response_format={type:'json_object'}
	sys.rule=undefined
	}
	if(!/^http/.test(api)) { if(tok= api.find?.(r=>am[0].content.includes(r[0]))?.[1]) return {content:tok, valueOf:()=>tok}; apai='https://openrouter.ai/api/v1/chat/completions' } //MOCK
	const chat = {
	model: ai,
	messages: am, ...sys
	},
	response = await fetch(apai, {
	method: 'POST',
	headers: {
	'Authorization': `Bearer ${tok}`,
	'Content-Type': 'application/json'
	},
	body: JSON.stringify(chat)
	}),
	data = await response.json(),
	res = With(data.choices?.[0]?.message, u=>u.toString=()=>u.content)
	return !res? Error(data.error.message) : (sys.response_format? JSON.parse(res+'') : res)
	}
	// aii= fetchChat('',[['鸡','太美']])


	With=(u,f)=>u!=null? (f(u),u) : u
	shuf=a=>a.sort(() => Math.random() - 0.5)
	md=(lit, ...val)=>val.reduce((A,B,i)=>A+String(B).replace(/([*_#`>\-![\.\]()\|~+={}])/g, '\\$1')+lit[i+1], lit[0])

	function* listWeekAmPmDates(dt=new Date, apm=[[8, 0, 0, 0], [20, 0, 0, 0]]) {
	let week1 = With(dt, u=>new Date(u.setDate(u.getDate() - u.getDay() + 1)));
	// 遍历7天
	for (let i = 0; i < 7; i++) {
	const day = new Date(week1);
	day.setDate(week1.getDate() + i);
	for(hr of apm) { dt=new Date(day); dt.setHours(...hr); yield dt }
	}
	}
	/////
	let
	ai = fetchChat('google/gemini-2.5-pro:sk-or-v1-visitOpenRouter.ai')

	$=await LocalStorage('F12')

	function enableTouch(element, kRoll=-1) {
	if(!navigator.maxTouchPoints)return;
	let startY = 0;
	element.addEventListener('touchstart', e => startY = e.touches[0].clientY);
	element.addEventListener('touchmove', e => {
	e.preventDefault(); // å¯é€‰ï¼Œé˜»æ¢é»˜è®¤æ»šåŠ¨
	const deltaY = startY - e.touches[0].clientY;
	element.dispatchEvent(new WheelEvent('mousewheel', { bubbles: true, deltaY: deltaY * kRoll }));
	startY = e.touches[0].clientY;
	});
	}


	function forwardEvent(fromElement, toElement, eventType) {
	fromElement.addEventListener(eventType, e => {
	const newEvent = new e.constructor(e.type, e);
	toElement.dispatchEvent(newEvent);
	e.preventDefault()
	});
	}

	function serializeForm(e, st=localStorage, v) {
	addEventListener('unload', () => {
	v=JSON.stringify(Object.fromEntries(new FormData(e)))
	st[e.id]=v
	})
	jq(() => {
	v = JSON.parse(st[e.id] \|\| '{}');
	Object.entries(v).forEach(([key, value]) => {
	const input = e.querySelector(`[name="${key}"]`);
	if (input) input.value = value; try{input.onchange(value)}catch{}
	});
	})
	}

	const
	_404=(genkey,u={})=>new Proxy(u, {get:(u,k)=>u[k]?? (u[k]=genkey(k)) })
	,setInterPoll=(f,n,dt_ms=500, dep=()=>((n.nodeType?n.isConnected : (n-->1))? setTimeout(dep, dt_ms) :0, f()))=>dep()
	,useChanged=(find=()=>true, opt=[document, { attributes: true, childList: true, subtree: true }])=>new Promise(OK=>new MutationObserver((_, obs,e) =>{e=find(); e&&(obs.disconnect(),OK(e)) }).observe(...opt))

	,useVisibleEventPair = (e, rw, percent = 10) => {
	// use IntersectionObserver(e)
	let opt = {
	root: null, // viewport
	rootMargin: '0px',
	threshold: percent / 100,
	},
	res = new IntersectionObserver((entries) => {
	entries.forEach(it => rw(!it.isIntersecting));
	}, opt);

	res.observe(e);
	return () => res.disconnect();
	}
	{
	let n = 1, _dispose = [];
	useHover = (rule, rw) => {
	let k = `--js_f${n}`, js_fn = app.appendChild(doc.createElement('span'))
	js_fn.style.cssText = `
	position: fixed;
	top: 0;
	display: var(${k});
	`;
	rule(qs => `:has(${qs}){${k}: none}`); n++
	_dispose.push(useVisibleEventPair(js_fn, rw, 100))
	}
	}
	{let
	dsl=(tag,...cfg_ee)=>{
	tag=tag.substr? document.createElement(tag) : tag
	for(let i=0,e; e=cfg_ee[i];i++) e.call? e(tag)
	: e.nodeType? tag.append(e)
	: Object.entries(e).forEach(i==0? (([k,v])=>tag.setAttribute(k,v)) : ([k,f])=>tag.addEventListener(k,f))
	return tag
	}
	el=_404(k=>k=='As'? dsl : dsl.bind(0, k))
	}

	URL.svg=([W,H],s)=>`data:image/svg+xml,%3Csvg xmlns='http://www.w3.org/2000/svg' width='${W}' height='${H}'%3E${encodeURI(s)}%3C/svg%3E`
	CSS.href=s=>document.adoptedStyleSheets.push(With(new CSSStyleSheet(),c=>c.replaceSync(s)) )

	////
	const CACHE = 'v1'
	const MAX_AGE = 60 * 60 * 1000; // 1小时
	const OFFLINE = `<!DOCTYPE html><head>
	<meta charset="utf-8"></head>
	<body style="font:sans-serif;text-align:center;margin:50px"><h1>离线</h1><button onclick="location.reload()">刷新</button></body>
	`;

	self.oninstall = self.skipWaiting;
	self.onfetch = (ev) => {
	const req = ev.request, url = new URL(req.url), DATE = 'Date';
	if (ev.request.method !== 'GET' \|\| url.origin !== self.location.origin) {
	return;
	}
	const swr =
	caches.open(CACHE).then(cache =>
	cache.match(req).then(body => {
	const now = Date.now(), dt = body? Date.parse(body.headers.get(DATE)) : now,
	// headers要重克隆才可变，算了
	sets = async(k,res, u)=>(u=res.clone(), u.headers.set(k, (new Date).toUTCString()), await cache.put(req, u.clone()), res),
	age = body ? (now - dt) : Infinity;

	// 1. 有缓存且未过期 → 直接返回
	if (body && age < MAX_AGE) {
	return body;
	}

	// 发起网络请求（带 ETag 省流量），有更新&200 → 存新缓存
	let upd = fetch(req).then(body1 => {
	if (body1.status === 304) {
	// 服务端说“没变” → 一小时后更新旧缓存
	return sets(DATE, body);
	}
	return body1.ok? sets(DATE, body1) : body1;
	})
	return (req.mode!='navigate')? upd :
	upd.catch(() => (body&&url.searchParams.get('swr')=='offline')? body
	: new Response(OFFLINE, {status: 503, headers: { 'Content-Type': 'text/html' }}) );
	})
	)
	ev.respondWith(swr)
	};

	////
	caches.open('v2').then(r=>{self.cache = r; addEventListener('fetch', main)})
	const HTM_OFFLINE = c=>`<!DOCTYPE html><html><head>
	<title>离线</title></head><body><h1>${c.ti}</h1>
	<pre>页游的其他域名（双击选中，右键访问）：
	trtbf.ca
	bililibi.com
	squid4046.t.me
	🙏 感谢您的谅解！
	${c.dur}秒后访问，将会显示缓存内的版本，直到重新连接或重启。
	</pre>
	<style>
	body{font-family:system-ui,sans-serif;margin:2rem;background:#fffbef;}
	h1{color:#d33;}
	pre{background:#f8f8f8;padding:1rem;border-radius:8px;font-size:0.9rem;}
	</style>
	</body></html>`,
	RE_OUR404=/nginx<\/center>/,
	RE_UNSAFE=/.*/,

	IPLAY_PAGE=`
	&mod=upgrade&act=index
	&mod=faction&act=index
	&mod=goods&act=index
	&mod=auction&act=index
	&mod=fairy&act=index
	&mod=breach&act=index
	&mod=mountain&act=index
	&mod=marry&act=index
	&mod=index&act=index
	`.replace(/(.+)/gm, '/plugin.php?id=iplay:front$1&server=1').split(/\n+/), //RegExp(s.trim().split(/\n+/).join('\|'))

	WAF_HOST=new Set([
	"static.cloudflareinsights.com",
	"store.steampowered.com",
	"w.soundcloud.com",
	"www.googletagmanager.com",
	]),
	WAF_IFWIN=`script-src ${[...WAF_HOST].join(' ')};`,
	WAF_CSP=`upgrade-insecure-requests; sandbox allow-scripts allow-same-origin;
	default-src 'self'; img-src * data:; media-src ; font-src ; style-src 'self' 'unsafe-inline';
	object-src 'none'; base-uri 'self'; frame-ancestors 'self'; form-action 'self';`+
	WAF_IFWIN .replace(/.(-src) (.);/, "script; connect; frame;".replaceAll(';', "$1 'self' $2;\n").replaceAll(' /', ' https://wojs.org/'))




	// 【可选】让新 SW 立即接管
	self.addEventListener('install', () => self.skipWaiting())
	self.addEventListener('activate', () => self.clients.claim())

	// sw.js
	function main(ev) {
	const { request: rq } = ev, u = new URL(rq.url)
	if (u.origin !== location.origin) return

	if (u.search.startsWith('?id=iplay:front')) { // 页游不兼容AJAX时清缓存
	if (/&mod=bag&act=index\|&mod=upgrade&act=pking/.test(u.search)) IPLAY_PAGE.forEach(k=> cache.delete(k))
	}

	if (rq.destination === 'document') {
	let csp = {
	'Content-Security-Policy': RE_UNSAFE.test(rq.url)? WAF_CSP.replace('script-src', "script-src 'unsafe-inline' 'unsafe-eval'") : WAF_CSP,
	'Permissions-Policy': `geolocation=(), camera=(), microphone=()`
	}
	return ev.respondWith(swr(rq).then(addHeader.bind(0, csp)))
	}
	ev.respondWith(swr(rq))
	}
	addHeader=(kv, r, MIME='text/html')=>{
	const contentType = r.headers.get('content-type');
	if (!contentType \|\| !contentType.includes(MIME)) {
	return r; // 非 HTML，直接返回
	}
	const kv1 = new Headers(r.headers); Object.keys(kv).forEach(k=>kv1.set(k, (''+kv[k]).replaceAll('\n','') ))
	return new Response(r.body, {
	headers: kv1,
	status: r.status,
	statusText: r.statusText,
	})
	}

	async function swr(req) {
	let net = (self.navigator?.onLine ?? true), r = await cache.match(req), dur
	try {
	if(!net) { if(!dtOff \|\| (dur=Date.now()-dtOff)<10*1000) {dtOff=dtOff\|\|Date.now(); throw ''} }
	else { dtOff = 0 }
	r = r?? await fetch(req)
	if(await verify(r)\|\|verify.bad) throw ''
	F5(req)
	return r
	} catch (_) {
	r = new Response(HTM_OFFLINE({ti:net? (verify.bad\|\| "您似乎来到了没有知识的洼地"):"您已离线……", dur: Math.max(0, net?404: 10-dur/1000 >>0)}), {
	headers: { 'Content-Type': 'text/html; charset=utf-8' }
	})
	verify.bad=''; return r
	}
	}
	let
	dtOff=0,
	verify=async(r)=>{
	if(r.status==404\|\|r.status==521) {
	let s=await r.clone().text()
	verify.bad=RE_OUR404.test(s)? '': '服务端正在打怪升级'; return true
	}
	},
	F5=(req)=>{
	fetch(req).then(r => {
	if (r && r.ok) cache.put(req, r.clone())
	else verify(r)
	}).catch(ex => { })
	}


	/*
	// if(!WAF_HOST.has(u.hostname)) return ev.respondWith(new Response('Domain not whitelisted', { status: 403 }))
	<script>if (navigator.serviceWorker) {
	navigator.serviceWorker.register ('./sw.js')
	{
	// WARN: Run first & CSP deny iframe,worker-src. IPCs(sw.controller) are not hooked.
	let hook=(T,k,f, f0)=>{T=T.prototype?? T, f0=T[k], Object.defineProperty(T,k, {value: f(f0), writable:0,configurable:0})}
	hook(ServiceWorkerRegistration,'unregister', to=>async()=>{})
	hook(navigator.serviceWorker,'register', to=>async()=>{})
	}
	} </script>
	*/
No results found