md-riaz/whatsapp.class.php

## whatsapp.class.php
<?php

class WhatsappClass
{
    private $phoneNumberId;
    private $accessToken;
    private $url;

    /**
     * @param string $phoneNumberId
     * @param string $accessToken
     * @param string $version
     * @throws Exception
     */
    public function __construct(string $phoneNumberId, string $accessToken, string $version = "v19.0")
    {
        if (empty($phoneNumberId) || empty($accessToken)) {
            throw new Exception('phone_number_id and access_token are required');
        }
        $this->phoneNumberId = $phoneNumberId;
        $this->accessToken = $accessToken;
        $this->url = "https://graph.facebook.com/{$version}/{$this->phoneNumberId}/messages";
    }

    /**
     * @param string $url
     * @param array $data
     * @return mixed
     * @throws Exception
     */
    private function sendRequest(string $url, array $data)
    {
        $ch = curl_init($url);

        curl_setopt($ch, CURLOPT_HTTPHEADER, [
            'Content-Type: application/json',
            'Authorization: Bearer ' . $this->accessToken,
            'Accept: application/json'
        ]);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_POST, true);
        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));

        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);

        if ($httpCode >= 400) {
            throw new Exception("HTTP Error: $httpCode - Response: $response");
        }

        if (curl_errno($ch)) {
            throw new Exception('Curl error: ' . curl_error($ch));
        }

        curl_close($ch);

        return json_decode($response, true);
    }

    /**
     * @param string $message
     * @param string $recipientId
     * @param string $recipientType
     * @param bool $previewUrl
     * @return mixed
     * @throws Exception
     */
    public function sendMessage(
        string $message,
        string $recipientId,
        string $recipientType = "individual",
        bool $previewUrl = true
    ) {
        $data = [
            "messaging_product" => "whatsapp",
            "recipient_type" => $recipientType,
            "to" => $recipientId,
            "type" => "text",
            "text" => ["preview_url" => $previewUrl, "body" => $message],
        ];

        return $this->sendRequest($this->url, $data);
    }

     /**
     * @param string $template
     * @param string $recipientId
     * @param string $lang
     * @param array $parameters
     * @return mixed
     * @throws Exception
     */
    public function sendTemplate(string $template, string $recipientId, string $lang = "en_US", array $parameters = [])
    {
        $templateData = ["name" => $template, "language" => ["code" => $lang]];

        if (!empty($parameters)) {
            $templateData["components"] = [["type" => "body", "parameters" => $this->buildParameters($parameters)]];
        }

        $data = [
            "messaging_product" => "whatsapp",
            "to" => $recipientId,
            "type" => "template",
            "template" => $templateData,
        ];

        return $this->sendRequest($this->url, $data);
    }

    /**
     * @param string $lat
     * @param string $long
     * @param string $name
     * @param string $address
     * @param string $recipientId
     * @return mixed
     * @throws Exception
     */
    public function sendLocation(string $lat, string $long, string $name, string $address, string $recipientId)
    {
        $data = [
            "messaging_product" => "whatsapp",
            "to" => $recipientId,
            "type" => "location",
            "location" => [
                "latitude" => $lat,
                "longitude" => $long,
                "name" => $name,
                "address" => $address,
            ],
        ];

        return $this->sendRequest($this->url, $data);
    }

    /**
     * @param string $image
     * @param string $recipientId
     * @param string $recipientType
     * @param string|null $caption
     * @param bool $link
     * @return mixed
     * @throws Exception
     */
    public function sendImage($image, $recipientId, string $recipientType = "individual", $caption = null, $link = true)
    {
        $imageData = $link ? ["link" => $image, "caption" => $caption] : ["id" => $image, "caption" => $caption];

        $data = [
            "messaging_product" => "whatsapp",
            "recipient_type" => $recipientType,
            "to" => $recipientId,
            "type" => "image",
            "image" => $imageData,
        ];

        return $this->sendRequest($this->url, $data);
    }

    /**
     * @param string $audio
     * @param string $recipientId
     * @param bool $link
     * @return mixed
     * @throws Exception
     */
    public function sendAudio($audio, $recipientId, $link = true)
    {
        $audioData = $link ? ["link" => $audio] : ["id" => $audio];

        $data = [
            "messaging_product" => "whatsapp",
            "to" => $recipientId,
            "type" => "audio",
            "audio" => $audioData,
        ];

        return $this->sendRequest($this->url, $data);
    }

    /**
     * @param string $video
     * @param string $recipientId
     * @param string|null $caption
     * @param bool $link
     * @return mixed
     * @throws Exception
     */
    public function sendVideo($video, $recipientId, $caption = null, $link = true)
    {
        $videoData = $link ? ["link" => $video, "caption" => $caption] : ["id" => $video, "caption" => $caption];

        $data = [
            'messaging_product' => 'whatsapp',
            'to' => $recipientId,
            'type' => 'video',
            'video' => $videoData,
        ];

        return $this->sendRequest($this->url, $data);
    }

    /**
     * @param string $document
     * @param string $recipientId
     * @param string|null $caption
     * @param bool $link
     * @return mixed
     * @throws Exception
     */
    public function sendDocument($document, $recipientId, $caption = null, $link = true)
    {
        $documentData = $link ? ["link" => $document, "caption" => $caption] : ["id" => $document, "caption" => $caption];

        $data = [
            "messaging_product" => "whatsapp",
            "to" => $recipientId,
            "type" => "document",
            "document" => $documentData,
        ];

        return $this->sendRequest($this->url, $data);
    }

    /**
     * @param array $button
     * @return array
     */
    public function createButton(array $button)
    {
        return [
            "type" => "list",
            "header" => ["type" => "text", "text" => $button["header"]],
            "body" => ["text" => $button["body"]],
            "footer" => ["text" => $button["footer"]],
            "action" => $button["action"],
        ];
    }

    /**
     * @param array $button
     * @param string $recipientId
     * @return mixed
     * @throws Exception
     */
    public function sendButton(array $button, string $recipientId)
    {
        $data = [
            "messaging_product" => "whatsapp",
            "to" => $recipientId,
            "type" => "interactive",
            "interactive" => $this->createButton($button),
        ];

        return $this->sendRequest($this->url, $data);
    }


    /**
     * @param array $data
     * @return mixed
     */
    public function preprocess(array $data)
    {
        return $data["entry"][0]["changes"][0]["value"];
    }

  /**
     * @param array $data
     * @return mixed|null
     */
    public function getMobile(array $data)
    {
        $data = $this->preprocess($data);
        return $data["contacts"][0]["wa_id"] ?? null;
    }

    /**
     * @param array $data
     * @return mixed|null
     */
    public function getName(array $data)
    {
        $contact = $this->preprocess($data);
        return $contact["contacts"][0]["profile"]["name"] ?? null;
    }

    /**
     * @param array $data
     * @return mixed|null
     */
    public function getMessage(array $data)
    {
        $data = $this->preprocess($data);
        return $data["messages"][0]["text"]["body"] ?? null;
    }

    /**
     * @param array $data
     * @return mixed|null
     */
    public function getMessageId(array $data)
    {
        $data = $this->preprocess($data);
        return $data["messages"][0]["id"] ?? null;
    }

    /**
     * @param array $data
     * @return mixed|null
     */
    public function getMessageTimestamp(array $data)
    {
        $data = $this->preprocess($data);
        return $data["messages"][0]["timestamp"] ?? null;
    }

    /**
     * @param array $data
     * @return mixed|null
     */
    public function getInteractiveResponse(array $data)
    {
        $data = $this->preprocess($data);
        return $data["messages"][0]["interactive"]["list_reply"] ?? null;
    }

    /**
     * @param array $data
     * @return mixed|null
     */
    public function getMessageType(array $data)
    {
        $data = $this->preprocess($data);
        return $data["messages"][0]["type"] ?? null;
    }

    /**
     * @param array $data
     * @return mixed|null
     */
    public function getDelivery(array $data)
    {
        $data = $this->preprocess($data);
        return $data["statuses"][0]["status"] ?? null;
    }

    /**
     * @param array $data
     * @return string
     */
    public function changedField(array $data)
    {
        return $data["entry"][0]["changes"][0]["field"];
    }

    /**
     * Build Parameters for Template Message
     *
     * @param array $params
     * @return array
     */
    public function buildParameters(array $params)
    {
        $parameters = [];

        foreach ($params as $param) {
            if (isset($param['type'])) {
                $parameters[] = $param;
            } else {
                $parameters[] = [
                    'type' => 'text',
                    'text' => $param,
                ];
            }
        }

        return $parameters;
    }
}

    /**
     * Download media from WhatsApp
     * @param string $mediaId
     * @return string
     * @throws Exception
     */
    private function downloadMedia(string $mediaId)
    {
        $mediaUrl = "https://graph.facebook.com/v19.0/{$mediaId}";
        $ch = curl_init($mediaUrl);

        curl_setopt($ch, CURLOPT_HTTPHEADER, [
            'Authorization: Bearer ' . $this->accessToken,
        ]);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);

        if ($httpCode >= 400) {
            throw new Exception("HTTP Error: $httpCode - Response: $response");
        }

        if (curl_errno($ch)) {
            throw new Exception('Curl error: ' . curl_error($ch));
        }

        curl_close($ch);

        $responseArray = json_decode($response, true);
        return $responseArray['url'] ?? '';
    }

    /**
     * Save media content to database
     * @param string $url
     * @return string Path to the saved file
     * @throws Exception
     */
    private function saveMediaToDatabase(string $url)
    {
        $ch = curl_init($url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

        $mediaContent = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);

        if ($httpCode >= 400) {
            throw new Exception("HTTP Error: $httpCode - Response: $mediaContent");
        }

        if (curl_errno($ch)) {
            throw new Exception('Curl error: ' . curl_error($ch));
        }

        curl_close($ch);

        // Save media to database or filesystem
        // Assuming we save it to the filesystem for this example
        $filePath = 'path/to/save/' . basename($url);
        file_put_contents($filePath, $mediaContent);

        return $filePath;
    }

    /**
     * Handle incoming messages and extract media
     * @param array $data
     * @throws Exception
     */
    public function handleIncomingMessage(array $data)
    {
        $messageData = $this->preprocess($data);

        foreach ($messageData["messages"] as $message) {
            if (isset($message["image"])) {
                $mediaUrl = $this->downloadMedia($message["image"]["id"]);
                $savedPath = $this->saveMediaToDatabase($mediaUrl);
                // Save the file path to your database here
            } elseif (isset($message["document"])) {
                $mediaUrl = $this->downloadMedia($message["document"]["id"]);
                $savedPath = $this->saveMediaToDatabase($mediaUrl);
                // Save the file path to your database here
            }
            // Handle other media types similarly
        }
    }
}
	<?php

	class WhatsappClass
	{
	private $phoneNumberId;
	private $accessToken;
	private $url;

	/**
	* @param string $phoneNumberId
	* @param string $accessToken
	* @param string $version
	* @throws Exception
	*/
	public function __construct(string $phoneNumberId, string $accessToken, string $version = "v19.0")
	{
	if (empty($phoneNumberId) \|\| empty($accessToken)) {
	throw new Exception('phone_number_id and access_token are required');
	}
	$this->phoneNumberId = $phoneNumberId;
	$this->accessToken = $accessToken;
	$this->url = "https://graph.facebook.com/{$version}/{$this->phoneNumberId}/messages";
	}

	/**
	* @param string $url
	* @param array $data
	* @return mixed
	* @throws Exception
	*/
	private function sendRequest(string $url, array $data)
	{
	$ch = curl_init($url);

	curl_setopt($ch, CURLOPT_HTTPHEADER, [
	'Content-Type: application/json',
	'Authorization: Bearer ' . $this->accessToken,
	'Accept: application/json'
	]);
	curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
	curl_setopt($ch, CURLOPT_POST, true);
	curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));

	$response = curl_exec($ch);
	$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);

	if ($httpCode >= 400) {
	throw new Exception("HTTP Error: $httpCode - Response: $response");
	}

	if (curl_errno($ch)) {
	throw new Exception('Curl error: ' . curl_error($ch));
	}

	curl_close($ch);

	return json_decode($response, true);
	}

	/**
	* @param string $message
	* @param string $recipientId
	* @param string $recipientType
	* @param bool $previewUrl
	* @return mixed
	* @throws Exception
	*/
	public function sendMessage(
	string $message,
	string $recipientId,
	string $recipientType = "individual",
	bool $previewUrl = true
	) {
	$data = [
	"messaging_product" => "whatsapp",
	"recipient_type" => $recipientType,
	"to" => $recipientId,
	"type" => "text",
	"text" => ["preview_url" => $previewUrl, "body" => $message],
	];

	return $this->sendRequest($this->url, $data);
	}

	/**
	* @param string $template
	* @param string $recipientId
	* @param string $lang
	* @param array $parameters
	* @return mixed
	* @throws Exception
	*/
	public function sendTemplate(string $template, string $recipientId, string $lang = "en_US", array $parameters = [])
	{
	$templateData = ["name" => $template, "language" => ["code" => $lang]];

	if (!empty($parameters)) {
	$templateData["components"] = [["type" => "body", "parameters" => $this->buildParameters($parameters)]];
	}

	$data = [
	"messaging_product" => "whatsapp",
	"to" => $recipientId,
	"type" => "template",
	"template" => $templateData,
	];

	return $this->sendRequest($this->url, $data);
	}

	/**
	* @param string $lat
	* @param string $long
	* @param string $name
	* @param string $address
	* @param string $recipientId
	* @return mixed
	* @throws Exception
	*/
	public function sendLocation(string $lat, string $long, string $name, string $address, string $recipientId)
	{
	$data = [
	"messaging_product" => "whatsapp",
	"to" => $recipientId,
	"type" => "location",
	"location" => [
	"latitude" => $lat,
	"longitude" => $long,
	"name" => $name,
	"address" => $address,
	],
	];

	return $this->sendRequest($this->url, $data);
	}

	/**
	* @param string $image
	* @param string $recipientId
	* @param string $recipientType
	* @param string\|null $caption
	* @param bool $link
	* @return mixed
	* @throws Exception
	*/
	public function sendImage($image, $recipientId, string $recipientType = "individual", $caption = null, $link = true)
	{
	$imageData = $link ? ["link" => $image, "caption" => $caption] : ["id" => $image, "caption" => $caption];

	$data = [
	"messaging_product" => "whatsapp",
	"recipient_type" => $recipientType,
	"to" => $recipientId,
	"type" => "image",
	"image" => $imageData,
	];

	return $this->sendRequest($this->url, $data);
	}

	/**
	* @param string $audio
	* @param string $recipientId
	* @param bool $link
	* @return mixed
	* @throws Exception
	*/
	public function sendAudio($audio, $recipientId, $link = true)
	{
	$audioData = $link ? ["link" => $audio] : ["id" => $audio];

	$data = [
	"messaging_product" => "whatsapp",
	"to" => $recipientId,
	"type" => "audio",
	"audio" => $audioData,
	];

	return $this->sendRequest($this->url, $data);
	}

	/**
	* @param string $video
	* @param string $recipientId
	* @param string\|null $caption
	* @param bool $link
	* @return mixed
	* @throws Exception
	*/
	public function sendVideo($video, $recipientId, $caption = null, $link = true)
	{
	$videoData = $link ? ["link" => $video, "caption" => $caption] : ["id" => $video, "caption" => $caption];

	$data = [
	'messaging_product' => 'whatsapp',
	'to' => $recipientId,
	'type' => 'video',
	'video' => $videoData,
	];

	return $this->sendRequest($this->url, $data);
	}

	/**
	* @param string $document
	* @param string $recipientId
	* @param string\|null $caption
	* @param bool $link
	* @return mixed
	* @throws Exception
	*/
	public function sendDocument($document, $recipientId, $caption = null, $link = true)
	{
	$documentData = $link ? ["link" => $document, "caption" => $caption] : ["id" => $document, "caption" => $caption];

	$data = [
	"messaging_product" => "whatsapp",
	"to" => $recipientId,
	"type" => "document",
	"document" => $documentData,
	];

	return $this->sendRequest($this->url, $data);
	}

	/**
	* @param array $button
	* @return array
	*/
	public function createButton(array $button)
	{
	return [
	"type" => "list",
	"header" => ["type" => "text", "text" => $button["header"]],
	"body" => ["text" => $button["body"]],
	"footer" => ["text" => $button["footer"]],
	"action" => $button["action"],
	];
	}

	/**
	* @param array $button
	* @param string $recipientId
	* @return mixed
	* @throws Exception
	*/
	public function sendButton(array $button, string $recipientId)
	{
	$data = [
	"messaging_product" => "whatsapp",
	"to" => $recipientId,
	"type" => "interactive",
	"interactive" => $this->createButton($button),
	];

	return $this->sendRequest($this->url, $data);
	}


	/**
	* @param array $data
	* @return mixed
	*/
	public function preprocess(array $data)
	{
	return $data["entry"][0]["changes"][0]["value"];
	}

	/**
	* @param array $data
	* @return mixed\|null
	*/
	public function getMobile(array $data)
	{
	$data = $this->preprocess($data);
	return $data["contacts"][0]["wa_id"] ?? null;
	}

	/**
	* @param array $data
	* @return mixed\|null
	*/
	public function getName(array $data)
	{
	$contact = $this->preprocess($data);
	return $contact["contacts"][0]["profile"]["name"] ?? null;
	}

	/**
	* @param array $data
	* @return mixed\|null
	*/
	public function getMessage(array $data)
	{
	$data = $this->preprocess($data);
	return $data["messages"][0]["text"]["body"] ?? null;
	}

	/**
	* @param array $data
	* @return mixed\|null
	*/
	public function getMessageId(array $data)
	{
	$data = $this->preprocess($data);
	return $data["messages"][0]["id"] ?? null;
	}

	/**
	* @param array $data
	* @return mixed\|null
	*/
	public function getMessageTimestamp(array $data)
	{
	$data = $this->preprocess($data);
	return $data["messages"][0]["timestamp"] ?? null;
	}

	/**
	* @param array $data
	* @return mixed\|null
	*/
	public function getInteractiveResponse(array $data)
	{
	$data = $this->preprocess($data);
	return $data["messages"][0]["interactive"]["list_reply"] ?? null;
	}

	/**
	* @param array $data
	* @return mixed\|null
	*/
	public function getMessageType(array $data)
	{
	$data = $this->preprocess($data);
	return $data["messages"][0]["type"] ?? null;
	}

	/**
	* @param array $data
	* @return mixed\|null
	*/
	public function getDelivery(array $data)
	{
	$data = $this->preprocess($data);
	return $data["statuses"][0]["status"] ?? null;
	}

	/**
	* @param array $data
	* @return string
	*/
	public function changedField(array $data)
	{
	return $data["entry"][0]["changes"][0]["field"];
	}

	/**
	* Build Parameters for Template Message
	*
	* @param array $params
	* @return array
	*/
	public function buildParameters(array $params)
	{
	$parameters = [];

	foreach ($params as $param) {
	if (isset($param['type'])) {
	$parameters[] = $param;
	} else {
	$parameters[] = [
	'type' => 'text',
	'text' => $param,
	];
	}
	}

	return $parameters;
	}
	}

	/**
	* Download media from WhatsApp
	* @param string $mediaId
	* @return string
	* @throws Exception
	*/
	private function downloadMedia(string $mediaId)
	{
	$mediaUrl = "https://graph.facebook.com/v19.0/{$mediaId}";
	$ch = curl_init($mediaUrl);

	curl_setopt($ch, CURLOPT_HTTPHEADER, [
	'Authorization: Bearer ' . $this->accessToken,
	]);
	curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

	$response = curl_exec($ch);
	$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);

	if ($httpCode >= 400) {
	throw new Exception("HTTP Error: $httpCode - Response: $response");
	}

	if (curl_errno($ch)) {
	throw new Exception('Curl error: ' . curl_error($ch));
	}

	curl_close($ch);

	$responseArray = json_decode($response, true);
	return $responseArray['url'] ?? '';
	}

	/**
	* Save media content to database
	* @param string $url
	* @return string Path to the saved file
	* @throws Exception
	*/
	private function saveMediaToDatabase(string $url)
	{
	$ch = curl_init($url);
	curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

	$mediaContent = curl_exec($ch);
	$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);

	if ($httpCode >= 400) {
	throw new Exception("HTTP Error: $httpCode - Response: $mediaContent");
	}

	if (curl_errno($ch)) {
	throw new Exception('Curl error: ' . curl_error($ch));
	}

	curl_close($ch);

	// Save media to database or filesystem
	// Assuming we save it to the filesystem for this example
	$filePath = 'path/to/save/' . basename($url);
	file_put_contents($filePath, $mediaContent);

	return $filePath;
	}

	/**
	* Handle incoming messages and extract media
	* @param array $data
	* @throws Exception
	*/
	public function handleIncomingMessage(array $data)
	{
	$messageData = $this->preprocess($data);

	foreach ($messageData["messages"] as $message) {
	if (isset($message["image"])) {
	$mediaUrl = $this->downloadMedia($message["image"]["id"]);
	$savedPath = $this->saveMediaToDatabase($mediaUrl);
	// Save the file path to your database here
	} elseif (isset($message["document"])) {
	$mediaUrl = $this->downloadMedia($message["document"]["id"]);
	$savedPath = $this->saveMediaToDatabase($mediaUrl);
	// Save the file path to your database here
	}
	// Handle other media types similarly
	}
	}
	}