Removed bin/test in favor of starting services on a per-test level directly in node

Author: shnhrrsn

.travis.yml

@@ -5,6 +5,6 @@ node_js:
 sudo: false
 script:
   - "npm run lint"
-  - "bin/test"
+  - "npm test"
 services:
   - docker

bin/test

@@ -38,7 +38,7 @@
   "scripts": {
     "prepublish": "bin/build",
     "lint": "eslint src",
-    "test": "bin/test --verbose"
+    "test": "ava --verbose"
   },
   "ava": {
     "require": [

package.json

@@ -2,12 +2,19 @@ import { serial as test } from 'ava'
 
 import './helpers/TestJob'
 import './helpers/Listener'
+import './helpers/Service'
+
 import '../src/Drivers/BeanstalkDriver'
 
+const service = new Service(test, 'beanstalk', {
+	image: 'kusmierz/beanstalkd',
+	port: 11300
+})
+
 test.beforeEach(t => {
 	t.context.driver = new BeanstalkDriver(null, {
 		host: 'localhost',
-		port: process.env.BEANSTALK_PORT
+		port: service.port
 	})
 
 	return t.context.driver.connect()

test/BeanstalkDriver.js

@@ -2,12 +2,19 @@ import { serial as test } from 'ava'
 
 import './helpers/TestJob'
 import './helpers/Listener'
+import './helpers/Service'
+
 import '../src/Drivers/RabbitDriver'
 
+const service = new Service(test, 'rabbitmq', {
+	image: 'rabbitmq:3.7-alpine',
+	port: 5672
+})
+
 test.beforeEach(t => {
 	t.context.driver = new RabbitDriver(null, {
 		host: 'localhost',
-		port: process.env.RABBIT_PORT
+		port: service.port
 	})
 
 	return t.context.driver.connect()

test/RabbitDriver.js

@@ -0,0 +1,71 @@
+const { promisify } = require('util')
+const execFile = promisify(require('child_process').execFile)
+
+export class Service {
+
+	constructor(test, service, { image, port }) {
+		this.service = service
+		this.config = {
+			image,
+			port: {
+				host: 43210 + port,
+				container: port
+			}
+		}
+
+		test.before(() => this.start())
+		test.after.always(() => this.stop())
+	}
+
+	get port() {
+		return this.config.port.host
+	}
+
+	async start() {
+		Log.comment(`${this.service} starting`)
+		const { image, port: { host, container } } = this.config
+
+		// Clean up old containers
+		await this.exec('rm', '--force', this._container, this._containerWait).catch(() => { })
+
+		// Start the container
+		await this.exec(
+			'run',
+			`--name=${this._container}`,
+			'-d',
+			'-p', `${host}:${container}`,
+			image
+		)
+
+		// Wait for the container to become avaiable
+		Log.comment(`${this.service} waiting`)
+		await this.exec(
+			'run',
+			'--rm',
+			`--name=${this._containerWait}`,
+			`--link=grind-${this.service}:${this.service}`,
+			'dadarek/wait-for-dependencies',
+			`${this.service}:${container}`
+		)
+		Log.comment(`${this.service} started`)
+	}
+
+	async stop() {
+		Log.comment(`${this.service} stopping`)
+		await this.exec('stop', this._container).catch(() => { })
+		await this.exec('rm', this._container).catch(() => { })
+	}
+
+	get _container() {
+		return `grind-${this.service}`
+	}
+
+	get _containerWait() {
+		return `grind-wait-for-${this.service}`
+	}
+
+	exec(...args) {
+		return execFile('docker', args)
+	}
+
+}