fix: remaining Async function in tests are replaced by pure promise() from aws sdk

Author: piercus

test/scenarios/failed-fn.js

@@ -81,7 +81,7 @@ test.serial('Step function Activity Worker with A failing worker', t => {
 		});
 
 		worker.on('success', reject);
-		stepFunction.startExecutionAsync(params).promise();
+		stepFunction.startExecution(params).promise();
 	});
 });
 

test/scenarios/test.js

@@ -87,10 +87,10 @@ test.serial('Step function Activity Worker with 2 consecutive tasks', t => {
 				});
 			});
 
-			stepFunction.startExecutionAsync(params).promise();
+			stepFunction.startExecution(params).promise();
 		});
 
-		stepFunction.startExecutionAsync(params).promise();
+		stepFunction.startExecution(params).promise();
 	});
 });
 
@@ -161,9 +161,9 @@ test.serial('Step function with 3 concurrent worker', t => {
 		worker.on('success', onSuccess);
 		worker.on('task', onTask);
 		worker.on('error', reject);
-		stepFunction.startExecutionAsync(params1).promise();
-		stepFunction.startExecutionAsync(params2).promise();
-		stepFunction.startExecutionAsync(params3).promise();
+		stepFunction.startExecution(params1).promise();
+		stepFunction.startExecution(params2).promise();
+		stepFunction.startExecution(params3).promise();
 	});
 });
 

test/utils/clean-up.js

@@ -9,14 +9,14 @@ module.exports = function ({
 	let p1;
 	let p2;
 	if (activityArn) {
-		p1 = stepFunction.deleteActivityAsync({
+		p1 = stepFunction.deleteActivity({
 			activityArn
 		}).promise();
 	} else {
 		p1 = Promise.resolve();
 	}
 	if (stateMachineArn) {
-		p2 = stepFunction.deleteStateMachineAsync({
+		p2 = stepFunction.deleteStateMachine({
 			stateMachineArn
 		}).promise();
 	} else {

test/utils/create-activity.js

@@ -25,19 +25,21 @@ if (!stateMachineRoleArn) {
 
 module.exports = function ({context = {}, activityName, workerName, stateMachineName}) {
 	return stepFunction
-		.createActivityAsync({
+		.createActivity({
 			name: activityName
-		}).promise().bind(context).then(data => {
+		}).promise().then(data => {
 			context.activityArn = data.activityArn;
 			context.workerName = workerName;
 		}).then(function () {
 			const params = {
-				definition: JSON.stringify(stateMachineDefinition({activityArn: this.activityArn})), /* Required */
+				definition: JSON.stringify(stateMachineDefinition({activityArn: context.activityArn})), /* Required */
 				name: stateMachineName, /* Required */
 				roleArn: stateMachineRoleArn /* Required */
 			};
-			return stepFunction.createStateMachineAsync(params).promise();
+			return stepFunction.createStateMachine(params).promise();
 		}).then(data => {
 			context.stateMachineArn = data.stateMachineArn;
-		}).return(context);
+		}).then(() => {
+			return context
+		});
 };