FacebookBot.php

<?php

class FacebookBot
{
	private $_validationToken;
	private $_pageAccessToken;
	private $_receivedMessages;
	

	/*PER DEBUG;
	public function __construct($vaildation_token,$page_token)
	{
		$this->_validationToken = $vaildation_token;
		$this->_pageAccessToken = $page_token;
	}
	*/
	
	public function __construct()
	{
		$this->_validationToken = getenv('FACEBOOK_VALIDATION_TOKEN');
		$this->_pageAccessToken = getenv('FACEBOOK_PAGE_ACCESS_TOKEN');
		$this->setupWebhook();
	}
	
	public function getReceivedMessages()
	{
		return $this->_receivedMessages;
	}
	public function getPageAccessToken()
	{
		return $this->_pageAccessToken;
	}
	public function getValidationToken()
	{
		return $this->_validationToken;
	}
	private function setupWebhook()
	{
		if(isset($_REQUEST['hub_challenge']) && isset($_REQUEST['hub_verify_token']) && $this->getValidationToken()==$_REQUEST['hub_verify_token'])
		{
			echo $_REQUEST['hub_challenge'];
			exit;
		}
	}
	public function sendTextMessage($recipientId, $text)
	{
		$url = "https://graph.facebook.com/v2.6/me/messages?access_token=%s";
		$url = sprintf($url, $this->getPageAccessToken());
		$recipient = new \stdClass();
		$recipient->id = $recipientId;
		$message = new \stdClass();
		$message->text = $text;
		$parameters = ['recipient' => $recipient, 'message' => $message];
		$response = self::executePost($url, $parameters, true);
		if($response)
		{
			$responseObject = json_decode($response);
			return is_object($responseObject) && isset($responseObject->recipient_id) && isset($responseObject->message_id);
		}
		return false;
	}


	public function sendGenericMessage($recipientId, $feedTitle, $feedLink) {
		$url = "https://graph.facebook.com/v2.6/me/messages?access_token=%s";
		$url = sprintf($url, $this->getPageAccessToken());
	
		$recipient = new \stdClass();
		$recipient->id = $recipientId;
		
		$message = new \stdClass();
		$attachment = new \stdClass();
		$attachment->type = "template";
		$payload = new \stdClass();
		$payload->template_type = "generic";
		$elements = array();
		$el = new \stdClass();
		$el->title = $feedTitle;
		$buttons = array();
		$button = new \stdClass();
		$button->type = "web_url";
		$button->url = $feedLink;
		$button->title = "Vai alla notizia";
		$buttons[] = $button;
		$el->buttons = $buttons;
		$elements[] = $el;
		$payload->elements = $elements;
		$attachment->payload = $payload;
		$message->attachment = $attachment;

		$parameters = ['recipient' => $recipient, 'message' => $message];
		$response = self::executePost($url, $parameters, true);
		if($response)
		{
			$responseObject = json_decode($response);
			return is_object($responseObject) && isset($responseObject->recipient_id) && isset($responseObject->message_id);
		}
		return false;
	}

	//Imposta un pulsante start, visualizzato la prima volta che l'utente interagisce con la pagina
	public function setStartButton($callToSet)
	{
		$url = "https://graph.facebook.com/v2.6/me/thread_settings?access_token=%s";
		$url = sprintf($url, $this->getPageAccessToken());
		$request = new \stdClass();
		$request->setting_type = 'call_to_actions';
		$request->thread_state = 'new_thread';
		$callToAction = array();
		$callToAction[0] = new \stdClass();
		$callToAction[0]->payload = $callToSet;
		$request->call_to_actions = $callToAction;
		$response = self::executePost($url, $request, true);
		if($response)
		{
			$responseObject = json_decode($response);
			return is_object($responseObject) && isset($responseObject->result) && strpos($responseObject->result, 'Success') !== false;
		}
		return false;
	}

