build: wait for mysql server start with node

Author: dougwilson

.travis.yml

@@ -65,13 +65,14 @@ before_install:
 
   # Setup environment
   - "export MYSQL_DATABASE=node_mysql"
+  - "export MYSQL_HOST=localhost"
   - "export MYSQL_PORT=$(node tool/free-port.js)"
   - "export MYSQL_USER=root"
 
 install:
   - "docker run -d --name mysql -e MYSQL_ALLOW_EMPTY_PASSWORD=yes -e MYSQL_DATABASE=$MYSQL_DATABASE -p $MYSQL_PORT:3306 $DOCKER_MYSQL_TYPE:$DOCKER_MYSQL_VERSION"
   - "npm install"
-  - "docker run --link mysql:db -e CHECK_PORT=3306 -e CHECK_HOST=db giorgos/takis"
+  - "node tool/wait-mysql.js $MYSQL_PORT $MYSQL_HOST"
 
 before_script:
   - "docker --version"

appveyor.yml

@@ -4,6 +4,7 @@ environment:
   MYSQL_USER: root
   MYSQL_PASSWORD: Password12!
   MYSQL_PATH: C:\Program Files\MySQL\MySQL Server 5.7
+  MYSQL_PORT: 3306
 
   matrix:
     - nodejs_version: "0.8"
@@ -41,6 +42,7 @@ build: off
 
 before_test:
   - SET PATH=%MYSQL_PATH%\bin;%PATH%
+  - node tool/wait-mysql.js %MYSQL_PORT% %MYSQL_HOST%
   - mysqladmin --host=%MYSQL_HOST% --user=%MYSQL_USER% --password=%MYSQL_PASSWORD% create %MYSQL_DATABASE%
 
 test_script:

tool/wait-mysql.js

@@ -0,0 +1,49 @@
+var Net = require('net');
+
+var CHECK_INTERVAL_MS = 200;
+var CHECK_TIMEOUT     = 120000;
+var TCP_TIMEOUT       = 1000;
+
+process.nextTick(run);
+
+function check(host, port, callback) {
+  var socket = Net.createConnection(port, host);
+  var timer  = setTimeout(function () {
+    socket.destroy();
+    callback(false);
+  }, TCP_TIMEOUT);
+
+  socket.once('data', function () {
+    clearTimeout(timer);
+    socket.destroy();
+    callback(true);
+  });
+
+  socket.on('error', function () {
+    clearTimeout(timer);
+    callback(false);
+  });
+}
+
+function run() {
+  var host = process.argv[3] || 'localhost';
+  var port = Number(process.argv[2]);
+
+  function next() {
+    check(host, port, function (connected) {
+      if (connected) {
+        console.log('connected to %s:%d', host, port);
+        process.exit(0);
+      } else {
+        setTimeout(next, CHECK_INTERVAL_MS);
+      }
+    });
+  }
+
+  setTimeout(function () {
+    console.error('timeout waiting for %s:%d', host, port);
+    process.exit(1);
+  }, CHECK_TIMEOUT);
+
+  next();
+}