diff options
Diffstat (limited to 'FedoraClient.php')
| -rw-r--r-- | FedoraClient.php | 138 |
1 files changed, 138 insertions, 0 deletions
diff --git a/FedoraClient.php b/FedoraClient.php new file mode 100644 index 0000000..da62e4f --- /dev/null +++ b/FedoraClient.php @@ -0,0 +1,138 @@ +<?php +/* + * FedoraClient is a PHP classe to interact with web services + * + * Copyright (C) 2010 Remi Collet + * http://github.com/remicollet/rpmphp. + * + * Inspired from python-fedora + * + * FedoraClient is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * python-fedora is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * See <http://www.gnu.org/licenses/> + * + */ + +define ('FEDORACLIENT_VERSION','0.1'); + +if (!function_exists('curl_version')) { + die("curl extention required\n"); +} + +abstract class FedoraClient { + private $url; + private $agent; + protected $debug = 0; + + function __construct ($url, array $options) { + $this->url = $url; + if (isset($options['agent']) && !empty($options['agent'])) { + $this->agent = $options['agent']; + } else { + $this->agent = 'PHP FedoraClient/'.FEDORACLIENT_VERSION; + } + if (isset($options['debug']) && intval($options['debug'])>0) { + $this->debug = intval($options['debug']); + } + if ($this->debug >= 2) { + echo "[debug] ".__CLASS__."::".__FUNCTION__.": url='$url', agent='".$this->agent."'\n"; + } + } + + function sendRequest($method, array $options=array()) { + $curl = curl_init(); + # And join to make our url. + $url = $this->url.urlencode($method); + curl_setopt($curl, CURLOPT_URL, $url); + # Boilerplate so pycurl processes cookies + curl_setopt($curl, CURLOPT_COOKIEFILE, '/dev/null'); + + # Associate with the response to accumulate data + $this->data=''; + curl_setopt($curl, CURLOPT_WRITEFUNCTION, array($this, 'receive')); + + # Follow redirect + curl_setopt($curl, CURLOPT_FOLLOWLOCATION, true); + curl_setopt($curl, CURLOPT_MAXREDIRS, 5); + + # Set standard headers + curl_setopt($curl, CURLOPT_HTTPHEADER, array('User-agent: '.$this->agent, 'Accept: application/json')); + + if ($this->debug >= 1) { + echo "[debug] ".__CLASS__."::".__FUNCTION__.": call '$url'\n"; + } + # run the request + curl_exec($curl); + + + # Check for auth failures + # Note: old TG apps returned 403 Forbidden on authentication failures. + # Updated apps return 401 Unauthorized + # We need to accept both until all apps are updated to return 401. + $http_status = curl_getinfo($curl, CURLINFO_HTTP_CODE); + if ($http_status==401 || $http_status==403) { + if ($this->debug >= 1) { + echo "[debug] ".__CLASS__."::".__FUNCTION__.": http_status '$http_status' Authentication failed logging in\n"; + } + return array(); + } else if ($http_status>=400) { + if ($this->debug >= 1) { + echo "[debug] ".__CLASS__."::".__FUNCTION__.": http_status '$http_status' Unknown HTTP Server Response\n"; + } + return array(); + } else if ($this->debug >= 2) { + echo "[debug] ".__CLASS__."::".__FUNCTION__.": http_status '$http_status'\n"; + } + + if ($this->debug >= 1) { + echo "[debug] ".__CLASS__."::".__FUNCTION__.": close connexion\n"; + } + curl_close($curl); + return json_decode($this->data, true); + } + + function receive($curl, $data) { + if ($this->debug >= 9) { + echo "[debug] ".__CLASS__."::".__FUNCTION__.": $data\n"; + } + $this->data .= $data; + return strlen($data); + } +} + + + +class FedoraPkgdb extends FedoraClient { + private $branches = array(); + + function __construct (array $options=array()) { + parent::__construct('https://admin.fedoraproject.org/pkgdb/', $options); + if ($this->debug>=2) { + echo "[debug] ".__CLASS__."::".__FUNCTION__."\n"; + } + } + + function getBranches($refresh=false) { + if (count($this->branches) && !$refresh) { + return $this->branches; + } + $rep =$this->sendRequest('collections'); + + if (isset($rep['collections'])) { + $this->branches = array(); + foreach ($rep['collections'] as $coll) if (isset($coll[0]['branchname'])) { + $this->branches[$coll[0]['branchname']] = $coll[0]; + } + } + return $this->branches; + } +} +?> |