Performance improvements for webhook Lambda

Author: madhead

.deploy/lambda/lib/JProfByBotStack.ts

@@ -131,7 +131,7 @@ export class JProfByBotStack extends cdk.Stack {
             compatibleRuntimes: [lambda.Runtime.JAVA_11],
         });
 
-        const lambdaWebhookTimeout = cdk.Duration.seconds(30);
+        const lambdaWebhookTimeout = cdk.Duration.seconds(29);
         const lambdaWebhook = new lambda.Function(this, 'jprof-by-bot-lambda-webhook', {
             functionName: 'jprof-by-bot-lambda-webhook',
             runtime: lambda.Runtime.JAVA_11,
@@ -140,6 +140,7 @@ export class JProfByBotStack extends cdk.Stack {
                 layerLibfontconfig,
             ],
             timeout: lambdaWebhookTimeout,
+            maxEventAge: cdk.Duration.minutes(5),
             retryAttempts: 0,
             memorySize: 512,
             code: lambda.Code.fromAsset('../../launchers/lambda/build/libs/jprof_by_bot-launchers-lambda-all.jar'),
@@ -163,6 +164,10 @@ export class JProfByBotStack extends cdk.Stack {
             },
         });
 
+        (lambdaWebhook.node.defaultChild as lambda.CfnFunction).snapStart = {
+            applyOn: 'PublishedVersions'
+        };
+
         const lambdaDailyUrbanDictionary = new lambda.Function(this, 'jprof-by-bot-lambda-daily-urban-dictionary', {
             functionName: 'jprof-by-bot-lambda-daily-urban-dictionary',
             runtime: lambda.Runtime.JAVA_11,
@@ -233,7 +238,7 @@ export class JProfByBotStack extends cdk.Stack {
 
         api.root
             .addResource(props.telegramToken.replace(':', '_'))
-            .addMethod('POST', new apigateway.LambdaIntegration(lambdaWebhook));
+            .addMethod('POST', new apigateway.LambdaIntegration(lambdaWebhook.currentVersion));
 
         new cdk.CfnOutput(this, 'URL', {
             value: api.deploymentStage.urlForPath()

launchers/lambda/src/main/kotlin/by/jprof/telegram/bot/launchers/lambda/JProf.kt

@@ -21,7 +21,7 @@ import kotlinx.serialization.ExperimentalSerializationApi
 import kotlinx.serialization.json.Json
 import org.apache.logging.log4j.LogManager
 import org.koin.core.component.KoinComponent
-import org.koin.core.component.inject
+import org.koin.core.component.get
 import org.koin.core.context.startKoin
 
 @PreviewFeature
@@ -59,8 +59,8 @@ class JProf : RequestHandler<APIGatewayV2HTTPEvent, APIGatewayV2HTTPResponse>, K
         }
     }
 
-    private val json: Json by inject()
-    private val pipeline: UpdateProcessingPipeline by inject()
+    private val json: Json = get()
+    private val pipeline: UpdateProcessingPipeline = get()
 
     override fun handleRequest(input: APIGatewayV2HTTPEvent, context: Context): APIGatewayV2HTTPResponse {
         logger.debug("Incoming request: {}", input)