buffering-cache
Advanced tools
Comparing version 1.0.2 to 1.0.3
@@ -22,4 +22,4 @@ const stringify = require('json-stable-stringify'); | ||
const remoteCache = new Cache(remoteCacheSpec); | ||
const localCache = localCacheSpec ? new Cache(localCacheSpec) : new Cache(defaultLocalCacheSpec); | ||
self.remoteCache = new Cache(remoteCacheSpec); | ||
self.localCache = localCacheSpec ? new Cache(localCacheSpec) : new Cache(defaultLocalCacheSpec); | ||
@@ -50,4 +50,4 @@ if (!remoteCacheSpec.bufferTtl) { | ||
log.debug(`delete cache entry for key: ${deleteKey}`); | ||
return localCache.delete(deleteKey) | ||
.then(() => remoteCache.delete(key)); | ||
return self.localCache.delete(deleteKey) | ||
.then(() => self.remoteCache.delete(key)); | ||
}; | ||
@@ -57,3 +57,3 @@ | ||
return localCache.get(key) | ||
return self.localCache.get(key) | ||
.then((localValue) => { | ||
@@ -65,6 +65,6 @@ if (typeof localValue !== 'undefined') { | ||
return remoteCache.get(key).then((remoteValue) => { | ||
return self.remoteCache.get(key).then((remoteValue) => { | ||
if (typeof remoteValue !== 'undefined' && remoteValue !== null) { | ||
log.debug('Found value in remote cache'); | ||
return localCache.setpx(key, remoteValue, localCacheSpec.ttl).return(remoteValue); | ||
return self.localCache.setpx(key, remoteValue, localCacheSpec.ttl).return(remoteValue); | ||
} | ||
@@ -87,4 +87,4 @@ | ||
const updateCaches = (key, value) => localCache.setpx(key, value) | ||
.then(() => remoteCache.setpx(key, value)); | ||
const updateCaches = (key, value) => self.localCache.setpx(key, value) | ||
.then(() => self.remoteCache.setpx(key, value)); | ||
@@ -94,3 +94,3 @@ self.__refreshBuffer = (key, cachedValue, action, that, args) => { | ||
return remoteCache.pttl(key).then((ttl) => { | ||
return self.remoteCache.pttl(key).then((ttl) => { | ||
const minTimeRemaining = remoteCacheSpec.ttl - remoteCacheSpec.bufferTtl; | ||
@@ -105,4 +105,4 @@ | ||
return Promise.resolve(action.apply(that, args)) | ||
.then((response) => remoteCache.setpx(key, response) | ||
.then(() => localCache.setpx(key, response, localCacheSpec.ttl))) | ||
.then((response) => self.remoteCache.setpx(key, response) | ||
.then(() => self.localCache.setpx(key, response, localCacheSpec.ttl))) | ||
.finally(() => self.releaseRefreshLock(key)); | ||
@@ -121,6 +121,6 @@ } else { | ||
self.obtainRefreshLock = (key) => remoteCache.setnx(`${key}-${REFRESH_LOCK_SUFFIX}`, 'TRUE', REFRESH_LOCK_TIMEOUT_MSEC) | ||
self.obtainRefreshLock = (key) => self.remoteCache.setnx(`${key}-${REFRESH_LOCK_SUFFIX}`, 'TRUE', REFRESH_LOCK_TIMEOUT_MSEC) | ||
.then((res) => res === 'OK'); | ||
self.releaseRefreshLock = (key) => remoteCache.delete(`${key}-${REFRESH_LOCK_SUFFIX}`); | ||
self.releaseRefreshLock = (key) => self.remoteCache.delete(`${key}-${REFRESH_LOCK_SUFFIX}`); | ||
@@ -127,0 +127,0 @@ return self; |
{ | ||
"name": "buffering-cache", | ||
"version": "1.0.2", | ||
"version": "1.0.3", | ||
"description": "Node cache wrapper that keeps your cache warm", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
46185