diff --git a/config/redis.config.ts b/config/redis.config.ts new file mode 100644 index 0000000..3d6cf0b --- /dev/null +++ b/config/redis.config.ts @@ -0,0 +1,10 @@ +import { createClient } from "redis"; +const redisURL = new URL(process.env.REDIS_URI); + +const pubClient = createClient({ url: `redis://${redisURL.hostname}:6379` }); +(async () => { + await pubClient.connect(); +})(); +const subClient = pubClient.duplicate(); + +export { subClient, pubClient }; diff --git a/services/socket.service.ts b/services/socket.service.ts index 40add1c..eedd2f5 100644 --- a/services/socket.service.ts +++ b/services/socket.service.ts @@ -3,14 +3,9 @@ import { Service, ServiceBroker, ServiceSchema, Context } from "moleculer"; import { createClient } from "redis"; import { createAdapter } from "@socket.io/redis-adapter"; import Session from "../models/session.model"; +import { pubClient, subClient } from "../config/redis.config"; const SocketIOService = require("moleculer-io"); const { v4: uuidv4 } = require("uuid"); -const redisURL = new URL(process.env.REDIS_URI); -const pubClient = createClient({ url: `redis://${redisURL.hostname}:6379` }); -(async () => { - await pubClient.connect(); -})(); -const subClient = pubClient.duplicate(); export default class SocketService extends Service { // @ts-ignore