従来のLINE BOT APIが廃止予定ということで
新たに発表されたLINE Messaging APIに移行しました。
作ったものはこんな感じ普通です。
LINE Messaging API は管理画面から背景色とかアカウント設定できる項目はめっちゃ増えてて
LINE BOT APIよりは個性的なものが作れそう(^o^)
LINE Messaging API
誰でも手軽に叩けるAPIです。
BOTも作成できるし、管理画面も用意されてて分かりやすい。
無料で作成するBOTはユーザーの発言に対しての返信はできる(REPLY_MESSAGE) が
BOTから直接メッセージを送信(PUSH_MESSAGE)するのは月2万ぐらいかかる。
しかし友達登録上限50人という制限付きBOTでは REPLY_MESSAGE & PUSH_MESSAGE
どちらも使える。
従来のLINE BOT APIと変わったことはそんなことなくて
移行難易度はそんなに高くないと思います。
Webhookの設定
今回実装にあたって少しだけハマったところは
Webhookの設定で、CloudflareのSSL機能を使ったサーバーを指定すると
Webhookが飛んでこないという仕様だった。
LINE BOT APIでは使えたんですけどね、いずれか使えるようにはなりそう。
ちなみにLet’s Encryptでは可能です。
実装
今回もPHPです。
特に理由はありません。楽だからです。
callback
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 |
<?php require_once './lib/callback_class.php'; /* LINE */ $CHANNEL_SECRET = ''; $CHANNEL_ACCESS_TOKEN = ''; /* TWITTER */ $CONSUMER_KEY = ''; $CONSUMER_SECRET = ""; $ACCESS_TOKEN = ""; $ACCESS_TOKEN_SECRET = ""; $json_input = file_get_contents('php://input'); $yows = new YOWS($CHANNEL_SECRET, $CHANNEL_ACCESS_TOKEN, $json_input); if ($yows->type === "unfollow") { $yows->unRegister($yows->userid); } elseif ($yows->type === "follow" && $yows->checkRegister($yows->userid) === 0) { $profile = $yows->getProfile($yows->userid); $yows->register($yows->userid); $yows->pushMessage($yows->userid, "登録ありがとうございます ??3 hearts?\n\n・田村ゆかり公式サイト\n・ファンクラブサイト\nの更新をお知らせ致します??light bulb?\n\nなお、当アカウントをブロックすることで利用の停止ができます ??content?"); } elseif ($yows->type === "follow" && $yows->checkRegister($yows->userid) === 1) { $yows->pushMessage($yows->userid, "既に登録済みです。"); } else { die(); } |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 |
<?php require_once 'twitteroauth/twitteroauth.php'; class YOWS { private $CHANNEL_SECRET = ''; private $CHANNEL_ACCESS_TOKEN = ''; public $header = []; public $data, $userid, $type = ''; public function __construct($CHANNEL_SECRET, $CHANNEL_ACCESS_TOKEN, $data) { $this->CHANNEL_SECRET = $CHANNEL_SECRET; $this->CHANNEL_ACCESS_TOKEN = $CHANNEL_ACCESS_TOKEN; $this->data = $data; $this->getallheaders(); $this->checkSignature(); $this->setVariables(); } private function getallheaders() { $header = ''; foreach ($_SERVER as $name => $value) { if (substr($name, 0, 5) == 'HTTP_') { $header[strtoupper(str_replace(' ', '-', ucwords(str_replace('_', ' ', substr($name, 5)))))] = $value; } } $this->header = $header; } public function checkSignature() { if (base64_decode($this->header["X-LINE-SIGNATURE"]) === hash_hmac('sha256', $this->data, $this->CHANNEL_SECRET, true)) { $this->data = json_decode($this->data, true); } else { die(); } } private function setVariables() { foreach ($this->data as $row) { $this->type = $row[0]['type']; $this->userid = $row[0]['source']['userId']; } } /** * @param $USERID * @return int 0=not register / 1=registerd */ public function checkRegister($USERID) { try { $pdo = new PDO('mysql:dbname=; host=', '', '', array(PDO::ATTR_EMULATE_PREPARES => false)); $sql = "SELECT * FROM line WHERE userid='${USERID}'"; $stmt = $pdo->query($sql); foreach ($stmt as $row) { $query_result = $row['id']; } empty($query_result) === true ? $result = 0 : $result = 1; return $result; } catch (PDOException $e) { $this->debug('Error:' . $e->getMessage()); die(); } } public function register($USERID) { try { $pdo = new PDO('mysql:dbname=; host=', '', '', array(PDO::ATTR_EMULATE_PREPARES => false)); $stmt = $pdo->prepare('INSERT INTO line (userid, date) VALUES (:register_userid, :date)'); $stmt->execute(array(':register_userid' => $USERID, ':date' => $this->getDate())); } catch (PDOException $e) { $this->debug('Error:' . $e->getMessage()); die(); } } public function unRegister($USERID) { try { $pdo = new PDO('mysql:dbname=; host=', '', '', array(PDO::ATTR_EMULATE_PREPARES => false)); $stmt = $pdo->prepare('DELETE FROM line WHERE userid = :delete_userid'); $stmt->execute(array(':delete_userid' => $USERID)); } catch (PDOException $e) { $this->debug('Error:' . $e->getMessage()); die(); } } private function getDate() { return date("Y-m-d H:i:s"); } public function pushMessage($USERID, $msg) { $format_text = [ "type" => "text", "text" => $msg ]; $post_data = [ "to" => $USERID, "messages" => [$format_text] ]; $header = array( 'Content-Type: application/json', 'Authorization: Bearer ' . $this->CHANNEL_ACCESS_TOKEN ); $ch = curl_init('https://api.line.me/v2/bot/message/push'); curl_setopt($ch, CURLOPT_POST, true); curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST'); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($post_data)); curl_setopt($ch, CURLOPT_HTTPHEADER, $header); $result = curl_exec($ch); curl_close($ch); } public function debug($string) { error_log(print_r($string, true), 3, '/var/log/nginx/error.log'); } } |
LINEからのアクセスかどうかは従来のLINE BOT APIと同じで
1 2 3 4 5 6 7 8 |
public function checkSignature() { if (base64_decode($this->header["X-LINE-SIGNATURE"]) === hash_hmac('sha256', $this->data, $this->CHANNEL_SECRET, true)) { $this->data = json_decode($this->data, true); } else { die(); } } |
こんな感じで署名の確認ができる。
Push(BOTからユーザーへメッセージ送信)
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 |
<?php require_once 'lib/push_class.php'; $URL = "http://www.tamurayukari.com/"; $old_url = file_get_contents('old_url'); /* LINE */ $CHANNEL_ACCESS_TOKEN = ''; $yows = new Push($URL, $CHANNEL_ACCESS_TOKEN); $latest_content = $yows->crawler->filter('div#news_table td a')->text(); $latest_url = $yows->crawler->filter('div#news_table td a')->attr('href'); if($latest_url !== $old_url) { $msg = "【サイト更新通知BOTよりお知らせ】\r\n公式サイトが更新されました!\r\n\r\n【タイトル】\r\n{$latest_content}\r\n\r\n詳しくはこちらへ!\r\n${latest_url}"; foreach ($yows->getUserid() as $userid) { $yows->pushMessage($userid, $msg); } file_put_contents('old_url', $latest_url); } |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 |
<?php require_once 'goutte/vendor/autoload.php'; use Goutte\Client; class Push { private $CHANNEL_ACCESS_TOKEN, $url = ''; public $client, $crawler = ''; public function __construct($url, $CHANNEL_ACCESS_TOKEN) { $this->client = new Client(); $this->url = $url; $this->CHANNEL_ACCESS_TOKEN = $CHANNEL_ACCESS_TOKEN; $this->crawler = $this->client->request('GET', $this->url); } public function getUserid() { try { $array_userid = []; $pdo = new PDO('mysql:dbname=yukarinotification; host=database.cma0jldtuyey.us-west-2.rds.amazonaws.com', 'luis', 'luism8526', array(PDO::ATTR_EMULATE_PREPARES => false)); $stmt = $pdo->query("SELECT * FROM line"); foreach ($stmt as $row) { $array_userid[] = $row['userid']; } return $array_userid; } catch (PDOException $e) { /** ERROR HANDLING */ die(); } } public function pushMessage($USERID, $msg) { $format_text = [ "type" => "text", "text" => $msg ]; $post_data = [ "to" => $USERID, "messages" => [$format_text] ]; $header = array( 'Content-Type: application/json', 'Authorization: Bearer ' . $this->CHANNEL_ACCESS_TOKEN ); $ch = curl_init('https://api.line.me/v2/bot/message/push'); curl_setopt($ch, CURLOPT_POST, true); curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST'); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($post_data)); curl_setopt($ch, CURLOPT_HTTPHEADER, $header); $result = curl_exec($ch); curl_close($ch); } } |
LINEにリクエストを投げるときはCHANNEL_ACCESS_TOKEN
をヘッダーに載せるだけ。
LINE DeveloperからサーバーのIPをホワイトリストに登録する必要はあります。
今回の話に関係はないですけどGoutte便利だし何より速い。
メッセージを送信する関数は
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 |
public function pushMessage($USERID, $msg) { $format_text = [ "type" => "text", "text" => $msg ]; $post_data = [ "to" => $USERID, "messages" => [$format_text] ]; $header = array( 'Content-Type: application/json', 'Authorization: Bearer ' . $this->CHANNEL_ACCESS_TOKEN ); $ch = curl_init('https://api.line.me/v2/bot/message/push'); curl_setopt($ch, CURLOPT_POST, true); curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST'); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($post_data)); curl_setopt($ch, CURLOPT_HTTPHEADER, $header); $result = curl_exec($ch); curl_close($ch); |
特筆することなし!
戯言
Webhookに関してはイベント内容がJSON見れば一発で分かるようになったので楽でした。
LINE BOT APIでは type 1 が友達追加時で~ type3 がユーザーからのメッセージとかで
分かりにくかった。
あとはドキュメントも日本語が用意されて、各言語のSDKも用意されているので
比較的容易に移行(作成)できました。
ソースコードはこちら
rluisr/yukari-line-botA – github