ok

Author: reakaleek

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

@@ -23,7 +23,7 @@
 
 return;
 
-static async Task<string> Handler(SQSEvent ev, ILambdaContext context)
+static async Task<SQSBatchResponse> Handler(SQSEvent ev, ILambdaContext context)
 {
 	var s3Client = new AmazonS3Client();
 	var batchItemFailures = new List<SQSBatchResponse.BatchItemFailure>();
@@ -78,7 +78,7 @@ static async Task<string> 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 JsonSerializer.Serialize(new SQSBatchResponse(batchItemFailures), LinkIndexUpdaterSerializerContext.Default.SQSBatchResponse);
+		return new SQSBatchResponse(batchItemFailures);
 	}
 	catch (Exception ex)
 	{
@@ -90,15 +90,10 @@ static async Task<string> Handler(SQSEvent ev, ILambdaContext context)
 			context.Logger.LogInformation($"Returning message {m.MessageId} to the queue.");
 		});
 
-		return JsonSerializer.Serialize(new SQSBatchResponse(ev.Records.Select(r => new SQSBatchResponse.BatchItemFailure
+		return new SQSBatchResponse(ev.Records.Select(r => new SQSBatchResponse.BatchItemFailure
 		{
 			ItemIdentifier = r.MessageId
-		}).ToList()), LinkIndexUpdaterSerializerContext.Default.SQSBatchResponse);
-		//
-		// return new SQSBatchResponse(ev.Records.Select(r => new SQSBatchResponse.BatchItemFailure
-		// {
-		// 	ItemIdentifier = r.MessageId
-		// }).ToList());
+		}).ToList());
 	}
 }