vk/LongPoll.php

<?php
namespace VK;

/**
 * Class LongPoll
 * @package VK
 */
class LongPoll extends vk_api
{
    /**
     * @var
     */
    private $vk;
    /**
     * @var
     */
    private $group_id;
    /**
     * @var
     */
    private $user_id;
    /**
     * @var
     */
    private $key;
    /**
     * @var
     */
    private $server;
    /**
     * @var
     */
    private $ts;

    /**
     * LongPoll constructor.
     * @param $vk
     */
    public function __construct($vk)
    {
        parent::setAllDataclass($vk->copyAllDataclass());
        $this->vk = $vk;
        $data = $this->vk->userInfo();
        if ($data != false) {
            $this->vk->auth_type = 'user';
            $this->user_id = $data['id'];
        } else {
            $this->vk->auth_type = 'group';
            $this->group_id = $this->vk->request('groups.getById', [])[0]['id'];
            $this->vk->request('groups.setLongPollSettings', [
                'group_id' => $this->group_id,
                'enabled' => 1,
                'api_version' => $this->vk->version,
                'message_new' => 1,
            ]);
        }
        $this->getLongPollServer();
    }

    /**
     *
     */
    public function getLongPollServer()
    {
        if ($this->vk->auth_type == 'user')
            $data = $this->vk->request('messages.getLongPollServer', ['need_pts' => 1, 'lp_version' => 3]);
        else
            $data = $this->vk->request('groups.getLongPollServer', ['group_id' => $this->group_id]);
        unset($this->key);
        unset($this->server);
        unset($this->ts);
        list($this->key, $this->server, $this->ts) = [$data['key'], $data['server'], $data['ts']];
    }

    /**
     * @param $anon
     * @throws VkApiException
     */
    public function listen($anon)
    {
        while ($data = $this->processingData()) {
            foreach ($data->updates as $event) {
                unset($this->vk->data);
                $this->vk->data = $event;
                $anon($event);
            }
            if ($this->vk instanceof Execute) {
                $this->vk->exec();
            }
        }
    }

    /**
     * @return mixed
     * @throws VkApiException
     */
    public function processingData()
    {
        $data = $this->getData();
        if (isset($data->failed)) {
            if ($data->failed == 1) {
                unset($this->ts);
                $this->ts = $data->ts;
            }
            else {
                $this->getLongPollServer();
                $data = $this->getData();
            }
        }
        unset($this->ts);
        $this->ts = $data->ts;
        return $data;
    }

    /**
     * @return mixed
     * @throws VkApiException
     */
    public function getData()
    {
        $defult_params = ['act' => 'a_check', 'key' => $this->key, 'ts' => $this->ts, 'wait' => 55];
        if($this->vk->auth_type == 'user') {
            $params = ['mode' => 32, 'version' => 3];
            $data = $this->request_core('https://' . $this->server . '?', $defult_params + $params);
        } else {
            $data = $this->request_core($this->server . '?', $defult_params);
        }
        return $data;
    }

    /**
     * @param $type
     * @param $anon
     */
    public function on($type, $anon)
    {
        $summands = [];
        $data = json_decode(json_encode($this->vk->data), true);
        switch ($type) {
            case 'message_new':
                {
                    if ($data[0] == 4) {
                        foreach ([1, 2, 4, 8, 16, 32, 64, 128, 256, 512, 65536] as $key) {
                            if ($data[2] & $key)
                                $summands[] = $key;
                        }
                        if (!in_array(2, $summands)) { //только входящие сообщения
                            $this->vk->data = [];
                            $this->vk->data['object']['peer_id'] = $data[3];
                            $this->vk->data['object']['text'] = $data[5];
                            $this->vk->data = json_decode(json_encode($this->vk->data));
                            $anon($data);
                        }
                    }
                    break;
                }
        }
    }

     /**
     * @param $id
     * @param null $message
     * @param null $payload
     * @param null $user_id
     * @param null $type
     * @param null $data
     * @return |null
     */
    public function initVars(&$id = null, &$message = null, &$payload = null, &$user_id = null, &$type = null, &$data = null)
    {
        $data = $this->vk->data;
        $data_backup = $this->vk->data;
        $type = isset($data->type) ? $data->type : null;
        if($type == 'message_new' && isset($data->object->message)) {
            $data->object = $data->object->message;
        }
        $id = isset($data->object->peer_id) ? $data->object->peer_id : null;
        $message = isset($data->object->text) ? $data->object->text : null;
        $payload = isset($data->object->payload) ? json_decode($data->object->payload, true) : null;
        $user_id = isset($data->object->from_id) ? $data->object->from_id : null;
        $data = $data_backup;
        return $data_backup;
    }
    
    public function reply($message, $params = []) {
        $message = $this->vk->placeholders($this->vk->data->object->peer_id, $message);
        return $this->vk->request('messages.send', ['message' => $message, 'peer_id' => $this->vk->data->object->peer_id] + $params);
    }

    /**
     * @param $url
     * @param array $params
     * @return mixed
     * @throws VkApiException
     */
    private function request_core($url, $params = [])
    {
        if (function_exists('curl_init')) {
            $ch = curl_init();
            curl_setopt($ch, CURLOPT_URL, $url.http_build_query($params));
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
            curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);
            $result = json_decode(curl_exec($ch));
            curl_close($ch);
        } else {
            $result = json_decode(file_get_contents($url, true, stream_context_create([
                'http' => [
                    'method' => 'POST',
                    'header' => "Content-type: application/x-www-form-urlencoded\r\n",
                    'content' => http_build_query($params)
                ]
            ])));
        }
        if (!isset($result) or isset($result->error))
            throw new VkApiException(json_encode($result));
        return $result;
    }
}