const ING_DB_VERSION = 4;

// @See https://github.com/mdn/learning-area/blob/master/javascript/apis/client-side-storage/indexeddb/video-store/index.js

let idb;
let ireload = false;
let ings;
let recipes;

/*
 * Load item set from local DB. Calls init() on success.
 */
async function ing_load_local(init_func) {
    let get_tx = idb.transaction(['ing_db', 'recipe_db'], 'readonly');
    let ings_store = get_tx.objectStore('ing_db');
    let recipes_store = get_tx.objectStore('recipe_db');
    let request3 = ings_store.getAll();
    request3.onerror = function(event) {
        console.log("Could not read local ingredient db...");
    }
    request3.onsuccess = function(event) {
        console.log("Successfully read local ingredient db.");
        ings = request3.result;
    }
    let request4 = recipes_store.getAll();
    request4.onerror = function(event) {
        console.log("Could not read local recipe db...");
    }
    request4.onsuccess = function(event) {
        console.log("Successfully read local recipe db.");
        recipes = request4.result;
        init_func();
    }
    await get_tx.complete;
    idb.close();
}

/*
 * Load item set from remote DB (aka a big json file). Calls init() on success.
 */
async function load_ings(init_func) {

    let getUrl = window.location;
    let baseUrl = getUrl.protocol + "//" + getUrl.host + "/" + getUrl.pathname.split('/')[1];
    let url = baseUrl + "/ingreds_compress.json";
    url = url.replace("/crafter.html", ""); //JANK
    let result = await (await fetch(url)).json();

    result = await (await fetch(url)).json();
    ings = result.ingredients;

    url = url.replace("/ingreds_compress.json", "/recipes_compress.json");
    result = await (await fetch(url)).json();
    recipes = result.recipes;

    // https://developer.mozilla.org/en-US/docs/Web/API/IDBObjectStore/clear
    /*let clear_tx2 = db.transaction(['ing_db'], 'readwrite');
    let clear_ings = clear_tx2.objectStore('ing_db');
    let clear_tx3 = db.transaction(['recipe_db'], 'readwrite');
    let clear_recipes = clear_tx3.objectStore('recipe_db');
    await clear_ings.clear();
    await clear_recipes.clear();
    await clear_tx2.complete;
    await clear_tx3.complete;*/
    let add_promises = [];
    let add_tx2 = idb.transaction(['ing_db'], 'readwrite');
    let ings_store = add_tx2.objectStore('ing_db');
    for (const ing in ings) {
        add_promises.push(ings_store.add(ings[ing], ing));
    }
    let add_tx3 = idb.transaction(['recipe_db'], 'readwrite');
    let recipes_store = add_tx3.objectStore('recipe_db');
    for (const recipe in recipes) {
        add_promises.push(recipes_store.add(recipes[recipe], recipe));
    }
    add_promises.push(add_tx2.complete);
    add_promises.push(add_tx3.complete);
    Promise.all(add_promises).then((values) => {
        idb.close();
        init_func();
    });
}

function load_ing_init(init_func) {
    
    let request = window.indexedDB.open("ing_db", ING_DB_VERSION)
    request.onerror = function() {
        console.log("DB failed to open...");
    }

    request.onsuccess = function() {
        idb = request.result;
        if (!ireload) {
            console.log("Using stored data...")
            ing_load_local(init_func);
        }
        else {
            console.log("Using new data...")
            load_ings(init_func);
        }
    }

    request.onupgradeneeded = function(e) {
        ireload = true;

        let idb = e.target.result;
        
        try {
            idb.deleteObjectStore('ing_db');
        }
        catch (error) {
            console.log("Could not delete ingredient DB. This is probably fine");
        }
        try {
            idb.deleteObjectStore('recipe_db');
        }
        catch (error) {
            console.log("Could not delete recipe DB. This is probably fine");
        }
        idb.createObjectStore('ing_db');
        idb.createObjectStore('recipe_db');

        console.log("DB setup complete...");
    }
}