Skip to content

Commit

Permalink
Migrated to system text json
Browse files Browse the repository at this point in the history
  • Loading branch information
@gabrieldwight
gabrieldwight committed Feb 20, 2025
1 parent b68541c commit 2e0e419
Showing 1 changed file with 31 additions and 32 deletions.
63 changes: 31 additions & 32 deletions Samples/WhatsAppBusinessCloudAPI.Web/Controllers/WhatsAppNotificationController.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -65,40 +65,40 @@ public ActionResult<string> ConfigureWhatsAppMessageWebhook([FromQuery(Name = "h
}

[HttpPost("receive/TextMessage")]
public async Task<IActionResult> ReceiveWhatsAppTextMessage([FromBody] dynamic messageReceived)
public async Task<IActionResult> ReceiveWhatsAppTextMessage([FromBody] JsonElement messageReceived)
{
try
{
if (messageReceived is null)
if (messageReceived.ValueKind == JsonValueKind.Undefined)
{
return BadRequest(new
{
Message = "Message not received"
});
}

// Message status updates will be trigerred in different scenario
var changesResult = messageReceived["entry"][0]["changes"][0]["value"];
// Message status updates will be triggered in different scenarios
var changesResult = messageReceived.GetProperty("entry")[0].GetProperty("changes")[0].GetProperty("value");

if (changesResult["statuses"] != null)
if (changesResult.TryGetProperty("statuses", out JsonElement statuses))
{
var messageStatus = Convert.ToString(messageReceived["entry"][0]["changes"][0]["value"]["statuses"][0]["status"]);
var messageStatus = statuses[0].GetProperty("status").GetString();

if (messageStatus.Equals("sent"))
{
var messageStatusReceived = await JsonSerializer.DeserializeAsync<UserInitiatedMessageSentStatus>(Convert.ToString(messageReceived)) as UserInitiatedMessageSentStatus;
var messageStatusReceived = JsonSerializer.Deserialize<UserInitiatedMessageSentStatus>(messageReceived.GetRawText());
var messageStatusResults = new List<UserInitiatedStatus>(messageStatusReceived.Entry.SelectMany(x => x.Changes).SelectMany(x => x.Value.Statuses));
_logger.LogInformation(JsonSerializer.Serialize(messageStatusResults, JsonSerializerOptions));

return Ok(new
return Ok(new
{
Message = $"Message Status Received: {messageStatus}"
});
}

if (messageStatus.Equals("delivered"))
{
var messageStatusReceived = await JsonSerializer.DeserializeAsync<UserInitiatedMessageDeliveredStatus>(Convert.ToString(messageReceived)) as UserInitiatedMessageDeliveredStatus;
var messageStatusReceived = JsonSerializer.Deserialize<UserInitiatedMessageDeliveredStatus>(messageReceived.GetRawText());
var messageStatusResults = new List<UserInitiatedMessageDeliveryStatus>(messageStatusReceived.Entry.SelectMany(x => x.Changes).SelectMany(x => x.Value.Statuses));
_logger.LogInformation(JsonSerializer.Serialize(messageStatusResults, JsonSerializerOptions));

Expand All @@ -110,7 +110,7 @@ public async Task<IActionResult> ReceiveWhatsAppTextMessage([FromBody] dynamic m

if (messageStatus.Equals("read"))
{
var messageStatusReceived = await JsonSerializer.DeserializeAsync<MessageStatusUpdateNotification>(Convert.ToString(messageReceived)) as MessageStatusUpdateNotification;
var messageStatusReceived = JsonSerializer.Deserialize<MessageStatusUpdateNotification>(messageReceived.GetRawText());
var messageStatusResults = new List<MessageStatus>(messageStatusReceived.Entry.SelectMany(x => x.Changes).SelectMany(x => x.Value.Statuses));
_logger.LogInformation(JsonSerializer.Serialize(messageStatusResults, JsonSerializerOptions));

Expand All @@ -122,11 +122,11 @@ public async Task<IActionResult> ReceiveWhatsAppTextMessage([FromBody] dynamic m
}
else
{
var messageType = Convert.ToString(messageReceived["entry"][0]["changes"][0]["value"]["messages"][0]["type"]);
var messageType = changesResult.GetProperty("messages")[0].GetProperty("type").GetString();

if (messageType.Equals("text"))
{
var textMessageReceived = await JsonSerializer.DeserializeAsync<TextMessageReceived>(Convert.ToString(messageReceived)) as TextMessageReceived;
var textMessageReceived = JsonSerializer.Deserialize<TextMessageReceived>(messageReceived.GetRawText());
textMessage = new List<TextMessage>(textMessageReceived.Entry.SelectMany(x => x.Changes).SelectMany(x => x.Value.Messages));
_logger.LogInformation(JsonSerializer.Serialize(textMessage, JsonSerializerOptions));

Expand Down Expand Up @@ -154,7 +154,7 @@ public async Task<IActionResult> ReceiveWhatsAppTextMessage([FromBody] dynamic m

if (messageType.Equals("image"))
{
var imageMessageReceived = await JsonSerializer.DeserializeAsync<ImageMessageReceived>(Convert.ToString(messageReceived)) as ImageMessageReceived;
var imageMessageReceived = JsonSerializer.Deserialize<ImageMessageReceived>(messageReceived.GetRawText());
imageMessage = new List<ImageMessage>(imageMessageReceived.Entry.SelectMany(x => x.Changes).SelectMany(x => x.Value.Messages));
_logger.LogInformation(JsonSerializer.Serialize(imageMessage, JsonSerializerOptions));

Expand All @@ -172,7 +172,7 @@ public async Task<IActionResult> ReceiveWhatsAppTextMessage([FromBody] dynamic m

if (messageType.Equals("audio"))
{
var audioMessageReceived = await JsonSerializer.DeserializeAsync<AudioMessageReceived>(Convert.ToString(messageReceived)) as AudioMessageReceived;
var audioMessageReceived = JsonSerializer.Deserialize<AudioMessageReceived>(messageReceived.GetRawText());
audioMessage = new List<AudioMessage>(audioMessageReceived.Entry.SelectMany(x => x.Changes).SelectMany(x => x.Value.Messages));
_logger.LogInformation(JsonSerializer.Serialize(audioMessage, JsonSerializerOptions));

Expand Down Expand Up @@ -221,7 +221,7 @@ public async Task<IActionResult> ReceiveWhatsAppTextMessage([FromBody] dynamic m

if (messageType.Equals("document"))
{
var documentMessageReceived = await JsonSerializer.DeserializeAsync<DocumentMessageReceived>(Convert.ToString(messageReceived)) as DocumentMessageReceived;
var documentMessageReceived = JsonSerializer.Deserialize<DocumentMessageReceived>(messageReceived.GetRawText());
documentMessage = new List<DocumentMessage>(documentMessageReceived.Entry.SelectMany(x => x.Changes).SelectMany(x => x.Value.Messages));
_logger.LogInformation(JsonSerializer.Serialize(documentMessage, JsonSerializerOptions));

Expand Down Expand Up @@ -270,9 +270,9 @@ public async Task<IActionResult> ReceiveWhatsAppTextMessage([FromBody] dynamic m

if (messageType.Equals("sticker"))
{
var stickerMessageReceived = await JsonSerializer.DeserializeAsync<StickerMessageReceived>(Convert.ToString(messageReceived)) as StickerMessageReceived;
var stickerMessageReceived = JsonSerializer.Deserialize<StickerMessageReceived>(messageReceived.GetRawText());
stickerMessage = new List<StickerMessage>(stickerMessageReceived.Entry.SelectMany(x => x.Changes).SelectMany(x => x.Value.Messages));
_logger.LogInformation(JsonSerializer.Serialize(imageMessage, JsonSerializerOptions));
_logger.LogInformation(JsonSerializer.Serialize(stickerMessage, JsonSerializerOptions));

MarkMessageRequest markMessageRequest = new MarkMessageRequest();
markMessageRequest.MessageId = stickerMessage.SingleOrDefault().Id;
Expand All @@ -282,13 +282,13 @@ public async Task<IActionResult> ReceiveWhatsAppTextMessage([FromBody] dynamic m

return Ok(new
{
Message = "Image Message received"
Message = "Sticker Message received"
});
}

if (messageType.Equals("contacts"))
{
var contactMessageReceived = await JsonSerializer.DeserializeAsync<ContactMessageReceived>(Convert.ToString(messageReceived)) as ContactMessageReceived;
var contactMessageReceived = JsonSerializer.Deserialize<ContactMessageReceived>(messageReceived.GetRawText());
contactMessage = new List<ContactMessage>(contactMessageReceived.Entry.SelectMany(x => x.Changes).SelectMany(x => x.Value.Messages));
_logger.LogInformation(JsonSerializer.Serialize(contactMessage, JsonSerializerOptions));

Expand All @@ -304,10 +304,9 @@ public async Task<IActionResult> ReceiveWhatsAppTextMessage([FromBody] dynamic m
});
}


if (messageType.Equals("location"))
{
var locationMessageReceived = await JsonSerializer.DeserializeAsync<StaticLocationMessageReceived>(Convert.ToString(messageReceived)) as StaticLocationMessageReceived;
var locationMessageReceived = JsonSerializer.Deserialize<StaticLocationMessageReceived>(messageReceived.GetRawText());
locationMessage = new List<LocationMessage>(locationMessageReceived.Entry.SelectMany(x => x.Changes).SelectMany(x => x.Value.Messages));
_logger.LogInformation(JsonSerializer.Serialize(locationMessage, JsonSerializerOptions));

Expand Down Expand Up @@ -337,7 +336,7 @@ public async Task<IActionResult> ReceiveWhatsAppTextMessage([FromBody] dynamic m

if (messageType.Equals("button"))
{
var quickReplyMessageReceived = await JsonSerializer.DeserializeAsync<QuickReplyButtonMessageReceived>(Convert.ToString(messageReceived)) as QuickReplyButtonMessageReceived;
var quickReplyMessageReceived = JsonSerializer.Deserialize<QuickReplyButtonMessageReceived>(messageReceived.GetRawText());
quickReplyButtonMessage = new List<QuickReplyButtonMessage>(quickReplyMessageReceived.Entry.SelectMany(x => x.Changes).SelectMany(x => x.Value.Messages));
_logger.LogInformation(JsonSerializer.Serialize(quickReplyButtonMessage, JsonSerializerOptions));

Expand All @@ -355,11 +354,11 @@ public async Task<IActionResult> ReceiveWhatsAppTextMessage([FromBody] dynamic m

if (messageType.Equals("interactive"))
{
var getInteractiveType = Convert.ToString(messageReceived["entry"][0]["changes"][0]["value"]["messages"][0]["interactive"]["type"]);
var getInteractiveType = changesResult.GetProperty("messages")[0].GetProperty("interactive").GetProperty("type").GetString();

if (getInteractiveType.Equals("button_reply"))
{
var replyMessageReceived = await JsonSerializer.DeserializeAsync<ReplyButtonMessageReceived>(Convert.ToString(messageReceived)) as ReplyButtonMessageReceived;
var replyMessageReceived = JsonSerializer.Deserialize<ReplyButtonMessageReceived>(messageReceived.GetRawText());
replyButtonMessage = new List<ReplyButtonMessage>(replyMessageReceived.Entry.SelectMany(x => x.Changes).SelectMany(x => x.Value.Messages));
_logger.LogInformation(JsonSerializer.Serialize(replyButtonMessage, JsonSerializerOptions));

Expand All @@ -377,7 +376,7 @@ public async Task<IActionResult> ReceiveWhatsAppTextMessage([FromBody] dynamic m

if (getInteractiveType.Equals("list_reply"))
{
var listReplyMessageReceived = await JsonSerializer.DeserializeAsync<ListReplyButtonMessageReceived>(Convert.ToString(messageReceived)) as ListReplyButtonMessageReceived;
var listReplyMessageReceived = JsonSerializer.Deserialize<ListReplyButtonMessageReceived>(messageReceived.GetRawText());
listReplyButtonMessage = new List<ListReplyButtonMessage>(listReplyMessageReceived.Entry.SelectMany(x => x.Changes).SelectMany(x => x.Value.Messages));
_logger.LogInformation(JsonSerializer.Serialize(listReplyButtonMessage, JsonSerializerOptions));

Expand All @@ -393,20 +392,20 @@ public async Task<IActionResult> ReceiveWhatsAppTextMessage([FromBody] dynamic m
});
}

if (getInteractiveType.Equals("nfm_reply")) // Flow message rceived
if (getInteractiveType.Equals("nfm_reply")) // Flow message received
{
var flowMessageReceived = await JsonSerializer.DeserializeAsync<FlowMessageReceived>(Convert.ToString(messageReceived)) as FlowMessageReceived;
var flowMessageReceived = JsonSerializer.Deserialize<FlowMessageReceived>(messageReceived.GetRawText());
flowMessage = new List<FlowMessage>(flowMessageReceived.Messages);
_logger.LogInformation(JsonSerializer.Serialize(flowMessage, JsonSerializerOptions));
_logger.LogInformation($"User flow message sent: {flowMessage.SingleOrDefault().Interactive.NfmReply.Body}\n{flowMessage.SingleOrDefault().Interactive.NfmReply.ResponseJson}");

MarkMessageRequest markMessageRequest = new MarkMessageRequest();
markMessageRequest.MessageId = flowMessage.SingleOrDefault().Id;
markMessageRequest.Status = "read";
MarkMessageRequest markMessageRequest = new MarkMessageRequest();
markMessageRequest.MessageId = flowMessage.SingleOrDefault().Id;
markMessageRequest.Status = "read";

await _whatsAppBusinessClient.MarkMessageAsReadAsync(markMessageRequest);
await _whatsAppBusinessClient.MarkMessageAsReadAsync(markMessageRequest);

return Ok(new
return Ok(new
{
Message = "Flow Message Received"
});
Expand Down

0 comments on commit 2e0e419

Please sign in to comment.