fix(RedisAdapter): change redis client

packages/redis-adapter/package.json

@@ -16,10 +16,11 @@
 		"dev": "tsc --watch",
 		"build": "tsc",
 		"lint": "biome lint --write ./src",
-		"format": "biome format --write ./src"
+		"format": "biome format --write ./src",
+		"test": "node --test ./test/*"
 	},
 	"dependencies": {
-		"ioredis": "^5.4.1",
+		"iovalkey": "^0.1.0",
 		"seyfert": "^2.0.0"
 	},
 	"devDependencies": {

packages/redis-adapter/src/adapter.ts

@@ -1,6 +1,6 @@
-import type { RedisOptions } from 'ioredis';
+import type { RedisOptions } from 'iovalkey';
 import type { Adapter } from 'seyfert/lib/cache';
-import { Redis } from 'ioredis';
+import { Redis } from 'iovalkey';
 
 interface RedisAdapterOptions {
 	namespace?: string;
@@ -63,7 +63,12 @@ export class RedisAdapter implements Adapter {
 			pipeline.hgetall(this.buildKey(key));
 		}
 
-		return (await pipeline.exec())?.filter(x => !!x[1]).map(x => toNormal(x[1] as Record<string, any>)) ?? [];
+		return (
+			(await pipeline.exec())
+				?.filter(x => !!x[1])
+				.map(x => toNormal(x[1] as Record<string, any>))
+				.filter(x => x) ?? []
+		);
 	}
 
 	async get(keys: string): Promise<any> {

packages/redis-adapter/test/adapter.test.js

@@ -0,0 +1,72 @@
+const { strict } = require("node:assert/strict");
+const { test, describe, after, before } = require('node:test');
+const { RedisAdapter } = require('../lib/adapter');
+
+describe('RedisAdapter', async () => {
+	const bulk = [['key1', { value: 'value1' }], ['key2', { value: 'value2' }]]
+
+	const adapter = new RedisAdapter({
+		redisOptions: {
+			host: 'localhost',
+			port: 6379,
+		},
+		namespace: 'test',
+	});
+
+	before(async () => {
+		// Clean the Redis instance before each test
+		await adapter.flush();
+
+	});
+
+	await test('constructor', () => {
+		strict.strictEqual(adapter.isAsync, true);
+		strict.strictEqual(adapter.namespace, 'test');
+	});
+
+	await test('get', async () => {
+		const result = await adapter.get('testKey');
+		strict.deepStrictEqual(result, undefined);
+	});
+
+	await test('set', async () => {
+		await strict.doesNotReject(async () => {
+			await adapter.set('testKey', { value: 'testValue' });
+		});
+	});
+
+	await test('bulkSet', async () => {
+		await strict.doesNotReject(async () => {
+			await adapter.bulkSet(bulk);
+		});
+	});
+
+	await test('bulkGet', async () => {
+		const result = await adapter.bulkGet(['key1', 'key2']);
+		strict.deepStrictEqual(result, bulk.map(x => x[1]));
+	});
+
+
+
+	await test('patch', async () => {
+		await strict.doesNotReject(async () => {
+			await adapter.patch(false, 'testKey', { newValue: 'updatedValue' });
+		});
+	});
+
+	await test('bulkPatch', async () => {
+		await strict.doesNotReject(async () => {
+			await adapter.bulkPatch(false, [['key1', { newValue: 'updatedValue1' }], ['key2', { newValue: 'updatedValue2' }]]);
+		});
+	});
+
+	await test('scan', async () => {
+		const result = await adapter.scan('test*');
+		strict.strictEqual(result.length, 3);
+	});
+
+	after(async () => {
+		await adapter.flush();
+		await adapter.client.quit();
+	});
+});

packages/redis-adapter/test/cache.test.js

@@ -0,0 +1,37 @@
+const { describe, test, after, before } = require('node:test');
+const { Cache, Client } = require('seyfert');
+const { RedisAdapter } = require('../lib/index');
+const { doesNotReject } = require('node:assert/strict');
+const { setTimeout } = require('node:timers/promises');
+const { doesNotThrow } = require('node:assert/strict');
+
+// all intents
+const intents = 53608447;
+
+describe('Test Adapter cache', async t => {
+	const adapter = new RedisAdapter({
+		redisOptions: {
+			host: 'localhost',
+			port: 6379,
+		},
+		namespace: 'test_cache',
+	});
+
+	test('discord cache', async () => {
+		doesNotThrow(async () => {
+			const client = new Client({ getRC: () => ({ intents }) });
+			client.setServices({
+				cache: {
+					adapter,
+				}
+			})
+			await client.cache.testAdapter();
+		});
+		await setTimeout(5000);
+	});
+
+	after(async () => {
+		await adapter.flush()
+		await adapter.client.quit();
+	});
+});