feat(fargate): emit phaseStarted and phaseCompleted events to cloud

packages/artillery/lib/platform/aws-ecs/legacy/run-cluster.js

@@ -1906,6 +1906,14 @@ async function listen(context, ee) {
       ee.emit('stats', stats);
     });
 
+    r.on('phaseStarted', (phase) => {
+      global.artillery.globalEvents.emit('phaseStarted', phase);
+    });
+
+    r.on('phaseCompleted', (phase) => {
+      global.artillery.globalEvents.emit('phaseCompleted', phase);
+    });
+
     r.start();
   });
 }

packages/artillery/lib/platform/aws-ecs/legacy/sqs-reporter.js

@@ -29,6 +29,9 @@ class SqsReporter extends EventEmitter {
     this.metricsByPeriod = {}; // individual intermediates by worker
     this.mergedPeriodMetrics = []; // merged intermediates for a period
 
+    this.phaseStartedEventsSeen = {};
+    this.phaseCompletedEventsSeen = {};
+
     // Debug info:
     this.messagesProcessed = {};
     this.metricsMessagesFromWorkers = {};
@@ -187,6 +190,28 @@ class SqsReporter extends EventEmitter {
         return;
       }
 
+      if (body.event === 'phaseStarted') {
+        if (
+          typeof self.phaseStartedEventsSeen[body.phase.index] === 'undefined'
+        ) {
+          self.phaseStartedEventsSeen[body.phase.index] = Date.now();
+          self.emit(body.event, body.phase);
+        }
+
+        return;
+      }
+
+      if (body.event === 'phaseCompleted') {
+        if (
+          typeof self.phaseCompletedEventsSeen[body.phase.index] === 'undefined'
+        ) {
+          self.phaseCompletedEventsSeen[body.phase.index] = Date.now();
+          self.emit(body.event, body.phase);
+        }
+
+        return;
+      }
+
       // 'done' event is from SQS Plugin - unused for now
       if (body.event === 'done') {
         return;