82 lines
2.9 KiB
TypeScript
82 lines
2.9 KiB
TypeScript
|
import { EventEmitter } from 'events'
|
||
|
|
|
||
|
|
// BullMQ calls defineCommand + info internally — provide stubs
|
||
|
|
function defineCommandStub(_name: string, _opts: any) {
|
||
|
|
return undefined
|
||
|
|
}
|
||
|
|
|
||
|
|
class MockRedis extends EventEmitter {
|
||
|
|
// ===== BullMQ compatibility =====
|
||
|
|
defineCommand = defineCommandStub
|
||
|
|
info() { return Promise.resolve('# Server\r\nredis_version:7.0.0\r\n') }
|
||
|
|
options = { keyPrefix: '', host: 'localhost', port: 6379 }
|
||
|
|
// =====
|
||
|
|
|
||
|
|
constructor() { super(); this.setMaxListeners(100) }
|
||
|
|
connect() { return Promise.resolve() }
|
||
|
|
disconnect() { return Promise.resolve(); this.removeAllListeners() }
|
||
|
|
quit() { return Promise.resolve(); this.removeAllListeners() }
|
||
|
|
duplicate() { return new MockRedis() }
|
||
|
|
get() { return Promise.resolve(null) }
|
||
|
|
set() { return Promise.resolve('OK') }
|
||
|
|
del() { return Promise.resolve(0) }
|
||
|
|
incr() { return Promise.resolve(1) }
|
||
|
|
expire() { return Promise.resolve(1) }
|
||
|
|
keys() { return Promise.resolve([]) }
|
||
|
|
exists() { return Promise.resolve(0) }
|
||
|
|
ttl() { return Promise.resolve(-1) }
|
||
|
|
setnx() { return Promise.resolve(1) }
|
||
|
|
hset() { return Promise.resolve(1) }
|
||
|
|
hget() { return Promise.resolve(null) }
|
||
|
|
hdel() { return Promise.resolve(0) }
|
||
|
|
sadd() { return Promise.resolve(1) }
|
||
|
|
srem() { return Promise.resolve(0) }
|
||
|
|
smembers() { return Promise.resolve([]) }
|
||
|
|
zadd() { return Promise.resolve(1) }
|
||
|
|
zrem() { return Promise.resolve(0) }
|
||
|
|
zrange() { return Promise.resolve([]) }
|
||
|
|
zcard() { return Promise.resolve(0) }
|
||
|
|
zrangebyscore() { return Promise.resolve([]) }
|
||
|
|
lpush() { return Promise.resolve(1) }
|
||
|
|
rpush() { return Promise.resolve(1) }
|
||
|
|
lpop() { return Promise.resolve(null) }
|
||
|
|
rpop() { return Promise.resolve(null) }
|
||
|
|
llen() { return Promise.resolve(0) }
|
||
|
|
lrange() { return Promise.resolve([]) }
|
||
|
|
lrem() { return Promise.resolve(0) }
|
||
|
|
publish() { return Promise.resolve(0) }
|
||
|
|
subscribe() { return Promise.resolve() }
|
||
|
|
unsubscribe() { return Promise.resolve() }
|
||
|
|
xadd() { return Promise.resolve('1-0') }
|
||
|
|
xread() { return Promise.resolve(null) }
|
||
|
|
xgroup() { return Promise.resolve('OK') }
|
||
|
|
xreadgroup() { return Promise.resolve(null) }
|
||
|
|
xack() { return Promise.resolve(1) }
|
||
|
|
xpending() { return Promise.resolve([]) }
|
||
|
|
xrange() { return Promise.resolve([]) }
|
||
|
|
xtrim() { return Promise.resolve(0) }
|
||
|
|
xlen() { return Promise.resolve(0) }
|
||
|
|
xdel() { return Promise.resolve(0) }
|
||
|
|
xautoclaim() { return Promise.resolve([]) }
|
||
|
|
xinfo() { return Promise.resolve({}) }
|
||
|
|
call() { return Promise.resolve(null) }
|
||
|
|
multi() { return new MockMulti() }
|
||
|
|
exec() { return Promise.resolve([]) }
|
||
|
|
watch() { return Promise.resolve('OK') }
|
||
|
|
unwatch() { return Promise.resolve('OK') }
|
||
|
|
pipeline() { return { exec: () => Promise.resolve([]) } }
|
||
|
|
brpoplpush() { return Promise.resolve(null) }
|
||
|
|
status = 'ready'
|
||
|
|
}
|
||
|
|
|
||
|
|
class MockMulti {
|
||
|
|
get() { return this }
|
||
|
|
set() { return this }
|
||
|
|
del() { return this }
|
||
|
|
incr() { return this }
|
||
|
|
expire() { return this }
|
||
|
|
exec() { return Promise.resolve([]) }
|
||
|
|
}
|
||
|
|
|
||
|
|
export default MockRedis
|