test

Author: reakaleek

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,7 +77,7 @@ static async Task<SQSBatchResponse> Handler(SQSEvent ev, ILambdaContext context)
 		context.Logger.LogInformation($"Processed {processedMessageCount} messages.");
 		if (batchItemFailures.Count > 0)
 			context.Logger.LogInformation($"Failed to process {batchItemFailures.Count}  messages. Returning them to the queue.");
-		return new SQSBatchResponse(batchItemFailures);
+		return JsonSerializer.Serialize(new SQSBatchResponse(batchItemFailures), LinkIndexUpdaterSerializerContext.Default.SQSBatchResponse);
 	}
 	catch (Exception ex)
 	{
@@ -88,10 +88,16 @@ static async Task<SQSBatchResponse> Handler(SQSEvent ev, ILambdaContext context)
 		{
 			context.Logger.LogInformation($"Returning message {m.MessageId} to the queue.");
 		});
-		return new SQSBatchResponse(ev.Records.Select(r => new SQSBatchResponse.BatchItemFailure
+
+		return JsonSerializer.Serialize(new SQSBatchResponse(ev.Records.Select(r => new SQSBatchResponse.BatchItemFailure
 		{
 			ItemIdentifier = r.MessageId
-		}).ToList());
+		}).ToList()), LinkIndexUpdaterSerializerContext.Default.SQSBatchResponse);
+		//
+		// return new SQSBatchResponse(ev.Records.Select(r => new SQSBatchResponse.BatchItemFailure
+		// {
+		// 	ItemIdentifier = r.MessageId
+		// }).ToList());
 	}
 }