File Manager

Editing File: /home/ubuntu/code_review/arcanist/src/future/twitch/PhutilTwitchFuture.php

<?php

final class PhutilTwitchFuture extends FutureProxy {

private $future;
  private $clientID;
  private $accessToken;
  private $action;
  private $params;
  private $method = 'GET';

public function __construct() {
    parent::__construct(null);
  }

public function setAccessToken($token) {
    $this->accessToken = $token;
    return $this;
  }

public function setClientID($client_id) {
    $this->clientID = $client_id;
    return $this;
  }

public function setRawTwitchQuery($action, array $params = array()) {
    $this->action = $action;
    $this->params = $params;
    return $this;
  }

public function setMethod($method) {
    $this->method = $method;
    return $this;
  }

protected function getProxiedFuture() {
    if (!$this->future) {
      $params = $this->params;

if (!$this->action) {
        throw new Exception(pht('You must %s!', 'setRawTwitchQuery()'));
      }

if (!$this->accessToken) {
        throw new Exception(pht('You must %s!', 'setAccessToken()'));
      }

$uri = new PhutilURI('https://api.twitch.tv/');
      $uri->setPath('/kraken/'.ltrim($this->action, '/'));
      $uri->replaceQueryParam('oauth_token', $this->accessToken);

$future = new HTTPSFuture($uri);
      $future->setData($this->params);
      $future->setMethod($this->method);

// NOTE: This is how the Twitch API is versioned.
      $future->addHeader('Accept', 'application/vnd.twitchtv.2+json');

// NOTE: This is required to avoid rate limiting.
      $future->addHeader('Client-ID', $this->clientID);

$this->future = $future;
    }

return $this->future;
  }

protected function didReceiveResult($result) {
    list($status, $body, $headers) = $result;

if ($status->isError()) {
      throw $status;
    }

$data = null;
    try {
      $data = phutil_json_decode($body);
    } catch (PhutilJSONParserException $ex) {
      throw new PhutilProxyException(
        pht('Expected JSON response from Twitch.'),
        $ex);
    }

if (idx($data, 'error')) {
      $error = $data['error'];
      throw new Exception(pht('Received error from Twitch: %s', $error));
    }

return $data;
  }

}

Back to Directory File Manager