WangDL
6a13edc7fb
All checks were successful
Deploy API Server / build-and-deploy (push) Successful in 44s
H0-01: Reject Apple login mock fallback in production H0-02: Protect /internal/* with InternalAuthGuard (X-Internal-API-Key) H0-03: JwtAuthGuard check user status (deletedAt, status) H0-04: Refresh token check user status + revoke all on deleted H0-05: User/admin JWT isolation (type=user/admin, enforce ADMIN_JWT_ACCESS_SECRET) H0-06: Add DTOs for import/source/learning-session controllers H0-07: 22 E2E tests (h0.e2e-spec.ts), 5 iOS integration docs Tests: 47/47 (H0 22 + M0 25), no regression. Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
83 lines
3.0 KiB
TypeScript
83 lines
3.0 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) }
|
|
eval() { return Promise.resolve(1) }
|
|
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
|