Haketilo

/**

 * This file is part of Haketilo.

 *

 * Function: Storage manager, lighter than the previous one.

 *

 * Copyright (C) 2021 Wojtek Kosior

 *

 * This program is free software: you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation, either version 3 of the License, or

 * (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * As additional permission under GNU GPL version 3 section 7, you

 * may distribute forms of that code without the copy of the GNU

 * GPL normally required by section 4, provided you include this

 * license notice and, in case of non-source distribution, a URL

 * through which recipients can access the Corresponding Source.

 * If you modify file(s) with this exception, you may extend this

 * exception to your version of the file(s), but you are not

 * obligated to do so. If you do not wish to do so, delete this

 * exception statement from your version.

 *

 * As a special exception to the GPL, any HTML file which merely

 * makes function calls to this code, and for that purpose

 * includes it by reference shall be deemed a separate work for

 * copyright law purposes. If you modify this code, you may extend

 * this exception to your version of the code, but you are not

 * obligated to do so. If you do not wish to do so, delete this

 * exception statement from your version.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program.  If not, see <https://www.gnu.org/licenses/>.

 *

 * I, Wojtek Kosior, thereby promise not to sue for violation of this file's

 * license. Although I request that you do not make use this code in a

 * proprietary program, I am not going to enforce this in court.

 */

/*

 * IMPORTS_START

 * IMPORT TYPE_PREFIX

 * IMPORT raw_storage

 * IMPORT is_mozilla

 * IMPORT observables

 */

const reg_spec = new Set(["\\", "[", "]", "(", ")", "{", "}", ".", "*", "+"]);

const escape_reg_special = c => reg_spec.has(c) ? "\\" + c : c;

function make_regex(name)

{

    return new RegExp(`^${name.split("").map(escape_reg_special).join("")}\$`);

}

const listeners_by_callback = new Map();

function listen(callback, prefix, name)

{

    let by_prefix = listeners_by_callback.get(callback);

    if (!by_prefix) {

	by_prefix = new Map();

	listeners_by_callback.set(callback, by_prefix);

    }

    let by_name = by_prefix.get(prefix);

    if (!by_name) {

	by_name = new Map();

	by_prefix.set(prefix, by_name);

    }

    let name_reg = by_name.get(name);

    if (!name_reg) {

	name_reg = name.test ? name : make_regex(name);

	by_name.set(name, name_reg);

    }

}

function no_listen(callback, prefix, name)

{

    const by_prefix = listeners_by_callback.get(callback);

    if (!by_prefix)

	return;

    const by_name = by_prefix.get(prefix);

    if (!by_name)

	return;

    const name_reg = by_name.get(name);

    if (!name_reg)

	return;

    by_name.delete(name);

    if (by_name.size === 0)

	by_prefix.delete(prefix);

    if (by_prefix.size === 0)

	listeners_by_callback.delete(callback);

}

function storage_change_callback(changes, area)

{

    if (is_mozilla && area !== "local")

    {console.log("area", area);return;}

    for (const item of Object.keys(changes)) {

	for (const [callback, by_prefix] of listeners_by_callback.entries()) {

	    const by_name = by_prefix.get(item[0]);

	    if (!by_name)

		continue;

	    for (const reg of by_name.values()) {

		if (!reg.test(item.substring(1)))

		    continue;

		try {

		    callback(item, changes[item]);

		} catch(e) {

		    console.error(e);

		}

	    }

	}

    }

}

raw_storage.listen(storage_change_callback);

const created_observables = new Map();

async function observe(prefix, name)

{

    const observable = observables.make();

    const callback = (it, ch) => observables.set(observable, ch.newValue);

    listen(callback, prefix, name);

    created_observables.set(observable, [callback, prefix, name]);

    observables.silent_set(observable, await raw_storage.get(prefix + name));

    return observable;

}

const observe_var = name => observe(TYPE_PREFIX.VAR, name);

function no_observe(observable)

{

    no_listen(...created_observables.get(observable) || []);

    created_observables.delete(observable);

}

const light_storage = {};

Object.assign(light_storage, raw_storage);

Object.assign(light_storage,

	      {listen, no_listen, observe, observe_var, no_observe});

/*

 * EXPORTS_START

 * EXPORT light_storage

 * EXPORTS_END

 */