11/*
2- * Copyright 2014-2020 MarkLogic Corporation
2+ * Copyright 2014-2021 MarkLogic Corporation
33 *
44 * Licensed under the Apache License, Version 2.0 (the "License");
55 * you may not use this file except in compliance with the License.
@@ -27,7 +27,7 @@ var marklogic = require('../');
2727var q = marklogic . queryBuilder ;
2828
2929var db = marklogic . createDatabaseClient ( testconfig . restEvaluatorConnection ) ;
30-
30+ // Run tests from test-complete-proxy folder. Else adjust paths of worker's js files.
3131 describe ( 'Multiple-Worker-Test' , function ( ) {
3232 before ( function ( done ) {
3333 // runs once before the first test in this block
@@ -44,7 +44,7 @@ var db = marklogic.createDatabaseClient(testconfig.restEvaluatorConnection);
4444 var uris2 = [ 'Test1stream21' , 'Test1stream22' ] ;
4545
4646 if ( isMainThread ) {
47- const workerOneInsert = new Worker ( './test-complete-proxy/ insertFromMultipleStreams.js' , { workerData : { files : inputFiles1 , uris :uris1 } } ) ;
47+ const workerOneInsert = new Worker ( './insertFromMultipleStreams.js' , { workerData : { files : inputFiles1 , uris :uris1 } } ) ;
4848 workerOneInsert . on ( 'done' , ( result ) => {
4949 //console.log('workerOneInsert message is ' + result );
5050 } ) ;
@@ -55,7 +55,7 @@ var db = marklogic.createDatabaseClient(testconfig.restEvaluatorConnection);
5555 //else console.debug('workerOneInsert exits normally');
5656 } ) ;
5757
58- const workerTwoInsert = new Worker ( './test-complete-proxy/ insertFromMultipleStreams.js' , { workerData : { files : inputFiles2 , uris :uris2 } } ) ;
58+ const workerTwoInsert = new Worker ( './insertFromMultipleStreams.js' , { workerData : { files : inputFiles2 , uris :uris2 } } ) ;
5959 workerTwoInsert . on ( 'message' , ( result ) => {
6060 //console.log('workerTwoInsert message is ' + result );
6161 } ) ;
@@ -100,7 +100,7 @@ var db = marklogic.createDatabaseClient(testconfig.restEvaluatorConnection);
100100 var searchResults2 = [ ] ;
101101
102102 if ( isMainThread ) {
103- const workerOneSearch = new Worker ( './test-complete-proxy/ searchMultiple.js' , { workerData : { search :'Bush' } } ) ;
103+ const workerOneSearch = new Worker ( './searchMultiple.js' , { workerData : { search :'Bush' } } ) ;
104104 workerOneSearch . on ( 'done' , ( result ) => {
105105 searchResults1 . push ( result ) ;
106106 //console.log('Results 1 from search is :', searchResults1);
@@ -127,14 +127,14 @@ var db = marklogic.createDatabaseClient(testconfig.restEvaluatorConnection);
127127 var searchResults2 = [ ] ;
128128
129129 if ( isMainThread ) {
130- const workerOneSearch = new Worker ( './test-complete-proxy/ searchMultiple.js' , { workerData : { search :'Bush' } } ) ;
130+ const workerOneSearch = new Worker ( './searchMultiple.js' , { workerData : { search :'Bush' } } ) ;
131131 workerOneSearch . on ( 'done' , ( result ) => {
132132 searchResults1 . push ( result ) ;
133133 //console.log('Results 1 from search is :', searchResults1);
134134 expect ( searchResults1 [ 0 ] ) . to . have . members ( [ "/Test1stream11.json" , "/Test1stream21.json" ] ) ;
135135 } ) ;
136136
137- const workerTwoSearch = new Worker ( './test-complete-proxy/ searchMultiple.js' , { workerData : { search :'Lisa' } } ) ;
137+ const workerTwoSearch = new Worker ( './searchMultiple.js' , { workerData : { search :'Lisa' } } ) ;
138138 workerTwoSearch . on ( 'done' , ( result ) => {
139139 searchResults2 . push ( result ) ;
140140 //console.log('Results 2 from search is :', searchResults2);
@@ -156,14 +156,14 @@ var db = marklogic.createDatabaseClient(testconfig.restEvaluatorConnection);
156156 var searchResults2 = [ ] ;
157157
158158 if ( isMainThread ) {
159- const workerOneSearch = new Worker ( './test-complete-proxy/ searchMultiple.js' , { workerData : { search :'Bush' } } ) ;
159+ const workerOneSearch = new Worker ( './searchMultiple.js' , { workerData : { search :'Bush' } } ) ;
160160 workerOneSearch . on ( 'done' , ( result ) => {
161161 searchResults1 . push ( result ) ;
162162 //console.log('Results 1 from search is :', searchResults1);
163163 expect ( searchResults1 [ 0 ] ) . to . have . members ( [ "/Test1stream11.json" , "/Test1stream21.json" ] ) ;
164164 } ) ;
165165
166- const workerTwoSearch = new Worker ( './test-complete-proxy/ searchMultiple.js' , { workerData : { search :'100' } } ) ;
166+ const workerTwoSearch = new Worker ( './searchMultiple.js' , { workerData : { search :'100' } } ) ;
167167 workerTwoSearch . on ( 'done' , ( result ) => {
168168 searchResults2 . push ( result ) ;
169169 //console.log('Results 2 from search is :', searchResults2);
@@ -185,15 +185,15 @@ var db = marklogic.createDatabaseClient(testconfig.restEvaluatorConnection);
185185 var searchResults2 = [ ] ;
186186
187187 if ( isMainThread ) {
188- const workerOneSearch = new Worker ( './test-complete-proxy/ searchMultiple.js' , { workerData : { search :'Bush' } } ) ;
188+ const workerOneSearch = new Worker ( './searchMultiple.js' , { workerData : { search :'Bush' } } ) ;
189189 workerOneSearch . on ( 'done' , ( result ) => {
190190 searchResults1 . push ( result ) ;
191191 //console.log('Results 1 from search is :', searchResults1);
192192 expect ( searchResults1 [ 0 ] ) . to . have . members ( [ "/Test1stream11.json" , "/Test1stream21.json" ] ) ;
193193 } ) ;
194194
195195 expect (
196- ( ) => new Worker ( './test-complete-proxy/ searchMultiple.js' , { workerData : { find :100 } } ) . to . throw ( 'null value not allowed for parameter' ) ) ;
196+ ( ) => new Worker ( './searchMultiple.js' , { workerData : { find :100 } } ) . to . throw ( 'null value not allowed for parameter' ) ) ;
197197 done ( ) ;
198198 }
199199 }
0 commit comments