1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
/**
* part of Hachette
* Storage manager, lighter than the previous one.
*
* Copyright (C) 2021 Wojtek Kosior
* Redistribution terms are gathered in the `copyright' file.
*/
/*
* 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
*/
|
