[test] Add getCountWithStatusCase test

This commit is contained in:
Sergey Konovalov
2024-09-03 14:27:33 +03:00
parent 5a68653305
commit 5a8b10a86f

View File

@ -101,6 +101,9 @@ const getExpiredCase = [
'baseConnector-getExpired()-tester-1',
'baseConnector-getExpired()-tester-2',
];
const getCountWithStatusCase = [
'baseConnector-getCountWithStatusCase()-tester-0'
];
const upsertCases = {
insert: 'baseConnector-upsert()-tester-row-inserted',
update: 'baseConnector-upsert()-tester-row-updated'
@ -205,7 +208,7 @@ afterAll(async function () {
const upsertIds = Object.values(upsertCases);
const tableChangesIds = [...emptyCallbacksCase, ...documentsWithChangesCase, ...changesIds, ...insertIds];
const tableResultIds = [...emptyCallbacksCase, ...documentsWithChangesCase, ...getExpiredCase, ...upsertIds];
const tableResultIds = [...emptyCallbacksCase, ...documentsWithChangesCase, ...getExpiredCase, ...getCountWithStatusCase, ...upsertIds];
const deletionPool = [
deleteRowsByIds(cfgTableChanges, tableChangesIds),
@ -413,6 +416,20 @@ describe('Base database connector', function () {
expect(resultAfterNewRows.length).toEqual(resultBeforeNewRows.length + getExpiredCase.length);
});
test('Get Count With Status', async function () {
let countWithStatus;
let unknownStatus = 99;//to avoid collision with running server
countWithStatus = await baseConnector.getCountWithStatus(ctx, unknownStatus);
expect(countWithStatus).toEqual(0);
for (const id of getCountWithStatusCase) {
const task = createTask(id);
task.status = unknownStatus;
await insertIntoResultTable(date, task);
}
countWithStatus = await baseConnector.getCountWithStatus(ctx, unknownStatus);
expect(countWithStatus).toEqual(getCountWithStatusCase.length);
});
});
describe('upsert() method', function () {