refactor: use ioredis

.config/example.yml

@@ -58,6 +58,7 @@ redis:
   #path: /var/run/redis/redis-server.sock #unixsocket
   host: localhost
   port: 6379
+  #family: 0 # 0=Both, 4=IPv4, 6=IPv6
   #pass: example-pass
   #prefix: example-prefix
   #db: 1

src/config/types.ts

@@ -22,6 +22,7 @@ export type Source = {
 		path: string;
 		host: string;
 		port: number;
+		family?: number;
 		pass: string;
 		db?: number;
 		prefix?: string;

src/db/redis.ts

@@ -1,30 +1,29 @@
-import * as redis from 'redis';
+import * as Redis from 'ioredis';
 import config from '../config';
 
 export function createConnection() {
 	if (config.redis.path == null) { 
-		return redis.createClient(
-			config.redis.port,
-			config.redis.host,
-			{
+		return new Redis({
+				port: config.redis.port,
+				host: config.redis.host,
+				family: config.redis.family == null ? 0 : config.redis.family,
 				password: config.redis.pass,
-				prefix: config.redis.prefix,
+				keyPrefix: `${config.redis.prefix}:`,
 				db: config.redis.db || 0
 			}
 		);
 	} else {
-		return redis.createClient(
-			config.redis.path,
-			{
+		return new Redis({
+				path: config.redis.path,
 				password: config.redis.pass,
-				prefix: config.redis.prefix,
+				keyPrefix: `${config.redis.prefix}:`,
 				db: config.redis.db || 0
 			}
 		);
 	}
 }
 
 export const subsdcriber = createConnection();
-subsdcriber.subscribe(config.host);
+//subsdcriber.subscribe(config.host);
 
 export const redisClient = createConnection();

src/queue/initialize.ts

@@ -8,12 +8,14 @@ if (config.redis.path == null) {
 	redisOpts = {
 		port:  config.redis.port,
 		host: config.redis.host,
+		family: config.redis.family == null ? 0 : config.redis.family,
 		password: config.redis.pass,
 		db: config.redis.db || 0,
 	}
 } else {
 	redisOpts = {
 		path: config.redis.path,
+		family: config.redis.family == null ? 0 : config.redis.family,
 		password: config.redis.pass,
 		db: config.redis.db || 0,
 	}