work-graph-simple/service-worker.js

71 lines
1.8 KiB
JavaScript

import * as FSAccess from "./store-directory-handle.js";
self.addEventListener('install', ()=>{console.log("SW INSTALL"); return self.skipWaiting()}); // Activate worker immediately);
self.addEventListener('activate', ()=>{
console.log("SW ACTIVATE");
return self.clients.claim();
}); // Become available to all pages);
self.addEventListener('fetch', (event) =>event.respondWith(Interceptor(event)));
const options = {
headers: {
'Content-Type': 'application/javascript',
'Cache-Control': 'no-cache'
}
}
/** @type {(event:{request:Request})=>Promise<Response>} */
async function Interceptor(event)
{
const url = new URL(event.request.url);
const pathname = url.pathname.substring(1);
let parts = pathname.split("/");
if(parts[0] == "graph" || parts[0] == "store")
{
console.log("intercept:", pathname);
const handle = await FSAccess.getDirectoryHandle();
if(event.request.method == "PUT")
{
console.log("put operation");
const payloadJSON = await event.request.clone().json();
let text = await FSAccess.Read(handle, parts) || "{}";
const fileJSON = JSON.parse(text);
for(const key in payloadJSON)
{
const value = payloadJSON[key];
let field = fileJSON[key];
if(!field)
{
field = [];
fileJSON[key] = field;
}
field.push(value);
}
console.log(`incoming:`, payloadJSON);
console.log(`outgoing:`, fileJSON);
text = JSON.stringify(fileJSON, null, 2);
const result = await FSAccess.Write(handle, parts, text);
return new Response(result+"", options);
}
const text = await FSAccess.Read(handle, parts);
if(text)
{
return new Response(text, options);
}
}
return fetch(event.request);
}