feat: Handle TODOs for dynamoDB

Author: m-pizarro

src/services/cloudFormationStack/connections.ts

@@ -1,12 +1,10 @@
 import { ServiceConnection } from '@cloudgraph/sdk'
 import { Stack } from 'aws-sdk/clients/cloudformation'
 import isEmpty from 'lodash/isEmpty'
-import resources from '../../enums/resources'
 import services from '../../enums/services'
 import { RawAwsCloudFormationStack } from './data'
 import { RawAwsIamRole } from '../iamRole/data'
 import { TagMap } from '../../types'
-import { getIamId } from '../../utils/ids'
 import { globalRegionName } from '../../enums/regions'
 
 /**
@@ -84,14 +82,10 @@ export default ({
     )
     if (!isEmpty(dataAtRegion)) {
       for (const instance of dataAtRegion) {
-        const { RoleId: roleId, RoleName: roleName } = instance
+        const { Arn: arn }: RawAwsIamRole = instance
 
         connections.push({
-          id: getIamId({
-            resourceId: roleId,
-            resourceName: roleName,
-            resourceType: resources.iamRole,
-          }),
+          id: arn,
           resourceType: services.iamRole,
           relation: 'child',
           field: 'iamRole',

src/services/cloudFormationStack/format.ts

@@ -124,7 +124,7 @@ export default ({
     timeoutInMinutes,
     capabilities,
     outputs: outputsList,
-    roleArn: roleArn || '', // TODO: create connection to IAM role if possible
+    roleArn: roleArn || '',
     tags: formatTagsFromMap(tags),
     enableTerminationProtection: enableTerminationProtection ? t.yes : t.no,
     parentId: parentId || '',

src/services/cognitoUserPool/connections.ts

@@ -1,7 +1,47 @@
-import { UserPoolType } from 'aws-sdk/clients/cognitoidentityserviceprovider';
+import { UserPoolType, LambdaConfigType } from 'aws-sdk/clients/cognitoidentityserviceprovider'
 
-import { ServiceConnection } from '@cloudgraph/sdk';
-import services from '../../enums/services';
+import { ServiceConnection } from '@cloudgraph/sdk'
+import { isEmpty } from 'lodash'
+import services from '../../enums/services'
+import { sesArn } from '../../utils/generateArns'
+import { RawAwsLambdaFunction } from '../lambda/data'
+import { RawAwsSes } from '../ses/data'
+import { RawAwsIamRole } from '../iamRole/data'
+import { AwsKms } from '../kms/data'
+
+const getLambdasArn = (
+  lambdaConfig?: LambdaConfigType
+): string[] => {
+  if (isEmpty(lambdaConfig)) {
+    return []
+  }
+
+  const {
+    PreSignUp,
+    CustomMessage,
+    PostConfirmation,
+    PreAuthentication,
+    PostAuthentication,
+    DefineAuthChallenge,
+    CreateAuthChallenge,
+    VerifyAuthChallengeResponse,
+    PreTokenGeneration,
+    UserMigration,
+  } = lambdaConfig
+
+  return [
+    PreSignUp,
+    CustomMessage,
+    PostConfirmation,
+    PreAuthentication,
+    PostAuthentication,
+    DefineAuthChallenge,
+    CreateAuthChallenge,
+    VerifyAuthChallengeResponse,
+    PreTokenGeneration,
+    UserMigration,
+  ]?.filter(l => l)
+}
 
 /**
  * Cognito User Pool
@@ -11,7 +51,9 @@ export default ({
   service: userPool,
   data,
   region,
+  account,
 }: {
+  account: string
   data: { name: string; data: { [property: string]: any[] } }[]
   service: UserPoolType & {
     region: string
@@ -23,38 +65,104 @@ export default ({
   const {
     Id: id,
     LambdaConfig: lambdaConfig,
+    EmailConfiguration: emailConfiguration,
+    SmsConfiguration: smsConfiguration,
   } = userPool
 
-  const defineAuthChallengeArn = lambdaConfig?.DefineAuthChallenge
-
   /**
    * Find Lambda Functions
-   * related to this Auto Scaling Group
+   * related to this cognito user pool
    */
+  const lambdasArn: string[] = getLambdasArn(lambdaConfig)
   const lambdas = data.find(({ name }) => name === services.lambda)
 
