return message

.gitignore

@@ -1,4 +1,5 @@
 bin/
 lib/
- __pycache__/ 
+__pycache__/
+.env
 pyvenv.cfg

main.py

@@ -1,6 +1,6 @@
-from fastapi import FastAPI, Request, Query, Body
-from typing import List
+from fastapi import FastAPI, Request, Query
 import logging
+from whatsapp_client import WhatsAppWrapper
 
 logger = logging.getLogger()
 
@@ -30,8 +30,17 @@ async def verify(
 
 @app.post("/webook")
 async def callback(request: Request):
-    print("callback is being called")
-    print(f"HEADERS [{request.headers}]")
-    print(f"BODY [{await request.body()}]")
+    print("============ callback is being called ============")
+    data = await request.body()
+    
+    phone_num = data['entry'][0]['changes'][0]['value']['messages'][0]['from']
+    mesg_body = data['entry'][0]['changes'][0]['value']['messages'][0]['text']['body']
+    phone_number_id = data['entry'][0]['changes'][0]['value']['metadata']['phone_number_id']
+
+    print(f"PHONE# {phone_num} \nMSG: {mesg_body}\nPONE_NUM_ID: {phone_number_id}")
+    
+    client = WhatsAppWrapper()
+    client.send_template_message("hello_world", "en_US", phone_num)
+    client.send_text_message("hello, right back at ya ..." + mesg_body,  phone_num)
     return {"status": "success"}
 

requirements.txt

@@ -1,2 +1,3 @@
 fastapi
-uvicorn[standard]
+uvicorn[standard]
+python-dotenv

test.py

@@ -0,0 +1,46 @@
+data = {
+  "object": "whatsapp_business_account",
+  "entry": [
+    {
+      "id": "270451259495375",
+      "changes": [
+        {
+          "value": {
+            "messaging_product": "whatsapp",
+            "metadata": {
+              "display_phone_number": "15556024077",
+              "phone_number_id": "297527496785471"
+            },
+            "contacts": [
+              {
+                "profile": {
+                  "name": "Eric Landry"
+                },
+                "wa_id": "15127404620"
+              }
+            ],
+            "messages": [
+              {
+                "from": "15127404620",
+                "id": "wamid.HBgLMTUxMjc0MDQ2MjAVAgASGBQzQTEyQTM0OURGQUI4QzZDNTg2MAA=",
+                "timestamp": "1716933996",
+                "text": {
+                  "body": "hello"
+                },
+                "type": "text"
+              }
+            ]
+          },
+          "field": "messages"
+        }
+      ]
+    }
+  ]
+}
+
+phone_num = data['entry'][0]['changes'][0]['value']['messages'][0]['from']
+mesg_body = data['entry'][0]['changes'][0]['value']['messages'][0]['text']['body']
+phone_number_id = data['entry'][0]['changes'][0]['value']['metadata']['phone_number_id']
+
+
+print(f"PHONE# {phone_num} \nMSG: {mesg_body}\nPONE_NUM_ID: {phone_number_id}")

whatsapp_client.py

@@ -0,0 +1,60 @@
+# whatsapp_client.py
+import os
+import requests
+from dotenv import load_dotenv
+
+load_dotenv()
+
+class WhatsAppWrapper:
+
+    API_URL = "https://graph.facebook.com/v19.0/"
+    WHATSAPP_API_TOKEN = os.environ.get("WHATSAPP_API_TOKEN")
+    WHATSAPP_CLOUD_NUMBER_ID = os.environ.get("WHATSAPP_CLOUD_NUMBER_ID")
+
+    def __init__(self):
+        self.headers = {
+            "Authorization": f"Bearer {self.WHATSAPP_API_TOKEN}",
+            "Content-Type": "application/json",
+        }
+        self.API_URL = self.API_URL + self.WHATSAPP_CLOUD_NUMBER_ID
+
+    def send_template_message(self, template_name, language_code, phone_number):
+
+        payload = {
+            "messaging_product": "whatsapp",
+            "to": phone_number,
+            "type": "template",
+            "template": {
+                "name": template_name,
+                "language": {
+                    "code": language_code
+                }
+            }
+        }
+
+        response = requests.post(f"{self.API_URL}/messages", json=payload,headers=self.headers)
+        print(response)
+        assert response.status_code == 200, "Error sending message"
+
+        return response.status_code
+    
+    def send_text_message(self,message, phone_number):
+        payload = {
+            "messaging_product": 'whatsapp',
+            "to": phone_number,
+            "type": "text",
+            "text": {
+                "preview_url": False,
+                "body": message
+            }
+        }
+        response = requests.post(f"{self.API_URL}/messages", json=payload,headers=self.headers)
+        print(response.status_code)
+        print(response.text)
+        assert response.status_code == 200, "Error sending message"
+        return response.status_code
+
+if __name__ == "__main__":
+    client = WhatsAppWrapper()
+    # send a template message
+    client.send_template_message("hello_world", "en_US", "+15127404620")