Create a WhatsApp Bot in PYTHON

Flask==3.0.0
requests==2.27.1
requests-toolbelt==0.9.1
python-dotenv==0.20.0

pip install -r requirements.txt

API_TOKEN=8FjpwmyFUulh7emXOprrET3xKrwJ984O # API token from your channel
API_URL=https://gate.whapi.cloud # API endpoint URL
PORT=80 # example, 80 or 443
#URL_LINK= The Webhook link to your server {link to server}/hook.

from dotenv import load_dotenv
import os

load_dotenv()
api_token = os.getenv("API_TOKEN")

                                    
import requests

# URL for sending text messages. Can be pulled from .env
url = "https://gate.whapi.cloud/messages/text"

# Data for sending a message
payload = {
    "to": "919984351847",  # Enter the recipient's number in international format
    "body": "Hello! This is a test message."  # Text of message
}

# Headers, including authorization token
headers = {
    "accept": "application/json",
    "content-type": "application/json",
    "authorization": f"Bearer {api_token}"  # Use the token from the .env file
}

# Sending a POST request
response = requests.post(url, json=payload, headers=headers)

# Output server response
print(response.status_code)
print(response.text)
                                    
                                

                                    
from flask import Flask, request, jsonify

app = Flask(__name__)

# Route for processing incoming messages
@app.route('/hook', methods=['POST'])
def webhook():
    # Retrieving data from a request
    data = request.json

    # Logging an incoming message
    print("Received message:", data)

    # Example of incoming message processing
    if "messages" in data:
        for message in data["messages"]:
            sender = message["from"]  # Sender's number
            text = message.get("body", "")  # Text of message

            print(f"Message from {sender}: {text}")

            # Logic for replying to a message
            # Check out our examples on GitHub, where we use more branching on commands for the bot
            if text.lower() == "hello":
                send_response(sender, "Hi there! How can I help you?")
            elif text.lower() == "bye":
                send_response(sender, "Goodbye!")

    return jsonify({"status": "success"}), 200

# Function for sending a reply
def send_response(to, body):
    import requests

    url = "https://gate.whapi.cloud/messages/text"
    payload = {
        "to": to,
        "body": body
    }
    headers = {
        "accept": "application/json",
        "content-type": "application/json",
        "authorization": f"Bearer {api_token}"  # Use the token from the .env file
    }

    response = requests.post(url, json=payload, headers=headers)
    print(f"Response to {to}: {response.status_code}, {response.text}")

if __name__ == '__main__':
    app.run(host='0.0.0.0', port=80)

                                    
                                

                                    
import requests

url = "https://gate.whapi.cloud/messages/image"

payload = {
    "to": "919984351847",
    "media": "https://upload.wikimedia.org/wikipedia/en/a/a9/Example.jpg",
    "caption": "An example image"
}
headers = {
    "accept": "application/json",
    "content-type": "application/json",
    "authorization": "Bearer Your_Token"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)
                                    
                                

                                    
import requests

url = "https://gate.whapi.cloud/messages/document"

payload = {
    "to": "919984351847",
    "media": "data:application/pdf;base64,JVBERi0xLjQKJdPr6eEKMSAwIG9iago8PC9UaXRsZSAoVGVybXMgb2YgU2VydmljZSBXaGFwaS5DbG91ZCkKL0NyZWF0b3IgKE1vemlsbGEvNS4wIFwoV2luZG93cyBOVCAxMC4wOyBXaW42NDsgeDY0XCkgQXBwbGVXZWJLaXQvNTM3LjM2IFwoS0h............",
    "filename": "Terms of Service Whapi.Cloud.pdf",
    "caption": "Hello, I am attaching an important file to my message"
}
headers = {
    "accept": "application/json",
    "content-type": "application/json",
    "authorization": "Bearer Your_Token"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)
                                    
                                

                                    
import requests

url = "https://gate.whapi.cloud/groups"

payload = {
    "participants": ["919984351847", "919984351848", "919984351849"],
    "subject": "Group Subject 3"
}
headers = {
    "accept": "application/json",
    "content-type": "application/json",
    "authorization": "Bearer Your_Token"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)