File size: 2,169 Bytes
bf48b89 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 | import { describe, expect, it, vi } from 'vitest';
const errorSpy = vi.fn();
const infoSpy = vi.fn();
vi.mock('@/utils/logger', () => ({
default: {
error: errorSpy,
info: infoSpy,
},
}));
class RedisMock extends EventTarget {
mget = vi.fn();
expire = vi.fn();
set = vi.fn();
on(event: string, listener: (...args: any[]) => void) {
this.addEventListener(event, (evt) => {
listener((evt as Event & { detail?: unknown }).detail);
});
return this;
}
emit(event: string, detail?: unknown) {
const evt = new Event(event) as Event & { detail?: unknown };
evt.detail = detail;
this.dispatchEvent(evt);
return true;
}
}
vi.mock('ioredis', () => ({
default: RedisMock,
}));
describe('redis cache module', () => {
it('throws on reserved cache ttl key', async () => {
const redisCache = (await import('@/utils/cache/redis')).default;
redisCache.status.available = true;
redisCache.clients.redisClient = new RedisMock() as any;
await expect(redisCache.get('rsshub:cacheTtl:bad')).rejects.toThrow('reserved for the internal usage');
});
it('expires cache ttl key when present', async () => {
const redisCache = (await import('@/utils/cache/redis')).default;
const client = new RedisMock() as any;
client.mget.mockResolvedValue(['value', '30']);
redisCache.status.available = true;
redisCache.clients.redisClient = client;
const value = await redisCache.get('mock', true);
expect(value).toBe('value');
expect(client.expire).toHaveBeenCalledWith('rsshub:cacheTtl:mock', '30');
expect(client.expire).toHaveBeenCalledWith('mock', '30');
});
it('marks redis unavailable on error', async () => {
const redisCache = (await import('@/utils/cache/redis')).default;
redisCache.init();
const client = redisCache.clients.redisClient as RedisMock;
client.emit('error', new Error('boom'));
expect(redisCache.status.available).toBe(false);
expect(errorSpy).toHaveBeenCalled();
});
});
|