fix: rm bluebird from test utils

Author: piercus

package.json

@@ -31,7 +31,6 @@
   "homepage": "https://github.com/piercus/step-function-worker#readme",
   "devDependencies": {
     "ava": "^0.25.0",
-    "bluebird": "^3.5.0",
     "semantic-release": "^15.1.7",
     "vows": "^0.8.1",
     "winston": "^2.4.1",

test/scenarios/failed-fn.js

@@ -1,14 +1,12 @@
 const test = require('ava').test;
 const AWS = require('aws-sdk');
-const PromiseBlue = require('bluebird');
 const winston = require('winston');
 
 const StepFunctionWorker = require('../../index.js');
 const createActivity = require('../utils/create-activity');
 const cleanUp = require('../utils/clean-up');
 
-const stepfunction = new AWS.StepFunctions();
-const stepFunctionPromises = PromiseBlue.promisifyAll(stepfunction);
+const stepFunction = new AWS.StepFunctions();
 
 const logger = new winston.Logger({
 	transports: [new winston.transports.Console({
@@ -83,7 +81,7 @@ test.serial('Step function Activity Worker with A failing worker', t => {
 		});
 
 		worker.on('success', reject);
-		stepFunctionPromises.startExecutionAsync(params);
+		stepFunction.startExecutionAsync(params).promise();
 	});
 });
 

test/scenarios/test.js

@@ -1,12 +1,10 @@
 const test = require('ava').test;
-const PromiseBlue = require('bluebird');
 const AWS = require('aws-sdk');
 const StepFunctionWorker = require('../../index.js');
 const createActivity = require('../utils/create-activity');
 const cleanUp = require('../utils/clean-up');
 
-const stepfunction = new AWS.StepFunctions();
-const stepFunctionPromises = PromiseBlue.promisifyAll(stepfunction);
+const stepFunction = new AWS.StepFunctions();
 const workerName = 'test worker name';
 const stateMachineName = 'test-state-machine-' + Math.floor(Math.random() * 1000);
 const activityName = 'test-step-function-worker-' + Math.floor(Math.random() * 1000);
@@ -89,10 +87,10 @@ test.serial('Step function Activity Worker with 2 consecutive tasks', t => {
 				});
 			});
 
-			stepFunctionPromises.startExecutionAsync(params);
+			stepFunction.startExecutionAsync(params).promise();
 		});
 
-		stepFunctionPromises.startExecutionAsync(params);
+		stepFunction.startExecutionAsync(params).promise();
 	});
 });
 
@@ -163,9 +161,9 @@ test.serial('Step function with 3 concurrent worker', t => {
 		worker.on('success', onSuccess);
 		worker.on('task', onTask);
 		worker.on('error', reject);
-		stepFunctionPromises.startExecutionAsync(params1);
-		stepFunctionPromises.startExecutionAsync(params2);
-		stepFunctionPromises.startExecutionAsync(params3);
+		stepFunction.startExecutionAsync(params1).promise();
+		stepFunction.startExecutionAsync(params2).promise();
+		stepFunction.startExecutionAsync(params3).promise();
 	});
 });
 

test/utils/clean-up.js

@@ -1,8 +1,6 @@
-const PromiseBlue = require('bluebird');
 const AWS = require('aws-sdk');
 
-const stepfunction = new AWS.StepFunctions();
-const stepFunctionPromises = PromiseBlue.promisifyAll(stepfunction);
+const stepFunction = new AWS.StepFunctions();
 
 module.exports = function ({
 	activityArn = null,
@@ -11,16 +9,16 @@ module.exports = function ({
 	let p1;
 	let p2;
 	if (activityArn) {
-		p1 = stepFunctionPromises.deleteActivityAsync({
+		p1 = stepFunction.deleteActivityAsync({
 			activityArn
-		});
+		}).promise();
 	} else {
 		p1 = Promise.resolve();
 	}
 	if (stateMachineArn) {
-		p2 = stepFunctionPromises.deleteStateMachineAsync({
+		p2 = stepFunction.deleteStateMachineAsync({
 			stateMachineArn
-		});
+		}).promise();
 	} else {
 		p2 = Promise.resolve();
 	}

test/utils/create-activity.js

@@ -1,8 +1,6 @@
-const PromiseBlue = require('bluebird');
 const AWS = require('aws-sdk');
 
-const stepfunction = new AWS.StepFunctions();
-const stepFunctionPromises = PromiseBlue.promisifyAll(stepfunction);
+const stepFunction = new AWS.StepFunctions();
 
 const stateMachineDefinition = function (options) {
 	return {
@@ -26,10 +24,10 @@ if (!stateMachineRoleArn) {
 }
 
 module.exports = function ({context = {}, activityName, workerName, stateMachineName}) {
-	return stepFunctionPromises
+	return stepFunction
 		.createActivityAsync({
 			name: activityName
-		}).bind(context).then(data => {
+		}).promise().bind(context).then(data => {
 			context.activityArn = data.activityArn;
 			context.workerName = workerName;
 		}).then(function () {
@@ -38,7 +36,7 @@ module.exports = function ({context = {}, activityName, workerName, stateMachine
 				name: stateMachineName, /* Required */
 				roleArn: stateMachineRoleArn /* Required */
 			};
-			return stepFunctionPromises.createStateMachineAsync(params);
+			return stepFunction.createStateMachineAsync(params).promise();
 		}).then(data => {
 			context.stateMachineArn = data.stateMachineArn;
 		}).return(context);