Subversion Repositories qbpwcf-lib(archive)

<?php

/*

MIT License

Copyright (c) 2017 Galih Akbar Moerbayaksa

Permission is hereby granted, free of charge, to any person obtaining a copy

of this software and associated documentation files (the "Software"), to deal

in the Software without restriction, including without limitation the rights

to use, copy, modify, merge, publish, distribute, sublicense, and/or sell

copies of the Software, and to permit persons to whom the Software is

furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in all

copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR

IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,

FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE

AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER

LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,

OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE

SOFTWARE.

*/

namespace Line;

class LineTimeline{

    private $line_host = 'https://timeline.line.me/api/';

    public $timeline_order = 'TIME'; // RANKING

    public $post_limit = 10;

    public $user;

    public $gnb;

    public $home_id;

    public $session_id;

    private $is_true_last = false;

    private $last_response = [];

    public function __construct(){

        // To do...

    }

    /*

        @title Set Session Cookies

        @param $ids string

        @return

    */

    public function setSession($ids){

        $this->session_id = $ids;

        return $this;

    }

    /*

        @title Set Type Order Untuk Timeline

        @param $param string

        @return

    */

    public function order($param){

        if(!in_array($param, ['TIME', 'RANKING'])) throw new Exception("Invalid Order Type");

        $this->timeline_order = $param;

    }

    /*

        @return

    */

    public function userinfo(){

        $this->sessID();

        $http = $this->response($this->http('gnb/userInfo.json'));

        if($this->isOK()){

            $data = [];

            $this->user = $http['userInfo'];

            $this->gnb = $http['gnb'];

            $this->home_id = $this->gnb['homeInfo']['homeId'];

            return $this;

        }

        else{

            throw new Exception('Invalid sesssion!');

        }

    }

    /*

        @title Get Latest Response if One

        @param

        @return

    */

    public function get(){

        return $this->last_response;

    }

    /*

        @title Get Notification

        @param

        @return

    */

    public function notification(){

        $http = $this->response($this->http('gnb/noticenter.json'));

        if($this->isOK()){

            return $http['notifications'];

        }

        else{

            throw new Exception('Invalid sesssion!');

        }

    }

    /*

        @title Get Friend List

        @param $total integer

        @param $callback callable

        @return

    */

    public function friendList($total, callable $callback = NULL){

        if(!is_numeric($total) OR $total <= 0) throw new Exception("Invalid total!");

        $multiple = ($total <= 20) ? 1 : ($total - ($total % 20)) / 20;

        if($total % 20 != 0) $multiple++;

        $tmp_arr = [];

        for($i=0;$i<$multiple;$i++){

            $scrool_id = ($i * 20) + 1;

            $this->getFriend($scrool_id, function($data) use (&$tmp_arr){

                if(empty($data) OR count($data) == 0) break;

                $tmp_arr = array_merge($tmp_arr, $data);

            });

        }

        $this->last_response = array_slice($tmp_arr, 0, $total);

        return ($this->_end($this->isOK(), $callback) == true);

    }

    /*

        @title Post Status to Timeline

        @param $text string

        @param $type integer

        @param $large_text boolean

        @param $callback callable

        @return

    */

    public function postTimeline($text, $type = 1, $large_text = false, $sticker = [], callable $callback = NULL){

        $this->sessId();

        /* Sticker example

        $sticker[] = ["id"=>5,"packageId"=>1,"packageVersion"=>100];

        $sticker[] = ["id"=>1,"packageId"=>1,"packageVersion"=>100];

        */

        switch($type){

            case 1:

                $permission = 'ALL';

                break;

            case 2:

                $permission = 'FRIEND';

                break;

            case 3:

                $permission = 'NONE';

                break;

            default:

                throw new Exception("Invalid post type!");

        }

        $large_text = ($large_text == true) ? 'true' : 'false';

        $stickers = json_encode($sticker);

        $post = '{"postInfo":{"readPermission":{"type":"'.$permission.'","gids":null}},"contents":{"text":"'.$text.'","largeText":'.$large_text.',"stickers":'.$stickers.',"media":[]}}';

        $http = $this->response($this->http('post/create.json?sourceType=TIMELINE ', $post));

        return ($this->_end($this->isOK(), $callback) == true);

    }

    /*

        @title Delete Comment by ID and Comment Id

        @param $postid string

    */

    public function deleteComment($postid, $commentid, callable $callback = NULL){

        $this->sessID();

        $post = '{"postId":"'.$postid.'","actorId":"x","commentId":"'.$commentid.'"}';

        $http = $this->response($this->http('post/delete.json?sourceType=TIMELINE&homeId=' . $this->home_id, $post));

        return ($this->_end($this->isOK(), $callback) == true);

    }

    /*

        @title Add Friend

        @param $homeid string

    */

    public function addFriend($homeid, callable $callback = NULL){

        $this->sessID();

        $post = '{"mid":"' . $homeid . '"}';

        $http = $this->response($this->http('friend/add.json', $post));

        return ($this->_end($this->isOK(), $callback) == true);

    }

