StreamElements.php

<?php

use League\OAuth2\Client\Provider\Exception\IdentityProviderException;

/**
 * Created by PhpStorm.
 * User: Lx
 * Date: 19.06.2018
 * Time: 18:00
 */
class StreamElements
{
  /**
   * URL to SE API
   * @var string
   */
  protected $url = 'https://api.streamelements.com/kappa/v2';

  /**
   * oAuth2 handler
   * @var string
   */
  protected $provider;

  /**
   * Auth type
   * @var string
   */
  protected $auth;

  /**
   * Token
   * @var string
   */
  protected $token;

  /**
   * API limits
   * @var string
   */
  protected $apiLimits;
  /**
   * CURL Options array
   * @var array
   */
  protected $options;
  /**
   * @var \GuzzleHttp\Client
   */
  protected $api;
  /**
   *
   * @var string
   */
  public $channelName;
  /**
   * Profile information received on handshake
   * @var object
   */
  public $profile;
  /**
   * Channel id received on handshake
   * @var int
   */
  public $channelId;
  /**
   * bot data
   * @var array
   */
  public $botInfo;

  /**
   * StreamElements constructor.
   * @param $token - OAuth/JWT Token
   * @param $auth - Authorization method (Bearer,OAuth)
   * @return boolean
   * @throws Exception
   */
  public function __construct($token, $auth)
  {
    $this->api = new GuzzleHttp\Client();
    $this->auth = $auth;
    $this->options = array(
      "headers" => array(
        "Accept" => "application/json",
        "Authorization" => $auth . " " . $token
      ),
      "debug" => false,
      "verify" => false);
    if (!$this->getInfo()) {
      throw new Exception("Invalid credentials");
    }
  }

  /**
   *
   */
  public function __destruct()
  {}

  /**
   * @param $method
   * @param $endpoint
   * @param array $params
   * @param bool $isUpload
   * @return bool|mixed
   */
  protected function sendRequest($method, $endpoint, $params = array(), $isUpload = false)
  {
    if (!is_null($this->apiLimits) && is_array($this->apiLimits['global']))
    {
        if ($this->apiLimits['global']['reset'] > new DateTime() && !$this->apiLimits['global']['remaining']) return false;
    }

    $url = $this->url . '/' . $endpoint;
    $options = $this->options;
    if (is_array($params))
    {
      $options['json'] = $params;
    }
    if ($isUpload)
    {
      $options['multipart'][] = $params;
      unset($options['json']);
    }

    $res = array();
    try
    {
      if ($method == 'GET')
      {
        $res = $this->api->get($url, $this->options);
      }
      else if ($method == 'POST')
      {
        $res = $this->api->post($url, $options);

      }
      else if ($method == 'PUT')
      {
        $res = $this->api->put($url, $options);
      }
      else if ($method == 'DELETE')
      {
        $res = $this->api->delete($url, $options);
      }
      $headers = $res->getHeaders();
      $scope = $headers['x-ratelimit-bucket'][0];
      $this->apiLimits[$scope] = [
        'limit' => $headers['x-ratelimit-limit'][0],
        'remaining' => $headers['x-ratelimit-remaining'][0],
        'reset' => new DateTime()
      ];
      $this->apiLimits[$scope]['reset']->setTimestamp((int)($headers['x-ratelimit-reset'][0] / 1000));

    }
    catch (GuzzleHttp\Exception\ClientException $e)
    {
      if ($e->hasResponse())
      {
        return (json_decode($e->getResponse()->getBody()->getContents(), 1));
      }
      return false;
    }
    //var_dump($res);
    //die();
    $response = json_decode($res->getBody()->getContents(), true);
    return $response;
  }

  /**
   * @return bool
   */
  public function getInfo()
  {
    $endpoint = 'channels/me';
    try
    {
      $res = $this->sendRequest('GET', $endpoint);
    }
    catch (Exception $e)
    {
      echo($e->getMessage());
      $this->__destruct();
      return false;
    }
    $this->profile = $res;
    if (!isset($this->profile["username"]) || !isset($this->profile["_id"])) return false;
    $this->channelName = $this->profile["username"];
    $this->channelId = $this->profile["_id"];
    return true;
  }

// BOT

