diff --git a/tests/unit/services/response-queue.test.ts b/tests/unit/services/response-queue.test.ts index a64224c..7fff240 100644 --- a/tests/unit/services/response-queue.test.ts +++ b/tests/unit/services/response-queue.test.ts @@ -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(); });