[STORE] Added MyModel.all finder method

    Person.all.to_a

    # 2014-05-05 15:02:24 +0200: GET http://localhost:9250/people/person/_search [status:200, request:0.047s, query:0.024s]
    # 2014-05-05 15:02:24 +0200: > {"query":{"match_all":{}},"size":10000}
    # 2014-05-05 15:02:24 +0200: < # {"took":24,"timed_out":false,"_shards":{"total":5,"successful":5,"failed":0},"hits":{"total":100,"max_score":1.0,"hits":[ .... ]}}
    # => [#<Person:0x007ff1d8fb04b0 ... ]

Author: karmi

elasticsearch-persistence/lib/elasticsearch/persistence/model.rb

@@ -6,6 +6,7 @@
 require 'elasticsearch/persistence'
 require 'elasticsearch/persistence/model/errors'
 require 'elasticsearch/persistence/model/store'
+require 'elasticsearch/persistence/model/find'
 
 module Elasticsearch
   module Persistence
@@ -45,6 +46,8 @@ def self.included(base)
           extend  Elasticsearch::Persistence::Model::Store::ClassMethods
           include Elasticsearch::Persistence::Model::Store::InstanceMethods
 
+          extend  Elasticsearch::Persistence::Model::Find::ClassMethods
+
           class << self
             def attribute(name, type=nil, options={}, &block)
               mapping = options.delete(:mapping) || {}

elasticsearch-persistence/lib/elasticsearch/persistence/model/find.rb

@@ -0,0 +1,28 @@
+module Elasticsearch
+  module Persistence
+    module Model
+
+      module Find
+        module ClassMethods
+
+          # Return all documents (up to 10,000) for a model
+          #
+          # @example Retrieve all people
+          #
+          #     Person.all
+          #     # => [#<Person:0x007ff1d8fb04b0 ... ]
+          #
+          # @example Retrieve all people matching a query
+          #
+          #     Person.all query: { match: { last_name: 'Smith'  } }
+          #     # => [#<Person:0x007ff1d8fb04b0 ... ]
+          #
+          def all(options={})
+            gateway.search( { query: { match_all: {} }, size: 10_000 }.merge(options) )
+          end
+        end
+      end
+
+    end
+  end
+end

elasticsearch-persistence/test/unit/model_find_test.rb

@@ -0,0 +1,87 @@
+require 'test_helper'
+
+require 'active_model'
+require 'virtus'
+
+require 'elasticsearch/persistence/model/errors'
+require 'elasticsearch/persistence/model/find'
+
+class Elasticsearch::Persistence::ModelFindTest < Test::Unit::TestCase
+  context "The model find module," do
+
+    class DummyFindModel
+      include ActiveModel::Naming
+      include ActiveModel::Conversion
+      include ActiveModel::Serialization
+      include ActiveModel::Serializers::JSON
+      include ActiveModel::Validations
+
+      include Virtus.model
+
+      extend  Elasticsearch::Persistence::Model::Find::ClassMethods
+
+      extend  ActiveModel::Callbacks
+      define_model_callbacks :create, :save, :update, :destroy
+      define_model_callbacks :find, :touch, only: :after
+
+      attribute :id,    String, writer: :private
+      attribute :title, String
+      attribute :count, Integer, default: 0
+      attribute :created_at, DateTime, default: lambda { |o,a| Time.now.utc }
+      attribute :updated_at, DateTime, default: lambda { |o,a| Time.now.utc }
+
+      def set_id(id); self.id = id; end
+    end
+
+    setup do
+      @gateway         = stub
+      DummyFindModel.stubs(:gateway).returns(@gateway)
+
+      @response = MultiJson.load <<-JSON
+        {
+          "took": 14,
+          "timed_out": false,
+          "_shards": {
+            "total": 5,
+            "successful": 5,
+            "failed": 0
+          },
+          "hits": {
+            "total": 1,
+            "max_score": 1.0,
+            "hits": [
+              {
+                "_index": "dummy",
+                "_type": "dummy",
+                "_id": "abc123",
+                "_score": 1.0,
+                "_source": {
+                  "name": "TEST"
+                }
+              }
+            ]
+          }
+        }
+      JSON
+    end
+
+    should "find all records" do
+      @gateway
+        .expects(:search)
+        .with({ query: { match_all: {} }, size: 10_000 })
+        .returns(@response)
+
+      DummyFindModel.all
+    end
+
+    should "pass options when finding all records" do
+      @gateway
+        .expects(:search)
+        .with({ query: { match: { title: 'test' } }, size: 10_000, routing: 'abc123' })
+        .returns(@response)
+
+      DummyFindModel.all( { query: { match: { title: 'test' } }, routing: 'abc123' } )
+    end
+
+  end
+end