-  if (defineAuthChallengeArn && lambdas?.data?.[region]) {
-    const lambdaInRegion = lambdas.data[region].find(lambda =>
-      defineAuthChallengeArn === lambda.FunctionArn)
-      
-    if (lambdaInRegion) {
-      const lambdaFunctionArn = lambdaInRegion.FunctionArn
+  if (lambdasArn?.length > 0 && lambdas?.data?.[region]) {
+    const lambdasInRegion: RawAwsLambdaFunction[] = lambdas.data[region].filter(
+      ({ FunctionArn }: RawAwsLambdaFunction) =>
+        lambdasArn.includes(FunctionArn)
+    )
 
+    if (!isEmpty(lambdasInRegion)) {
+      for (const lambda of lambdasInRegion) {
+        connections.push({
+          id: lambda.FunctionArn,
+          resourceType: services.lambda,
+          relation: 'child',
+          field: 'lambdas',
+        })
+      }
+    }
+  }
+
+  /**
+   * Find MKS
+   * related to this cognito user pool
+   */
+  const kmsKeyID = lambdaConfig?.KMSKeyID
+  const kms = data.find(({ name }) => name === services.kms)
+
+  if (kmsKeyID && kms?.data?.[region]) {
+    const kmsInRegion: AwsKms = kms.data[region].find(
+      ({ KeyId }: AwsKms) => kmsKeyID === KeyId
+    )
+
+    if (kmsInRegion) {
       connections.push({
-        id: lambdaFunctionArn,
-        resourceType: services.lambda,
+        id: kmsInRegion.KeyId,
+        resourceType: services.kms,
         relation: 'child',
-        field: 'lambda',
+        field: 'kms',
       })
     }
   }
 
-  // TODO Email Sender
+  /**
+   * Find SES sender
+   * related to this cognito user pool
+   */
+  const emailConfigSourceArn = emailConfiguration?.SourceArn
+  const emails = data.find(({ name }) => name === services.ses)
 
-  // TODO SMS Sender
+  if (emailConfigSourceArn && emails?.data?.[region]) {
+    const emailInRegion: RawAwsSes = emails.data[region].find(
+      ({ Identity }: RawAwsSes) =>
+        emailConfigSourceArn === sesArn({ region, account, email: Identity })
+    )
+
+    if (emailInRegion) {
+      connections.push({
+        id: sesArn({ region, account, email: emailInRegion.Identity }),
+        resourceType: services.ses,
+        relation: 'child',
+        field: 'ses',
+      })
+    }
+  }
+
+  /**
+   * Find SNS caller
+   * related to this cognito user pool
+   */
+  const smsConfigSnsCallerArn = smsConfiguration?.SnsCallerArn
+  const iamRoles = data.find(({ name }) => name === services.iamRole)
+
+  if (smsConfigSnsCallerArn && iamRoles?.data?.[region]) {
+    const iamRoleInRegion: RawAwsIamRole = iamRoles.data[region].find(
+      ({ Arn }: RawAwsIamRole) => smsConfigSnsCallerArn === Arn
+    )
+
+    if (iamRoleInRegion) {
+      connections.push({
+        id: iamRoleInRegion.Arn,
+        resourceType: services.iamRole,
+        relation: 'child',
+        field: 'iamRole',
+      })
+    }
+  }
 
   const userPoolResult = {
     [id]: connections,
   }
   return userPoolResult
-}
+}

src/services/cognitoUserPool/schema.graphql

@@ -115,9 +115,9 @@ type awsCognitoUserPool @key(fields: "id") {
   usernameConfigurationCaseSensitive: String @search(by: [hash, regexp])
   accountRecoverySettings: [awsAccountRecoverySetting]
   tags: [awsRawTag]
-  lambda: [awsLambda] @hasInverse(field: cognitoUserPool) #change to plural
+  lambdas: [awsLambda] @hasInverse(field: cognitoUserPools)
   appSync: [awsAppSync] @hasInverse(field: cognitoUserPool)
-}
-
-# TODO: add connetion to kms
-# TODO: add connection to iamRole using SmsConfiguration.SnsCallerArn
+  kms: [awsKms] @hasInverse(field: cognitoUserPools)
+  ses: [awsSes] @hasInverse(field: cognitoUserPools)
+  iamRole: [awsIamRole] @hasInverse(field: cognitoUserPools)
+}

src/services/iamRole/schema.graphql

@@ -23,4 +23,5 @@ type awsIamRole @key(fields: "id") {
   sageMakerNotebookInstances: [awsSageMakerNotebookInstance] @hasInverse(field: iamRole)
   systemsManagerInstances: [awsSystemsManagerInstance] @hasInverse(field: iamRole)
   iamInstanceProfiles: [awsIamInstanceProfile] @hasInverse(field: iamRole)
+  cognitoUserPools: [awsCognitoUserPool] @hasInverse(field: iamRole)
 }

src/services/kms/schema.graphql

@@ -30,4 +30,5 @@ type awsKms @key(fields: "id"){
   dmsReplicationInstances: [awsDmsReplicationInstance] @hasInverse(field: kms)
   sageMakerNotebookInstances: [awsSageMakerNotebookInstance] @hasInverse(field: kms)
   rdsClusterSnapshots: [awsRdsClusterSnapshot] @hasInverse(field: kms)
+  cognitoUserPools: [awsCognitoUserPool] @hasInverse(field: kms)
 }

