mirror of
https://github.com/docmost/docmost.git
synced 2026-08-28 01:07:08 +08:00
Michael LohrandPhilipinho
8c2c49ea6d
* fix: handle empty password, missing port, and TLS in Redis URL parsing --------- Co-authored-by: Philipinho <16838612+Philipinho@users.noreply.github.com>
39 lines
1.2 KiB
TypeScript
39 lines
1.2 KiB
TypeScript
import { IoAdapter } from '@nestjs/platform-socket.io';
|
|
import { ServerOptions } from 'socket.io';
|
|
import { createAdapter } from '@socket.io/redis-adapter';
|
|
import Redis, { RedisOptions } from 'ioredis';
|
|
import {
|
|
createRetryStrategy,
|
|
parseRedisUrl,
|
|
RedisConfig,
|
|
} from '../../common/helpers';
|
|
|
|
export class WsRedisIoAdapter extends IoAdapter {
|
|
private adapterConstructor: ReturnType<typeof createAdapter>;
|
|
private redisConfig: RedisConfig;
|
|
|
|
async connectToRedis(): Promise<void> {
|
|
this.redisConfig = parseRedisUrl(process.env.REDIS_URL);
|
|
|
|
const options: RedisOptions = {
|
|
family: this.redisConfig.family,
|
|
tls: this.redisConfig.tls,
|
|
retryStrategy: createRetryStrategy(),
|
|
};
|
|
|
|
const pubClient = new Redis(process.env.REDIS_URL, options);
|
|
const subClient = new Redis(process.env.REDIS_URL, options);
|
|
|
|
pubClient.on('error', (err) => () => {});
|
|
subClient.on('error', (err) => () => {});
|
|
|
|
this.adapterConstructor = createAdapter(pubClient, subClient);
|
|
}
|
|
|
|
createIOServer(port: number, options?: ServerOptions): any {
|
|
const server = super.createIOServer(port, options);
|
|
server.adapter(this.adapterConstructor);
|
|
return server;
|
|
}
|
|
}
|