@@ -5,60 +5,60 @@ |
||
5 | 5 | |
6 | 6 | class InstagramOAuth |
7 | 7 | { |
8 | - /** @var string $accessToken */ |
|
9 | - private $accessToken; |
|
8 | + /** @var string $accessToken */ |
|
9 | + private $accessToken; |
|
10 | 10 | |
11 | - /** @var object $user */ |
|
12 | - private $user; |
|
11 | + /** @var object $user */ |
|
12 | + private $user; |
|
13 | 13 | |
14 | - /* |
|
14 | + /* |
|
15 | 15 | * @param \stdClass $oauth |
16 | 16 | * @throws InstagramOAuthException |
17 | 17 | */ |
18 | - public function __construct(\stdClass $oauth) |
|
19 | - { |
|
20 | - if (!empty($oauth)) { |
|
21 | - $this->accessToken = $oauth->access_token; |
|
22 | - $this->user = isset($oauth->user) ? $oauth->user : null; |
|
23 | - } else { |
|
24 | - throw new InstagramOAuthException("Bad Request 400 empty Response", 400); |
|
25 | - } |
|
26 | - } |
|
18 | + public function __construct(\stdClass $oauth) |
|
19 | + { |
|
20 | + if (!empty($oauth)) { |
|
21 | + $this->accessToken = $oauth->access_token; |
|
22 | + $this->user = isset($oauth->user) ? $oauth->user : null; |
|
23 | + } else { |
|
24 | + throw new InstagramOAuthException("Bad Request 400 empty Response", 400); |
|
25 | + } |
|
26 | + } |
|
27 | 27 | |
28 | - /* |
|
28 | + /* |
|
29 | 29 | * Get Access Token |
30 | 30 | * @return string |
31 | 31 | */ |
32 | - public function getAccessToken() |
|
33 | - { |
|
34 | - return $this->accessToken; |
|
35 | - } |
|
32 | + public function getAccessToken() |
|
33 | + { |
|
34 | + return $this->accessToken; |
|
35 | + } |
|
36 | 36 | |
37 | - /* |
|
37 | + /* |
|
38 | 38 | * Set Access Token |
39 | 39 | * @param string $token |
40 | 40 | * @return void |
41 | 41 | */ |
42 | - public function setAccessToken($token) |
|
43 | - { |
|
44 | - $this->accessToken = $token; |
|
45 | - } |
|
42 | + public function setAccessToken($token) |
|
43 | + { |
|
44 | + $this->accessToken = $token; |
|
45 | + } |
|
46 | 46 | |
47 | - /* |
|
47 | + /* |
|
48 | 48 | * If AccessToken is set return true else false |
49 | 49 | * @return bool |
50 | 50 | */ |
51 | - public function isAccessTokenSet() |
|
52 | - { |
|
53 | - return isset($this->accessToken) ? true : false; |
|
54 | - } |
|
51 | + public function isAccessTokenSet() |
|
52 | + { |
|
53 | + return isset($this->accessToken) ? true : false; |
|
54 | + } |
|
55 | 55 | |
56 | - /* |
|
56 | + /* |
|
57 | 57 | * Get User Info |
58 | 58 | * @return object |
59 | 59 | */ |
60 | - public function getUserInfo() |
|
61 | - { |
|
62 | - return $this->user; |
|
63 | - } |
|
60 | + public function getUserInfo() |
|
61 | + { |
|
62 | + return $this->user; |
|
63 | + } |
|
64 | 64 | } |
@@ -6,14 +6,14 @@ discard block |
||
6 | 6 | |
7 | 7 | class InstagramResponse |
8 | 8 | { |
9 | - /** @var int $status_code */ |
|
10 | - private $statusCode; |
|
9 | + /** @var int $status_code */ |
|
10 | + private $statusCode; |
|
11 | 11 | |
12 | - /** @var string $protocol */ |
|
13 | - private $protocol = '1.1'; |
|
12 | + /** @var string $protocol */ |
|
13 | + private $protocol = '1.1'; |
|
14 | 14 | |
15 | - /** @var array $headers */ |
|
16 | - private $headers = []; |
|
15 | + /** @var array $headers */ |
|
16 | + private $headers = []; |
|
17 | 17 | |
18 | 18 | /** @var bool */ |
19 | 19 | private $isPagination = false; |
@@ -30,35 +30,35 @@ discard block |
||
30 | 30 | /** @var object */ |
31 | 31 | private $data; |
32 | 32 | |
33 | - /** @var object $body */ |
|
34 | - private $body; |
|
33 | + /** @var object $body */ |
|
34 | + private $body; |
|
35 | 35 | |
36 | 36 | /* |
37 | 37 | * @param Response $response |
38 | 38 | * @throws InstagramResponseException |
39 | 39 | */ |
40 | - public function __construct(Response $response) |
|
41 | - { |
|
42 | - if ($response instanceof Response) { |
|
43 | - $this->setParams($response); |
|
44 | - } else { |
|
45 | - throw new InstagramResponseException('Bad Request: Response is not valid instance of GuzzleHttp\Psr7\Response', 404); |
|
46 | - } |
|
47 | - } |
|
40 | + public function __construct(Response $response) |
|
41 | + { |
|
42 | + if ($response instanceof Response) { |
|
43 | + $this->setParams($response); |
|
44 | + } else { |
|
45 | + throw new InstagramResponseException('Bad Request: Response is not valid instance of GuzzleHttp\Psr7\Response', 404); |
|
46 | + } |
|
47 | + } |
|
48 | 48 | |
49 | 49 | /* |
50 | 50 | * Set Values to the class members |
51 | 51 | * @param Response $response |
52 | 52 | * @return void |
53 | 53 | */ |
54 | - private function setParams(Response $response) |
|
55 | - { |
|
56 | - $this->protocol = $response->getProtocolVersion(); |
|
57 | - $this->statusCode = (int) $response->getStatusCode(); |
|
58 | - $this->headers = $response->getHeaders(); |
|
59 | - $this->body = json_decode($response->getBody()->getContents()); |
|
54 | + private function setParams(Response $response) |
|
55 | + { |
|
56 | + $this->protocol = $response->getProtocolVersion(); |
|
57 | + $this->statusCode = (int) $response->getStatusCode(); |
|
58 | + $this->headers = $response->getHeaders(); |
|
59 | + $this->body = json_decode($response->getBody()->getContents()); |
|
60 | 60 | $this->extractBodyParts(); |
61 | - } |
|
61 | + } |
|
62 | 62 | |
63 | 63 | private function extractBodyParts() |
64 | 64 | { |
@@ -79,38 +79,38 @@ discard block |
||
79 | 79 | * Get response |
80 | 80 | * @return object|string |
81 | 81 | */ |
82 | - public function getBody() |
|
83 | - { |
|
84 | - return $this->body; |
|
85 | - } |
|
82 | + public function getBody() |
|
83 | + { |
|
84 | + return $this->body; |
|
85 | + } |
|
86 | 86 | |
87 | 87 | /* |
88 | 88 | * Get Status Code |
89 | 89 | * @return int |
90 | 90 | */ |
91 | - public function getStatusCode() |
|
92 | - { |
|
93 | - return $this->statusCode; |
|
94 | - } |
|
91 | + public function getStatusCode() |
|
92 | + { |
|
93 | + return $this->statusCode; |
|
94 | + } |
|
95 | 95 | |
96 | 96 | /* |
97 | 97 | * Get specific header |
98 | 98 | * @param string $header |
99 | 99 | * @retrun string |
100 | 100 | */ |
101 | - public function getHeader($header) |
|
102 | - { |
|
103 | - return isset($this->headers[$header]) ? $this->headers[$header] : []; |
|
104 | - } |
|
101 | + public function getHeader($header) |
|
102 | + { |
|
103 | + return isset($this->headers[$header]) ? $this->headers[$header] : []; |
|
104 | + } |
|
105 | 105 | |
106 | 106 | /* |
107 | 107 | * Get all headers |
108 | 108 | * @retrun array |
109 | 109 | */ |
110 | - public function getHeaders() |
|
111 | - { |
|
112 | - return $this->headers; |
|
113 | - } |
|
110 | + public function getHeaders() |
|
111 | + { |
|
112 | + return $this->headers; |
|
113 | + } |
|
114 | 114 | |
115 | 115 | /* |
116 | 116 | * Get data from body |
@@ -11,33 +11,33 @@ discard block |
||
11 | 11 | |
12 | 12 | class HelperFactory |
13 | 13 | { |
14 | - /** @var Response $response */ |
|
15 | - protected static $response; |
|
14 | + /** @var Response $response */ |
|
15 | + protected static $response; |
|
16 | 16 | |
17 | - /** @var Stream $stream */ |
|
18 | - protected static $stream; |
|
17 | + /** @var Stream $stream */ |
|
18 | + protected static $stream; |
|
19 | 19 | |
20 | - /** @var object $content */ |
|
21 | - protected static $content; |
|
20 | + /** @var object $content */ |
|
21 | + protected static $content; |
|
22 | 22 | |
23 | - private function __construct() |
|
24 | - { |
|
25 | - // a factory constructor should never be invoked |
|
26 | - } |
|
23 | + private function __construct() |
|
24 | + { |
|
25 | + // a factory constructor should never be invoked |
|
26 | + } |
|
27 | 27 | |
28 | - /* |
|
28 | + /* |
|
29 | 29 | * Factory Client method to create \GuzzleHttp\Client object |
30 | 30 | * @param string $uri |
31 | 31 | * @return Client |
32 | 32 | */ |
33 | - public static function client($uri) |
|
34 | - { |
|
35 | - return new Client([ |
|
36 | - 'base_uri' => $uri |
|
37 | - ]); |
|
38 | - } |
|
33 | + public static function client($uri) |
|
34 | + { |
|
35 | + return new Client([ |
|
36 | + 'base_uri' => $uri |
|
37 | + ]); |
|
38 | + } |
|
39 | 39 | |
40 | - /* |
|
40 | + /* |
|
41 | 41 | * @param Client $client |
42 | 42 | * @param string $endpoint |
43 | 43 | * @param array|string $options |
@@ -46,79 +46,79 @@ discard block |
||
46 | 46 | * @throws InstagramOAuthException |
47 | 47 | * @throws InstagramException |
48 | 48 | */ |
49 | - public static function request(Client $client, $endpoint, $options, $method = 'GET') |
|
50 | - { |
|
51 | - try { |
|
52 | - return $client->request($method, $endpoint, [ |
|
53 | - 'headers' => ['Accept' => 'application/json'], |
|
54 | - 'body' => static::createBody($options, $method) |
|
55 | - ]); |
|
56 | - } catch (ClientException $e) { |
|
57 | - static::throwException(static::extractOriginalExceptionMessage($e), $e); |
|
58 | - } |
|
59 | - } |
|
49 | + public static function request(Client $client, $endpoint, $options, $method = 'GET') |
|
50 | + { |
|
51 | + try { |
|
52 | + return $client->request($method, $endpoint, [ |
|
53 | + 'headers' => ['Accept' => 'application/json'], |
|
54 | + 'body' => static::createBody($options, $method) |
|
55 | + ]); |
|
56 | + } catch (ClientException $e) { |
|
57 | + static::throwException(static::extractOriginalExceptionMessage($e), $e); |
|
58 | + } |
|
59 | + } |
|
60 | 60 | |
61 | - /* |
|
61 | + /* |
|
62 | 62 | * Create body for Guzzle client request |
63 | 63 | * @param array|null|string $options |
64 | 64 | * @param string $method GET|POST |
65 | 65 | * @return string|mixed |
66 | 66 | */ |
67 | - protected static function createBody($options, $method) |
|
68 | - { |
|
69 | - return ('GET' !== $method) ? is_array($options) ? http_build_query($options) : ltrim($options, '&') : null; |
|
70 | - } |
|
67 | + protected static function createBody($options, $method) |
|
68 | + { |
|
69 | + return ('GET' !== $method) ? is_array($options) ? http_build_query($options) : ltrim($options, '&') : null; |
|
70 | + } |
|
71 | 71 | |
72 | - /* |
|
72 | + /* |
|
73 | 73 | * Method to extract all exceptions for Guzzle ClientException |
74 | 74 | * @param ClientException $e |
75 | 75 | * @return |
76 | 76 | */ |
77 | - protected static function extractOriginalExceptionMessage(ClientException $e) |
|
78 | - { |
|
79 | - self::$response = $e->getResponse(); |
|
80 | - self::$stream = self::$response->getBody(); |
|
81 | - self::$content = self::$stream->getContents(); |
|
82 | - if (empty(self::$content)) { |
|
83 | - throw new InstagramServerException( |
|
84 | - $e->getMessage(), |
|
85 | - $e->getCode(), |
|
86 | - $e |
|
87 | - ); |
|
88 | - } else { |
|
89 | - return json_decode(self::$content); |
|
90 | - } |
|
91 | - } |
|
77 | + protected static function extractOriginalExceptionMessage(ClientException $e) |
|
78 | + { |
|
79 | + self::$response = $e->getResponse(); |
|
80 | + self::$stream = self::$response->getBody(); |
|
81 | + self::$content = self::$stream->getContents(); |
|
82 | + if (empty(self::$content)) { |
|
83 | + throw new InstagramServerException( |
|
84 | + $e->getMessage(), |
|
85 | + $e->getCode(), |
|
86 | + $e |
|
87 | + ); |
|
88 | + } else { |
|
89 | + return json_decode(self::$content); |
|
90 | + } |
|
91 | + } |
|
92 | 92 | |
93 | - /* |
|
93 | + /* |
|
94 | 94 | * @param \stdClass $object |
95 | 95 | * @param ClientException $e |
96 | 96 | * @return void |
97 | 97 | */ |
98 | - protected static function throwException(\stdClass $object, ClientException $e) |
|
99 | - { |
|
100 | - $exception = array(); |
|
101 | - if (isset($object->meta)) { |
|
102 | - $exception['error_type'] = $object->meta->error_type; |
|
103 | - $exception['error_message'] = $object->meta->error_message; |
|
104 | - $exception['error_code'] = $object->meta->code; |
|
105 | - } else { |
|
106 | - $exception['error_type'] = $object->error_type; |
|
107 | - $exception['error_message'] = $object->error_message; |
|
108 | - $exception['error_code'] = $object->code; |
|
109 | - } |
|
110 | - if (stripos($exception['error_type'], "oauth") !== false) { |
|
111 | - throw new InstagramOAuthException( |
|
112 | - json_encode(array("Type" => $exception['error_type'], "Message" => $exception['error_message'])), |
|
113 | - $exception['error_code'], |
|
114 | - $e |
|
115 | - ); |
|
116 | - } else { |
|
117 | - throw new InstagramException( |
|
118 | - json_encode(array("Type" => $exception['error_type'], "Message" => $exception['error_message'])), |
|
119 | - $exception['error_code'], |
|
120 | - $e |
|
121 | - ); |
|
122 | - } |
|
123 | - } |
|
98 | + protected static function throwException(\stdClass $object, ClientException $e) |
|
99 | + { |
|
100 | + $exception = array(); |
|
101 | + if (isset($object->meta)) { |
|
102 | + $exception['error_type'] = $object->meta->error_type; |
|
103 | + $exception['error_message'] = $object->meta->error_message; |
|
104 | + $exception['error_code'] = $object->meta->code; |
|
105 | + } else { |
|
106 | + $exception['error_type'] = $object->error_type; |
|
107 | + $exception['error_message'] = $object->error_message; |
|
108 | + $exception['error_code'] = $object->code; |
|
109 | + } |
|
110 | + if (stripos($exception['error_type'], "oauth") !== false) { |
|
111 | + throw new InstagramOAuthException( |
|
112 | + json_encode(array("Type" => $exception['error_type'], "Message" => $exception['error_message'])), |
|
113 | + $exception['error_code'], |
|
114 | + $e |
|
115 | + ); |
|
116 | + } else { |
|
117 | + throw new InstagramException( |
|
118 | + json_encode(array("Type" => $exception['error_type'], "Message" => $exception['error_message'])), |
|
119 | + $exception['error_code'], |
|
120 | + $e |
|
121 | + ); |
|
122 | + } |
|
123 | + } |
|
124 | 124 | } |