fixes #1614 Whatsapp Clound Connector: Filter incoming message by con…

…figured phoneNumberId
theopenconversationkit · Jun 8, 2024 · 402d254 · 402d254
1 parent 44e3d6d
commit 402d254
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/bot/connector-whatsapp-cloud/src/main/kotlin/WhatsAppConnectorCloudConnector.kt b/bot/connector-whatsapp-cloud/src/main/kotlin/WhatsAppConnectorCloudConnector.kt
@@ -147,7 +147,9 @@ class WhatsAppConnectorCloudConnector internal constructor(
 
     private fun handleWebHook(requestBody: WebHookEventReceiveMessage, controller: ConnectorController) {
         requestBody.entry.forEach { entry: Entry ->
-            entry.changes.forEach { change: Change ->
+            entry.changes.filter {
+                it.value.metadata.phoneNumberId == phoneNumberId
+            }.forEach { change: Change ->
                 change.value.messages.forEach { message: WhatsAppCloudMessage ->
                     executor.executeBlocking {
                         val event = WebhookActionConverter.toEvent(message, applicationId)