    /*

        @title Delete Post by ID

        @param $postid string

    */

    public function deletePost($postid, callable $callback = NULL){

        $this->sessID();

        $post = '{"postId":"'.$postid.'"}';

        $http = $this->response($this->http('post/delete.json?sourceType=TIMELINE&homeId=' . $this->home_id, $post));

        return ($this->_end($this->isOK(), $callback) == true);

    }

    /*

        @title Get group list

        @param $limit integer

        $param $callback callable

    */

    public function groupList($limit = 100, callable $callback = NULL){

        $this->sessID();

        $http = $this->response($this->http('group/list.json?limit=' . $limit));

        $this->last_response = $http;

        return ($this->_end($this->isOK(), $callback) == true);

    }

    /*

        @title Search Post by Hashtag

        @param $hashtag string

        @param $limit integer

        $param $callback callable

    */

    public function searchByHashtag($hashtag, $limit = 10, callable $callback = NULL){

        $this->sessID();

        $http = $this->response($this->http('hashtag/search.json?query='.$hashtag.'&postLimit='.$limit.'&commentLimit=1&likeLimit=1'));

        $this->last_response = $http;

        return ($this->_end($this->isOK(), $callback) == true);

    }

    /*

        @title Comment a Post by Post ID

        @param $home_id string

        @param $post_id string

        @param $comment_text string

        @param $callback callable

        @return

    */

    public function commentPost($home_id, $post_id, $comment_text, callable $callback = NULL){

        $this->sessID();

        $post = '{"contentId":"'.$post_id.'","commentText":"'.$comment_text.'","contentsList":[],"actorId":"'.$this->home_id.'","recallInfos":[]}';

        $http = $this->response($this->http('comment/create.json?sourceType=MYHOME_END&homeId=' . $home_id, $post));

        return ($this->_end($this->isOK(), $callback) == true);

    }

    /*

        @title Like a Post by Post ID

        @param $post_id string

        @param $reaction integer

        @param $shareable boolean

        @param $callback callable

        @return

    */

    public function likePost($post_id, $reaction = 0, $shareable = false, callable $callback = NULL){

        $this->sessID();

        // 1 love 2 haha 3 ok 4 terharu 5 kaget 6 cry 0 random

        if(!in_array($reaction, [0,1,2,3,4,5,6])) throw new Exception('Invalid reaction id!');

        $shareable = ($shareable == true) ? 'true' : 'false';

        if($reaction == 0) $reaction = mt_rand(1, 6);

        $post = '{"contentId":"'.$post_id.'","actorId":"x","likeType":"100'.$reaction.'","sharable":'.$shareable.'}';

        $http = $this->response($this->http('like/create.json?sourceType=TIMELINE&homeId=x', $post));

        return ($this->_end($this->isOK(), $callback) == true);

    }

    /*

        @title Cancel Like a Post by Post ID

        @param $post_id string

        @param $callback callable

        @return

    */

    public function unlikePost($post_id, callable $callback = NULL){

        $this->sessID();

        $post = '{"contentId":"'.$post_id.'"}';

        $http = $this->response($this->http('like/cancel.json?sourceType=TIMELINE&homeId=x', $post));

        return ($this->_end($this->isOK(), $callback) == true);

    }

    /*

        @title Like Timeline (This Session)

        @param $max integer

        @param $reaction integer

        @param $mode integer

        @param $share_mode integer

        @param $callback callable

        @return

    */

    public function likeTimeline($user = NULL, $max = 1, $reaction = 0, $mode = 1, $share_mode = 1, callable $callback = NULL){

        $this->sessID();

        if(!in_array($mode, [1,2,3])) throw new Exception('Invalid mode!');

        if(!in_array($share_mode, [1,2,3,4])) throw new Exception('Invalid share mode!');

        if(!in_array($reaction, [0,1,2,3,4,5,6])) throw new Exception('Invalid reaction id!');

        $this->getHomeList($user, function($timeline) use ($max, $reaction, $mode, $share_mode, $callback){

            $n = 0;

            if(is_array($timeline) && count($timeline) > 0){

                foreach($timeline as $tl){

                    if($n >= $max) break;

                    if($reaction == 0) $reaction = mt_rand(1, 6);

                    $post_d = $tl['post']['postInfo']['postId'];

                    $liked = $tl['post']['postInfo']['liked'];

                    if($liked == false && $this->isPassLikesMode($tl, $mode)){

                        $this->likePost($post_d, $reaction, $this->isShareableMode($tl, $share_mode), $callback);

                        $n++;

                    }

                }

                return $this;

            } else {

                throw new Exception("Error occured!");

            }

        });

    }

    private function getFriend($scrool_id = 1, callable $callback = NULL){

        $http = $this->response($this->http('friend/list.json?scrollId='.$scrool_id.'&limit=20'));

        if($this->isOK()){

            if(empty($http['friends'])) throw new Exception('Invalid response data!');

            if(is_callable($callback) && $callback != NULL){

                $callback($http['friends']);

            }

            else {

                return $http['friends'];

            }

        }

        else {

            throw new Exception('Invalid session data!');

        }

    }

