From d1819f3876e34e6a6e5a61cf83b5de3b7169c000 Mon Sep 17 00:00:00 2001
From: Fen Dweller <chemicalcrux@gmail.com>
Date: Fri, 4 Jan 2019 15:33:59 -0600
Subject: [PATCH] Set up a caching system

---
 audio.js   | 116 +++++++++++++++++++++++++++++++++++++++++++++++------
 satiate.js |   2 +-
 2 files changed, 104 insertions(+), 14 deletions(-)

diff --git a/audio.js b/audio.js
index dd68109..4fdfb34 100644
--- a/audio.js
+++ b/audio.js
@@ -19,31 +19,121 @@ function playAudio(name) {
 
 // asynchronously load an audio file
 
-function loadAudio(name) {
+function loadAudio(name, flush=false) {
+
+  // do we already have the audio?
+
+  if (audioDict[name] && !flush) {
+    return;
+  }
+
+  // is the audio already stored locally?
+
+  if (!flush) {
+    checkCache(
+      "audio",
+      name,
+      (data) => parseAudioData(name, data),
+      () => loadRemoteAudio(name)
+    );
+  } else {
+    loadRemoteAudio(name);
+  }
+}
+
+function cacheAndParse(name, data) {
+  storeCache("audio", name, data.slice(0));
+  parseAudioData(name, data);
+}
+
+function parseAudioData(name, data) {
+  console.log(data);
+
+  audioContext.decodeAudioData(data, function(buffer) {
+    audioDict[name] = buffer;
+  }, function(e){ console.log("Error with decoding audio data" + e.err);});
+
+}
+
+function loadRemoteAudio(name) {
   let xhr = new XMLHttpRequest();
 
   xhr.open("GET", audioBaseUrl + name, true);
-
-  console.log(audioBaseUrl + name);
   xhr.responseType = "arraybuffer";
-    console.log("a");
+  xhr.onload = (xhr) => cacheAndParse(name, xhr.data);
+  xhr.send();
+}
 
-  xhr.onload = function() {
-    let data = xhr.response;
-      console.log("FDSEW");
+// check if the content is cached
+function checkCache(type, name, hit, miss) {
+  const req = window.indexedDB.open("cache", 1);
+  req.onsuccess = () => {
+    const db = req.result;
+    const tx = db.transaction([type], "readonly");
 
-    audioContext.decodeAudioData(data, function(buffer) {
-      console.log("SADFDS");
-      audioDict[name] = buffer;
-    }, function(e){ console.log("Error with decoding audio data" + e.err);});
+    const audio = tx.objectStore(type);
 
-  }
+    const read = audio.get(name);
 
-  xhr.send();
+    read.onsuccess = (event) => {
+      const res = event.target.result;
+
+      if (res) {
+        console.log("cache hit on " + name);
+        hit(res.content);
+      } else {
+        console.log("cache miss on " + name);
+        miss();
+      }
+    }
+
+    tx.oncomplete = () => {
+      db.close();
+    }
+  }
 }
 
 function initAudio() {
   audioContext = new (window.AudioContext || window.webkitAudioContext)();
 
+  console.log("Initialized audio context");
   console.log(audioContext);
 }
+
+// caching stuff here
+
+function storeCache(type, name, blob) {
+  const req = window.indexedDB.open("cache", 1);
+  req.onsuccess = () => {
+    const db = req.result;
+    const tx = db.transaction([type], "readwrite");
+
+    const audio = tx.objectStore(type);
+
+    const update = audio.put({
+      name: name,
+      content: blob
+    });
+
+    tx.oncomplete = () => {
+      db.close();
+    }
+  }
+}
+
+// if the indexedDB table doesn't exist at all, make it
+function createCache() {
+  let idb = window.indexedDB;
+
+  let req = idb.open("cache", 1);
+
+  req.onupgradeneeded = event => {
+    const db = event.target.result;
+
+    const audio = db.createObjectStore("audio", { keyPath: "name" });
+  }
+
+  req.onerror = event => {
+    alert("Couldn't open the database?");
+  }
+}
diff --git a/satiate.js b/satiate.js
index b39b4f9..8f4b63c 100644
--- a/satiate.js
+++ b/satiate.js
@@ -12,4 +12,4 @@ function init() {
 
 }
 
-document.addEventListener("load", init);
+window.addEventListener("load", init);