mirror of
https://github.com/Instadapp/chains.git
synced 2024-07-29 22:37:19 +00:00
60 lines
1.9 KiB
JavaScript
60 lines
1.9 KiB
JavaScript
/* Partytown 0.5.4 - MIT builder.io */
|
|
const resolves = new Map;
|
|
|
|
const swMessageError = (accessReq, $error$) => ({
|
|
$msgId$: accessReq.$msgId$,
|
|
$error$: $error$
|
|
});
|
|
|
|
const httpRequestFromWebWorker = req => new Promise((async resolve => {
|
|
const accessReq = await req.clone().json();
|
|
const responseData = await (accessReq => new Promise((async resolve => {
|
|
const clients = await self.clients.matchAll();
|
|
const client = [ ...clients ].sort(((a, b) => a.url > b.url ? -1 : a.url < b.url ? 1 : 0))[0];
|
|
if (client) {
|
|
const timeout = 12e4;
|
|
const msgResolve = [ resolve, setTimeout((() => {
|
|
resolves.delete(accessReq.$msgId$);
|
|
resolve(swMessageError(accessReq, "Timeout"));
|
|
}), timeout) ];
|
|
resolves.set(accessReq.$msgId$, msgResolve);
|
|
client.postMessage(accessReq);
|
|
} else {
|
|
resolve(swMessageError(accessReq, "NoParty"));
|
|
}
|
|
})))(accessReq);
|
|
resolve(response(JSON.stringify(responseData), "application/json"));
|
|
}));
|
|
|
|
const response = (body, contentType) => new Response(body, {
|
|
headers: {
|
|
"content-type": contentType || "text/html",
|
|
"Cache-Control": "no-store"
|
|
}
|
|
});
|
|
|
|
self.oninstall = () => self.skipWaiting();
|
|
|
|
self.onactivate = () => self.clients.claim();
|
|
|
|
self.onmessage = ev => {
|
|
const accessRsp = ev.data;
|
|
const r = resolves.get(accessRsp.$msgId$);
|
|
if (r) {
|
|
resolves.delete(accessRsp.$msgId$);
|
|
clearTimeout(r[1]);
|
|
r[0](accessRsp);
|
|
}
|
|
};
|
|
|
|
self.onfetch = ev => {
|
|
const req = ev.request;
|
|
const url = new URL(req.url);
|
|
const pathname = url.pathname;
|
|
if (pathname.endsWith("sw.html")) {
|
|
ev.respondWith(response('<!DOCTYPE html><html><head><meta charset="utf-8"><script src="./partytown-sandbox-sw.js?v=0.5.4"><\/script></head></html>'));
|
|
} else {
|
|
pathname.endsWith("proxytown") && ev.respondWith(httpRequestFromWebWorker(req));
|
|
}
|
|
};
|