debug

Author: reakaleek

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

@@ -76,9 +76,13 @@ static async Task<SQSBatchResponse> Handler(SQSEvent ev, ILambdaContext context)
 		_ = await s3Client.PutObjectAsync(putObjectRequest);
 		context.Logger.LogInformation($"Successfully updated {bucketName}/{indexFile}.");
 		context.Logger.LogInformation($"Processed {processedMessageCount} messages.");
+		var response = new SQSBatchResponse(batchItemFailures);
 		if (batchItemFailures.Count > 0)
+		{
 			context.Logger.LogInformation($"Failed to process {batchItemFailures.Count}  messages. Returning them to the queue.");
-		return new SQSBatchResponse(batchItemFailures);
+			context.Logger.LogInformation(JsonSerializer.Serialize(response, LinkIndexUpdaterSerializerContext.Default.SQSBatchResponse));
+		}
+		return response;
 	}
 	catch (Exception ex)
 	{
@@ -90,10 +94,12 @@ 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
+		var response = new SQSBatchResponse(ev.Records.Select(r => new SQSBatchResponse.BatchItemFailure
 		{
 			ItemIdentifier = r.MessageId
 		}).ToList());
+		context.Logger.LogInformation(JsonSerializer.Serialize(response, LinkIndexUpdaterSerializerContext.Default.SQSBatchResponse));
+		return response;
 	}
 }