123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131 |
- <?php
- namespace OC\Remote;
- use OC\Remote\Api\NotFoundException;
- use OCP\Http\Client\IClientService;
- use OCP\ICache;
- use OCP\Remote\IInstance;
- class Instance implements IInstance {
-
- private $url;
-
- private $cache;
-
- private $clientService;
-
- private $status;
-
- public function __construct($url, ICache $cache, IClientService $clientService) {
- $url = str_replace('https://', '', $url);
- $this->url = str_replace('http://', '', $url);
- $this->cache = $cache;
- $this->clientService = $clientService;
- }
-
- public function getUrl() {
- return $this->url;
- }
-
- public function getFullUrl() {
- return $this->getProtocol() . '://' . $this->getUrl();
- }
-
- public function getVersion() {
- $status = $this->getStatus();
- return $status['version'];
- }
-
- public function getProtocol() {
- $status = $this->getStatus();
- return $status['protocol'];
- }
-
- public function isActive() {
- $status = $this->getStatus();
- return $status['installed'] && !$status['maintenance'];
- }
-
- private function getStatus() {
- if ($this->status) {
- return $this->status;
- }
- $key = 'remote/' . $this->url . '/status';
- $httpsKey = 'remote/' . $this->url . '/https';
- $status = $this->cache->get($key);
- if (!$status) {
- $response = $this->downloadStatus('https://' . $this->getUrl() . '/status.php');
- $protocol = 'https';
- if (!$response) {
- if ($status = $this->cache->get($httpsKey)) {
- throw new \Exception('refusing to connect to remote instance(' . $this->url . ') over http that was previously accessible over https');
- }
- $response = $this->downloadStatus('http://' . $this->getUrl() . '/status.php');
- $protocol = 'http';
- } else {
- $this->cache->set($httpsKey, true, 60 * 60 * 24 * 365);
- }
- $status = json_decode($response, true);
- if ($status) {
- $status['protocol'] = $protocol;
- }
- if ($status) {
- $this->cache->set($key, $status, 5 * 60);
- $this->status = $status;
- } else {
- throw new NotFoundException('Remote server not found at address ' . $this->url);
- }
- }
- return $status;
- }
-
- private function downloadStatus($url) {
- try {
- $request = $this->clientService->newClient()->get($url);
- return $request->getBody();
- } catch (\Exception $e) {
- return false;
- }
- }
- }
|