-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
chore(promise-cache): handle set, map, object, array (#653)
Co-authored-by: Juan Pablo Vargas Martinez <juan@Juans-MacBook-Pro.local> Co-authored-by: Alexander Czigler <3116043+alexanderczigler@users.noreply.github.com>
- Loading branch information
1 parent
46bec06
commit 8466c95
Showing
9 changed files
with
724 additions
and
54 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,7 @@ | ||
--- | ||
"@sebspark/promise-cache": major | ||
--- | ||
|
||
- TTL is always seconds. | ||
- Support logger injection. | ||
- Handle complex types; set, map, object, array. |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,23 +1,163 @@ | ||
# `@sebspark/promise-cache` | ||
|
||
A simple caching wrapper for promises. | ||
Simple caching wrapper | ||
|
||
## **Features** | ||
|
||
- **PromiseCache**: Simple caching wraper for promises | ||
- **Persistor**: Simple Key/Value caching wrapper, can be used with redis or with local memory. | ||
|
||
## **Installation** | ||
|
||
To install promise-cache, use `yarn`: | ||
|
||
```bash | ||
yarn install @sebspark/promise-cache | ||
``` | ||
## **Usage** | ||
|
||
### **PromiseCache Class** | ||
|
||
| Params | Type | Default |Description | | ||
|---------------|----------|---------|---------------------------------------------| | ||
| redis | RedisClientOptions | undefined |Redis instance url, skip if use local memory | | ||
| ttlInSeconds | number | undefined |Persist time in Seconds | | ||
| caseSensituve | boolean | false |Retrieving cache with case sensitive | | ||
| onSuccess | function | undefined |Callback function if connection is success | | ||
| onError | function | undefined |Callback function if there is an error | | ||
| logger | winston Logger | undefined |Logger | | ||
|
||
```typescript | ||
import { PromiseCache } from '@sebspark/promise-cache' | ||
|
||
// with redis | ||
const cacheInRedis = new PromiseCache<T>({ | ||
redis: REDIS_URL, | ||
ttlInSeconds: ttl, | ||
caseSensitive: true | ||
}) | ||
|
||
// without redis | ||
const cacheLocalMemory = new PromiseCache<T>({ | ||
ttlInSeconds: ttl, | ||
caseSensitive: true | ||
}) | ||
``` | ||
|
||
## **PromiseCache Methods** | ||
|
||
```typescript | ||
// Wrap | ||
/* Simple promise cache wrapper | ||
* @param key Cache key. | ||
* @param delegate The function to execute if the key is not in the cache. | ||
* @param ttlInSeconds Time to live in seconds. | ||
* @param ttlKeyInSeconds The key in the response object that contains the TTL. | ||
* @returns The result of the delegate function. | ||
*/ | ||
const ttl = 5 // 5 seconds | ||
const delegate = new Promise((reject, resolve) => { resolve(123)}) | ||
const response = await cacheInRedis.wrap('Key', delegate, ttl) | ||
expect(response).toBe(123) | ||
|
||
// Size | ||
/* | ||
* Pseudocode example. | ||
* Cache size | ||
* @returns The number of entries in the cache | ||
*/ | ||
|
||
const entries = await cacheInRedis.size() | ||
expect(entries).toBe(1) | ||
|
||
// Find | ||
/** | ||
* Get a value from the cache. | ||
* @param key Cache key. | ||
*/ | ||
|
||
const cachedValue = await cacheInRedis.find('Key') | ||
expect(cachedValue).toBe(123) | ||
|
||
// Override | ||
/** | ||
* Set a value in the cache. | ||
* @param key Cache key. | ||
* @param value Cache value. | ||
* @param ttlInSeconds? Time to live in seconds. | ||
*/ | ||
import { PromiseCache } from '@sebspark/promise-cache' | ||
|
||
// Instantiate the cache with a TTL. | ||
const cache = new PromiseCache<number>(60, true, true) // 1 minute cache TTL / is case sensitive / use local storage | ||
await cacheInRedis.override('Key', 234) // keep the same ttl | ||
const cached = cacheInRedis.find('Key') | ||
expect(cached).toBe(234) | ||
``` | ||
|
||
### **Persistor Class** | ||
|
||
| Params | Type | Default |Description | | ||
|---------------|----------|---------|---------------------------------------------| | ||
| redis | RedisClientOptions | undefined |Redis instance url, skip if use local memory | | ||
| onSuccess | function | undefined |Callback function if connection is success | | ||
| onError | function | undefined |Callback function if there is an error | | ||
| logger | winston Logger | undefined |Logger | | ||
| clientId | any | undefined |Object internal id | | ||
|
||
```typescript | ||
import { Persistor } from '@sebspark/promise-cache' | ||
|
||
const redisCache = new PromiseCache<number>(60, false, false) // 1 minute cache TTL / is not case sensitive / use redis storage | ||
// with redis | ||
const store = new Persistor<T>({ | ||
redis: REDIS_URL, | ||
}) | ||
|
||
// without redis | ||
const store = new Persistor<T>() | ||
``` | ||
|
||
## **Persistor Methods** | ||
|
||
```typescript | ||
|
||
// Use the cache wrapper for a database query to relieve the database. | ||
const query = 'SELECT username FROM users ORDER BY created DESC LIMIT 1' | ||
const newestUser = await cache.wrap('newestUser', () => database.query(query)) | ||
/** | ||
* Size | ||
* @returns The number of entries in the cache | ||
*/ | ||
|
||
const size = await store.size() | ||
expect(size).toBe(0) | ||
|
||
/** | ||
* Set | ||
* Set a value in the cache. | ||
* @param key Cache key. | ||
* @param object.value Value to set in the cache. | ||
* @param object.ttl Time to live in seconds. | ||
* @param object.timestamp Timestamp | ||
*/ | ||
|
||
await store.set<number>('MyKey', { | ||
value: 123, | ||
ttl: 10 // In seconds, default undefined | ||
timestamp: Date.now() // default Date.now() | ||
}) | ||
|
||
/** | ||
* Get a value from the cache. | ||
* @param key Cache key. | ||
* @returns GetType<T> value | ||
*/ | ||
|
||
const cached = await store.get('MyKey') | ||
expect(cached).toBe({ | ||
value: 43, | ||
ttl: 10, | ||
timestamp: // The timestamp | ||
}) | ||
|
||
/** | ||
* Delete a value from the cache. | ||
* @param key Cache key | ||
*/ | ||
|
||
// Use the cache wrapper for a database query to relieve the database. | ||
const query = 'SELECT username FROM users ORDER BY created DESC LIMIT 1' | ||
const newestUser = await redisCache.wrap('newestUserRedis', () => database.query(query)) | ||
``` | ||
await store.delete('MyKey') | ||
expect(await store.get('MyKey').toBe(null) | ||
``` |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -19,7 +19,6 @@ | |
"tsconfig": "*" | ||
}, | ||
"dependencies": { | ||
"redis": "4.7.0", | ||
"@sebspark/retry": "*" | ||
"redis": "4.7.0" | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,3 +1,2 @@ | ||
export * from './promiseCache' | ||
export * from './localMemory' | ||
export * from './persistor' |
Oops, something went wrong.