This repository has been archived on 2022-08-19. You can view files and clone it, but cannot push or open issues or pull requests.
hydrogen-web/src/observable/map/ObservableMap.js

147 lines
4.1 KiB
JavaScript
Raw Normal View History

import BaseObservableMap from "./BaseObservableMap.js";
2019-02-21 04:18:16 +05:30
export default class ObservableMap extends BaseObservableMap {
2019-02-24 23:54:28 +05:30
constructor(keyFn, initialValues) {
2019-02-21 04:18:16 +05:30
super();
2019-02-24 23:54:28 +05:30
this._keyFn = keyFn;
2019-02-21 04:18:16 +05:30
this._values = new Map(initialValues);
}
update(key, params) {
const value = this._values.get(key);
if (value !== undefined) {
2019-02-24 23:54:28 +05:30
// could be the same value, so it's already updated
// but we don't assume this here
this._values.set(key, value);
this.emitUpdate(key, value, params);
2019-02-21 04:18:16 +05:30
return true;
}
return false; // or return existing value?
}
add(key, value) {
if (!this._values.has(key)) {
2019-02-24 23:54:28 +05:30
this._values.set(key, value);
2019-02-21 04:18:16 +05:30
this.emitAdd(key, value);
return true;
}
return false; // or return existing value?
}
remove(key) {
const value = this._values.get(key);
if (value !== undefined) {
this._values.delete(key);
this.emitRemove(key, value);
return true;
} else {
return false;
}
}
reset() {
this._values.clear();
this.emitReset();
}
get(key) {
return this._values.get(key);
}
get size() {
return this._values.size;
}
[Symbol.iterator]() {
2019-02-24 23:54:28 +05:30
return this._values.entries();
}
}
//#ifdef TESTS
2019-02-24 23:54:28 +05:30
export function tests() {
return {
test_add(assert) {
let fired = 0;
const map = new ObservableMap();
map.subscribe({
onAdd(key, value) {
fired += 1;
assert.equal(key, 1);
assert.deepEqual(value, {value: 5});
}
});
map.add(1, {value: 5});
assert.equal(map.size, 1);
assert.equal(fired, 1);
},
test_update(assert) {
let fired = 0;
const map = new ObservableMap();
const value = {number: 5};
map.add(1, value);
map.subscribe({
onUpdate(key, value, params) {
fired += 1;
assert.equal(key, 1);
assert.deepEqual(value, {number: 6});
assert.equal(params, "test");
}
});
value.number = 6;
map.update(1, "test");
assert.equal(fired, 1);
},
test_update_unknown(assert) {
let fired = 0;
const map = new ObservableMap(v => v.id);
map.subscribe({
onUpdate() { fired += 1; }
});
const result = map.update(1);
assert.equal(fired, 0);
assert.equal(result, false);
},
test_remove(assert) {
let fired = 0;
const map = new ObservableMap();
const value = {value: 5};
map.add(1, value);
map.subscribe({
onRemove(key, value) {
fired += 1;
assert.equal(key, 1);
assert.deepEqual(value, {value: 5});
}
});
map.remove(1);
assert.equal(map.size, 0);
assert.equal(fired, 1);
},
test_iterate(assert) {
const results = [];
const map = new ObservableMap();
map.add(1, {number: 5});
map.add(2, {number: 6});
map.add(3, {number: 7});
for (let e of map) {
results.push(e);
}
assert.equal(results.length, 3);
assert.equal(results.find(([key]) => key === 1)[1].number, 5);
assert.equal(results.find(([key]) => key === 2)[1].number, 6);
assert.equal(results.find(([key]) => key === 3)[1].number, 7);
},
test_size(assert) {
const map = new ObservableMap();
map.add(1, {number: 5});
map.add(2, {number: 6});
assert.equal(map.size, 2);
},
2019-02-21 04:18:16 +05:30
}
}
//#endif