mirror of
https://github.com/node-red/node-red.git
synced 2025-03-01 10:36:34 +00:00
Ensure all httpRequest test servers are ready before tests run
This commit is contained in:
parent
d7dcceef60
commit
02f7cdd5aa
@ -60,6 +60,7 @@ describe('HTTP Request Node', function() {
|
|||||||
function startServer(done) {
|
function startServer(done) {
|
||||||
testPort += 1;
|
testPort += 1;
|
||||||
testServer = stoppable(http.createServer(testApp));
|
testServer = stoppable(http.createServer(testApp));
|
||||||
|
const promises = []
|
||||||
testServer.listen(testPort,function(err) {
|
testServer.listen(testPort,function(err) {
|
||||||
testSslPort += 1;
|
testSslPort += 1;
|
||||||
console.log("ssl port", testSslPort);
|
console.log("ssl port", testSslPort);
|
||||||
@ -82,13 +83,16 @@ describe('HTTP Request Node', function() {
|
|||||||
};
|
};
|
||||||
testSslServer = stoppable(https.createServer(sslOptions,testApp));
|
testSslServer = stoppable(https.createServer(sslOptions,testApp));
|
||||||
console.log('> start testSslServer')
|
console.log('> start testSslServer')
|
||||||
testSslServer.listen(testSslPort, function(err){
|
promises.push(new Promise((resolve, reject) => {
|
||||||
if (err) {
|
testSslServer.listen(testSslPort, function(err){
|
||||||
console.log(err);
|
console.log(' done testSslServer')
|
||||||
} else {
|
if (err) {
|
||||||
console.log("started testSslServer");
|
reject(err)
|
||||||
}
|
} else {
|
||||||
});
|
resolve()
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}))
|
||||||
|
|
||||||
testSslClientPort += 1;
|
testSslClientPort += 1;
|
||||||
var sslClientOptions = {
|
var sslClientOptions = {
|
||||||
@ -98,11 +102,17 @@ describe('HTTP Request Node', function() {
|
|||||||
requestCert: true
|
requestCert: true
|
||||||
};
|
};
|
||||||
testSslClientServer = stoppable(https.createServer(sslClientOptions, testApp));
|
testSslClientServer = stoppable(https.createServer(sslClientOptions, testApp));
|
||||||
console.log('> start testSslClientServer.listen')
|
console.log('> start testSslClientServer')
|
||||||
testSslClientServer.listen(testSslClientPort, function(err){
|
promises.push(new Promise((resolve, reject) => {
|
||||||
console.log("ssl-client", err)
|
testSslClientServer.listen(testSslClientPort, function(err){
|
||||||
});
|
console.log(' done testSslClientServer')
|
||||||
|
if (err) {
|
||||||
|
reject(err)
|
||||||
|
} else {
|
||||||
|
resolve()
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}))
|
||||||
testProxyPort += 1;
|
testProxyPort += 1;
|
||||||
testProxyServer = stoppable(httpProxy(http.createServer()))
|
testProxyServer = stoppable(httpProxy(http.createServer()))
|
||||||
|
|
||||||
@ -112,9 +122,16 @@ describe('HTTP Request Node', function() {
|
|||||||
}
|
}
|
||||||
})
|
})
|
||||||
console.log('> testProxyServer')
|
console.log('> testProxyServer')
|
||||||
testProxyServer.listen(testProxyPort, function(err) {
|
promises.push(new Promise((resolve, reject) => {
|
||||||
console.log('testProxyServer start', err)
|
testProxyServer.listen(testProxyPort, function(err) {
|
||||||
})
|
console.log(' done testProxyServer')
|
||||||
|
if (err) {
|
||||||
|
reject(err)
|
||||||
|
} else {
|
||||||
|
resolve()
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}))
|
||||||
|
|
||||||
testProxyAuthPort += 1
|
testProxyAuthPort += 1
|
||||||
testProxyServerAuth = stoppable(httpProxy(http.createServer()))
|
testProxyServerAuth = stoppable(httpProxy(http.createServer()))
|
||||||
@ -137,11 +154,18 @@ describe('HTTP Request Node', function() {
|
|||||||
}
|
}
|
||||||
})
|
})
|
||||||
console.log('> testProxyServerAuth')
|
console.log('> testProxyServerAuth')
|
||||||
testProxyServerAuth.listen(testProxyAuthPort, function(err) {
|
promises.push(new Promise((resolve, reject) => {
|
||||||
console.log('testProxyServerAuth start', err)
|
testProxyServerAuth.listen(testProxyAuthPort, function(err) {
|
||||||
})
|
console.log(' done testProxyServerAuth')
|
||||||
|
if (err) {
|
||||||
|
reject(err)
|
||||||
|
} else {
|
||||||
|
resolve()
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}))
|
||||||
|
|
||||||
done(err);
|
Promise.all(promises).then(() => { done() }).catch(done)
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user