ok

Author: reakaleek

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

@@ -95,14 +95,33 @@ static async Task<SQSBatchResponse> Handler(SQSEvent ev, ILambdaContext context)
 	if (string.IsNullOrEmpty(message.Body))
 		throw new Exception("No Body in SQS Message.");
 	context.Logger.LogInformation($"Received message {message.Body}");
-	var s3Event = JsonSerializer.Deserialize<S3Event>(message.Body, LinkIndexUpdaterEventSerializerContext.Default.S3Event);
+
+	S3Event? s3Event;
+
+	try
+	{
+		s3Event = JsonSerializer.Deserialize<S3Event>(message.Body, LinkIndexUpdaterEventSerializerContext.Default.S3Event);
+	}
+	catch (JsonSerializerException ex)
+	{
+		context.Logger.LogError(ex, "Failed to deserialize S3 event");
+		throw new Exception("Failed to deserialize S3 event", ex);
+	}
+	catch (Exception ex)
+	{
+		context.Logger.LogError(ex, "Failed to deserialize S3 event");
+		throw new Exception("Failed to deserialize S3 event", ex);
+	}
+
+
 	if (s3Event?.Records == null || s3Event.Records.Count == 0)
 		throw new Exception("Invalid S3 event message format");
 	var linkReferences = new ConcurrentBag<(S3Event.S3EventNotificationRecord, LinkReference)>();
 	await Parallel.ForEachAsync(s3Event.Records, async (record, ctx) =>
 	{
 		var s3Bucket = record.S3.Bucket;
 		var s3Object = record.S3.Object;
+
 		context.Logger.LogInformation($"Get object {s3Object.Key} from bucket {s3Bucket.Name}");
 		var getObjectResponse = await s3Client.GetObjectAsync(s3Bucket.Name, s3Object.Key, ctx);
 		await using var stream = getObjectResponse.ResponseStream;