|
|
|
|
@ -19,8 +19,7 @@ describe('ResponseQueue (persistent add)', () => {
|
|
|
|
|
|
|
|
|
|
afterAll(() => {
|
|
|
|
|
process.env = envBackup;
|
|
|
|
|
(ResponseQueue as any).dbInstance = originalDbInstance;
|
|
|
|
|
testDb.close();
|
|
|
|
|
// No cerramos ni restablecemos la DB aquí; se hará al final del bloque de reintentos.
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
beforeEach(() => {
|
|
|
|
|
@ -108,15 +107,9 @@ describe('ResponseQueue (persistent add)', () => {
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
describe('ResponseQueue (retries/backoff)', () => {
|
|
|
|
|
beforeAll(() => {
|
|
|
|
|
// Re-crear DB en memoria y reinyectar para este bloque
|
|
|
|
|
testDb = new Database(':memory:');
|
|
|
|
|
initializeDatabase(testDb);
|
|
|
|
|
originalDbInstance = (ResponseQueue as any).dbInstance;
|
|
|
|
|
(ResponseQueue as any).dbInstance = testDb;
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
// Reutiliza la misma DB inyectada en el bloque anterior
|
|
|
|
|
afterAll(() => {
|
|
|
|
|
// Restaurar DB original y cerrar la de prueba al finalizar todos los tests de reintentos
|
|
|
|
|
(ResponseQueue as any).dbInstance = originalDbInstance;
|
|
|
|
|
testDb.close();
|
|
|
|
|
});
|
|
|
|
|
|