Update app.py

app.py

@@ -1,8 +1,9 @@
-from flask import Flask, request
+from flask import Flask, request, jsonify
 import requests
 from dotenv import load_dotenv
 import os
 
+# Load environment variables from .env file
 load_dotenv()
 
 app = Flask(__name__)
@@ -12,40 +13,52 @@ VERIFY_TOKEN = os.getenv('VERIFY_TOKEN')
 PAGE_ACCESS_TOKEN = os.getenv('PAGE_ACCESS_TOKEN')
 OPENAI_API_KEY = os.getenv('OPENAI_API_KEY')
 
-# Debugging: Print the loaded environment variables
-print(f"VERIFY_TOKEN: {VERIFY_TOKEN}")
-print(f"PAGE_ACCESS_TOKEN: {PAGE_ACCESS_TOKEN}")
-print(f"OPENAI_API_KEY: {OPENAI_API_KEY}")
+# Define the API endpoint for sending messages
+API_URL = f"https://graph.facebook.com/v13.0/me/messages?access_token={PAGE_ACCESS_TOKEN}"
 
-# This is API key for facebook messenger.
-API = "https://graph.facebook.com/LATEST-API-VERSION/me/messages?access_token="+PAGE_ACCESS_TOKEN
-
-@app.route("/", methods=['GET'])
+@app.route("/facebook", methods=['GET'])
 def fbverify():
-    if request.args.get("hub.mode") == "subscribe" and request.args.get("hub.challenge"):
-        if not request.args.get("hub.verify_token")== "imseldrith":
-            return "Verification token missmatch", 403
-        return request.args['hub.challenge'], 200
+    mode = request.args.get("hub.mode")
+    token = request.args.get("hub.verify_token")
+    challenge = request.args.get("hub.challenge")
+
+    if mode == "subscribe" and challenge:
+        if token == VERIFY_TOKEN:
+            return challenge, 200
+        else:
+            return "Verification token mismatch", 403
     return "Hello world", 200
+
 @app.route("/", methods=['POST'])
 def fbwebhook():
     data = request.get_json()
     print(data)
+
     try:
-        # Read messages from facebook messanger.
-        message = data['entry'][0]['messaging'][0]['message']
-        sender_id = data['entry'][0]['messaging'][0]['sender']['id']
-        if message['text'] == "hi":
+        # Extract the message and sender ID from the request
+        messaging_event = data['entry'][0]['messaging'][0]
+        message = messaging_event.get('message', {})
+        sender_id = messaging_event['sender']['id']
+
+        # Check if the received message is "hi"
+        if message.get('text') == "hi":
             request_body = {
                 "recipient": {
                     "id": sender_id
                 },
                 "message": {
-                    "text": "hello, world!"
+                    "text": "Hello, world!"
                 }
             }
-            response = requests.post(API, json=request_body).json()
-            return response
+            response = requests.post(API_URL, json=request_body)
+            return jsonify(response.json()), response.status_code
+
+    except KeyError as e:
+        print(f"KeyError: {e}")
+        return "Invalid payload structure", 400
+    except Exception as e:
+        print(f"Exception: {e}")
+        return "Internal Server Error", 500
 
 if __name__ == '__main__':
-    app.run(host="0.0.0.0", port=7860, debug=True)
+    app.run(host="0.0.0.0", port=7860, debug=True)