feat(aws): Add ssm parameter service and update redshift

Author: m-pizarro

package.json

@@ -32,6 +32,7 @@
   },
   "dependencies": {
     "@aws-sdk/client-elastic-beanstalk": "^3.338.0",
+    "@aws-sdk/client-ssm": "^3.341.0",
     "@aws-sdk/credential-providers": "^3.256.0",
     "@aws-sdk/shared-ini-file-loader": "^3.254.0",
     "@cloudgraph/sdk": "^0.22.1",

src/enums/schemasMap.ts

@@ -104,6 +104,7 @@ export default {
   [services.sns]: 'awsSns',
   [services.systemsManagerInstance]: 'awsSystemsManagerInstance',
   [services.systemsManagerDocument]: 'awsSystemsManagerDocument',
+  [services.systemsManagerParameter]: 'awsSystemsManagerParameter',
   [services.transitGateway]: 'awsTransitGateway',
   [services.transitGatewayAttachment]: 'awsTransitGatewayAttachment',
   [services.transitGatewayRouteTable]: 'awsTransitGatewayRouteTable',

src/enums/serviceAliases.ts

@@ -74,6 +74,7 @@ export default {
   [services.subnet]: 'subnets',
   [services.systemsManagerDocument]: 'systemsManagerDocuments',
   [services.systemsManagerInstance]: 'systemsManagerInstances',
+  [services.systemsManagerParameter]: 'systemsManagerParameters',
   [services.transitGateway]: 'transitGateways',
   [services.transitGatewayAttachment]: 'transitGatewayAttachments',
   [services.transitGatewayRouteTable]: 'transitGatewayRouteTables',

src/enums/serviceMap.ts

@@ -98,6 +98,7 @@ import DmsReplicationInstance from '../services/dmsReplicationInstance'
 import SageMakerNotebookInstance from '../services/sageMakerNotebookInstance'
 import SystemsManagerInstance from '../services/systemsManagerInstance'
 import SystemsManagerDocument from '../services/systemsManagerDocument'
+import SystemsManagerParameter from '../services/systemsManagerParameter'
 import RdsClusterSnapshot from '../services/rdsClusterSnapshot'
 import VpcEndpoint from '../services/vpcEndpoint'
 import APIGatewayDomainName from '../services/apiGatewayDomainName'
@@ -218,5 +219,6 @@ export default {
   [services.wafV2WebAcl]: WafV2WebAcl,
   [services.systemsManagerInstance]: SystemsManagerInstance,
   [services.systemsManagerDocument]: SystemsManagerDocument,
+  [services.systemsManagerParameter]: SystemsManagerParameter,
   tag: AwsTag,
 }

src/enums/services.ts

@@ -95,6 +95,7 @@ export default {
   subnet: 'subnet',
   systemsManagerInstance: 'systemsManagerInstance',
   systemsManagerDocument: 'systemsManagerDocument',
+  systemsManagerParameter: 'systemsManagerParameter',
   transitGateway: 'transitGateway',
   transitGatewayAttachment: 'transitGatewayAttachment',
   transitGatewayRouteTable: 'transitGatewayRouteTable',

src/services/redshift/format.ts

@@ -45,6 +45,7 @@ export default ({
     id: arn,
     accountId: account,
     arn,
+    name: id,
     region,
     allowVersionUpgrade,
     automatedSnapshotRetentionPeriod,

src/services/redshift/schema.graphql

@@ -1,4 +1,5 @@
 type awsRedshiftCluster implements awsBaseService @key(fields: "arn") {
+  name: String @search(by: [hash, regexp])
   allowVersionUpgrade: Boolean @search
   automatedSnapshotRetentionPeriod: Int @search
   availabilityZone: String @search(by: [hash, regexp])

src/services/systemsManagerParameter/data.ts

@@ -0,0 +1,89 @@
+import {
+  DescribeParametersCommand,
+  DescribeParametersCommandInput,
+  ParameterMetadata,
+  SSMClient,
+} from '@aws-sdk/client-ssm'
+import CloudGraph from '@cloudgraph/sdk'
+import { Config } from 'aws-sdk'
+import isEmpty from 'lodash/isEmpty'
+import awsLoggerText from '../../properties/logger'
+import AwsErrorLog from '../../utils/errorLog'
+
+const lt = { ...awsLoggerText }
+const { logger } = CloudGraph
+const serviceName = 'SystemsManagerParameter'
+const errorLog = new AwsErrorLog(serviceName)
+const MAX_ITEMS = 50
+
+const listParameters = async (ssm: SSMClient): Promise<ParameterMetadata[]> =>
+  new Promise(async resolve => {
+    const parameters: ParameterMetadata[] = []
+
+    const input: DescribeParametersCommandInput = {
+      MaxResults: MAX_ITEMS,
+    }
+
+    const listAllParameters = (token?: string): void => {
+      if (token) {
+        input.NextToken = token
+      }
+      const command = new DescribeParametersCommand(input)
+      ssm
+        .send(command)
+        .then(data => {
+          if (isEmpty(data)) {
+            return resolve([])
+          }
+
+          const { Parameters = [], NextToken: nextToken } = data || {}
+
+          parameters.push(...Parameters)
+
+          if (nextToken) {
+            logger.debug(lt.foundAnotherThousand)
+            listAllParameters(nextToken)
+          } else {
+            resolve(parameters)
+          }
+        })
+        .catch(err => {
+          errorLog.generateAwsErrorLog({
+            functionName: 'ssm:describeParameters',
+            err,
+          })
+          resolve([])
+        })
+    }
+    listAllParameters()
+  })
+
+export default async ({
+  regions,
+  config,
+}: {
+  regions: string
+  config: Config
+}): Promise<{ [property: string]: ParameterMetadata[] }> =>
+  new Promise(async resolve => {
+    const { credentials } = config
+    const output: { [property: string]: ParameterMetadata[] } = {}
+
+    await Promise.all(
+      regions.split(',').map(region => {
+        const ssm = new SSMClient({
+          credentials,
+          region,
+        })
+        output[region] = []
+        return new Promise<void>(async resolveRegion => {
+          const params = (await listParameters(ssm)) || []
+          output[region] = params
+          resolveRegion()
+        })
+      })
+    )
+    errorLog.reset()
+
+    resolve(output)
+  })

src/services/systemsManagerParameter/format.ts

@@ -0,0 +1,28 @@
+import { ParameterMetadata } from '@aws-sdk/client-ssm'
+import { AwsSystemsManagerParameter } from '../../types/generated'
+import { ssmParameterArn } from '../../utils/generateArns'
+
+/**
+ * Systems Manager Parameter
+ */
+export default ({
+  account,
+  region,
+  service: parameter,
+}: {
+  account: string
+  region: string
+  service: ParameterMetadata
+}): AwsSystemsManagerParameter => {
+  const { Name: name } = parameter
+
+  const arn = ssmParameterArn({ region, account, name })
+
+  return {
+    accountId: account,
+    arn,
+    id: arn,
+    name,
+    region,
+  }
+}

src/services/systemsManagerParameter/index.ts

@@ -0,0 +1,13 @@
+import { Service } from '@cloudgraph/sdk'
+import BaseService from '../base'
+import format from './format'
+import getData from './data'
+import mutation from './mutation'
+
+export default class SystemsManagerParameter extends BaseService implements Service {
+  format = format.bind(this)
+
+  getData = getData.bind(this)
+
+  mutation = mutation
+}