# Cache
6.30.0+Caching is a great and simple technique that helps improve your app's performance. It acts as a temporary data store providing high performance data access.
Ts.ED provides a unified system caching by using the popular cache-manager
(opens new window) Node.js module.
Cache-manager provides various storage to cache content like Redis, MongoDB, etc... and multi caching!
By using the UseCache on endpoint methods or on service methods, you'll be able to cache the response returned by the Ts.ED server or the result returned by a Service.
# Configuration
Cache-manager module is already installed with the @tsed/common
package (since v6.30.0). You just have
to configure cache options and use the decorator to enable cache.
import {Configuration} from "@tsed/common";
@Configuration({
cache: {
ttl: 300, // default TTL
store: "memory"
// options options depending on the choosen storage type
}
})
export class Server {}
2
3
4
5
6
7
8
9
10
# Store Engines
- node-cache-manager-redis (opens new window) (uses sol-redis-pool (opens new window))
- node-cache-manager-redis-store (opens new window) (uses node_redis (opens new window))
- node-cache-manager-ioredis (opens new window) (uses ioredis (opens new window))
- node-cache-manager-mongodb (opens new window)
- node-cache-manager-mongoose (opens new window)
- node-cache-manager-fs (opens new window)
- node-cache-manager-fs-binary (opens new window)
- node-cache-manager-fs-hash (opens new window)
- node-cache-manager-hazelcast (opens new window)
- node-cache-manager-memcached-store (opens new window)
- node-cache-manager-memory-store (opens new window)
# Example with mongoose
import {Configuration} from "@tsed/common";
import mongoose from "mongoose";
const mongooseStore = require("cache-manager-mongoose");
@Configuration({
cache: {
ttl: 300, // default TTL
store: mongooseStore,
mongoose,
modelOptions: {
collection: "caches",
versionKey: false
}
}
})
export class Server {}
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
# Sharing IORedis instance
import {Configuration, registerProvider} from "@tsed/di";
import {Logger} from "@tsed/logger";
import Redis from "ioredis";
export const REDIS_CONNECTION = Symbol("redis:connection");
export type REDIS_CONNECTION = Redis;
registerProvider({
provide: REDIS_CONNECTION,
deps: [Configuration, Logger],
async useAsyncFactory(configuration: Configuration, logger: Logger) {
const cacheSettings = configuration.get("cache");
const redisSettings = configuration.get("redis");
const connection = new Redis({...redisSettings, lazyConnect: true});
cacheSettings.redisInstance = connection;
try {
await connection.connect();
logger.info("Connected to redis database...");
} catch (error) {
logger.error({
event: "REDIS_ERROR",
error
});
}
return connection;
},
hooks: {
$onDestroy(connection: Redis) {
return connection.disconnect();
}
}
});
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
Then:
import {Configuration} from "@tsed/common";
import redisStore from "cache-manager-ioredis";
@Configuration({
cache: {
ttl: 300, // default TTL
store: redisStore
},
redis: {
port: 6379
}
})
export class Server {}
2
3
4
5
6
7
8
9
10
11
12
13
TIP
This example works for a single redis connection. If you look for a complete example with Redis Cluster and Redis single connection, go to this example: https://gist.github.com/Romakita/432b1a8afaa726b41d0baf2456b205aa
# Interacting with the cache store
To interact with the cache manager instance, inject it to your class using the PlatformCache token, as follows:
@Injectable()
export class MyService {
@Inject()
cache: PlatformCache;
}
2
3
4
5
The get
method on the
PlatformCache
instance is used to retrieve items from the cache.
const value = await this.cache.get("key");
To add an item to the cache, use the set
method:
await this.cache.set("key", "value");
The default expiration time of the cache depends on the configured TTL on Server configuration level.
You can manually specify a TTL (expiration time) for this specific key, as follows:
await this.cache.set("key", "value", {ttl: 1000});
To disable the expiration of the cache, set the ttl
configuration property to null
:
await this.cache.set("key", "value", {ttl: null});
To remove an item from the cache, use the del
method:
await this.cache.del("key");
To clear the entire cache, use the reset
method:
await this.cache.reset();
# Cache response
To enable cache on endpoint, use UseCache decorator on a method as follows:
import {Controller, UseCache, Get, PathParams} from "@tsed/common";
@Controller("/my-path")
export class MyController {
@Get("/:id")
@UseCache()
get(@PathParams("id") id: string) {
return "something with " + id;
}
}
2
3
4
5
6
7
8
9
10
Note
UseCache will generate automatically a key based on the Verb and Uri of your route. If QueryParams and/or PathParams are used on the method, the key will be generated with them. According to our previous example, the generated key will be:
GET:my-path:1 // if the id is 1
GET:my-path:2 // etc...
2
WARNING
Only GET
endpoints are cached. Also, HTTP server routes that use the native response object (
Res
) cannot use the
PlatformCacheInterceptor
.
# Cache a value
Because UseCache uses PlatformCacheInterceptor and not a middleware, you can also apply the decorator on any Service/Provider.
import {Injectable} from "@tsed/di";
import {UseCache} from "@tsed/common";
@Injectable()
export class MyService {
@UseCache()
get(id: string) {
return "something with " + id;
}
}
2
3
4
5
6
7
8
9
10
WARNING
node-cache-manager serialize all data as JSON object. It means, if you want to cache a complex data like an instance of class, you have to give extra parameters
to the UseCache decorator. Ts.ED will use
deserialize
function based on the given type
(and collectionType
) to return the expected instance.
import {Injectable} from "@tsed/di";
import {UseCache} from "@tsed/common";
@Injectable()
export class MyService {
@UseCache({type: MyClass})
get(id: string): MyClass {
return new MyClass({id});
}
@UseCache({type: MyClass, collectionType: Array})
getAll(): MyClass[] {
return [new MyClass({id: 1})];
}
}
2
3
4
5
6
7
8
9
10
11
12
13
14
15
# Configure key resolver
By default, Ts.ED uses the request VERB & URL (in an HTTP app) or cache key (for other Service and Provider) to associate cache records with your endpoints. Nevertheless, sometimes you might want to set up the generated key based on different factors, for example, using HTTP headers (e.g. Authorization to properly identify profile endpoints).
There are two ways to do that. The first one is to configure it globally on the Server:
import {Configuration} from "@tsed/di";
import {PlatformContext} from "@tsed/common";
@Configuration({
cache: {
keyResolver(args: any[], $ctx?: PlatformContext): string {
// NOTE $ctx is only available for endpoints
return "key"
}
}
})
2
3
4
5
6
7
8
9
10
11
The second way is to use the key
option with
UseCache
decorator:
import {Controller, UseCache, Get, PathParams, PlatformContext} from "@tsed/common";
@Controller("/my-path")
export class MyController {
@Get("/:id")
@UseCache({key: "key"})
get(@PathParams("id") id: string) {
return "something with " + id;
}
@Get("/:id")
@UseCache({key: (args: any[], $ctx?: PlatformContext) => "key"})
get(@PathParams("id") id: string) {
return "something with " + id;
}
}
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
# Configure TTL
TTL can be defined per endpoint with UseCache :
import {Controller, UseCache, Get, PathParams, PlatformContext} from "@tsed/common";
@Controller("/my-path")
export class MyController {
@Get("/:id")
@UseCache({ttl: 500})
get(@PathParams("id") id: string) {
return "something with " + id;
}
}
2
3
4
5
6
7
8
9
10
# Refresh cache keys in background 6.103.0+
The caching
module support a mechanism to refresh expiring cache keys
in background is you use UseCache
on a Service method (not on controller method).
This is done by adding a refreshThreshold
option to the
UseCache
decorator.
If refreshThreshold
is set and if the ttl
method is available for the used store,
after retrieving a value from cache TTL will be checked. If the remaining current ttl
key is under the configured ttl
- refreshThreshold
, the system will spawn a background worker to update the value, following same rules as standard fetching.
const currentTTL = cache.ttl(key);
if (currentTTL < ttl - refreshThreshold) {
refresh();
}
2
3
4
5
In the meantime, the system will return the old value until expiration.
import {Controller, UseCache, Get, PathParams, PlatformContext} from "@tsed/common";
@Injectable()
export class MyService {
@Get("/:id")
@UseCache({ttl: 3600, refreshThreshold: 900})
get(@PathParams("id") id: string) {
return "something with " + id;
}
}
2
3
4
5
6
7
8
9
10
In this example, the configured ttl
is 1 hour and the threshold is 15 minutes. So, the key will be refreshed in background if current ttl
is under 45 minutes.
# Multi caching
Cache-manager provides a way to use multiple caches. To use it, remove store
option and use caches
instead:
import {Configuration} from "@tsed/common";
@Configuration({
cache: {
ttl: 300, // default TTL
caches: [memoryCache, someOtherCache]
// options options depending on the choosen storage type
}
})
export class Server {}
2
3
4
5
6
7
8
9
10
# Disable cache for test
It can sometimes be useful during unit tests to disable the cache. You can do this by setting the cache
option to false
:
describe("MyCtrl", () => {
let request: SuperTest.SuperTest<SuperTest.Test>;
beforeAll(
TestMongooseContext.bootstrap(Server, {
cache: false,
mount: {
"/rest": [MyCtrl]
}
})
);
});
2
3
4
5
6
7
8
9
10
11
Last Updated: 8/18/2022, 2:07:32 PM
Other topics
- Session & cookies
- Passport.js
- Keycloak
- Prisma
- TypeORM
- MikroORM
- Mongoose
- GraphQL
- Socket.io
- Swagger
- AJV
- Multer
- Serve static files
- Templating
- Serverless HTTP
- Seq
- OIDC
- Stripe
- Agenda
- Terminus
- Serverless
- IORedis
- Controllers
- Providers
- Model
- JsonMapper
- Middlewares
- Pipes
- Interceptors
- Authentication
- Hooks
- Exceptions
- Throw HTTP Exceptions
- Cache
- Command
- Response Filter
- Injection scopes
- Custom providers
- Lazy-loading provider
- Custom endpoint decorator
- Testing
- Customize 404