feat(constructs): bring your own lambda (#284)

* chore(qa): add new prop to provide custom lambda function

* chore(rag): provide custom lambda props for rag construct

* chore(rag): provide custom lambda props for summarization construct

* chore(lambda layer): move generated props to a dedicated folder

* chore(eslint): fix linting

* chore(test): add tests and rename props for more clarity

* chore(doc): update documentation to reflect changes

Author: krokoko

.eslintrc.json

@@ -167,18 +167,24 @@ project.eslint?.addRules({
 
 project.eslint?.addIgnorePattern('LangchainProps.ts');
 project.eslint?.addIgnorePattern('AdapterProps.ts');
+project.eslint?.addIgnorePattern('DockerLambdaCustomProps.ts');
 
 // Shared interfaces extending pre-existing CDK interfaces
-new ProjenStruct(project, { name: 'LangchainProps', filePath: 'src/patterns/gen-ai/aws-langchain-common-layer/LangchainProps.ts' })
+new ProjenStruct(project, { name: 'LangchainProps', filePath: 'src/common/props/LangchainProps.ts' })
   .mixin(Struct.fromFqn('aws-cdk-lib.aws_lambda.LayerVersionProps'))
   .withoutDeprecated()
   .omit('code', 'compatibleRuntimes', 'compatibleArchitectures');
 
-new ProjenStruct(project, { name: 'AdapterProps', filePath: 'src/patterns/gen-ai/aws-langchain-common-layer/AdapterProps.ts' })
+new ProjenStruct(project, { name: 'AdapterProps', filePath: 'src/common/props/AdapterProps.ts' })
   .mixin(Struct.fromFqn('aws-cdk-lib.aws_lambda.LayerVersionProps'))
   .withoutDeprecated()
   .omit('code');
 
+new ProjenStruct(project, { name: 'DockerLambdaCustomProps', filePath: 'src/common/props/DockerLambdaCustomProps.ts' })
+  .mixin(Struct.fromFqn('aws-cdk-lib.aws_lambda.DockerImageFunctionProps'))
+  .withoutDeprecated()
+  .omit('tracing', 'functionName', 'description', 'role', 'vpc', 'vpcSubnets', 'securityGroups', 'role', 'layers', 'allowPublicSubnet', 'allowAllOutbound');
+
 const packageJson = project.tryFindObjectFile('package.json');
 packageJson?.patch(JsonPatch.add('/scripts/prepare', 'husky install')); // yarn 1
 packageJson?.patch(JsonPatch.add('/scripts/postinstall', 'husky install')); // yarn 2

.gitattributes

@@ -33,6 +33,7 @@
 - [ContainerImageConfig](interfaces/ContainerImageConfig.md)
 - [ContentGenerationAppSyncLambdaProps](interfaces/ContentGenerationAppSyncLambdaProps.md)
 - [CustomSageMakerEndpointProps](interfaces/CustomSageMakerEndpointProps.md)
+- [DockerLambdaCustomProps](interfaces/DockerLambdaCustomProps.md)
 - [HuggingFaceSageMakerEndpointProps](interfaces/HuggingFaceSageMakerEndpointProps.md)
 - [IInstanceAliase](interfaces/IInstanceAliase.md)
 - [IInstanceValiant](interfaces/IInstanceValiant.md)

.gitignore

@@ -20,6 +20,7 @@ The ContentGenerationAppSyncLambda class.
 
 ### Properties
 
+- [cgLambdaFunction](ContentGenerationAppSyncLambda.md#cglambdafunction)
 - [generatedImageBus](ContentGenerationAppSyncLambda.md#generatedimagebus)
 - [graphqlApi](ContentGenerationAppSyncLambda.md#graphqlapi)
 - [node](ContentGenerationAppSyncLambda.md#node)
@@ -69,6 +70,14 @@ Construct.constructor
 
 ## Properties
 
+### cgLambdaFunction
+
+• `Readonly` **cgLambdaFunction**: `DockerImageFunction`
+
+Returns an instance of appsync.IGraphqlApi created by the construct
+
+___
+
 ### generatedImageBus
 
 • `Readonly` **generatedImageBus**: `IEventBus`

.projen/files.json

@@ -23,6 +23,7 @@ The QaAppsyncOpensearch class.
 - [graphqlApi](QaAppsyncOpensearch.md#graphqlapi)
 - [node](QaAppsyncOpensearch.md#node)
 - [qaBus](QaAppsyncOpensearch.md#qabus)
+- [qaLambdaFunction](QaAppsyncOpensearch.md#qalambdafunction)
 - [s3InputAssetsBucket](QaAppsyncOpensearch.md#s3inputassetsbucket)
 - [s3InputAssetsBucketInterface](QaAppsyncOpensearch.md#s3inputassetsbucketinterface)
 - [securityGroup](QaAppsyncOpensearch.md#securitygroup)
@@ -97,6 +98,14 @@ Returns the instance of events.IEventBus used by the construct
 
 ___
 
+### qaLambdaFunction
+
+• `Readonly` **qaLambdaFunction**: `DockerImageFunction`
+
+Returns an instance of appsync.IGraphqlApi created by the construct
+
+___
+
 ### s3InputAssetsBucket
 
 • `Optional` `Readonly` **s3InputAssetsBucket**: `Bucket`

.projenrc.ts

@@ -20,8 +20,11 @@ The RagAppsyncStepfnOpensearch class.
 
 ### Properties
 
+- [embeddingsLambdaFunction](RagAppsyncStepfnOpensearch.md#embeddingslambdafunction)
+- [fileTransformerLambdaFunction](RagAppsyncStepfnOpensearch.md#filetransformerlambdafunction)
 - [graphqlApi](RagAppsyncStepfnOpensearch.md#graphqlapi)
 - [ingestionBus](RagAppsyncStepfnOpensearch.md#ingestionbus)
+- [inputValidationLambdaFunction](RagAppsyncStepfnOpensearch.md#inputvalidationlambdafunction)
 - [node](RagAppsyncStepfnOpensearch.md#node)
 - [s3InputAssetsBucket](RagAppsyncStepfnOpensearch.md#s3inputassetsbucket)
 - [s3InputAssetsBucketInterface](RagAppsyncStepfnOpensearch.md#s3inputassetsbucketinterface)
@@ -72,6 +75,22 @@ Construct.constructor
 
 ## Properties
 
+### embeddingsLambdaFunction
+
+• `Readonly` **embeddingsLambdaFunction**: `DockerImageFunction`
+
+Returns an instance of lambda.DockerImageFunction used for the embeddings job created by the construct
+
+___
+
+### fileTransformerLambdaFunction
+
+• `Readonly` **fileTransformerLambdaFunction**: `DockerImageFunction`
+
+Returns an instance of lambda.DockerImageFunction used for the file transformer job created by the construct
+
+___
+
 ### graphqlApi
 
 • `Readonly` **graphqlApi**: `IGraphqlApi`
@@ -88,6 +107,14 @@ Returns the instance of events.IEventBus used by the construct
 
 ___
 
+### inputValidationLambdaFunction
+
+• `Readonly` **inputValidationLambdaFunction**: `DockerImageFunction`
+
+Returns an instance of lambda.DockerImageFunction used for the input validation job created by the construct
+
+___
+
 ### node
 
 • `Readonly` **node**: `Node`

apidocs/README.md

@@ -16,14 +16,17 @@
 
 ### Properties
 
+- [documentReaderLambdaFunction](SummarizationAppsyncStepfn.md#documentreaderlambdafunction)
 - [eventBridgeBus](SummarizationAppsyncStepfn.md#eventbridgebus)
 - [graphqlApi](SummarizationAppsyncStepfn.md#graphqlapi)
 - [inputAssetBucket](SummarizationAppsyncStepfn.md#inputassetbucket)
+- [inputValidationLambdaFunction](SummarizationAppsyncStepfn.md#inputvalidationlambdafunction)
 - [node](SummarizationAppsyncStepfn.md#node)
 - [processedAssetBucket](SummarizationAppsyncStepfn.md#processedassetbucket)
 - [redisCluster](SummarizationAppsyncStepfn.md#rediscluster)
 - [securityGroup](SummarizationAppsyncStepfn.md#securitygroup)
 - [stateMachine](SummarizationAppsyncStepfn.md#statemachine)
+- [summaryGeneratorLambdaFunction](SummarizationAppsyncStepfn.md#summarygeneratorlambdafunction)
 - [vpc](SummarizationAppsyncStepfn.md#vpc)
 
 ### Methods
@@ -67,6 +70,14 @@ Construct.constructor
 
 ## Properties
 
+### documentReaderLambdaFunction
+
+• `Readonly` **documentReaderLambdaFunction**: `DockerImageFunction`
+
+Returns an instance of lambda.DockerImageFunction used for the document reading job created by the construct
+
+___
+
 ### eventBridgeBus
 
 • `Readonly` **eventBridgeBus**: `IEventBus`
@@ -91,6 +102,14 @@ Returns the instance of s3.IBucket used by the construct
 
 ___
 
+### inputValidationLambdaFunction
+
+• `Readonly` **inputValidationLambdaFunction**: `DockerImageFunction`
+
+Returns an instance of lambda.DockerImageFunction used for the input validation job created by the construct
+
+___
+
 ### node
 
 • `Readonly` **node**: `Node`
@@ -141,6 +160,14 @@ Step function
 
 ___
 
+### summaryGeneratorLambdaFunction
+
+• `Readonly` **summaryGeneratorLambdaFunction**: `DockerImageFunction`
+
+Returns an instance of lambda.DockerImageFunction used for the summary generation job created by the construct
+
+___
+
 ### vpc
 
 • `Readonly` **vpc**: `IVpc`

apidocs/classes/ContentGenerationAppSyncLambda.md

@@ -9,6 +9,7 @@ The properties for the ContentGenerationAppSyncLambdaProps class.
 ### Properties
 
 - [cognitoUserPool](ContentGenerationAppSyncLambdaProps.md#cognitouserpool)
+- [customDockerLambdaProps](ContentGenerationAppSyncLambdaProps.md#customdockerlambdaprops)
 - [enableOperationalMetric](ContentGenerationAppSyncLambdaProps.md#enableoperationalmetric)
 - [existingBusInterface](ContentGenerationAppSyncLambdaProps.md#existingbusinterface)
 - [existingGeneratedAssetsBucketObj](ContentGenerationAppSyncLambdaProps.md#existinggeneratedassetsbucketobj)
@@ -37,6 +38,15 @@ Cognito user pool used for authentication.
 
 ___
 
+### customDockerLambdaProps
+
+• `Optional` `Readonly` **customDockerLambdaProps**: [`DockerLambdaCustomProps`](DockerLambdaCustomProps.md)
+
+Optional. Allows to provide custom lambda code
+and settings instead of the existing
+
+___
+
 ### enableOperationalMetric
 
 • `Optional` `Readonly` **enableOperationalMetric**: `boolean`