scanStream in redis

[mohamadlounnas]

hey @everyone
i am trying to delete all keys started with "products:*" but scanStream not exists in redis

export async function deleteAllKeysByPattern(pattern: string): Promise<void> {
  const stream = redis.scanStream(pattern, { // Property 'scanStream' does not exist on type 'RedisService'
    match: pattern,
  })

  return new Promise((resolve, reject) => {
    stream.on('data', async (keys: string[]) => {
      for (const key of keys) {
        await redis.del(key)
      }
    })

    stream.on('end', resolve)
    stream.on('error', reject)
  })
}

[RomainLanz]

Hey @mohamadlounnas! 👋🏻

It needs to be added here: https://github.com/adonisjs/redis/blob/develop/src/connections/io_methods.ts#L17
We also need to update the typing accordingly.

Would you mind creating a PR?

[mohamadlounnas]

I tried the following code in the tests folder to remove keys using scanStream with the pattern temp:*.
It worked well after i used RedisManagerFactory, but I ran into issues with type safety when using the AdonisJS config file and it just didn't work.
this example works fine:

  const rredis = new RedisManagerFactory({
    connection: 'primary',
    connections: {
      primary: {
        host: process.env.REDIS_HOST,
        port: Number(process.env.REDIS_PORT),
      },
    },
  }).create()

  var stream = rredis.connection('primary').scanStream({
    match: 'temp:*',
  })

  stream.on('data', async function (keys) {
    for (const key of keys) {
      await redis.del(key)
    }
  })
  stream.on('end', function () {
    console.log('all keys have been removed')
  })