app.py

from flask import Flask, request, jsonify
from models import Message
from sheets_api import get_items, refresh_cache
from matcher import get_likely_items
from composer import get_message_for_options
from config import NUMBER, AUTHORIZATION, WHATSAPP_URL
import requests

app = Flask(__name__)


@app.route("/webhook", methods=["POST"])
def webhook():
    data = request.get_json()
    message = Message.from_json(data)
    print(message)

    handel_incoming_message(message)

    return jsonify({"status": "OK"})

def handel_incoming_message(message: Message)-> None:
    if message.text.lower() == "refresh":
        refresh_cache()
        return
    
    items = get_items()
    likely_items = get_likely_items(items, message.text)

    response_text = get_message_for_options(likely_items, message.text)

    payload = {
        "from": NUMBER,
        "to": message.sender,
        "content":{
            "text": response_text
        }
    }

    headers = {
        "Content_Type":"application/json",
        "Authorization": AUTHORIZATION
    }

    try:
        response = requests.post(WHATSAPP_URL, headers=headers, json=payload)
        print(f"Poslani odgovori: {response.status_code} - {response.text}")

    except Exception as e:
        print(f"Greška pri slanju odgovora: {e}")


if __name__ == "__main__":
    app.run(host="0.0.0.0", port=8080, debug=True)