@@ -21,7 +21,7 @@ const query = q.where(ctsQb.cts.directoryQuery('/test/dataMovement/requests/tran
2121describe ( 'data movement transformAll - nodejs-dmsdk-queryToTransformAll' , function ( ) {
2222
2323 before ( async function ( ) {
24- await restAdminDB . config . transforms . write ( transformName , 'javascript' ,
24+ await restAdminDB . config . transforms . write ( transformName , 'javascript' ,
2525 fs . createReadStream ( transformPath ) ) . result ( ) ;
2626 for ( let i = 0 ; i < 100 ; i ++ ) {
2727 uris . push ( '/test/dataMovement/requests/transformAll/' + i + '.json' ) ;
@@ -164,7 +164,7 @@ describe('data movement transformAll - nodejs-dmsdk-queryToTransformAll', functi
164164 }
165165 } ) ;
166166 } ) ;
167-
167+
168168 summary . docsTransformedSuccessfully . should . be . equal ( 100 ) ;
169169 summary . docsFailedToBeTransformed . should . be . equal ( 0 ) ;
170170 summary . timeElapsed . should . be . greaterThanOrEqual ( 0 ) ;
@@ -195,12 +195,12 @@ describe('data movement transformAll - nodejs-dmsdk-queryToTransformAll', functi
195195 summary . docsTransformedSuccessfully . should . be . equal ( 100 ) ;
196196 summary . docsFailedToBeTransformed . should . be . equal ( 0 ) ;
197197 summary . timeElapsed . should . be . greaterThanOrEqual ( 0 ) ;
198-
198+
199199 await verifyDocs ( 'transformedValue' ) ;
200200 } ) ;
201201
202202 it ( 'should queryToTransformAll documents with onCompletion option' , async function ( ) {
203- const summary = await new Promise ( ( resolve , reject ) => {
203+ const summary = await new Promise ( ( resolve , reject ) => {
204204 dbWriter . documents . queryToTransformAll ( query , {
205205 transform : [ transformName , { newValue : 'transformedValue' } ] ,
206206 onCompletion : ( ( summary ) => {
@@ -220,7 +220,7 @@ describe('data movement transformAll - nodejs-dmsdk-queryToTransformAll', functi
220220 } ) ;
221221
222222 it ( 'should work with batchSize less than 1' , async function ( ) {
223- const summary = await new Promise ( ( resolve , reject ) => {
223+ const summary = await new Promise ( ( resolve , reject ) => {
224224 dbWriter . documents . queryToTransformAll ( query , {
225225 transform : [ transformName , { newValue : 'transformedValue' } ] ,
226226 batchSize : 0 ,
@@ -296,8 +296,10 @@ describe('data movement transformAll - nodejs-dmsdk-queryToTransformAll', functi
296296
297297async function verifyDocs ( value ) {
298298 const documents = await dbWriter . documents . read ( uris ) . result ( ) ;
299+ should . exist ( documents ) ;
300+ documents . should . be . an . Array ( ) ;
299301 documents . length . should . equal ( 100 ) ;
300302 for ( let i = 0 ; i < documents . length ; i ++ ) {
301303 documents [ i ] . content . key . should . equal ( value ) ;
302304 }
303- }
305+ }
0 commit comments