    private function getHomeList($user_id = NULL, callable $callback = NULL){

        // $user_id example : _dQXvILQLzuN5-jSNMrfUNcemoCbkLSmRijRjFrU

        $this->sessID();

        if(empty($this->user)) $this->userinfo();

        if(empty($this->user) or empty($this->home_id)) throw new Exception('Invalid user info!');

        if($user_id == NULL){

            $http = $this->response($this->http('feed/list.json?postLimit='.$this->post_limit.'&commentLimit=2&likeLimit=20&order='.$this->timeline_order.'&requestTime=' . time()));

        }

        else {

            $http = $this->response($this->http('post/list.json?homeId='.$user_id.'&postLimit='.$this->post_limit.'&commentLimit=2&likeLimit=20&requestTime=' . time()));

        }

        if($this->isOK()){

            if(count($http['feeds']) < 1) throw new Exception('Invalid response data!');

            if(is_callable($callback) && $callback != NULL){

                $callback($http['feeds']);

            }

            else {

                return $http['feeds'];

            }

        }

        else {

            throw new Exception('Invalid session data!');

        }

    }

    private function is_official($data){

        if(!empty($data['post']['postInfo']['officialHome']['homeType']) && $data['post']['postInfo']['officialHome']['homeType'] == 'OFFICIAL'){

            return true;

        } else {

            return false;

        }

    }

    private function isPassLikesMode($data, $mode){

        switch($mode){

            case 1:

                return true;

                break;

            case 2: // User only

                if($this->is_official($data) == false){

                    return true;

                } else {

                    return false;

                }

                break;

            case 3: // line @ only

                if($this->is_official($data) == true){

                    return true;

                } else {

                    return false;

                }

                break;

            default:

                throw new Exception("Error occured!");

        }

    }

    private function isShareableMode($data, $mode){

        switch($mode){

            case 1: // dont share anything

                return false;

                break;

            case 2: // share anything

                return true;

                break;

            case 3: // share if user

                if($this->is_official($data) == false){

                    return true;

                } else {

                    return false;

                }

                break;

            case 4: // share if line @ account

                if($this->is_official($data) == true){

                    return true;

                } else {

                    return false;

                }

            default:

                throw new Exception("Error occured!");

        }

    }

    private function sessID(){

        if(empty($this->session_id)){

            throw new Exception("Please set session id first!");

        }

    }

    private function isOK(){

        return $this->is_true_last;

    }

    private function response($response, $return = false){

        $res = json_decode($response[1], true);

        if(!empty($res) && $res['message'] == 'success' && isset($res['result'])){

            $this->is_true_last = true;

        } else {

            $this->is_true_last = false;

        }

        if($this->is_true_last){

            return $res['result'];

        } else {

            return [];

        }

    }

    private function _end($isOK, $callback){

        if($isOK == true){

            if($callback != NULL && is_callable($callback)){

                $callback(false, $this);

            } else {

                return true;

            }

        } else {

            if($callback != NULL && is_callable($callback)){

                $callback(true);

            } else {

                return false;

            }

        }

    }

    private function http($path, $postdata = ''){

        $ch = curl_init();

        curl_setopt($ch, CURLOPT_URL, $this->line_host . $path);

        curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows NT 6.3; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/55.0.2883.87 Safari/537.36');

        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

        curl_setopt($ch, CURLOPT_VERBOSE, false);

        curl_setopt($ch, CURLOPT_ENCODING , "gzip");

        curl_setopt($ch, CURLOPT_HTTPHEADER, $this->getHeaderList($postdata));

        if(!empty($postdata)){

            curl_setopt($ch, CURLOPT_POST, true);

            curl_setopt($ch, CURLOPT_POSTFIELDS, $postdata);

        }

        $response = curl_exec($ch);

        $http = curl_getinfo($ch, CURLINFO_HTTP_CODE);

        curl_close($ch);

        return array($http, $response);

    }

    private function getHeaderList($p){

        $ht = 'Host: timeline.line.me

            Connection: keep-alive

            Accept: application/json, text/plain, */*

            X-Timeline-WebVersion: 1.4.2

            X-Line-AcceptLanguage: en

            User-Agent: Mozilla/5.0 (Windows NT 6.3; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/55.0.2883.87 Safari/537.36

            Origin: https://timeline.line.me

            Content-Type: application/json;charset=UTF-8

            Referer: https://timeline.line.me/

            Accept-Encoding: gzip, deflate, br

            Accept-Language: en,id;q=0.8,ja;q=0.6

            Cookie: tc="'.$this->session_id.'";';

        if(!empty($p) && strlen($p) > 0){

            $ht .= "\nContent-Length: " . strlen($p);

        }

        return array_map(function($val){

            return trim($val);

        }, explode("\n", $ht));

    }

}

/* post 文字

$app = new LineTimeline();

$app->setSession('COOKIESHERE');

$app->postTimeline('Hehehehe, welcome AskaEks', 1, false);

*/