Refactor AWS stepDefinitions

hpcc-systems · Jan 4, 2024 · 1a9a798 · 1a9a798
1 parent 4bad1c9
commit 1a9a798
Show file tree

Hide file tree

Showing 7 changed files with 724 additions and 725 deletions.
diff --git a/packages/aws/stepDefinitions/cloudwatch-logs.js b/packages/aws/stepDefinitions/cloudwatch-logs.js
@@ -8,39 +8,39 @@ setDefaultTimeout(15 * 60 * 1000)
 
 const cloudwatchLogsClientConfig = { maxAttempts: 3 }
 if (process.env.AWSENV && process.env.AWSENV.toUpperCase() === 'LOCALSTACK') {
-  cloudwatchLogsClientConfig.endpoint = process.env.LOCALSTACK_HOSTNAME ? `http://${process.env.LOCALSTACK_HOSTNAME}:4566` : 'http://localhost:4566'
+    cloudwatchLogsClientConfig.endpoint = process.env.LOCALSTACK_HOSTNAME ? `http://${process.env.LOCALSTACK_HOSTNAME}:4566` : 'http://localhost:4566'
 }
 const cloudwatchLogsClient = new CloudWatchLogsClient(cloudwatchLogsClientConfig)
 
 /**
  * Returns the value of the parameter from the parameter store
  */
 MAFWhen('parameter {string} value is retrieved from the parameter store', async function (parameterName) {
-  parameterName = filltemplate(parameterName, this.results)
-  const ssmClient = new SSMClient()
-  const res = await ssmClient.send(new GetParameterCommand({ Name: parameterName }))
-  return res.Parameter.Value
+    parameterName = filltemplate(parameterName, this.results)
+    const ssmClient = new SSMClient()
+    const res = await ssmClient.send(new GetParameterCommand({ Name: parameterName }))
+    return res.Parameter.Value
 })
 
 /**
  * Returns at most 10 query calls of 1 MB / 10,000 logs from cloudwatch
  */
 MAFWhen('cloudwatch logs from log group {string} from {int} minutes ago to now are retrieved', async function (logGroup, minutes) {
-  const startTime = DateTime.now().minus({ minutes }).toUTC().toMillis()
-  logGroup = filltemplate(logGroup, this.results)
-  let logs = []
-  let res = {}
-  let queries = 0
-  do {
-    const queryParameters = {
-      logGroupName: logGroup,
-      startTime
-    }
-    if (res.nextToken) {
-      queryParameters.nextToken = res.nextToken
-    }
-    res = await cloudwatchLogsClient.send(new FilterLogEventsCommand(queryParameters))
-    logs = logs.concat(res.events.map(event => event.message.replace(/\t/g, '    ')))
-  } while (res.nextToken && ++queries <= 10)
-  return logs
+    const startTime = DateTime.now().minus({ minutes }).toUTC().toMillis()
+    logGroup = filltemplate(logGroup, this.results)
+    let logs = []
+    let res = {}
+    let queries = 0
+    do {
+        const queryParameters = {
+            logGroupName: logGroup,
+            startTime
+        }
+        if (res.nextToken) {
+            queryParameters.nextToken = res.nextToken
+        }
+        res = await cloudwatchLogsClient.send(new FilterLogEventsCommand(queryParameters))
+        logs = logs.concat(res.events.map(event => event.message.replace(/\t/g, '    ')))
+    } while (res.nextToken && ++queries <= 10)
+    return logs
 })