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);

}