  /**
   * Gather bot information
   * @return bool|mixed
   */
  public function botInit()
  {
    $url = 'bot/' . $this->channelId;
    $res = $this->sendRequest('GET', $url);
    $this->botInfo = $res['bot'];
    return $res;
  }

  /**
   * Sends a message to channel as bot
   * @param $message
   * @return bool|mixed
   */
  public function botSay($message)
  {

    if (!$this->botInfo) $this->botInit();
    if (!$this->botInfo['joined']) return false;
    if ($this->botInfo['muted']) return false;

    $url = 'bot/' . $this->channelId . '/say';
    $params = array('message' => $message);

    $res = $this->sendRequest('POST', $url, $params);

    return $res;
  }

  /**
    * List all timers
    *  @return bool|mixed
    */
  public function listTimers()
  {
    $url = 'bot/timers/' . $this->channelId;

    $res = $this->sendRequest('GET', $url);

    return $res;
  }

  /**
    * Get timer based on provided id
    * @param string $timerId
    * @return bool|mixed
    */
  public function getTimer($timerId)
  {
    $url = 'bot/timers/' . $this->channelId . '/' . $timerId;

    $res = $this->sendRequest('GET', $url);

    return $res;
  }

  /**
    * Create new timer
    * @param string $name
    * @param array $messages
    * @param string $chatLines
    * @param bool $online
    * @param int $onlineInt
    * @param bool $offline
    * @param int $onlineInt
    * @return bool|mixed
    */
  public function createTimer($name, $messages, $chatLines, $online, $onlineInt, $offline, $offlineInt)
  {
    $url = 'bot/timers/' . $this->channelId;

    $timer = array(
      "online" => array(
        "enabled" => $online,
        "interval" => $onlineInt
      ),
      "offline" => array(
        "enabled" => $offline,
        "interval" => $offlineInt
      ),
      "enabled" => true,
      "chatLines" => $chatLines,
      "messages" => $messages,
      "name" => $name
    );

    $res = $this->sendRequest('POST', $url, $timer);
    return $res;
  }

  /**
    * Update timer
    * @param string $timerId
    * @param string $name
    * @param array $messages
    * @param string $chatLines
    * @param bool $enabled
    * @param bool $online
    * @param int $onlineInt
    * @param bool $offline
    * @param int $onlineInt
    * @return bool|mixed
    */
  public function updateTimer($timerId, $name, $messages, $chatLines, $enabled, $online, $onlineInt, $offline, $offlineInt)
  {
    $url = 'bot/timers/' . $this->channelId . '/' . $timerId;

    $timer = array(
      "online" => array(
        "enabled" => $online,
        "interval" => $onlineInt
      ),
      "offline" => array(
        "enabled" => $offline,
        "interval" => $offlineInt
      ),
      "enabled" => $enabled,
      "chatLines" => $chatLines,
      "messages" => $messages,
      "name" => $name
    );

    $res = $this->sendRequest('PUT', $url, $timer);

    return $res;
  }

  /**
    * @param string $timerId
    * @return bool|mixed
    */
  public function deleteTimer($timerId)
  {
    $url = 'bot/timers/' . $this->channelId . '/' . $timerId;

    $res = $this->sendRequest('DELETE', $url);

    return $res;
  }


  /**
    * @return bool|mixed
    */
  public function listCommands()
  {
    $url = 'bot/commands/' . $this->channelId;

    $res = $this->sendRequest('GET', $url);

    return $res;
  }

  /**
    * @param string $commandId
    * @return bool|mixed
    */

  public function getCommand($commandId)
  {
    $url = 'bot/commands/' . $this->channelId . '/' . $commandId;

    $res = $this->sendRequest('GET', $url);

    return $res;
  }
}