Elizhium/litlyx
1
0
Fork 0
mirror of https://github.com/Litlyx/litlyx synced 2025-12-10 15:58:38 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix pricing + limits email + redis

Browse Source
This commit is contained in:
Emily
2024-09-07 15:47:13 +02:00
parent 30b3ed80e2
commit 73739dde9d
15 changed files with 361 additions and 482 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
shared/services/RedisStreamService.ts
View File

@@ -25,10 +25,7 @@ export class RedisStreamService {
static async connect() {
console.log('RedisStreamService DEV_MODE=', process.env.DEV_MODE === 'true');
await this.client.connect();
setInterval(() => {
console.log('Processed:', (RedisStreamService.processed / 30).toFixed(), '/s');
RedisStreamService.processed = 0;
}, 30_000)
}
@@ -48,6 +45,11 @@ export class RedisStreamService {
static async startReadingLoop(options: ReadingLoopOptions, processFunction: (content: Record<string, string>) => Promise<any>) {
setInterval(() => {
console.log('Processed:', (RedisStreamService.processed / 30).toFixed(), '/s');
RedisStreamService.processed = 0;
}, 30_000)
try {
console.log('Start reading loop');
await this.client.xGroupCreate(options.streamName, 'broker', '0', { MKSTREAM: true, });