feat: add psetexBuffer

compat.md

@@ -242,7 +242,6 @@
 - [persistBuffer][1]
 - [pexpireBuffer][1]
 - [pexpireatBuffer][1]
-- [psetexBuffer][1]
 - [psubscribeBuffer][1]
 - [pttlBuffer][1]
 - [publishBuffer][1]

jest.config.redis.js

@@ -50,7 +50,6 @@ module.exports = {
     'test/integration/commands/persist.js',
     'test/integration/commands/pexpire.js',
     'test/integration/commands/pexpireat.js',
-    'test/integration/commands/psetex.js',
     'test/integration/commands/psubscribe.js',
     'test/integration/commands/pttl.js',
     'test/integration/commands/publish.js',

src/commands/psetex.js

@@ -7,3 +7,8 @@ export function psetex(key, milliseconds, value) {
 
   return 'OK'
 }
+
+export function psetexBuffer(...args) {
+  const val = psetex.apply(this, args)
+  return val ? Buffer.from(val) : val
+}

test/integration/commands/psetex.js

@@ -1,26 +1,26 @@
-import Promise from 'bluebird'
 import Redis from 'ioredis'
 
-describe('psetex', () => {
-  it('should set value and expire', () => {
-    const redis = new Redis()
-    return redis
-      .psetex('foo', 100, 'bar')
-      .then(status => {
-        return expect(status).toBe('OK')
-      })
-      .then(() => {
-        expect(redis.data.get('foo')).toBe('bar')
-        expect(redis.expires.has('foo')).toBe(true)
-      })
-      .then(() => {
-        return Promise.delay(200)
-      })
-      .then(() => {
-        return redis.get('foo')
-      })
-      .then(result => {
-        return expect(result).toBe(null)
+// eslint-disable-next-line import/no-relative-parent-imports
+import { runTwinSuite } from '../../../test-utils'
+
+runTwinSuite('psetex', (command, equals) => {
+  describe(command, () => {
+    it('should set value and expire', async () => {
+      const redis = new Redis()
+
+      const status = await redis[command]('foo', 100, 'bar')
+      expect(equals(status, 'OK')).toBe(true)
+      expect(await redis.get('foo')).toBe('bar')
+      expect(await redis.pttl('foo')).toBeGreaterThan(0)
+
+      await new Promise(resolve => {
+        return setTimeout(resolve, 200)
       })
+
+      expect(await redis.get('foo')).toBe(null)
+      expect(await redis.pttl('foo')).toBe(-2)
+
+      redis.disconnect()
+    })
   })
 })

test/integration/commands/setex.js

@@ -8,10 +8,17 @@ runTwinSuite('setex', (command, equals) => {
     it('should set value and expire', async () => {
       const redis = new Redis()
 
-      const status = await redis[command]('foo', 10, 'bar')
+      const status = await redis[command]('foo', 1, 'bar')
       expect(equals(status, 'OK')).toBe(true)
       expect(await redis.get('foo')).toBe('bar')
-      expect(await redis.ttl('foo')).toBeGreaterThan(0)
+      expect(await redis.ttl('foo')).toBe(1)
+
+      await new Promise(resolve => {
+        return setTimeout(resolve, 1500)
+      })
+
+      expect(await redis.get('foo')).toBe(null)
+      expect(await redis.ttl('foo')).toBe(-2)
 
       redis.disconnect()
     })