【PHP】LINE Messaging APIで田村ゆかりさんの公式サイト更新通知BOTを作りなおした #yukarin

2016年10月13日

1 LINE Messaging API
- 1.1 Webhookの設定
2 実装
- 2.1 callback
- 2.2 Push（BOTからユーザーへメッセージ送信）
3 戯言

従来のLINE BOT APIが廃止予定ということで
新たに発表されたLINE Messaging APIに移行しました。

作ったものはこんな感じ普通です。
LINE Messaging API は管理画面から背景色とかアカウント設定できる項目はめっちゃ増えてて
LINE BOT APIよりは個性的なものが作れそう(^o^)

田村ゆかりさんに興味がある人、待ってます＼(^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

<?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();
}

<?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();

}

<?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');
    }
}

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と同じで

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();
        }
    }

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からユーザーへメッセージ送信）

<?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);
}

<?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);

}

<?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);
    }
}

<?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便利だし何より速い。

メッセージを送信する関数は

    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);