[PHP] 텔레그램 웹훅(Webhook) 사용하여 실시간 체크 봇 만들기! #4

안녕하세요 곰이에요!

 

어제는 웹 훅과 폴링에 대해서 개념을 정리하는 포스팅을 올렸었는데요!

 

오늘은 웹 훅 방식으로 텔레그램 봇과 통신하는 법에 대해서 알아보도록 하겠습니다.

 

 

 

준비해야 하는 것

php 설치가 되어있는 웹서버

웹 훅 연결을 위한 callback url (도메인 연결된 사이트가 필요) 1번과 연결된 도메인이 여야 합니다.

 

저는 NAS가 있어서 웹서버라던지 callback url을 쉽게 만들 수 있었는데요

 

위의 준비물이 준비가 되었으니 저는 test_webhook.php라는 파일을 만들어주겠습니다.

 

https://자신의 도메인/test_webhook.php 이런 식으로 접근이 되게 끔요.

 

php 소스는 아래 접은 글로 표기하겠습니다. 필요하신 분은 펼쳐서 참고해주세요 ^^

<?
	/**
	*   @comment
	*     - 텔레그램 웹훅 방식 통신
	*   @modified by   개발쉽게하자곰
	*   @modified      22.11.01
	**/

	//봇 api 토큰
	define('BOT_TOKEN', '자신의 봇 토큰');
	//api url
	define('API_URL', 'https://api.telegram.org/bot'.BOT_TOKEN.'/');
	//웹훅 주소
	define('WEBHOOK_URL', API_URL.'setWebhook?url=자신의 도메인/test_webhook.php/'.BOT_TOKEN);

	function exec_curl_request($handle) 
	{
		$response = curl_exec($handle);

		if ($response === false) {
			$errno = curl_errno($handle);
			$error = curl_error($handle);
			error_log("Curl returned error $errno: $error\n");
			curl_close($handle);
			return false;
		}

		$http_code = intval(curl_getinfo($handle, CURLINFO_HTTP_CODE));
		curl_close($handle);

		if ($http_code >= 500) 
		{
			// do not wat to DDOS server if something goes wrong
			sleep(10);
			return false;
		} 
		else if ($http_code != 200) 
		{
			$response = json_decode($response, true);
			error_log("Request has failed with error {$response['error_code']}: {$response['description']}\n");
			if ($http_code == 401) 
			{
				throw new Exception('Invalid access token provided');
			}
			return false;
		} 
		else 
		{
			$response = json_decode($response, true);
			if (isset($response['description'])) 
			{
				error_log("Request was successful: {$response['description']}\n");
			}
			$response = $response['result'];
		}
		 return $response;
	}

	function apiRequest($method, $parameters) 
	{
		if (!is_string($method)) 
		{
			error_log("Method name must be a string\n");
			return false;
		}

		if (!$parameters) 
		{
			$parameters = array();
		} 
		else if (!is_array($parameters)) 
		{
			error_log("Parameters must be an array\n");
			return false;
		}

		foreach ($parameters as $key => &$val) 
		{
			// encoding to JSON array parameters, for example reply_markup
			if (!is_numeric($val) && !is_string($val)) 
			{
				$val = json_encode($val);
			}
		}
		$url = API_URL.$method.'?'.http_build_query($parameters);

		$handle = curl_init($url);
		curl_setopt($handle, CURLOPT_RETURNTRANSFER, true);
		curl_setopt($handle, CURLOPT_CONNECTTIMEOUT, 5);
		curl_setopt($handle, CURLOPT_TIMEOUT, 60);

		return exec_curl_request($handle);
	}

	function apiRequestJson($method, $parameters) 
	{
		if (!is_string($method)) 
		{
			error_log("Method name must be a string\n");
			return false;
		}

		if (!$parameters) 
		{
			$parameters = array();
		} 
		else if (!is_array($parameters)) 
		{
			error_log("Parameters must be an array\n");
			return false;
		}

		$parameters["method"] = $method;

		$handle = curl_init(API_URL);
		curl_setopt($handle, CURLOPT_RETURNTRANSFER, true);
		curl_setopt($handle, CURLOPT_CONNECTTIMEOUT, 5);
		curl_setopt($handle, CURLOPT_TIMEOUT, 60);
		curl_setopt($handle, CURLOPT_POST, true);
		curl_setopt($handle, CURLOPT_POSTFIELDS, json_encode($parameters));
		curl_setopt($handle, CURLOPT_HTTPHEADER, array("Content-Type: application/json"));

		return exec_curl_request($handle);
	}

	function processMessage($message) 
	{
		// process incoming message
		if(is_array($message["message"]) == true) 
		{
			$message_id	= $message["message"]['message_id'];
			$chat_id	= $message["message"]['chat']['id'];
		}
		else if(is_array($message["channel_post"]) == true)
		{
			$message_id	= $message["channel_post"]['message_id'];
			$chat_id	= $message["channel_post"]['chat']['id'];
		}

		if(isset($message["message"]['text']) || isset($message["channel_post"]['text'])) 
		{
			// incoming text message
			if(is_array($message["message"]) == true) 
			{
				$text = $message["message"]['text'];
			}
			else if(is_array($message["channel_post"]) == true)
			{
				$text = $message["channel_post"]['text'];
			}
			if(strpos($text, "/start") === 0)
			{
				apiRequestJson("sendMessage", array('chat_id' => $chat_id, "text" => 'Hello', 'reply_markup' => array(
					'keyboard' => array(array('Hello', 'Hi')),
					'one_time_keyboard' => true,
					'resize_keyboard' => true)));
			}
			else if ($text === "Hello" || $text === "Hi")
			{
				apiRequest("sendMessage", array('chat_id' => $chat_id, "text" => 'Nice to meet you'));
			}
			else 
			{
				apiRequest("sendMessage", array('chat_id' => $chat_id, "text" => 'Cool'));
			}
		}
		else 
		{
			apiRequest("sendMessage", array('chat_id' => $chat_id, "text" => 'No.'));
		}
	}

	if (php_sapi_name() == 'cli') 
	{
		// if run from console, set or delete webhook
		apiRequest('setWebhook', array('url' => isset($argv[1]) && $argv[1] == 'delete' ? '' : WEBHOOK_URL));
		exit;
	}

	$content = @file_get_contents("php://input");
	$update = json_decode($content, true);
	if(!$update) 
	{
		exit;
	}

	if(isset($update)) 
	{
		processMessage($update);
	}

	exit;
