Update app.py

app.py

@@ -1,10 +1,8 @@
-from flask import Flask, request, jsonify
+from flask import Flask, request
+import requests
 from dotenv import load_dotenv
 import os
-from helper.openai_api import chat_completion
-from helper.messenger_api import send_message, set_typing_on, set_typing_off
 
-# Load environment variables
 load_dotenv()
 
 app = Flask(__name__)
@@ -19,54 +17,35 @@ print(f"VERIFY_TOKEN: {VERIFY_TOKEN}")
 print(f"PAGE_ACCESS_TOKEN: {PAGE_ACCESS_TOKEN}")
 print(f"OPENAI_API_KEY: {OPENAI_API_KEY}")
 
-@app.route('/', methods=['GET'])
-def home():
-    return 'FACEBOOK CHATBOT', 200
-
-@app.route('/facebook', methods=['GET'])
-def verify_webhook():
-    mode = request.args.get('hub.mode')
-    token = request.args.get('hub.verify_token')
-    challenge = request.args.get('hub.challenge')
-
-    if mode == 'subscribe' and token == VERIFY_TOKEN:
-        return challenge, 200
-    else:
-        return 'Forbidden', 403
-
-@app.route('/webhook', methods=['POST'])
-def handle_messages():
-    body = request.get_json()
-    print('Incoming request body:', body)  # Log the entire request body
-
-    if not body.get('entry') or not body['entry'][0].get('messaging'):
-        return 'Invalid payload', 400
-
-    messaging_event = body['entry'][0]['messaging'][0]
-    sender_id = messaging_event['sender']['id']
-    message_text = messaging_event['message'].get('text')
-
-    if not sender_id or not message_text:
-        return 'Invalid message', 400
-
-    set_typing_on(sender_id)
-
-    result = chat_completion(message_text)
-    response_text = result.get('response', '')
-    
+# 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'])
+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
+    return "Hello world", 200
+@app.route("/", methods=['POST'])
+def fbwebhook():
+    data = request.get_json()
+    print(data)
     try:
-        parsed_response = response_text  # Caution: using eval() is dangerous, ensure the content is trusted
-        if not isinstance(parsed_response, dict):
-            raise ValueError("Response is not a valid dictionary")
-    except:
-        parsed_response = {'msg': response_text, 'image_url': None}
-
-    msg = parsed_response.get('msg')
-    image_url = parsed_response.get('image_url')
-    send_message(sender_id, msg, image_url)
-
-    set_typing_off(sender_id)
-    return 'OK', 200
+        # 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":
+            request_body = {
+                "recipient": {
+                    "id": sender_id
+                },
+                "message": {
+                    "text": "hello, world!"
+                }
+            }
+            response = requests.post(API, json=request_body).json()
+            return response
 
 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)