From e1b6523f5f9ba88e11fb822ad8a008095c05f1df Mon Sep 17 00:00:00 2001
From: Martin Edenhofer <me@edenhofer.de>
Date: Thu, 30 Jan 2014 00:51:55 +0100
Subject: [PATCH] Added init version of ES search.

---
 lib/search_index_backend.rb | 68 +++++++++++++++++++++++++++++++++----
 1 file changed, 61 insertions(+), 7 deletions(-)

diff --git a/lib/search_index_backend.rb b/lib/search_index_backend.rb
index 28bee04b3..01b20ff92 100644
--- a/lib/search_index_backend.rb
+++ b/lib/search_index_backend.rb
@@ -57,25 +57,78 @@ remove whole data from index
 
 =begin
 
-return all activity entries of an user
+return search result
 
-  result = SearchIndexBackend.search( user )
+  result = SearchIndexBackend.search( 'search query', limit, 'User' )
 
 =end
 
-  def self.search(user,limit)
+  def self.search( query, limit = 10, index = nil )
+    return [] if !query
+
+    url = build_url()
+    return if !url
+    if index 
+      url += "/#{index}/_search"
+    else
+      url += '/_search'
+    end
+    data = {}
+    data['from'] = 0
+    data['size'] = 10
+    data['query'] = {}
+#    data['query']['text_phrase'] = {}
+#    data['query']['text_phrase']['to'] = query
+#    data['query']['bool'] = {}
+#    data['query']['bool']['must'] = {}
+#    data['query']['bool']['must']['term'] = {}
+#    data['query']['bool']['must']['term']['title'] = '*z*'
+    data['query']['query_string'] = {}
+    data['query']['query_string']['query'] = query
+
+#    data['filtered'] = {}
+#    data['filtered']['query'] = {}
+#    data['filtered']['query']['match'] = {}
+#    data['filtered']['query']['match']['_all'] = query
+
+    puts "# curl -X POST \"#{url}\" -d '#{data.to_json}'"
+
+    conn     = connection( url )
+    response = conn.get do |req|
+      req.headers['Content-Type'] = 'application/json'
+      req.body = data.to_json
+    end
+#    puts response.body.to_s
+    puts "# #{response.status.to_s}"
+    puts response.body
+#    return true if response.success?
+    data = JSON.parse( response.body )
+#    return { :data => data, :response => response }
+    ids = []
+    return ids if !data
+    return ids if !data['hits']
+    return ids if !data['hits']['hits']
+    data['hits']['hits'].each { |item|
+      puts "... #{item['_type'].to_s} #{item['_id'].to_s}"
+      ids.push item['_id']
+    }
+    return ids
   end
 
   private
 
-  def self.build_url( type, o_id = nil )
+  def self.build_url( type = nil, o_id = nil )
     index = Setting.get('es_index').to_s + "_#{Rails.env}"
     url   = Setting.get('es_url')
     return if !url
-    if o_id
-      url = "#{url}/#{index}/#{type}/#{o_id}"
+    if type
+      if o_id
+        url = "#{url}/#{index}/#{type}/#{o_id}"
+      else
+        url = "#{url}/#{index}/#{type}"
+      end
     else
-      url = "#{url}/#{index}/#{type}"
+      url = "#{url}/#{index}"
     end
     url
   end
@@ -89,4 +142,5 @@ return all activity entries of an user
     end
     conn
   end
+
 end
\ No newline at end of file