WangDL
5fd737967f
Some checks failed
Deploy API Server / build-and-deploy (push) Failing after 23s
M1-01 AI Gateway: - DB-driven ModelRoute/ProviderConfig/FallbackEvent tables - ModelRouter rewrite with loadFromDb() hot-reload - Fallback event recording + AIUsageRecorded event publishing - Admin AAPI: routes CRUD, provider enable/disable, fallback events log M1-02 Vector & Retrieval: - VectorService with Qdrant client (upsert/delete/search/rerank) - Admin AAPI: collection status, vector count, reindex trigger M1-03 Task Queue: - 16 task types with default retry/timeout configs - Task stats dashboard, worker status panel, batch retry endpoint M0 audit fixes: - ApiMetric retention policy (30-day cleanup) - Content Safety integration in Files module - Queue registration centralized (domain-events) - SECRET_MASTER_KEY production validation E2E tests: - M0: 28 smoke tests covering all 14 M0 issues - M1: 16 tests covering M1-01/02/03 - Mock infrastructure: prisma, ioredis, jose, bullmq, qdrant Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
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
|