[MODEL] Added a minimal working version of the model integration

Example for ActiveRecord
------------------------

    $LOAD_PATH.unshift File.expand_path('../../lib', __FILE__)

    require 'pry'

    require 'logger'
    require 'ansi/core'
    require 'active_record'

    require 'elasticsearch/model'

    ActiveRecord::Base.logger = ActiveSupport::Logger.new(STDOUT)
    ActiveRecord::Base.establish_connection( adapter: 'sqlite3', database: ":memory:" )

    ActiveRecord::Schema.define(version: 1) do
      create_table :articles do |t|
        t.string :title
        t.date    :published_at
        t.timestamps
      end
    end

    class Article < ActiveRecord::Base
    end

    Article.__send__ :extend, Elasticsearch::Model::Searching::ClassMethods

    Article.create title: 'Foo'
    Article.create title: 'Bar'
    Article.create title: 'Foo Foo'

    response = Article.search 'foo';

    Pry.start(binding, input: StringIO.new('response.records.to_a'))

Example for Mongoid
-------------------

$LOAD_PATH.unshift File.expand_path('../../lib', __FILE__)

require 'pry'

require 'logger'
require 'ansi/core'
require 'mongoid'

require 'elasticsearch/model'

Mongoid.logger.level = Logger::DEBUG
Moped.logger.level = Logger::DEBUG

Mongoid.connect_to 'articles'

class Article
  include Mongoid::Document
  field :id, type: String
  field :title, type: String
  field :published_at, type: DateTime
  attr_accessible :id, :title, :published_at
end

Article.__send__ :extend, Elasticsearch::Model::Searching::ClassMethods

Article.delete_all
Article.create id: '1', title: 'Foo'
Article.create id: '2', title: 'Bar'
Article.create id: '3', title: 'Foo Foo'

response = Article.search 'foo';

Pry.start(binding, input: StringIO.new('response.records.to_a'))

Author: karmi

Diff for: elasticsearch-model/elasticsearch-model.gemspec

@@ -21,6 +21,9 @@ Gem::Specification.new do |s|
   s.extra_rdoc_files  = [ "README.md", "LICENSE.txt" ]
   s.rdoc_options      = [ "--charset=UTF-8" ]
 
+  s.add_dependency "elasticsearch",       '~> 0.4'
+  s.add_dependency "hashie"
+
   s.add_development_dependency "bundler", "~> 1.3"
   s.add_development_dependency "rake"
 

Diff for: elasticsearch-model/lib/elasticsearch/model.rb

@@ -1,4 +1,16 @@
-require "elasticsearch/model/version"
+require 'forwardable'
+
+require 'elasticsearch'
+
+require 'hashie'
+
+require 'elasticsearch/model/response'
+require 'elasticsearch/model/response/base'
+require 'elasticsearch/model/response/result'
+require 'elasticsearch/model/response/results'
+require 'elasticsearch/model/response/records'
+require 'elasticsearch/model/searching'
+require 'elasticsearch/model/version'
 
 module Elasticsearch
   module Model

Diff for: elasticsearch-model/lib/elasticsearch/model/response.rb

@@ -0,0 +1,28 @@
+module Elasticsearch
+  module Model
+    module Response
+      class Response
+        attr_reader :klass, :response
+
+        include Enumerable
+
+        extend  Forwardable
+        def_delegators :results, :each, :empty?, :size, :slice, :[], :to_ary
+
+        def initialize(klass, response)
+          @klass    = klass
+          @response = response
+        end
+
+        def results
+          @results ||= Results.new(klass, response)
+        end
+
+        def records
+          @records ||= Records.new(klass, response)
+        end
+
+      end
+    end
+  end
+end

Diff for: elasticsearch-model/lib/elasticsearch/model/response/base.rb

@@ -0,0 +1,25 @@
+module Elasticsearch
+  module Model
+    module Response
+      module Base
+        attr_reader :klass, :response
+
+        def initialize(klass, response)
+          @klass     = klass
+          @response  = response
+          @total     = response['total']
+          @max_score = response['max_score']
+        end
+
+        def results
+          raise NoMethodError, "Abstract method called"
+        end
+
+        def records
+          raise NoMethodError, "Abstract method called"
+        end
+
+      end
+    end
+  end
+end

Diff for: elasticsearch-model/lib/elasticsearch/model/response/records.rb

@@ -0,0 +1,31 @@
+module Elasticsearch
+  module Model
+    module Response
+      class Records
+        include Base
+
+        def initialize(klass, response)
+          super
+          @ids = response['hits']['hits'].map { |hit| hit['_id'] }
+        end
+
+        def records
+          @records = klass.find(@ids)
+        end
+
+        # Delegate methods to `@records`
+        #
+        def method_missing(method_name, *arguments)
+          records.respond_to?(method_name) ? records.__send__(method_name, *arguments) : super
+        end
+
+        # Respond to methods from `@records`
+        #
+        def respond_to?(method_name, include_private = false)
+          records.respond_to?(method_name) || super
+        end
+
+      end
+    end
+  end
+end

Diff for: elasticsearch-model/lib/elasticsearch/model/response/result.rb

@@ -0,0 +1,27 @@
+module Elasticsearch
+  module Model
+    module Response
+      class Result
+
+        def initialize(attributes)
+          @result = Hashie::Mash.new(attributes)
+        end
+
+        # Delegate methods to `@result`
+        #
+        def method_missing(method_name, *arguments)
+          @result.respond_to?(method_name.to_sym) ? @result[method_name.to_sym] : super
+        end
+
+        # Respond to methods from `@result`
+        #
+        def respond_to?(method_name, include_private = false)
+          @result.has_key?(method_name.to_sym) || super
+        end
+
+        # TODO: #to_s, #inspect, with support for Pry
+
+      end
+    end
+  end
+end

Diff for: elasticsearch-model/lib/elasticsearch/model/response/results.rb

@@ -0,0 +1,22 @@
+module Elasticsearch
+  module Model
+    module Response
+      class Results
+        include Base
+
+        attr_reader :klass, :results
+
+        include Enumerable
+
+        extend  Forwardable
+        def_delegators :results, :each, :empty?, :size, :slice, :[], :to_a, :to_ary
+
+        def initialize(klass, response)
+          super
+          @results   = response['hits']['hits'].map { |hit| Result.new(hit) }
+        end
+
+      end
+    end
+  end
+end

Diff for: elasticsearch-model/lib/elasticsearch/model/searching.rb

@@ -0,0 +1,20 @@
+module Elasticsearch
+  module Model
+    module Searching
+
+      module ClassMethods
+
+        def search(query_or_payload, options={})
+          response = client.search index: self.model_name.collection, q: query_or_payload
+          Response::Response.new(self, response)
+        end
+
+        def client
+          @client ||= Elasticsearch::Client.new
+        end
+
+      end
+
+    end
+  end
+end