use pExpire instead

tiramisulabs · Sep 18, 2024 · 226f62d · 226f62d
1 parent ed77123
commit 226f62d
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 8 deletions.
diff --git a/packages/redis-adapter/src/expirableAdapter.ts b/packages/redis-adapter/src/expirableAdapter.ts
@@ -73,7 +73,7 @@ export class ExpirableRedisAdapter extends RedisAdapter {
 			const cacheType = key.split('.')[0] as keyof ExpirableRedisAdapterOptions;
 			const expire = this.options[cacheType]?.expire ?? this.options.default.expire!;
 			if (expire > 0) {
-				promises.push(this.client.set(`${this.buildKey(key)}.uset.${value}`, 's', { EX: expire }));
+				promises.push(this.client.set(`${this.buildKey(key)}.uset.${value}`, 's', { PX: expire }));
 			} else {
 				promises.push(this.client.set(`${this.buildKey(key)}.uset.${value}`, 's'));
 			}
@@ -138,7 +138,7 @@ export class ExpirableRedisAdapter extends RedisAdapter {
 
 		const expire = this.options[cacheType]?.expire ?? this.options.default.expire!;
 		if (expire > 0) {
-			promises.push(this.client.expire(this.buildKey(id), expire));
+			promises.push(this.client.pExpire(this.buildKey(id), expire));
 		}
 
 		await Promise.all(promises);
@@ -167,7 +167,7 @@ export class ExpirableRedisAdapter extends RedisAdapter {
 		const cacheType = id.split('.')[0] as keyof ExpirableRedisAdapterOptions;
 		const expire = this.options[cacheType]?.expire ?? this.options.default.expire!;
 		if (expire > 0) {
-			promises.push(this.client.expire(this.buildKey(id), expire));
+			promises.push(this.client.pExpire(this.buildKey(id), expire));
 		}
 
 		await Promise.all(promises);

diff --git a/packages/redis-adapter/test/expirableadapter.test.js b/packages/redis-adapter/test/expirableadapter.test.js
@@ -8,10 +8,17 @@ describe('ExpirableRedisAdapter', async () => {
 		['key2', { value: 'value2' }],
 	];
 
-	const adapter = new ExpirableRedisAdapter({
-		redisOptions: {},
-		namespace: 'ex_custom_namespace',
-	});
+	const adapter = new ExpirableRedisAdapter(
+		{
+			redisOptions: {},
+			namespace: 'ex_custom_namespace',
+		},
+		{
+			default: {
+				expire: 2e3,
+			},
+		},
+	);
 
 	await adapter.start();
 

diff --git a/packages/redis-adapter/test/expirablecache.test.js b/packages/redis-adapter/test/expirablecache.test.js
@@ -13,7 +13,7 @@ describe('Test Adapter cache', async t => {
 		},
 		{
 			default: {
-				expire: 2,
+				expire: 2e3,
 			},
 		},
 	);