Hyperpipe/src/scripts/db.js

export function useSetupDB() {
  if ('indexedDB' in window) {
    const req = indexedDB.open('hyperpipedb', 1);

    req.onupgradeneeded = e => {
      const db = e.target.result;
      console.log(db);

      if (!db.objectStoreNames.contains('playlist')) {
        const store = db.createObjectStore('playlist', { keyPath: 'name' });

        store.createIndex('urls', 'urls', { unique: false });
      }
    };

    req.onerror = e => {
      console.log('Please let me use indexedDB!!');
      console.log(e);
      alert(e.target.error.message);
    };

    req.onsuccess = e => {
      window.db = e.target.result;
    };
  }
}

export function useUpdatePlaylist(key, obj, cb = () => null) {
  if (window.db && key) {
    const store = window.db
        .transaction(['playlist'], 'readwrite')
        .objectStore('playlist'),
      req = store.get(key);

    req.onerror = e => {
      console.log('Error!!', e);
    };

    req.onsuccess = e => {
      const itm = e.target.result;

      if (itm) {
        if ('number' == typeof obj) itm.urls.splice(obj, 1);
        else if ('object' == typeof obj) itm.urls.push(obj);
        store.put(itm);
        cb(true);
      }
    };
  } else alert('No indexedDB Created');
}

export function useCreatePlaylist(key, obj, cb = () => null) {
  if (window.db && key && obj) {
    const store = window.db
        .transaction(['playlist'], 'readwrite')
        .objectStore('playlist'),
      req = store.get(key);

    req.onerror = e => {
      console.log('Error!!', e);
    };

    req.onsuccess = e => {
      const res = e.target.result;

      if (!res) {
        store.add({
          name: key,
          urls: obj,
        });

        cb(res);
      } else {
        console.log(e.target.result);
        alert(`Error: Playlist with name ${key} exists`);
      }
    };
  } else alert('No indexedDB Created');
}

export function useRemovePlaylist(key, cb = () => null) {
  if (window.db && key) {
    const store = window.db
        .transaction(['playlist'], 'readwrite')
        .objectStore('playlist'),
      req = store.delete(key);

    req.onerror = e => {
      console.error('Error removing playlist ', e);
    };

    req.onsuccess = () => {
      cb();
    };
  }
}

export function useGetPlaylist(key, cb = () => null) {
  if (window.db && key) {
    const store = window.db.transaction(['playlist']).objectStore('playlist'),
      req = store.get(key);

    req.onerror = e => {
      console.log('Error!!', e);
    };

    req.onsuccess = e => {
      const res = e.target.result;

      if (res) {
        cb(res);
      }
    };
  } else alert('No indexedDB Created');
}

export function useListPlaylists(cb = () => null) {
  if (window.db) {
    let pls = [];

    const store = window.db.transaction(['playlist']).objectStore('playlist'),
      cursor = store.openCursor();

    cursor.onsuccess = e => {
      const pl = e.target.result;

      if (pl) {
        pls.push(pl.value);
        pl.continue();
      } else {
        cb(pls);
      }
    };
  }
}