From 33aa03a55fac735c3b2145ba75932b625368ce28 Mon Sep 17 00:00:00 2001
From: "nova@novas optiplex" <git@novafurry.win>
Date: Wed, 23 Oct 2024 07:21:27 +1000
Subject: [PATCH] migrating to serviceworker for custom FS shit

---
 assets/code/fs.js  |   2 +-
 assets/code/wfs.js |   6 +-
 desktop.html       | 245 +++++++++++++++++----------------
 serviceworker.js   | 331 +++++++++++++++++++++++++++++++++++++++++++++
 4 files changed, 467 insertions(+), 117 deletions(-)
 create mode 100644 serviceworker.js

diff --git a/assets/code/fs.js b/assets/code/fs.js
index a022766..73ecc5f 100644
--- a/assets/code/fs.js
+++ b/assets/code/fs.js
@@ -155,4 +155,4 @@ setTimeout(function () {
                 }
             }
         });
-}, 1000)
+}, 1000)
\ No newline at end of file
diff --git a/assets/code/wfs.js b/assets/code/wfs.js
index 0a144e0..5605df7 100644
--- a/assets/code/wfs.js
+++ b/assets/code/wfs.js
@@ -82,13 +82,13 @@ var foxyfs = {
                 }
                 return { items: content };
             }
-            var dirHandle = await opfsRoot.getDirectoryHandle(path[0]);
+            var dirHandle = await opfsRoot.getDirectoryHandle(path[0], {create:true});
             if (path.length > 1) {
                 for (var item of path) {
                     if (item == path[0]) {
 
                     } else {
-                        dirHandle = await dirHandle.getDirectoryHandle(item)
+                        dirHandle = await dirHandle.getDirectoryHandle(item, {create:true})
                     }
                 }
                 var content = [];
@@ -489,4 +489,4 @@ var fs2 = {
             };
         });
     }
-};
+};
\ No newline at end of file
diff --git a/desktop.html b/desktop.html
index 1a9bbce..01d242f 100644
--- a/desktop.html
+++ b/desktop.html
@@ -110,6 +110,7 @@ <h1>NovaOS</h1>
     </div> -->
   </body>
 </html>
+
 <script src="./assets/code/vals.js"></script>
 <script src="./assets/lib/jq.js"></script>
 <script src="./assets/lib/jszip.js"></script>
@@ -122,139 +123,157 @@ <h1>NovaOS</h1>
 <script src="./assets/code/fs.js"></script>
 <script src="./assets/code/apps.js"></script>
 <script>
