PhutilTwitchFuture.php
0fa7efbf09d7production

PhutilTwitchFuture.php
View Options

			<?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->setQueryParam('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;
			}

			}

libphutil/src/future/twitch/PhutilTwitchFuture.php0fa7efbf09d7production

PhutilTwitchFuture.phpView Options

libphutil/src/future/twitch/PhutilTwitchFuture.php
0fa7efbf09d7production

PhutilTwitchFuture.php
View Options