Whatsapp - Getting started in Peliqan

def sendTemplateMessageWithDynamicContent():
    message = {
        "to": "+32498776655",
        "type": "template",
        "template": {
            "name": "my_template_name",
            "language": {
                "code": "en"
            },
            "components": [
                {
                    "type": "body",
                    "parameters": [
                        {
                            "text": "Hi there John Doe",
                            "type": "text"
                        }
                    ]
                }
            ]
        },
        "messaging_product": "whatsapp",
        "from_phonenumber_id": "263567523509790"
    }
    result = whatsapp_api.add('message', message)
    st.json(result)
    
def sendWhatsappFlow():
    message = {
        "from_phonenumber_id": "263567523509790",
        "messaging_product": "whatsapp",
        "to": "+32498776655",
        "recipient_type": "individual",
        "type": "interactive",
        "interactive": {
            "type": "flow",
            "header": {
                "type": "text",
                "text": "Not shown in draft mode"
            },
            "body": {
                "text": "Not shown in draft mode"
            },
            "footer": {
                "text": "Not shown in draft mode"
            },
            "action": {
                "name": "flow",
                "parameters": {
                    "flow_message_version": "3",
                    "flow_action": "navigate",
                    "flow_token": "123",
                    "flow_id": "2344349045774215",
                    "flow_cta": "Not shown in draft mode",
                    "mode": "draft",
                    "flow_action_payload": {
                        "screen": "WELCOME_SCREEN",
                        "data": {
                            "welcome_text": "Hi John, here are your orders!",
                            "all_orders": [
                                {
                                    "id": "1",
                                    "title": "Order 123"
                                },
                                {
                                    "id": "2",
                                    "title": "Order 456"
                                }
                            ]
                        }
                    }
                }
            }
        }
    }
    result = whatsapp_api.add('message', message)
    st.json(result)

# This script can be scheduled to run e.g. every 5 minutes
# It will process incoming webhook events incrementally from the queue
# and for incoming Whatsapp messages it will send a reply
whatsapp_api = pq.connect('Whatsapp')
dw = pq.dbconnect(pq.DW_NAME)

def getIncomingMessagesIncremental():
    incoming_messages = []
    id = pq.get_state()
    if not id:
        id = 1
    webhooks = dw.fetch(pq.DW_NAME, query = f"SELECT * FROM webhook.incoming_webhooks WHERE id > %s ORDER BY id" % id)
    for webhook in webhooks:
        for entry in webhook["payload"].get("entry", []):
            for change in entry.get("changes", []):
                if change.get("field")=="messages":
                    for message in change.get("value", {}).get("messages", []):
                        message_from = message.get("from")
                        message_text = message.get("text", {}).get("body")
                        incoming_messages.append({"from": message_from, "text": message_text})
    if webhooks:
        pq.set_state(webhooks[-1]["id"])
    return incoming_messages

def sendTextMessage(to, text):
    textmessage = {
        'to': to,
        'text': text,
        'from_phonenumber_id': "263567523509790",
    }
    whatsapp_api.add('textmessage', textmessage)

incoming_messages = getIncomingMessagesIncremental()
if incoming_messages:
    for incoming_message in incoming_messages:
	    sendTextMessage(incoming_message["from"], 'Thank you! You wrote:' + incoming_message["text"])

# This script implements a real-time chatbot in Whatsapp, using OpenAI ChatGPT.
# 
# Add this script as an API handler in Peliqan.
# Configure an API endpoint linked to this script (method GET, change to POST after verification, see below).
# Configure your API endpoint as Callback URL in your Whatsapp in Facebook developer portal.
# Make sure to add an OpenAI and Whatsapp connection in your Peliqan account first.
import json

whatsapp_api = pq.connect('Whatsapp')
openai_api = pq.connect('OpenAI')

def sendTextMessage(to, text):
    textmessage = {
        'to': to,
        'text': text.replace('"', "'").replace("\n", ""),
        'from_phonenumber_id': "263567523509790"
    }
    result = whatsapp_api.add('textmessage', textmessage)
    print("Result of sending message to Whatsapp:", result)

def getMessages(data):
    incoming_messages = []
    for entry in data.get("entry", []):
        for change in entry.get("changes", []):
            if change.get("field")=="messages":
                for message in change.get("value", {}).get("messages", []):
                    message_from = message.get("from")
                    message_text = message.get("text", {}).get("body")
                    incoming_messages.append({"from": message_from, "text": message_text})
    return incoming_messages

def askAI(messages):
    messages_to_ai = []
    for message in messages:
        messages_to_ai.append({"role": "user", "content": message})
        
    request = {
        "model": "gpt-3.5-turbo",
        "messages": messages_to_ai,
        "temperature": 0.7
    }    
    llm_answer = openai_api.get('completion_raw', request)
    
    message = llm_answer["choices"][0]["message"]
    answer_content = message["content"]
    print("AI answer:", answer_content)
    return answer_content

def handler(request):
    query_string = request['query_string']
    data_str = request['data']
    print("Payload received from Whatsapp:", data_str)

    # Send challenge in response in first API call from Whatsapp (Facebook) to verify Callback URL.
    # Make sure the API handler is configured as a public endpoint with method GET.
    # After verification, change the method to POST.
    from urllib.parse import parse_qs
    query_string_dict = parse_qs(query_string)
    if "hub.challenge" in query_string_dict:
        challenge = query_string_dict['hub.challenge'][0]
        print("Sent challenge in response to verify new Callback URL in Whatsapp configuration.")
        return challenge
    
    else:
        data = json.loads(data_str)
        messages = getMessages(data)
        
        for message in messages:
            #sendTextMessage(message["from"], 'Thanks for your message ! You wrote: ' + message["text"])
            answer = askAI([message["text"]])
            sendTextMessage(message["from"], answer)
        return "ok"