From dd7e6e57167f2e2dd61d5e9560d2659ccff6f408 Mon Sep 17 00:00:00 2001 From: Joan Sanchez Date: Tue, 16 Jun 2020 12:27:17 +0200 Subject: [PATCH 1/2] 2300 - WaitForHealthy --- db/docker.js | 42 ++++++++++++++++++++++++++++++++++++++++-- 1 file changed, 40 insertions(+), 2 deletions(-) diff --git a/db/docker.js b/db/docker.js index 849cf182c..e3f105971 100644 --- a/db/docker.js +++ b/db/docker.js @@ -39,7 +39,8 @@ module.exports = class Docker { let runChown = process.platform != 'linux'; - let container = await this.execP(`docker run --env RUN_CHOWN=${runChown} -d ${dockerArgs} salix-db`); + const healthCheck = `--health-cmd='mysqladmin ping --silent'`; + const container = await this.execP(`docker run ${healthCheck} --env RUN_CHOWN=${runChown} -d ${dockerArgs} salix-db`); this.id = container.stdout; try { @@ -53,7 +54,7 @@ module.exports = class Docker { this.dbConf.port = netSettings.Ports['3306/tcp'][0]['HostPort']; } - if (runChown) await this.wait(); + await this.waitForHealthy(); } catch (err) { if (this.isRandom) await this.rm(); @@ -88,6 +89,43 @@ module.exports = class Docker { } } + waitForHealthy() { + return new Promise((resolve, reject) => { + let interval = 100; + let elapsedTime = 0; + let maxInterval = 4 * 60 * 1000; + + log('Waiting for MySQL init process...'); + + async function checker() { + elapsedTime += interval; + let status; + + try { + let result = await this.execP(`docker inspect -f "{{.State.Health.Status}}" ${this.id}`); + status = result.stdout.trimEnd(); + } catch (err) { + return reject(new Error(err.message)); + } + + if (status == 'unhealthy') + return reject(new Error('Docker exited, please see the docker logs for more info')); + + if (status == 'healthy') { + log('MySQL process ready.'); + return resolve(); + } + + if (elapsedTime >= maxInterval) + reject(new Error(`MySQL not initialized whithin ${elapsedTime / 1000} secs`)); + else + setTimeout(bindedChecker, interval); + } + let bindedChecker = checker.bind(this); + bindedChecker(); + }); + } + wait() { return new Promise((resolve, reject) => { const mysql = require('mysql2'); From 9970bb2c38f9384cea56f99cf5252ea3201b9234 Mon Sep 17 00:00:00 2001 From: Joan Sanchez Date: Tue, 16 Jun 2020 13:20:18 +0200 Subject: [PATCH 2/2] Debug logs --- gulpfile.js | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/gulpfile.js b/gulpfile.js index 678fda527..6cf75e3fc 100644 --- a/gulpfile.js +++ b/gulpfile.js @@ -83,6 +83,8 @@ async function backTestOnce(done) { port: container.dbConf.port }); + log('[Debug] dataSources', dataSources.vn); + let bootOptions = {dataSources}; let app = require(`./loopback/server/server`); @@ -90,6 +92,8 @@ async function backTestOnce(done) { try { app.boot(bootOptions); + log('[Debug] back started'); + await new Promise((resolve, reject) => { const jasmine = require('gulp-jasmine');