what

Author: reakaleek

src/infra/docs-lambda-index-publisher/Models.cs

@@ -9,6 +9,7 @@
 namespace Elastic.Documentation.Lambda.LinkIndexUploader;
 
 [JsonSerializable(typeof(SQSEvent))]
+[JsonSerializable(typeof(Amazon.Lambda.S3Events.S3Event))]
 [JsonSerializable(typeof(S3EventNotification))]
 [JsonSerializable(typeof(SQSBatchResponse))]
 public partial class LinkIndexUpdaterSerializerContext : JsonSerializerContext;

src/infra/docs-lambda-index-publisher/Program.cs

@@ -23,7 +23,7 @@
 
 return;
 
-static async Task<SQSBatchResponse> Handler(SQSEvent ev, ILambdaContext context)
+static async Task<string> Handler(SQSEvent ev, ILambdaContext context)
 {
 	var s3Client = new AmazonS3Client();
 	var batchItemFailures = new List<SQSBatchResponse.BatchItemFailure>();
@@ -77,12 +77,13 @@ static async Task<SQSBatchResponse> Handler(SQSEvent ev, ILambdaContext context)
 		context.Logger.LogInformation($"Successfully updated {bucketName}/{indexFile}.");
 		context.Logger.LogInformation($"Processed {processedMessageCount} messages.");
 		var response = new SQSBatchResponse(batchItemFailures);
+		var jsonString = JsonSerializer.Serialize(response, LinkIndexUpdaterSerializerContext.Default.SQSBatchResponse);
 		if (batchItemFailures.Count > 0)
 		{
 			context.Logger.LogInformation($"Failed to process {batchItemFailures.Count}  messages. Returning them to the queue.");
-			context.Logger.LogInformation(JsonSerializer.Serialize(response, LinkIndexUpdaterSerializerContext.Default.SQSBatchResponse));
+			context.Logger.LogInformation(jsonString);
 		}
-		return response;
+		return jsonString;
 	}
 	catch (Exception ex)
 	{
@@ -98,8 +99,9 @@ static async Task<SQSBatchResponse> Handler(SQSEvent ev, ILambdaContext context)
 		{
 			ItemIdentifier = r.MessageId
 		}).ToList());
-		context.Logger.LogInformation(JsonSerializer.Serialize(response, LinkIndexUpdaterSerializerContext.Default.SQSBatchResponse));
-		return response;
+		var jsonString = JsonSerializer.Serialize(response, LinkIndexUpdaterSerializerContext.Default.SQSBatchResponse);
+		context.Logger.LogInformation(jsonString);
+		return jsonString;
 	}
 }