src/services/lambda/schema.graphql

@@ -24,7 +24,7 @@ type awsLambda @key(fields: "arn") {
   securityGroups: [awsSecurityGroup] @hasInverse(field: lambda)
   subnet: [awsSubnet] @hasInverse(field: lambda) #change to plural
   vpc: [awsVpc] @hasInverse(field: lambda)
-  cognitoUserPool: [awsCognitoUserPool] @hasInverse(field: lambda) #change to plural
+  cognitoUserPools: [awsCognitoUserPool] @hasInverse(field: lambdas)
   appSync: [awsAppSync] @hasInverse(field: lambda)
 }
 

src/services/ses/schema.graphql

@@ -5,4 +5,5 @@ type awsSes @key(fields: "arn") {
   region: String @search(by: [hash, regexp])
   email: String @search(by: [hash, regexp])
   verificationStatus: String @search(by: [hash, regexp])
+  cognitoUserPools: [awsCognitoUserPool] @hasInverse(field: ses)
 }

src/types/generated.ts

@@ -1206,15 +1206,18 @@ export type AwsCognitoUserPool = {
   emailVerificationMessage?: Maybe<Scalars['String']>;
   emailVerificationSubject?: Maybe<Scalars['String']>;
   estimatedNumberOfUsers?: Maybe<Scalars['Int']>;
+  iamRole?: Maybe<Array<Maybe<AwsIamRole>>>;
   id: Scalars['String'];
-  lambda?: Maybe<Array<Maybe<AwsLambda>>>;
+  kms?: Maybe<Array<Maybe<AwsKms>>>;
   lambdaConfig?: Maybe<AwsCognitoUserPoolLambdaConfig>;
+  lambdas?: Maybe<Array<Maybe<AwsLambda>>>;
   lastModifiedDate?: Maybe<Scalars['String']>;
   mfaConfiguration?: Maybe<Scalars['String']>;
   name?: Maybe<Scalars['String']>;
   policies?: Maybe<AwsCognitoUserPoolPasswordPolicy>;
   region?: Maybe<Scalars['String']>;
   schemaAttributes?: Maybe<Array<Maybe<AwsCognitoUserPoolSchemaAttribute>>>;
+  ses?: Maybe<Array<Maybe<AwsSes>>>;
   smsAuthenticationMessage?: Maybe<Scalars['String']>;
   smsConfigurationExternalId?: Maybe<Scalars['String']>;
   smsConfigurationFailure?: Maybe<Scalars['String']>;
@@ -3187,6 +3190,7 @@ export type AwsIamRole = {
   assumeRolePolicy?: Maybe<AwsIamJsonPolicy>;
   cloudFormationStack?: Maybe<Array<Maybe<AwsCloudFormationStack>>>;
   codebuilds?: Maybe<Array<Maybe<AwsCodebuild>>>;
+  cognitoUserPools?: Maybe<Array<Maybe<AwsCognitoUserPool>>>;
   configurationRecorder?: Maybe<Array<Maybe<AwsConfigurationRecorder>>>;
   createdAt?: Maybe<Scalars['String']>;
   description?: Maybe<Scalars['String']>;
@@ -3338,6 +3342,7 @@ export type AwsKms = {
   cloudtrail?: Maybe<Array<Maybe<AwsCloudtrail>>>;
   cloudwatchLog?: Maybe<Array<Maybe<AwsCloudwatchLog>>>;
   codebuilds?: Maybe<Array<Maybe<AwsCodebuild>>>;
+  cognitoUserPools?: Maybe<Array<Maybe<AwsCognitoUserPool>>>;
   creationDate?: Maybe<Scalars['String']>;
   customerMasterKeySpec?: Maybe<Scalars['String']>;
   deletionDate?: Maybe<Scalars['String']>;
@@ -3370,7 +3375,7 @@ export type AwsLambda = {
   accountId: Scalars['String'];
   appSync?: Maybe<Array<Maybe<AwsAppSync>>>;
   arn: Scalars['String'];
-  cognitoUserPool?: Maybe<Array<Maybe<AwsCognitoUserPool>>>;
+  cognitoUserPools?: Maybe<Array<Maybe<AwsCognitoUserPool>>>;
   description?: Maybe<Scalars['String']>;
   environmentVariables?: Maybe<Array<Maybe<AwsLambdaEnvironmentVariable>>>;
   handler?: Maybe<Scalars['String']>;
@@ -4034,6 +4039,7 @@ export type AwsServiceBillingInfo = {
 export type AwsSes = {
   accountId: Scalars['String'];
   arn: Scalars['String'];
+  cognitoUserPools?: Maybe<Array<Maybe<AwsCognitoUserPool>>>;
   email?: Maybe<Scalars['String']>;
   id: Scalars['String'];
   region?: Maybe<Scalars['String']>;