From 226508cd8d3e8c147ad314a0de483e08be71c254 Mon Sep 17 00:00:00 2001 From: Christian Weiske Date: Wed, 3 Feb 2016 06:21:30 +0100 Subject: first frontend --- src/Elasticsearch.php | 138 -------------------------------------------------- 1 file changed, 138 deletions(-) delete mode 100644 src/Elasticsearch.php (limited to 'src/Elasticsearch.php') diff --git a/src/Elasticsearch.php b/src/Elasticsearch.php deleted file mode 100644 index b3f3067..0000000 --- a/src/Elasticsearch.php +++ /dev/null @@ -1,138 +0,0 @@ -baseUrl = $baseUrl; - } - - /** - * @link https://www.elastic.co/guide/en/elasticsearch/guide/current/_finding_exact_values.html - */ - public function isKnown($url) - { - $r = new Elasticsearch_Request( - $this->baseUrl . 'document/_search/exists', - \HTTP_Request2::METHOD_GET - ); - $r->allow404 = true; - $r->setBody( - json_encode( - array( - 'query' => array( - 'filtered' => array( - 'filter' => array( - 'term' => array( - 'url' => $url - ) - ) - ) - ) - ) - ) - ); - $res = json_decode($r->send()->getBody()); - return $res->exists; - } - - public function get($url) - { - $r = new Elasticsearch_Request( - $this->baseUrl . 'document/' . rawurlencode($url), - \HTTP_Request2::METHOD_GET - ); - $r->allow404 = true; - $res = $r->send(); - if ($res->getStatus() != 200) { - return null; - } - $d = json_decode($res->getBody()); - return $d->_source; - } - - public function markQueued($url) - { - $r = new Elasticsearch_Request( - $this->baseUrl . 'document/' . rawurlencode($url), - \HTTP_Request2::METHOD_PUT - ); - $doc = array( - 'status' => 'queued', - 'url' => $url - ); - $r->setBody(json_encode($doc)); - $r->send(); - } - - public function search($query, $page, $perPage) - { - $r = new Elasticsearch_Request( - $this->baseUrl . 'document/_search', - \HTTP_Request2::METHOD_GET - ); - $doc = array( - '_source' => array( - 'url', - 'title', - 'author', - 'modate', - ), - 'query' => array( - 'bool' => array( - 'must' => array( - array( - 'query_string' => array( - 'default_field' => '_all', - 'query' => $query - ) - ), - array( - 'term' => array( - 'status' => 'indexed' - ) - ) - ) - ) - ), - 'aggregations' => array( - 'tags' => array( - 'terms' => array( - 'field' => 'tags' - ) - ), - 'language' => array( - 'terms' => array( - 'field' => 'language' - ) - ), - 'domain' => array( - 'terms' => array( - 'field' => 'domain' - ) - ), - 'type' => array( - 'terms' => array( - 'field' => 'type' - ) - ) - ), - 'from' => $page * $perPage, - 'size' => $perPage, - 'sort' => array( - //array('modate' => array('order' => 'desc')) - ) - ); - //unset($doc['_source']); - - //ini_set('xdebug.var_display_max_depth', 10); - //return json_decode(json_encode($doc)); - $r->setBody(json_encode($doc)); - $res = $r->send(); - return json_decode($res->getBody()); - } -} -?> -- cgit v1.2.3