multipleof4/devsune
1
0
Fork 0
mirror of https://github.com/multipleof4/devsune.git synced 2026-01-13 16:07:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update sw.js

Browse Source
This commit is contained in:
multipleof4
2025-08-22 21:48:50 -07:00
committed by GitHub
parent 052db25809
commit 1d29564f0e
1 changed files with 35 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
public/sw.js
View File

@@ -1,14 +1,42 @@
const V='1'
const V='2'
const send=m=>self.clients.matchAll({type:'window',includeUncontrolled:true}).then(cs=>cs.forEach(c=>c.postMessage(m)))
self.addEventListener('install',e=>{
self.skipWaiting()
})
self.addEventListener('install',e=>{self.skipWaiting()})
self.addEventListener('activate',e=>{e.waitUntil(self.clients.claim().then(()=>send({type:'SW_ACTIVE',v:V,ts:Date.now()})))})
self.addEventListener('activate',e=>{
e.waitUntil((async()=>{await self.clients.claim();await send({type:'SW_ACTIVE',v:V,ts:Date.now()})})())
const ORIGINS=['openrouter.ai']
const isTarget=req=>{const u=new URL(req.url);return ORIGINS.some(h=>u.hostname.endsWith(h))&&req.method==='POST'}
const wantsStream=async req=>{try{return /"stream"\s*:\s*true/i.test(await req.clone().text())}catch{return false}}
self.addEventListener('fetch',e=>{
const req=e.request
const nav=req.mode==='navigate'
if(nav) return
if(!isTarget(req)) return
e.respondWith((async()=>{
if(!(await wantsStream(req))) return fetch(req)
const netRes=await fetch(req)
const reader=netRes.body?.getReader()
if(!reader) return netRes
send({type:'SW_STREAM_START',url:req.url,ts:Date.now()})
let done=false,bytes=0,buf=[],bufBytes=0,waiter=null,notify=null
const MAX=2*1024*1024,LOW=1*1024*1024
const pump=(async()=>{for(;;){const r=await reader.read();if(r.done){done=true;break}const chunk=r.value;buf.push(chunk);bufBytes+=chunk.byteLength||chunk.length;bytes+=chunk.byteLength||chunk.length;send({type:'SW_STREAM_BYTES',n:bytes})
if(bufBytes>MAX) await new Promise(r=>{notify=r;waiter=r})}})()
e.waitUntil(pump)
const stream=new ReadableStream({
start(c){const loop=async()=>{for(;;){if(buf.length){const x=buf.shift();bufBytes-=x.byteLength||x.length;c.enqueue(x);if(notify&&bufBytes<=LOW){const n=notify;notify=null;n()}}
else if(done){c.close();send({type:'SW_STREAM_END',bytes});break}
else await new Promise(r=>setTimeout(r,30))}}
loop()},
cancel(){try{reader.cancel()}catch{}}
})
const h=new Headers(netRes.headers);h.delete('content-length')
return new Response(stream,{status:netRes.status,statusText:netRes.statusText,headers:h})
})())
})
self.addEventListener('message',e=>{
if(e.data&&e.data.type==='PING'){(e.source||null)?.postMessage({type:'PONG',v:V,ts:Date.now()})||send({type:'PONG',v:V,ts:Date.now()})}
const m=e.data||{}
if(m&&m.type==='PING'){(e.source||null)?.postMessage({type:'PONG',v:V,ts:Date.now()})||send({type:'PONG',v:V,ts:Date.now()})}
})