pushbullethandler.class.php

Go to the documentation of this file.

<?php
class PushbulletHandler extends Pushbullet
{
    private $_apiKey;
    private $_curlCallback;
    const URL_PUSHES
        = 'https://api.pushbullet.com/v2/pushes';
    const URL_DEVICES
        = 'https://api.pushbullet.com/v2/devices';
    const URL_CONTACTS
        = 'https://api.pushbullet.com/v2/contacts';
    const URL_UPLOAD_REQUEST
        = 'https://api.pushbullet.com/v2/upload-request';
    const URL_USERS
        = 'https://api.pushbullet.com/v2/users';
    const URL_SUBSCRIPTIONS
        = 'https://api.pushbullet.com/v2/subscriptions';
    const URL_CHANNEL_INFO
        = 'https://api.pushbullet.com/v2/channel-info';
    const URL_EPHEMERALS
        = 'https://api.pushbullet.com/v2/ephemerals';
    public function __construct($apiKey)
    {
        $this->_apiKey = $apiKey;
        if (!function_exists('curl_init')) {
            throw new PushbulletException(
                'cURL library is not loaded.'
            );
        }
    }
    public function pushNote(
        $recipient,
        $title,
        $body = null
    ) {
        $data = array();
        PushbulletHandler::_parseRecipient(
            $recipient,
            $data
        );
        $data['type']  = 'note';
        $data['title'] = $title;
        $data['body']  = $body;
        return $this->_curlRequest(
            self::URL_PUSHES,
            'POST',
            $data
        );
    }
    public function pushLink(
        $recipient,
        $title,
        $url,
        $body = null
    ) {
        $data = array();
        PushbulletHandler::_parseRecipient(
            $recipient,
            $data
        );
        $data['type']  = 'link';
        $data['title'] = $title;
        $data['url']   = $url;
        $data['body']  = $body;
        return $this->_curlRequest(
            self::URL_PUSHES,
            'POST',
            $data
        );
    }
    public function pushAddress(
        $recipient,
        $name,
        $address
    ) {
        $data = array();
        PushbulletHandler::_parseRecipient(
            $recipient,
            $data
        );
        $data['type']    = 'address';
        $data['name']    = $name;
        $data['address'] = $address;
        return $this->_curlRequest(
            self::URL_PUSHES,
            'POST',
            $data
        );
    }
    public function pushList(
        $recipient,
        $title,
        array $items
    ) {
        $data = array();
        PushbulletHandler::_parseRecipient(
            $recipient,
            $data
        );
        $data['type']  = 'list';
        $data['title'] = $title;
        $data['items'] = $items;
        return $this->_curlRequest(
            self::URL_PUSHES,
            'POST',
            $data
        );
    }
    public function pushFile(
        $recipient,
        $filePath,
        $mimeType = null,
        $title = null,
        $body = null,
        $altFileName = null
    ) {
        $data = array();
        $fullFilePath = realpath($filePath);
        if (!is_readable($fullFilePath)) {
            throw new PushbulletException(
                'File: File does not exist or is unreadable.'
            );
        }
        if (self::getFilesize($fullFilePath) > 25 * 1024 * 1024) {
            throw new PushbulletException(
                'File: File size exceeds 25 MB.'
            );
        }
        $data['file_name'] = $altFileName === null ?
            basename($fullFilePath) :
            $altFileName;
        // Try to guess the MIME type if the argument is NULL
        $data['file_type'] = $mimeType === null ?
            mime_content_type($fullFilePath) :
            $mimeType;
        // Request authorization to upload the file
        $response = $this->_curlRequest(
            self::URL_UPLOAD_REQUEST,
            'GET',
            $data
        );
        $data['file_url'] = $response->file_url;
        if (version_compare(PHP_VERSION, '5.5.0', '>=')) {
            $response->data->file = new CURLFile($fullFilePath);
        } else {
            $response->data->file = '@' . $fullFilePath;
        }
        // Upload the file
        $this->_curlRequest(
            $response->upload_url,
            'POST',
            $response->data,
            false,
            false
        );
        PushbulletHandler::_parseRecipient(
            $recipient,
            $data
        );
        $data['type']  = 'file';
        $data['title'] = $title;
        $data['body']  = $body;
        return $this->_curlRequest(
            self::URL_PUSHES,
            'POST',
            $data
        );
    }
    public function getPushHistory(
        $modifiedAfter = 0,
        $cursor = null,
        $limit = null
    ) {
        $data = array();
        $data['modified_after'] = $modifiedAfter;
        if ($cursor !== null) {
            $data['cursor'] = $cursor;
        }
        if ($limit !== null) {
            $data['limit'] = $limit;
        }
        return $this->_curlRequest(
            self::URL_PUSHES,
            'GET',
            $data
        );
    }
    public function dismissPush($pushIden)
    {
        return $this->_curlRequest(
            self::URL_PUSHES . '/' . $pushIden,
            'POST',
            array('dismissed' => true)
        );
    }
    public function deletePush($pushIden)
    {
        return $this->_curlRequest(
            self::URL_PUSHES . '/' . $pushIden,
            'DELETE'
        );
    }
    public function getDevices(
        $modifiedAfter = 0,
        $cursor = null,
        $limit = null
    ) {
        $data = array();
        $data['modified_after'] = $modifiedAfter;
        if ($cursor !== null) {
            $data['cursor'] = $cursor;
        }
        if ($limit !== null) {
            $data['limit'] = $limit;
        }
        return $this->_curlRequest(
            self::URL_DEVICES,
            'GET',
            $data
        );
    }
    public function deleteDevice($deviceIden)
    {
        return $this->_curlRequest(
            self::URL_DEVICES . '/' . $deviceIden,
            'DELETE'
        );
    }
    public function createContact($name, $email)
    {
        if (filter_var($email, FILTER_VALIDATE_EMAIL) === false) {
            throw new PushbulletException(
                'Create contact: Invalid email address.'
            );
        }
        $queryData = array(
            'name'  => $name,
            'email' => $email
        );
        return $this->_curlRequest(
            self::URL_CONTACTS,
            'POST',
            $queryData
        );
    }
    public function getContacts(
        $modifiedAfter = 0,
        $cursor = null,
        $limit = null
    ) {
        $data = array();
        $data['modified_after'] = $modifiedAfter;
        if ($cursor !== null) {
            $data['cursor'] = $cursor;
        }
        if ($limit !== null) {
            $data['limit'] = $limit;
        }
        return $this->_curlRequest(
            self::URL_CONTACTS,
            'GET',
            $data
        );
    }
    public function updateContact($contactIden, $name)
    {
        return $this->_curlRequest(
            self::URL_CONTACTS . '/' . $contactIden,
            'POST',
            array('name' => $name)
        );
    }
    public function deleteContact($contactIden)
    {
        return $this->_curlRequest(
            self::URL_CONTACTS . '/' . $contactIden,
            'DELETE'
        );
    }
    public function getUserInformation()
    {
        return $this->_curlRequest(self::URL_USERS . '/me', 'GET');
    }
    public function updateUserPreferences($preferences)
    {
        return $this->_curlRequest(
            self::URL_USERS . '/me',
            'POST',
            array('preferences' => $preferences)
        );
    }
    public function subscribeToChannel($channelTag)
    {
        return $this->_curlRequest(
            self::URL_SUBSCRIPTIONS,
            'POST',
            array('channel_tag' => $channelTag)
        );
    }
    public function getSubscriptions()
    {
        return $this->_curlRequest(self::URL_SUBSCRIPTIONS, 'GET');
    }
    public function unsubscribeFromChannel($channelIden)
    {
        return $this->_curlRequest(
            self::URL_SUBSCRIPTIONS . '/' . $channelIden,
            'DELETE'
        );
    }
    public function getChannelInformation($channelTag)
    {
        return $this->_curlRequest(
            self::URL_CHANNEL_INFO,
            'GET',
            array('tag' => $channelTag)
        );
    }
    public function sendSms($fromDeviceIden, $toNumber, $message)
    {
        $data = array(
            'type' => 'push',
            'push' => array(
                'type'               => 'messaging_extension_reply',
                'package_name'       => 'com.pushbullet.android',
                'source_user_iden'   => $this->getUserInformation()->iden,
                'target_device_iden' => $fromDeviceIden,
                'conversation_iden'  => $toNumber,
                'message'            => $message
            ));
 
        return $this->_curlRequest(self::URL_EPHEMERALS, 'POST', $data, true, true);
    }
    public function addCurlCallback(callable $callback)
    {
        $this->_curlCallback = $callback;
    }
    private static function _parseRecipient($recipient, array &$data)
    {
        if (!empty($recipient)) {
            if (filter_var($recipient, FILTER_VALIDATE_EMAIL) !== false) {
                $data[email] = $recipient;
            } else {
                if (substr($recipient, 0, 1) == "#") {
                    $data[channel_tag] = substr($recipient, 1);
                } else {
                    $data[device_iden] = $recipient;
                }
            }
        }
    }
    private function _curlRequest(
        $url,
        $method,
        $data = null,
        $sendAsJSON = false,
        $auth = true
    ) {
        $data = self::$FOGURLRequests->process(
            $url,
            $method,
            $data,
            $sendAsJSON,
            (
                $auth ?
                $this->_apiKey :
                false
            ),
            $this->_curlCallback
        );
        return json_decode($data[0]);
    }
}