+    if ('serviceWorker' in navigator) {
+  navigator.serviceWorker.register('./serviceworker.js')
+    .then(registration => console.log('ServiceWorker registered'))
+    .catch(err => console.error('ServiceWorker registration failed:', err));
+}
   async function boot() {
-      var uname = "No Username, somehow."
-      uname = await fs.read('/user/info/name');
-      if (uname !== undefined) {
-          const name = await fs.read('/user/info/name');
-          const deskid = await fs.read('/system/deskid');
-          const darkpref = await fs.read('/user/info/lightdarkpref');
-          const lightdark = await fs.read('/user/info/lightdark');
-          const color = await fs.read('/user/info/color');
-          await wd.desktop(name, deskid, 'wait');
-          await ptp.go(deskid);
-          sys.setupd = true;
+    var uname = "No Username, somehow.";
+    var lsofuserinfo = await fs.ls("/user/info");
+    function hasNameFile(element, index, array) {
+      return element.name == "name";
+    }
+    var unamexist = lsofuserinfo.items.some(hasNameFile);
+    if (unamexist) {
+        console.log("yea")
+      const name = await fs.read("/user/info/name");
+      const deskid = await fs.read("/system/deskid");
+      const darkpref = await fs.read("/user/info/lightdarkpref");
+      const lightdark = await fs.read("/user/info/lightdark");
+      const color = await fs.read("/user/info/color");
+      await wd.desktop(name, deskid, "wait");
+      await ptp.go(deskid);
+      sys.setupd = true;
 
-          if (darkpref === "auto") {
-              sys.autodarkacc = true;
-          } else {
-              sys.autodarkacc = false;
-          }
-          if (lightdark === "dark") {
-              wd.dark();
-          } else if (lightdark === "clear") {
-              wd.clearm();
-          } else if (lightdark === "clear2") {
-              wd.clearm2();
-          } else {
-              wd.light();
-          }
-          ui.crtheme(color);
-          console.log(color)
-          if (!color) {
-              fs.write('/user/info/color', '#C68A00');
-              ui.crtheme('#C68A00');
-          }
+      if (darkpref === "auto") {
+        sys.autodarkacc = true;
+      } else {
+        sys.autodarkacc = false;
+      }
+      if (lightdark === "dark") {
+        wd.dark();
+      } else if (lightdark === "clear") {
+        wd.clearm();
+      } else if (lightdark === "clear2") {
+        wd.clearm2();
       } else {
-          const id = gen(4);
-          await ptp.go(id);
-          await fs.mkdir('/system', "opfs");
-          await fs.write('/system/deskid', id, "opfs");
-          app.setup.init();
-          sys.setupd = false;
+        wd.light();
+      }
+      ui.crtheme(color);
+      console.log(color);
+      if (!color) {
+        fs.write("/user/info/color", "#C68A00");
+        ui.crtheme("#C68A00");
       }
+    } else {
+      console.log("narr")
+      const id = gen(4);
+      await ptp.go(id);
+      await fs.mkdir("/system", "opfs");
+      await fs.write("/system/deskid", id, "opfs");
+      app.setup.init();
+      sys.setupd = false;
+    }
 
-      const dropZone = document.body;
-      ['dragenter', 'dragover', 'dragleave', 'drop'].forEach(eventName => {
-          dropZone.addEventListener(eventName, preventDefaults, false);
-          document.body.addEventListener(eventName, preventDefaults, false);
-      });
+    const dropZone = document.body;
+    ["dragenter", "dragover", "dragleave", "drop"].forEach((eventName) => {
+      dropZone.addEventListener(eventName, preventDefaults, false);
+      document.body.addEventListener(eventName, preventDefaults, false);
+    });
 
-      dropZone.addEventListener('drop', handleDrop, false);
+    dropZone.addEventListener("drop", handleDrop, false);
 
-      function preventDefaults(e) {
-          e.preventDefault();
-          e.stopPropagation();
-      }
+    function preventDefaults(e) {
+      e.preventDefault();
+      e.stopPropagation();
+    }
 
-      function handleDrop(e) {
-          let dt = e.dataTransfer;
-          let files = dt.files;
+    function handleDrop(e) {
+      let dt = e.dataTransfer;
+      let files = dt.files;
 
-          handleFiles(files);
-      }
+      handleFiles(files);
+    }
 
-      async function handleFiles(files) {
-          let filesArray = [...files];
-          filesArray.forEach(file => {
-              const reader = new FileReader();
-              reader.onload = function (e) {
-                  const contents = e.target.result;
-                  fs.write(`/user/files/${file.name}`, contents);
-              };
+    async function handleFiles(files) {
+      let filesArray = [...files];
+      filesArray.forEach((file) => {
+        const reader = new FileReader();
+        reader.onload = function (e) {
+          const contents = e.target.result;
+          fs.write(`/user/files/${file.name}`, contents);
+        };
 
-              if (file.type.startsWith('image')) {
-                  reader.readAsDataURL(file);
-              } else {
-                  reader.readAsArrayBuffer(file);
-              }
-          });
-      }
-  
-  const data = await fs.read('/system/apps.json');
-          if (data) {
-              const apps = JSON.parse(data);
-              try {
-                  const response = await fetch('https://appmarket.meower.xyz/refresh');
-                  const onlineApps = await response.json();
-                  for (const inapp of apps) {
-                      await wd.loadapps(inapp, onlineApps, apps);
-                  }
-              } catch (err) {
-                  console.log(err);
-                  try {
-                      for (const inapp of apps) {
-                          await wd.loadapps(inapp, inapp, inapp);
-                      }
-                  } catch (error) {
-                      if (sys.fucker === false) {
-                          sys.fucker = true;
-                          fs.del('/system/apps.json');
-                          fs.delfold('/system/apps');
-                          wm.notif('App Issues', 'All apps were uninstalled due to corruption or an update. Your data is safe, you can reinstall them anytime.', () => app.appmark.init(), 'App Market');
-                      }
-                  }
-              }
+        if (file.type.startsWith("image")) {
+          reader.readAsDataURL(file);
+        } else {
+          reader.readAsArrayBuffer(file);
+        }
+      });
+    }
+
+    const data = await fs.read("/system/apps.json");
+    if (data) {
+      const apps = JSON.parse(data);
+      try {
+        const response = await fetch("https://appmarket.meower.xyz/refresh");
+        const onlineApps = await response.json();
+        for (const inapp of apps) {
+          await wd.loadapps(inapp, onlineApps, apps);
+        }
+      } catch (err) {
+        console.log(err);
+        try {
+          for (const inapp of apps) {
+            await wd.loadapps(inapp, inapp, inapp);
           }
+        } catch (error) {
+          if (sys.fucker === false) {
+            sys.fucker = true;
+            fs.del("/system/apps.json");
+            fs.delfold("/system/apps");
+            wm.notif(
+              "App Issues",
+              "All apps were uninstalled due to corruption or an update. Your data is safe, you can reinstall them anytime.",
+              () => app.appmark.init(),
+              "App Market"
+            );
+          }
+        }
+      }
+    } else {
+      fs.write("/system/apps.json", "");
     }
+  }
   // if(localStorage.getItem("networking") == "false") {
   //     document.querySelector("#netw").classList.remove("on");
   // } else {
   //     document.querySelector("#netw").classList.add("on")
   // }
-  if(localStorage.getItem("doNotDisturb") == "falsbrthe") {
-      document.querySelector("#dnd").classList.remove("on");
+  if (localStorage.getItem("doNotDisturb") == "falsbrthe") {
+    document.querySelector("#dnd").classList.remove("on");
   } else {
-      document.querySelector("#dnd").classList.add("on")
+    document.querySelector("#dnd").classList.add("on");
   }
 
-  $("#dm").on("change", function() {
-      if($(this).val() == "dark") {
-          wd.dark();
-          fs.write('/user/info/lightdark', 'dark');
-      } else if($(this).val() == "light") {
-          wd.light();
-          fs.write('/user/info/lightdark', 'light');
-      } else if($(this).val() == "auto") {
-          fs.write('/user/info/lightdarkpref', 'auto');
-              fs.read('/user/info/color').then((col) => ui.crtheme(col));
-              sys.autodarkacc = true;
-      } else if($(this).val() == "cml") {
-          wd.clearm();
-          fs.write('/user/info/lightdark', 'clear');
-      } else if($(this).val() == "cmd") {
-          wd.clearm2();
-          fs.write('/user/info/lightdark', 'clear2');
-      }
+  $("#dm").on("change", function () {
+    if ($(this).val() == "dark") {
+      wd.dark();
+      fs.write("/user/info/lightdark", "dark");
+    } else if ($(this).val() == "light") {
+      wd.light();
+      fs.write("/user/info/lightdark", "light");
+    } else if ($(this).val() == "auto") {
+      fs.write("/user/info/lightdarkpref", "auto");
+      fs.read("/user/info/color").then((col) => ui.crtheme(col));
+      sys.autodarkacc = true;
+    } else if ($(this).val() == "cml") {
+      wd.clearm();
+      fs.write("/user/info/lightdark", "clear");
+    } else if ($(this).val() == "cmd") {
+      wd.clearm2();
+      fs.write("/user/info/lightdark", "clear2");
+    }
   });
 </script>
diff --git a/serviceworker.js b/serviceworker.js
new file mode 100644
index 0000000..23c80a5
--- /dev/null
+++ b/serviceworker.js
@@ -0,0 +1,331 @@
+var opfsRoot;
+navigator.storage.getDirectory().then(function (dir) {
+    opfsRoot = dir;
+    foxyfs.init()
+})
+var foxyfs = {
+  getFileHandle: async function (path1) {
+      var path = path1.split("/")
+      var nameofFile = path[path.length - 1]
+      path[path.length - 1] = '';
+      path = path.filter(function (el) {
+          return el != '';
+      });
+      var content = {};
+      console.log(path, nameofFile)
+      if (path.length == 0) {
+          var dirHandle = await opfsRoot.getFileHandle(nameofFile)
+          content[nameofFile] = dirHandle
+      }
+      else if (path.length > 1) {
+          var dirHandle = await opfsRoot.getDirectoryHandle(path[0]);
+
+          for (var item of path) {
+              if (item == path[0]) {
+
+              } else {
+                  dirHandle = await dirHandle.getDirectoryHandle(item)
+              }
+          }
+          var content = {};
+          for await (let [name, handle] of dirHandle.entries()) {
+              content[name] = handle
+          }
+      } else if (path.length == 1) {
+          var dirHandle = await opfsRoot.getDirectoryHandle(path[0]);
+
+          var content = {};
+          for await (let [name, handle] of dirHandle.entries()) {
+              content[name] = handle
+          }
+      }
+      return content[nameofFile]
+  },
+  getDirHandle: async function (path1) {
+      var path = path1.split("/")
+      var nameofFile = path[path.length - 1]
+      path[path.length - 1] = '';
+      path = path.filter(function (el) {
+          return el != '';
+      });
+      var content = {};
+      if (path.length == 0) {
+          var dirHandle = await opfsRoot.getDirectoryHandle(nameofFile);
+      }
+      else if (path.length > 1) {
+          var dirHandle = await opfsRoot.getDirectoryHandle(path[0]);
+
+          for (var item of path) {
+              if (item == path[0]) {
+
+              } else {
+                  dirHandle = await dirHandle.getDirectoryHandle(item)
+              }
+          }
+      } else if (path.length == 1) {
+          var dirHandle = await opfsRoot.getDirectoryHandle(path[0]);
+      }
+      return dirHandle
+  },
+  init: async function () {
+  },
+  ls: async function (dir) {
+      try {
+          var path = dir.split("/")
+          path = path.filter(function (el) {
+              return el != '';
+          });
+          if (path.length == 0) {
+              var content = [];
+              for await (let [name, handle] of opfsRoot.entries()) {
+                  content.push({ name: name, type: handle.kind, path: dir + name })
+              }
+              return { items: content };
+          }
+          var dirHandle = await opfsRoot.getDirectoryHandle(path[0], {create:true});
+          if (path.length > 1) {
+              for (var item of path) {
+                  if (item == path[0]) {
+
+                  } else {
+                      dirHandle = await dirHandle.getDirectoryHandle(item, {create:true})
+                  }
+              }
+              var content = [];
+              for await (let [name, handle] of dirHandle.entries()) {
+                  content.push({ name: name, type: handle.kind, path: dir + name })
+              }
+              return { items: content };
+          } else if (path.length == 1) {
+              var content = [];
+              for await (let [name, handle] of dirHandle.entries()) {
+                  content.push({ name: name, type: handle.kind, path: dir + name })
+              }
+              return { items: content };
+          }
+      } catch (error) {
+          console.log(error)
+      }
+
+  },
+  mkdir: async function (location, name) {
+      try {
+          if (location == '' || location == "/") {
+          return await opfsRoot.getDirectoryHandle(name, { create: true });
+      } else {
+          var path = location.split("/")
+          path = path.filter(function (el) {
+              return el != '';
+          });
+          var dirHandle = await opfsRoot.getDirectoryHandle(path[0])
+          for (var item of path) {
+              if (item == path[0]) {
+
+              } else {
+                  dirHandle = await dirHandle.getDirectoryHandle(item)
+              }
+          }
+          return await dirHandle.getDirectoryHandle(name, { create: true })
+      }
+      } catch (error) {
+          console.log(error)
+      }
+      
+  },
+  touch: async function (location, name) {
+      if (location == '' || location == "/") {
+          return await opfsRoot.getFileHandle(name, { create: true });
+      } else {
+          var path = location.split("/")
+          path = path.filter(function (el) {
+              return el != '';
+          });
+          var dirHandle = await opfsRoot.getDirectoryHandle(path[0])
+          for (var item of path) {
+              if (item == path[0]) {
+
+              } else {
+                  dirHandle = await dirHandle.getDirectoryHandle(item)
+              }
+          }
+          return await dirHandle.getFileHandle(name, { create: true })
+      }
+  },
+  typeof: async function (path1) {
+      var path = path1.split("/")
+      var nameofFile = path[path.length - 1]
+      path[path.length - 1] = '';
+      path = path.filter(function (el) {
+          return el != '';
+      });
+      var content = {};
+      if (path.length == 0) {
+          var dirHandle = await opfsRoot.getDirectoryHandle(nameofFile);
+          content[nameofFile] = dirHandle.kind
+      }
+      else if (path.length > 1) {
+          var dirHandle = await opfsRoot.getDirectoryHandle(path[0]);
+
+          for (var item of path) {
+              if (item == path[0]) {
+
+              } else {
+                  dirHandle = await dirHandle.getDirectoryHandle(item)
+              }
+          }
+          var content = {};
+          for await (let [name, handle] of dirHandle.entries()) {
+              content[name] = handle.kind
+          }
+      } else if (path.length == 1) {
+          var dirHandle = await opfsRoot.getDirectoryHandle(path[0]);
+
+          var content = {};
+          for await (let [name, handle] of dirHandle.entries()) {
+              content[name] = handle.kind
+          }
+      }
+      return content[nameofFile]
+  },
+  read: async function (path) {
+      try {
+          var h = await foxyfs.getFileHandle(path)
+          var file = await h.getFile()
+          return await file.text()
+      } catch (error) {
+          console.log(error)
+      }
+  },
+  write: async function (path, content) {
+      var h = await foxyfs.getFileHandle(path, { create: true })
+      var stream = await h.createWritable()
+      stream.write(content)
+      stream.close()
+      return h;
+  },
+  rmfile: async function (path) {
+      var h = await foxyfs.getFileHandle(path)
+      h.remove()
+  },
+  rmdir: async function (path) {
+      var h = await foxyfs.getDirHandle(path)
+      var returnVal = "it no worky :(";
+      try {
+          h.remove({ recursive: false })
+          returnVal = "Successful"
+      } catch {
+
+          h.remove({ recursive: true })
+          returnVal = "Successful, but had to work recursivly"
+
+      }
+      return returnVal;
+  },
+  rm: async function (path) {
+      var h = await foxyfs.getDirHandle(path)
+      var returnVal = "it no worky :(";
+      try {
+          var h = await foxyfs.getFileHandle(path)
+          h.remove()
+          returnVal = "baller, its a file"
+      } catch (error) {
+          try {
+              var h = await foxyfs.getDirHandle(path)
+              try {
+                  h.remove({ recursive: false })
+                  returnVal = "Successful, no recurse"
+              } catch {
+
+                  h.remove({ recursive: true })
+                  returnVal = "Successful, but had to work recursivly"
+
+              }
+          } catch (error) {
+              returnVal = "not baller, it doesnt work."
+          }
+      }
+      return returnVal;
+  }
+}
+
+// sw.js - Service Worker file
+self.addEventListener('install', (event) => {
+  console.log("[Service Worker] Install");
+  event.waitUntil(self.skipWaiting());
+});
+
+self.addEventListener('activate', (event) => {
+  console.log("[Service Worker] activate");
+  event.waitUntil(clients.claim());
+});
+
+self.addEventListener('fetch', async (event) => {
+  console.log("[Service Worker] fetch");
+
+  const url = new URL(event.request.url);
+  const path = url.pathname;
+
+  // Handle paths starting with /fs/opfs/
+  if (path.startsWith('/fs/opfs/')) {
+  console.log("[Service Worker] fetch opfs file");
+
+      const filePath = path.replace('/fs/opfs', ''); // Get the actual path for the file system
+
+      try {
+          // Access the file system (this may require user interaction)
+          const content = await foxyfs.read(filePath)
+        console.log("[Service Worker] opfs file "+filePath+" content "+content)
+          const response = new Response(content, {
+              headers: {
+                  'Content-Type': 'text/plain',
+                  'Cache-Control': 'no-cache',
+              },
+              status: 200
+          });
+
+          event.respondWith(response);
+          return; // Respond with file content
+      } catch (error) {
+          console.error('Error accessing file:', error);
+      }
+
+      // If we reach here, the file does not exist, so we return 404
+      const notFoundResponse = new Response('404 Not Found', {
+          status: 404,
+          headers: { 'Content-Type': 'text/plain' }
+      });
+
+      event.respondWith(notFoundResponse);
+      return; // Respond with 404
+  }
+
+  // Fallback for other requests (optional)
+  event.respondWith(fetch(event.request));
+});
+
+// Function to get a file handle (this is a simplified version)
+async function getFileHandle(filePath) {
+  // Implementation would depend on how you're managing file access
+  // This example assumes you have a root directory you are allowed to access
+  const rootDirectoryHandle = await getRootDirectoryHandle(); // You need to implement this
+
+  const parts = filePath.split('/');
+  let currentHandle = rootDirectoryHandle;
+
+  for (const part of parts) {
+      const entry = await currentHandle.getDirectoryHandle(part, { create: false });
+      currentHandle = entry; // Traverse down the directory
+  }
+
+  // Return the file handle
+  return currentHandle.getFileHandle(parts[parts.length - 1], { create: false });
+}
+
+// Function to get the root directory handle (implement as needed)
+async function getRootDirectoryHandle() {
+  // Implement your logic to get the root directory handle
+  // This might require user interaction to select a directory
+  // For example, using window.showDirectoryPicker() in a user gesture
+  const directoryHandle = await window.showDirectoryPicker();
+  return directoryHandle;
+}