?>

위처럼 php 파일을 만들어주고 봇 토큰과 가장 중요한 webhook 설정인데요.

 

웹 훅 설정 url은 

 

https://api.telegram.org/bot{봇토큰}/setWebhook?url={자신의도메인}/bot_webhook.php/{봇토큰} 

 

이런 식으로 설정할 수 있습니다.

 

저의 봇 토큰은 5695678451:AAEBBcGX3ZWCQG248E2Reo1x6HKqlc-IiDM 입니다.

 

대입을 하면

 

https://api.telegram.org/bot5695678451:AAEBBcGX3ZWCQG248E2Reo1x6HKqlc-IiDM/setWebhook?url={자신의도메인}/bot_webhook.php/5695678451:AAEBBcGX3ZWCQG248E2Reo1x6HKqlc-IiDM 

 

이렇게 되겠네요 자신의 도메인이라는 곳에는 아까 위에서 말씀드렸다시피 php 파일과 연결된 도메인이어야 합니다.

 

그럼 웹 훅을 설정해보겠습니다.

 

정상적으로 웹 훅이 설정되었다고 합니다.

 

이제부터 이 봇은 저와 대화를 할 수 있는 봇이 되었습니다.

 

function processMessage($message) 
	{
		// process incoming message
		if(is_array($message["message"]) == true) 
		{
			$message_id	= $message["message"]['message_id'];
			$chat_id	= $message["message"]['chat']['id'];
		}
		else if(is_array($message["channel_post"]) == true)
		{
			$message_id	= $message["channel_post"]['message_id'];
			$chat_id	= $message["channel_post"]['chat']['id'];
		}

		if(isset($message["message"]['text']) || isset($message["channel_post"]['text'])) 
		{
			// incoming text message
			if(is_array($message["message"]) == true) 
			{
				$text = $message["message"]['text'];
			}
			else if(is_array($message["channel_post"]) == true)
			{
				$text = $message["channel_post"]['text'];
			}
			if(strpos($text, "/start") === 0)
			{
				apiRequestJson("sendMessage", array('chat_id' => $chat_id, "text" => 'Hello', 'reply_markup' => array(
					'keyboard' => array(array('Hello', 'Hi')),
					'one_time_keyboard' => true,
					'resize_keyboard' => true)));
			}
			else if ($text === "Hello" || $text === "Hi")
			{
				apiRequest("sendMessage", array('chat_id' => $chat_id, "text" => 'Nice to meet you'));
			}
			else 
			{
				apiRequest("sendMessage", array('chat_id' => $chat_id, "text" => 'Cool'));
			}
		}
		else 
		{
			apiRequest("sendMessage", array('chat_id' => $chat_id, "text" => 'No.'));
		}
	}

접은 소스 중에서 processMessage라는 함수가 있었습니다.

 

여기서 제가 입력할 말을 받아서 어떻게 답을 해줘야 하는지 적혀있는데요.

 

저는 우선 /start라는 명령어를 입력하면 

 

봇은 hello 하면서 저에게 인라인 버튼 두 개를 주게 됩니다.

 

Hello와 Hi라는 값으로요 눈으로 직접 보시죠.

 

어때요?? 확실히 실시간으로 반응을 합니다.

 

그럼 제가 Hello라는 버튼을 클릭해 볼게요. 그럼 봇은 Nice to meet you라는 값을 주도록 설정되어있습니다.

 

이런 식으로 바로바로 제가 봇에게 입력받을 수 있는 값을 주었을 때 봇은 저에게 설정된 값으로 응답하게 됩니다.

 

값을 응답을 못 받게 설정하면 Cool이라는 값을 저에게 주게 됩니다.

 

이제 여기에 심화과정을 더하게 된다면 비로소 활용성 높고 멋진 봇이 탄생하겠죠 ㅎㅎ

 

아래는 제가 심심해서 만들고 있는 날씨 봇입니다.

그밖에도 비트코인 시세 알림 봇도 있어요 ㅎㅎ 아직 한참 물려있어서 ㅜㅜ

설정한 가격대에 도달하면 1분마다 알림이 계속 오게끔 되어있습니다.

 

웹 훅을 써보았는데요 이제 저의 봇 토큰은 삭제할 예정입니다.

 

원래 봇 토큰은 유출되면 안 되기에 포스팅을 위해 잠깐 동안 만든 거라서요 ㅎㅎ

 

이상 포스팅을 마치도록 하겠습니다 긴 글 읽어주셔서 감사합니다!