Expose the unique execution ID in the TTPs runner

internal/providers/aws.go

@@ -13,7 +13,7 @@ import (
 )
 
 var awsProvider = AWSProvider{
-	UniqueCorrelationId: uuid.New(),
+	UniqueCorrelationId: UniqueExecutionId,
 }
 
 func AWS() *AWSProvider {

internal/providers/kubernetes.go

@@ -26,7 +26,7 @@ type K8sProvider struct {
 }
 
 var (
-	k8sProvider               = K8sProvider{UniqueCorrelationId: uuid.New()}
+	k8sProvider               = K8sProvider{UniqueCorrelationId: UniqueExecutionId}
 	kubeConfigPath            string
 	kubeConfigPathWasResolved bool
 )

internal/providers/main.go

@@ -3,10 +3,13 @@ package providers
 import (
 	"errors"
 	"github.com/datadog/stratus-red-team/pkg/stratus"
+	"github.com/google/uuid"
 )
 
 const StratusUserAgent = "stratus-red-team"
 
+var UniqueExecutionId = uuid.New()
+
 // EnsureAuthenticated ensures that the current user is properly authenticated against a specific platform
 func EnsureAuthenticated(platform stratus.Platform) error {
 	switch platform {

pkg/stratus/runner/runner.go

@@ -2,6 +2,7 @@ package runner
 
 import (
 	"errors"
+	"github.com/datadog/stratus-red-team/internal/providers"
 	"log"
 	"path/filepath"
 	"strings"
@@ -194,6 +195,11 @@ func (m *Runner) setState(state stratus.AttackTechniqueState) {
 	m.TechniqueState = state
 }
 
+// GetUniqueExecutionId returns an unique execution ID, unique per run of Stratus Red Team (not for each TTP detonated)
+func (m *Runner) GetUniqueExecutionId() string {
+	return providers.UniqueExecutionId.String()
+}
+
 // Utility function to display better error messages than the Terraform ones
 func errorMessageFromTerraformError(err error) string {
 	const MissingRegionErrorMessage = "The argument \"region\" is required, but no definition was found"