feat: begin adding messaging

apps/namadillo/src/index.tsx

@@ -62,3 +62,23 @@ if ("serviceWorker" in navigator) {
       });
   });
 }
+
+const msgChannel = new MessageChannel();
+navigator.serviceWorker.controller?.postMessage(
+  {
+    type: "INIT_PORT",
+  },
+  [msgChannel.port2]
+);
+
+msgChannel.port1.onmessage = (event) => {
+  console.warn(event);
+};
+
+navigator.serviceWorker.ready.then((registration) => {
+  console.log("registration?", registration);
+  registration.active?.postMessage({
+    type: "namadillo:hasMaspParams",
+    param: "masp-output.params",
+  });
+});

apps/namadillo/sw/sw.ts

@@ -10,7 +10,7 @@ const { isProxy } = Object.fromEntries(urlParams);
 const MASP_MPC_URL =
   isProxy === "true" ?
     "http://localhost:8010/proxy"
-  : "https://github.com/anoma/masp-mpc/releases/download/namada-trusted-setup";
+    : "https://github.com/anoma/masp-mpc/releases/download/namada-trusted-setup";
 
 const store = new IndexedDBKVStore(STORAGE_PREFIX);
 
@@ -20,15 +20,18 @@ const resetMaspParamStore = async (): Promise<void> => {
   store.set(MaspParam.Convert, null);
 };
 
-// resetMaspParamStore();
+resetMaspParamStore();
 
 const logSuccess = ({ param, bytes }: MaspParamBytes): void =>
   console.info(`Fetched and stored ${param}`, bytes);
 
 const logError = (e: any) => console.error(e);
 
+const params = [MaspParam.Output, MaspParam.Spend, MaspParam.Convert];
+
+// TODO: Refactor into handler
 (async () => {
-  [MaspParam.Output, MaspParam.Spend, MaspParam.Convert].map(async (param) => {
+  params.forEach(async (param) => {
     if (!(await store.get(param))) {
       await fetchMaspParam(param)
         .then(validateMaspParamBytes)
@@ -38,3 +41,45 @@ const logError = (e: any) => console.error(e);
     }
   });
 })();
+
+/**
+ * EVENT HANDLERS
+ */
+const EVENT_PREFIX = "namadillo";
+
+enum EventMessage {
+  FetchMaspParams = `${EVENT_PREFIX}:fetchMaspParams`,
+  HasMaspParams = `${EVENT_PREFIX}:hasMaspParams`,
+  HasMaspParamsResponse = `${EVENT_PREFIX}:hasMaspParamsResponse`,
+}
+
+// PORT
+let port: MessagePort;
+
+self.addEventListener("message", (event: any) => {
+  if (event.data && event.data.type == "INIT_PORT") {
+    port = event.ports[0];
+  }
+
+  const { data } = event;
+
+  switch (data.type as EventMessage) {
+    case EventMessage.FetchMaspParams:
+      console.log(`${EventMessage.FetchMaspParams}`);
+      break;
+    case EventMessage.HasMaspParams: {
+      const { param } = data;
+      store.get(param).then((record) => {
+        port.postMessage(
+          {
+            type: EventMessage.HasMaspParamsResponse,
+            param,
+            hasMaspParam: !!record,
+          },
+          event.origin
+        );
+      });
+      break;
+    }
+  }
+});