c-l/immich
1
0
Fork 0
mirror of https://github.com/immich-app/immich.git synced 2025-01-01 08:31:59 +00:00
Code Releases Activity

chore(server): redis error handling (#2212)

Browse source 
* chore(server): bull error handler

* chore(server): redis error handling

* Let's not touch bull
This commit is contained in:
Skyler Mäntysaari 2023-04-09 04:35:08 +03:00 committed by GitHub
parent 9fc70fc24e
commit a68fbcc520
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
server/libs/infra/src/redis-io.adapter.ts
View file

@ -1,13 +1,21 @@
import { IoAdapter } from '@nestjs/platform-socket.io'; import { IoAdapter } from '@nestjs/platform-socket.io';
import { createAdapter } from '@socket.io/redis-adapter'; import { createAdapter } from '@socket.io/redis-adapter';
import Redis from 'ioredis'; import Redis from 'ioredis';
import { Logger } from '@nestjs/common';
import { ServerOptions } from 'socket.io'; import { ServerOptions } from 'socket.io';
import { redisConfig } from './infra.config'; import { redisConfig } from './infra.config';
export class RedisIoAdapter extends IoAdapter { export class RedisIoAdapter extends IoAdapter {
private readonly logger = new Logger(RedisIoAdapter.name);
createIOServer(port: number, options?: ServerOptions): any { createIOServer(port: number, options?: ServerOptions): any {
const pubClient = new Redis(redisConfig); const pubClient = new Redis(redisConfig);
pubClient.on('error', (error) => {
this.logger.error(`Redis pubClient: ${error}`);
});
const subClient = pubClient.duplicate(); const subClient = pubClient.duplicate();
subClient.on('error', (error) => {
this.logger.error(`Redis subClient: ${error}`);
});
const server = super.createIOServer(port, options); const server = super.createIOServer(port, options);
server.adapter(createAdapter(pubClient, subClient)); server.adapter(createAdapter(pubClient, subClient));
return server; return server;