mirror of
https://github.com/notion-enhancer/notion-enhancer.git
synced 2025-04-06 05:29:02 +00:00
117 lines
3.5 KiB
JavaScript
117 lines
3.5 KiB
JavaScript
/*
|
|
* notion-enhancer: api
|
|
* (c) 2021 dragonwocky <thedragonring.bod@gmail.com> (https://dragonwocky.me/)
|
|
* (https://notion-enhancer.github.io/) under the MIT license
|
|
*/
|
|
|
|
'use strict';
|
|
|
|
/** environment-specific data persistence */
|
|
|
|
const _queue = [],
|
|
_onChangeListeners = [];
|
|
|
|
/**
|
|
* get persisted data
|
|
* @param {string[]} path - the path of keys to the value being fetched
|
|
* @param {unknown=} fallback - a default value if the path is not matched
|
|
* @returns {Promise} value ?? fallback
|
|
*/
|
|
export const get = (path, fallback = undefined) => {
|
|
if (!path.length) return fallback;
|
|
return new Promise((res, rej) =>
|
|
chrome.storage.local.get(async (values) => {
|
|
let value = values;
|
|
while (path.length) {
|
|
if (value === undefined) {
|
|
value = fallback;
|
|
break;
|
|
}
|
|
value = value[path.shift()];
|
|
}
|
|
res(value ?? fallback);
|
|
})
|
|
);
|
|
};
|
|
|
|
/**
|
|
* persist data
|
|
* @param {string[]} path - the path of keys to the value being set
|
|
* @param {unknown} value - the data to save
|
|
* @returns {Promise} resolves when data has been saved
|
|
*/
|
|
export const set = (path, value) => {
|
|
if (!path.length) return undefined;
|
|
const precursor = _queue[_queue.length - 1] || undefined,
|
|
interaction = new Promise(async (res, rej) => {
|
|
if (precursor !== undefined) {
|
|
await precursor;
|
|
_queue.shift();
|
|
}
|
|
const pathClone = [...path],
|
|
namespace = path[0];
|
|
chrome.storage.local.get(async (values) => {
|
|
let pointer = values,
|
|
old;
|
|
while (path.length) {
|
|
const key = path.shift();
|
|
if (!path.length) {
|
|
old = pointer[key];
|
|
pointer[key] = value;
|
|
break;
|
|
}
|
|
pointer[key] = pointer[key] ?? {};
|
|
pointer = pointer[key];
|
|
}
|
|
chrome.storage.local.set({ [namespace]: values[namespace] }, () => {
|
|
_onChangeListeners.forEach((listener) =>
|
|
listener({ path: pathClone, new: value, old })
|
|
);
|
|
res(value);
|
|
});
|
|
});
|
|
});
|
|
_queue.push(interaction);
|
|
return interaction;
|
|
};
|
|
|
|
/**
|
|
* create a wrapper for accessing a partition of the storage
|
|
* @param {string[]} namespace - the path of keys to prefix all storage requests with
|
|
* @param {function=} get - the storage get function to be wrapped
|
|
* @param {function=} set - the storage set function to be wrapped
|
|
* @returns {object} an object with the wrapped get/set functions
|
|
*/
|
|
export const db = (namespace, getFunc = get, setFunc = set) => {
|
|
if (typeof namespace === 'string') namespace = [namespace];
|
|
return {
|
|
get: (path = [], fallback = undefined) => getFunc([...namespace, ...path], fallback),
|
|
set: (path, value) => setFunc([...namespace, ...path], value),
|
|
};
|
|
};
|
|
|
|
/**
|
|
* add an event listener for changes in storage
|
|
* @param {onStorageChangeCallback} callback - called whenever a change in
|
|
* storage is initiated from the current process
|
|
*/
|
|
export const addChangeListener = (callback) => {
|
|
_onChangeListeners.push(callback);
|
|
};
|
|
|
|
/**
|
|
* remove a listener added with storage.addChangeListener
|
|
* @param {onStorageChangeCallback} callback
|
|
*/
|
|
export const removeChangeListener = (callback) => {
|
|
_onChangeListeners = _onChangeListeners.filter((listener) => listener !== callback);
|
|
};
|
|
|
|
/**
|
|
* @callback onStorageChangeCallback
|
|
* @param {object} event
|
|
* @param {string} event.path- the path of keys to the changed value
|
|
* @param {string=} event.new - the new value being persisted to the store
|
|
* @param {string=} event.old - the previous value associated with the key
|
|
*/
|