feat: Added aws_lambda_event_invoke_config for RT

Author: Marco Franceschi

src/services/lambda/data.ts

@@ -11,7 +11,9 @@ import Lambda, {
   ReservedConcurrentExecutions,
   GetPolicyResponse,
   ListEventSourceMappingsResponse,
-  EventSourceMappingConfiguration
+  EventSourceMappingConfiguration,
+  ListFunctionEventInvokeConfigsResponse,
+  FunctionEventInvokeConfig
 } from 'aws-sdk/clients/lambda'
 import { AWSError } from 'aws-sdk/lib/error'
 import { Config } from 'aws-sdk/lib/config'
@@ -38,6 +40,7 @@ export interface RawAwsLambdaFunction extends FunctionConfiguration {
     RevisionId?: string
   }
   EventSourceMappings?: EventSourceMappingConfiguration[]
+  EventInvokeConfigs?: FunctionEventInvokeConfig[]
 }
 
 const listFunctionsForRegion = async ({
@@ -185,6 +188,29 @@ const getEventSourceMappings = async (lambda: Lambda, arn: string): Promise<Even
     }
   })
 
+const getEventInvokeConfigs = async (lambda: Lambda, name: string): Promise<FunctionEventInvokeConfig[]> =>
+  new Promise(resolve => {
+    try {
+      lambda.listFunctionEventInvokeConfigs(
+        { FunctionName: name },
+        (err: AWSError, data: ListFunctionEventInvokeConfigsResponse) => {
+          if (err) {
+            errorLog.generateAwsErrorLog({
+              functionName: 'lambda:listFunctionEventInvokeConfigs',
+              err,
+            })
+            resolve([])
+          }
+          const { FunctionEventInvokeConfigs = [] } = data || {}
+
+          resolve(FunctionEventInvokeConfigs)
+        }
+      )
+    } catch (error) {
+      resolve([])
+    }
+  })
+
 export default async ({
   regions,
   config,
@@ -225,7 +251,7 @@ export default async ({
     logger.debug(lt.fetchedLambdas(lambdaData.length))
 
     // get all tags and policy for each Lambda
-    lambdaData.map(({ FunctionArn: arn, region }, idx) => {
+    lambdaData.map(({ FunctionArn: arn, region, FunctionName: name }, idx) => {
       const lambda = new Lambda({ ...config, region, endpoint })
       const additionalMetadataPromise = new Promise<void>(async resolveData => {
         const envTags: TagMap = await getResourceTags(lambda, arn)
@@ -234,6 +260,8 @@ export default async ({
         lambdaData[idx].PolicyData = policy
         const eventSourceMappings = await getEventSourceMappings(lambda, arn)
         lambdaData[idx].EventSourceMappings = eventSourceMappings
+        const eventInvokeConfigs = await getEventInvokeConfigs(lambda, name)
+        lambdaData[idx].EventInvokeConfigs = eventInvokeConfigs
         resolveData()
       })
       tagsPromises.push(additionalMetadataPromise)

src/services/lambda/format.ts

@@ -1,10 +1,10 @@
 import { generateUniqueId } from '@cloudgraph/sdk'
 import isEmpty from 'lodash/isEmpty'
 import t from '../../properties/translations'
-import { AwsLambda, AwsLambdaEventSourceMappings } from '../../types/generated'
+import { AwsLambda, AwsLambdaEventInvokeConfig, AwsLambdaEventSourceMappings } from '../../types/generated'
 import { formatTagsFromMap, formatIamJsonPolicy } from '../../utils/format'
 import { RawAwsLambdaFunction } from './data'
-import { EventSourceMappingConfiguration } from 'aws-sdk/clients/lambda'
+import { EventSourceMappingConfiguration, FunctionEventInvokeConfig } from 'aws-sdk/clients/lambda'
 
 /**
  * Lambda
@@ -35,7 +35,8 @@ export default ({
     reservedConcurrentExecutions: rawReservedConcurrentExecutions,
     VpcConfig: vpcConfig,
     PolicyData: { Policy: policy = '', RevisionId: policyRevisionId = '' },
-    EventSourceMappings: eventSourceMappings = []
+    EventSourceMappings: eventSourceMappings = [],
+    EventInvokeConfigs: eventInvokeConfigs = []
   } = rawData
   const environmentVariables = []
   const secretNames = [t.pass, t.secret, t.private, t.cert]
@@ -127,6 +128,32 @@ export default ({
     )
   }
 
+  const formatEventInvokeConfigs = (
+    eventInvokeConfigs?: FunctionEventInvokeConfig[]
+  ): AwsLambdaEventInvokeConfig[] => {
+    return (
+      eventInvokeConfigs?.map(e => ({
+        id: generateUniqueId({
+          arn,
+          ...e,
+        }),
+        lastModified: e.LastModified?.toISOString(),
+        functionArn: e.FunctionArn,
+        maximumRetryAttempts: e.MaximumRetryAttempts,
+        maximumEventAgeInSeconds: e.MaximumEventAgeInSeconds,
+        destinationConfig: {
+          id: generateUniqueId({
+            arn,
+            ...e.DestinationConfig,
+
+          }),
+          OnSuccess: e.DestinationConfig?.OnSuccess?.Destination,
+          OnFailure: e.DestinationConfig?.OnFailure?.Destination
+        }
+      })) || []
+    )
+  }
+
   return {
     accountId: account,
     arn,
@@ -149,6 +176,7 @@ export default ({
     rawPolicy: policy,
     policy: formatIamJsonPolicy(policy),
     tags: formatTagsFromMap(Tags),
-    eventSourceMappings: formatEventSourceMappings(eventSourceMappings)
+    eventSourceMappings: formatEventSourceMappings(eventSourceMappings),
+    eventInvokeConfigs: formatEventInvokeConfigs(eventInvokeConfigs)
   }
 }

src/services/lambda/schema.graphql

@@ -30,6 +30,20 @@ type awsLambdaDestinationConfig
   OnFailure: String @search(by: [hash, regexp])
 }
 
+type awsLambdaEventInvokeConfig
+  @generate(
+    query: { get: false, query: true, aggregate: false }
+    mutation: { add: false, delete: false }
+    subscription: false
+  ) {
+  id: String! @id
+  lastModified: DateTime @search(by: [day])
+  functionArn: String @search(by: [hash, regexp])
+  maximumRetryAttempts: Int
+  maximumEventAgeInSeconds: Int
+  destinationConfig: awsLambdaDestinationConfig
+}
+
 type awsLambdaEventSourceMappings
   @generate(
     query: { get: false, query: true, aggregate: false }
@@ -80,6 +94,7 @@ type awsLambda implements awsBaseService @key(fields: "arn") {
   rawPolicy: String @search(by: [hash, regexp])
   policy: awsIamJSONPolicy
   eventSourceMappings: [awsLambdaEventSourceMappings]
+  eventInvokeConfigs: [awsLambdaEventInvokeConfig]
   tags: [awsRawTag]
   kms: [awsKms] @hasInverse(field: lambda)
   securityGroups: [awsSecurityGroup] @hasInverse(field: lambda)

src/types/generated.ts

@@ -3410,6 +3410,7 @@ export type AwsLambda = AwsBaseService & {
   cognitoUserPools?: Maybe<Array<Maybe<AwsCognitoUserPool>>>;
   description?: Maybe<Scalars['String']>;
   environmentVariables?: Maybe<Array<Maybe<AwsLambdaEnvironmentVariable>>>;
+  eventInvokeConfigs?: Maybe<Array<Maybe<AwsLambdaEventInvokeConfig>>>;
   eventSourceMappings?: Maybe<Array<Maybe<AwsLambdaEventSourceMappings>>>;
   handler?: Maybe<Scalars['String']>;
   iamRole?: Maybe<Array<Maybe<AwsIamRole>>>;
@@ -3447,6 +3448,15 @@ export type AwsLambdaEnvironmentVariable = {
   value?: Maybe<Scalars['String']>;
 };
 
+export type AwsLambdaEventInvokeConfig = {
+  destinationConfig?: Maybe<AwsLambdaDestinationConfig>;
+  functionArn?: Maybe<Scalars['String']>;
+  id: Scalars['String'];
+  lastModified?: Maybe<Scalars['DateTime']>;
+  maximumEventAgeInSeconds?: Maybe<Scalars['Int']>;
+  maximumRetryAttempts?: Maybe<Scalars['Int']>;
+};
+
 export type AwsLambdaEventSourceConfig = {
   consumerGroupId?: Maybe<Scalars['String']>;
   id: Scalars['String'];
@@ -3469,9 +3479,7 @@ export type AwsLambdaEventSourceMappings = {
   maximumRetryAttempts?: Maybe<Scalars['Int']>;
   parallelizationFactor?: Maybe<Scalars['Int']>;
   queues?: Maybe<Array<Maybe<Scalars['String']>>>;
-  selfManagedEventSource?: Maybe<Array<Maybe<Scalars['String']>>>;
   selfManagedKafkaEventSourceConfig?: Maybe<AwsLambdaEventSourceConfig>;
-  sourceAccessConfigurations?: Maybe<Array<Maybe<AwsLambdaSourceAccessConfiguration>>>;
   startingPosition?: Maybe<Scalars['String']>;
   state?: Maybe<Scalars['String']>;
   stateTransitionReason?: Maybe<Scalars['String']>;