mirror of
https://github.com/nasa/openmct.git
synced 2025-01-01 19:06:40 +00:00
Merge remote-tracking branch 'origin/open791' into open-master
This commit is contained in:
commit
78d8068789
@ -21,16 +21,38 @@ define(
|
|||||||
var spaces = CACHE_SPACES || [], // List of spaces to cache
|
var spaces = CACHE_SPACES || [], // List of spaces to cache
|
||||||
cache = {}; // Where objects will be stored
|
cache = {}; // Where objects will be stored
|
||||||
|
|
||||||
// Utility function; avoid sharing one instance everywhere.
|
// Update the cached instance of an object to a new value
|
||||||
function clone(value) {
|
function replaceValue(valueHolder, newValue) {
|
||||||
// Only clone truthy values (no need to clone undefined, false...)
|
var v = valueHolder.value;
|
||||||
return value && JSON.parse(JSON.stringify(value));
|
|
||||||
|
// If it's a JS object, we want to replace contents, so that
|
||||||
|
// everybody gets the same instance.
|
||||||
|
if (typeof v === 'object' && v !== null) {
|
||||||
|
// Only update contents if these are different instances
|
||||||
|
if (v !== newValue) {
|
||||||
|
// Clear prior contents
|
||||||
|
Object.keys(v).forEach(function (k) {
|
||||||
|
delete v[k];
|
||||||
|
});
|
||||||
|
// Shallow-copy contents
|
||||||
|
Object.keys(newValue).forEach(function (k) {
|
||||||
|
v[k] = newValue[k];
|
||||||
|
});
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
// Otherwise, just store the new value
|
||||||
|
valueHolder.value = newValue;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Place value in the cache for space, if there is one.
|
// Place value in the cache for space, if there is one.
|
||||||
function addToCache(space, key, value) {
|
function addToCache(space, key, value) {
|
||||||
if (cache[space]) {
|
if (cache[space]) {
|
||||||
cache[space][key] = { value: clone(value) };
|
if (cache[space][key]) {
|
||||||
|
replaceValue(cache[space][key], value);
|
||||||
|
} else {
|
||||||
|
cache[space][key] = { value: value };
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -110,7 +132,7 @@ define(
|
|||||||
*/
|
*/
|
||||||
readObject: function (space, key) {
|
readObject: function (space, key) {
|
||||||
return (cache[space] && cache[space][key]) ?
|
return (cache[space] && cache[space][key]) ?
|
||||||
fastPromise(clone(cache[space][key].value)) :
|
fastPromise(cache[space][key].value) :
|
||||||
persistenceService.readObject(space, key)
|
persistenceService.readObject(space, key)
|
||||||
.then(putCache(space, key));
|
.then(putCache(space, key));
|
||||||
},
|
},
|
||||||
|
@ -77,6 +77,17 @@ define(
|
|||||||
|
|
||||||
});
|
});
|
||||||
|
|
||||||
|
it("gives a single instance of cached objects", function () {
|
||||||
|
// Perform two reads
|
||||||
|
decorator.readObject(testSpace, "someKey", "someValue")
|
||||||
|
.then(mockCallback);
|
||||||
|
decorator.readObject(testSpace, "someKey", "someValue")
|
||||||
|
.then(mockCallback);
|
||||||
|
|
||||||
|
// Results should have been pointer-identical
|
||||||
|
expect(mockCallback.calls[0].args[0])
|
||||||
|
.toBe(mockCallback.calls[1].args[0]);
|
||||||
|
});
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
);
|
);
|
Loading…
Reference in New Issue
Block a user