sdr/search/SDRFedSearchClient.php5

<?php

class SDRFedSearchClient extends SObject {
    const RESULT_SIMPLEXML = 0;
    const RESULT_STRING = 1;
    const RESULT_OBJECTS = 2;

    protected $lastQuery = null;
    protected $lastResult = null;

    private static $XML_ERROR_TYPES = array(
        LIBXML_ERR_WARNING => 'Warning',
        LIBXML_ERR_ERROR => 'Error',
        LIBXML_ERR_FATAL => 'Fatal Error'
    );

    public function query($req, $resultType = self::RESULT_SIMPLEXML) {
        // TODO: make $req properly cloneable
        $this->lastQuery = clone $req;

        $queryURL = $req->buildQueryURL();
        $resultRaw = utf8_encode($this->doCurlCall($queryURL));

        $this->lastResult = $resultRaw;

        switch($resultType) {
            case self::RESULT_STRING:
                return $resultRaw;
            case self::RESULT_SIMPLEXML:
            case self::RESULT_OBJECTS:
                // TODO: grab errors from SimpleXML using the libxml crapadoola
                $oldErr = libxml_use_internal_errors(true);
                $resultXML = @simplexml_load_string($resultRaw);
                // if we can't parse it, set an error
                if($resultXML == null) {
                    $errors = libxml_get_errors();
                    foreach($errors as $error) {
                        $this->setError("XML " . self::$XML_ERROR_TYPES[$error->level] . " on line $error->line: $error->message");
                    }
                    $this->setError('Invalid XML Response.');
                    libxml_use_internal_errors($oldErr);
                    return false;
                }
                libxml_use_internal_errors($oldErr);
                // check to see if the result contains an error section
                // (there were errors on the server)
                if(isset($resultXML->error)) {
                    // if there were errors, add them to our object as errors
                    foreach($resultXML->error as $e)
                        $this->setError((string)$e);
                    return false;
                }
                // if everything is fine, return the result string as expected
                if($resultType == self::RESULT_SIMPLEXML)
                    return $resultXML;
                $type = $req->getType();
                STimer::start('buildObjects');
                switch($type) {
                    case SDRContract::REQUEST_TYPE_LIST:
                    case SDRContract::REQUEST_TYPE_QUICK:
                    case SDRContract::REQUEST_TYPE_ADVANCED:
                        $result = new SDRResourceResponse($resultXML);
                        break;
                    case SDRContract::REQUEST_TYPE_VOCAB:
                        $result = new SDRVocabResponse($resultXML);
                        break;
                }
                STimer::end('buildObjects');
                return $result;
        }

        $this->setError('Invalid result type specified: ' . $resultType);
        return false;
    }

    protected function doCurlCall($url, $key = null, $XMLData = null) {
        STimer::start('curl');
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 5);
        curl_setopt($ch, CURLOPT_TIMEOUT, 5);
        // if there is a key or XML data value, use POST to send those values
        if($key != null || $XMLData != null) {
            curl_setopt($ch, CURLOPT_POST, 1);
            curl_setopt($ch, CURLOPT_POSTFIELDS, 'key=' . $key . '&XMLData=' . $XMLData);
        }
        $store = curl_exec($ch);
        curl_close($ch);
        STimer::end('curl');
        return $store;
    }

    public function getLastQuery() {
        return $this->lastQuery;
    }

    public function getLastResult() {
        return $this->lastResult;
    }
}

?>

---