@@ -101,6 +101,9 @@ const getExpiredCase = [
101
101
'baseConnector-getExpired()-tester-1' ,
102
102
'baseConnector-getExpired()-tester-2' ,
103
103
] ;
104
+ const getCountWithStatusCase = [
105
+ 'baseConnector-getCountWithStatusCase()-tester-0'
106
+ ] ;
104
107
const upsertCases = {
105
108
insert : 'baseConnector-upsert()-tester-row-inserted' ,
106
109
update : 'baseConnector-upsert()-tester-row-updated'
@@ -205,7 +208,7 @@ afterAll(async function () {
205
208
const upsertIds = Object . values ( upsertCases ) ;
206
209
207
210
const tableChangesIds = [ ...emptyCallbacksCase , ...documentsWithChangesCase , ...changesIds , ...insertIds ] ;
208
- const tableResultIds = [ ...emptyCallbacksCase , ...documentsWithChangesCase , ...getExpiredCase , ...upsertIds ] ;
211
+ const tableResultIds = [ ...emptyCallbacksCase , ...documentsWithChangesCase , ...getExpiredCase , ...getCountWithStatusCase , ... upsertIds ] ;
209
212
210
213
const deletionPool = [
211
214
deleteRowsByIds ( cfgTableChanges , tableChangesIds ) ,
@@ -413,6 +416,17 @@ describe('Base database connector', function () {
413
416
414
417
expect ( resultAfterNewRows . length ) . toEqual ( resultBeforeNewRows . length + getExpiredCase . length ) ;
415
418
} ) ;
419
+
420
+ test ( 'Get Count With Status' , async function ( ) {
421
+ let countWithStatus = await baseConnector . getCountWithStatus ( ctx , commonDefines . FileStatus . SaveVersion ) ;
422
+ expect ( countWithStatus ) . toEqual ( 0 ) ;
423
+ for ( const id of getCountWithStatusCase ) {
424
+ const task = createTask ( id ) ;
425
+ task . status = commonDefines . FileStatus . SaveVersion ;
426
+ await insertIntoResultTable ( date , task ) ;
427
+ }
428
+ expect ( countWithStatus ) . toEqual ( getCountWithStatusCase . length ) ;
429
+ } ) ;
416
430
} ) ;
417
431
418
432
describe ( 'upsert() method' , function ( ) {
0 commit comments