@soundcore/heartbeat v0.0.1
Soundcore Redis Module
This package includes ioredis
as NestJS Module.
It is a more lightweight version of @nest-modules/ioredis
and contains only the necessary methods used in this monorepo.
Additionally, it introduces only support for NestJS 9.x.x
Installation
npm install --save @soundcore/redis ioredis
or using yarn
yarn add @soundcore/redis ioredis
Usage
First, you have to register the module in your app.module.ts
:
import { Module } from '@nestjs/common';
import { SoundcoreRedisModule } from '@soundcore/redis';
@Module({
imports: [
SoundcoreRedisModule.forRoot({
// IORedis options go here
})
]
})
export class AppModule {}
To configure the redis client, please read the docs of the ioredis package. After that, you can inject the redis client in your services like that:
import { Injectable } from '@nestjs/common';
import Redis from "ioredis";
@Injectable()
export class AppService {
constructor(private readonly redis: Redis) {}
}
Static Payload
If you want to send some static data via the heartbeat packet, you can do that be defining an object
on the staticPayload
property when registering the HeartbeatClientModule
.
The data defined there will then be sent at every heartbeat.
On the server side you can catch the heartbeat packet after it was processed by registering a handler
using the @OnHeartbeat()
decorator. Please see the following example:
import { Heartbeat, OnHeartbeat } from "@soundcore/heartbeat";
@OnHeartbeat()
public handleHeartbeat(heartbeat: Heartbeat) {
// Handle payload
}
Subscribe
Redis is known for its ability for Pub/Sub. To make subscribing to messages and channels more comfortable, a new decorator has been introduced: @RedisSubscribe(channel: string, expectJSON: boolean)
. This is a method decorator and takes in 2 parameters. The first one specifies the channel to which the client should listen. The second parameter defines, wether the client should parse the JSON string to an actual JSON object or not. Please see the following example on how to use the decorator:
import { RedisSubscribe } from "@soundcore/redis";
@RedisSubscribe("test", true)
public handleSubscribe(channel: string, payload: any) {
console.log(channel, payload);
}
The example above would subscribe on the channel called "test" and parse the received messages to an JSON object. Please make sure that on these channels, only json strings are sent. Otherwise it would cause parsing errors and the payload object may become a nullish value.
2 years ago