87 lines
2.1 KiB
JavaScript
87 lines
2.1 KiB
JavaScript
|
import { createContext, useContext, useEffect, useState } from "react";
|
|||
|
|
import browser from "../libs/browser";
|
|||
|
|
import {
|
|||
|
|
STOKEY_SETTING,
|
|||
|
|
STOKEY_RULES,
|
|||
|
|
STOKEY_MSAUTH,
|
|||
|
|
DEFAULT_SETTING,
|
|||
|
|
DEFAULT_RULES,
|
|||
|
|
} from "../config";
|
|||
|
|
import storage from "../libs/storage";
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 默认配置
|
|||
|
|
*/
|
|||
|
|
export const defaultStorage = {
|
|||
|
|
[STOKEY_MSAUTH]: null,
|
|||
|
|
[STOKEY_SETTING]: DEFAULT_SETTING,
|
|||
|
|
[STOKEY_RULES]: DEFAULT_RULES,
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
const StoragesContext = createContext(null);
|
|||
|
|
|
|||
|
|
export function StoragesProvider({ children }) {
|
|||
|
|
const [storages, setStorages] = useState(null);
|
|||
|
|
|
|||
|
|
const handleChanged = (changes) => {
|
|||
|
|
if (!browser) {
|
|||
|
|
const { key, oldValue, newValue } = changes;
|
|||
|
|
changes = {
|
|||
|
|
[key]: {
|
|||
|
|
oldValue,
|
|||
|
|
newValue,
|
|||
|
|
},
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
const newStorages = {};
|
|||
|
|
Object.entries(changes)
|
|||
|
|
.filter(([_, { oldValue, newValue }]) => oldValue !== newValue)
|
|||
|
|
.forEach(([key, { newValue }]) => {
|
|||
|
|
newStorages[key] = JSON.parse(newValue);
|
|||
|
|
});
|
|||
|
|
if (Object.keys(newStorages).length !== 0) {
|
|||
|
|
setStorages((pre) => ({ ...pre, ...newStorages }));
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
useEffect(() => {
|
|||
|
|
// 首次从storage同步配置到内存
|
|||
|
|
(async () => {
|
|||
|
|
const curStorages = {};
|
|||
|
|
const keys = Object.keys(defaultStorage);
|
|||
|
|
for (const key of keys) {
|
|||
|
|
const val = await storage.get(key);
|
|||
|
|
if (val) {
|
|||
|
|
curStorages[key] = JSON.parse(val);
|
|||
|
|
} else {
|
|||
|
|
await storage.setObj(key, defaultStorage[key]);
|
|||
|
|
curStorages[key] = defaultStorage[key];
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
setStorages(curStorages);
|
|||
|
|
})();
|
|||
|
|
|
|||
|
|
// 监听storage，并同步到内存中
|
|||
|
|
storage.onChanged(handleChanged);
|
|||
|
|
|
|||
|
|
// 解除监听
|
|||
|
|
return () => {
|
|||
|
|
if (browser?.storage) {
|
|||
|
|
browser.storage.onChanged.removeListener(handleChanged);
|
|||
|
|
} else {
|
|||
|
|
window.removeEventListener("storage", handleChanged);
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
}, []);
|
|||
|
|
|
|||
|
|
return (
|
|||
|
|
<StoragesContext.Provider value={storages}>
|
|||
|
|
{children}
|
|||
|
|
</StoragesContext.Provider>
|
|||
|
|
);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
export function useStorages() {
|
|||
|
|
return useContext(StoragesContext);
|
|||
|
|
}
|