	/*
	Imposta un messagio di testo di benvenuto.
	Viene visualizzato solo la prima volta in cui gli utenti interagiscono con le Pagine su Messenger.
	*/
	public function setWelcomeMessage($text)
	{
		$url = "https://graph.facebook.com/v2.6/me/thread_settings?access_token=%s";
		$url = sprintf($url, $this->getPageAccessToken());
		$request = new \stdClass();
		$request->setting_type = 'greeting';
		$message = new stdClass();
		$message->text = $text;
		$request->greeting = $message;
		$response = self::executePost($url, $request, true);
		if($response)
		{
			$responseObject = json_decode($response);
			return is_object($responseObject) && isset($responseObject->result) && strpos($responseObject->result, 'Success') !== false;
		}
		return false;
	}
	    

	public function deleteWelcomeMessage($pageId)
	{
		$url = "https://graph.facebook.com/v2.6/%s/thread_settings?access_token=%s";
		$url = sprintf($url, $pageId, $this->getPageAccessToken());
		$request = new \stdClass();
		$request->setting_type = "call_to_actions";
		$request->thread_state = "new_thread";
		$request->call_to_actions = [];
		$response = self::executePost($url, $request, true);
		if($response)
		{
			$responseObject = json_decode($response);
			return is_object($responseObject) && isset($responseObject->result) && strpos($responseObject->result, 'Success') !== false;
		}
		return false;
	}
	
	public function run()
	{
		$request = self::getJsonRequest();
		if(!$request) return;
		$entries = isset($request->entry) ? $request->entry : null;
		if(!$entries) return;
		$messages = [];
		foreach ($entries as $entry)
		{
			$messagingList = isset($entry->messaging) ? $entry->messaging : null;
			if(!$messagingList) continue;
			foreach ($messagingList as $messaging)
			{
				$message = new \stdClass();
				$message->entryId = isset($entry->id) ? $entry->id : null;
				$message->senderId = isset($messaging->sender->id) ? $messaging->sender->id : null;
				$message->recipientId = isset($messaging->recipient->id) ? $messaging->recipient->id : null;
				$message->timestamp = isset($messaging->timestamp) ? $messaging->timestamp : null;
				$message->messageId = isset($messaging->message->mid) ? $messaging->message->mid : null;
				$message->sequenceNumber = isset($messaging->message->seq) ? $messaging->message->seq : null;
				$message->text = isset($messaging->message->text) ? $messaging->message->text : null;
				$message->attachments = isset($messaging->message->attachments) ? $messaging->message->attachments : null;
				//Aggiunta per handle della postback
				$message->postback = isset($messaging->postback->payload) ? $messaging->postback->payload : null;
				$messages[] = $message;
			}
		}
		$this->_receivedMessages = $messages;
	}
	public function subscribeAppToThePage()
	{
		$url = "https://graph.facebook.com/v2.6/me/subscribed_apps";
		$parameters = ['access_token' => $this->getPageAccessToken()];
		$response = self::executePost($url, $parameters);
		if($response)
		{
			$responseObject = json_decode($response);
			return is_object($responseObject) && isset($responseObject->success) && $responseObject->success=="true";
		}
		return false;
	}
	private static function getJsonRequest()
	{
		$content = file_get_contents("php://input");
		return json_decode($content, false, 512, JSON_BIGINT_AS_STRING);
	}
	
	private static function executePost($url, $parameters, $json = false)
	{
		$ch = curl_init();
		curl_setopt($ch, CURLOPT_URL, $url);
		if($json)
		{
			$data = json_encode($parameters);
			curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
			curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
			curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type: application/json', 'Content-Length: ' . strlen($data)));
		}
		else
		{
			curl_setopt($ch, CURLOPT_POST, count($parameters));
			curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($parameters));
		}
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
		curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
		curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
		$response = curl_exec($ch);
		curl_close($ch);
		return $response;
	}
}