Port view_pagination integration test to elixir test suite

3 files changed, 192 insertions, 1 deletions

diff --git a/test/elixir/README.md b/test/elixir/README.md
index 4c81dd59e..453614700 100644
--- a/test/elixir/README.md
+++ b/test/elixir/README.md
@@ -108,7 +108,7 @@ X means done, - means partially
   - [ ] Port view_multi_key_design.js
   - [ ] Port view_multi_key_temp.js
   - [ ] Port view_offsets.js
-  - [ ] Port view_pagination.js
+  - [X] Port view_pagination.js
   - [ ] Port view_sandboxing.js
   - [ ] Port view_update_seq.js
 
diff --git a/test/elixir/test/view_pagination_test.exs b/test/elixir/test/view_pagination_test.exs
new file mode 100644
index 000000000..322b653cb
--- /dev/null
+++ b/test/elixir/test/view_pagination_test.exs
@@ -0,0 +1,189 @@
+defmodule ViewPaginationTest do
+  use CouchTestCase
+
+  @moduletag :view_pagination
+
+  @moduledoc """
+  Integration tests for pagination.
+  This is a port of the view_pagination.js test suite.
+  """
+
+  @tag :with_db
+  test "basic view pagination", context do
+    db_name = context[:db_name]
+
+    docs = make_docs(0..99)
+    bulk_save(db_name, docs)
+
+    query_function = "function(doc) { emit(doc.integer, null); }"
+
+    0..99
+    |> Enum.filter(fn number -> rem(number, 10) === 0 end)
+    |> Enum.each(fn i ->
+      query_options = %{"startkey" => i, "startkey_docid" => i, limit: 10}
+      result = query(db_name, query_function, nil, query_options)
+      assert result["total_rows"] === length(docs)
+      assert length(result["rows"]) === 10
+      assert result["offset"] === i
+      Enum.each(0..9, &assert(Enum.at(result["rows"], &1)["key"] === &1 + i))
+    end)
+  end
+
+  @tag :with_db
+  test "aliases start_key and start_key_doc_id should work", context do
+    db_name = context[:db_name]
+
+    docs = make_docs(0..99)
+    bulk_save(db_name, docs)
+
+    query_function = "function(doc) { emit(doc.integer, null); }"
+
+    0..99
+    |> Enum.filter(fn number -> rem(number, 10) === 0 end)
+    |> Enum.each(fn i ->
+      query_options = %{"start_key" => i, "start_key_docid" => i, limit: 10}
+      result = query(db_name, query_function, nil, query_options)
+      assert result["total_rows"] === length(docs)
+      assert length(result["rows"]) === 10
+      assert result["offset"] === i
+      Enum.each(0..9, &assert(Enum.at(result["rows"], &1)["key"] === &1 + i))
+    end)
+  end
+
+  @tag :with_db
+  test "descending view pagination", context do
+    db_name = context[:db_name]
+
+    docs = make_docs(0..99)
+    bulk_save(db_name, docs)
+
+    query_function = "function(doc) { emit(doc.integer, null); }"
+
+    100..0
+    |> Enum.filter(fn number -> rem(number, 10) === 0 end)
+    |> Enum.map(&(&1 - 1))
+    |> Enum.filter(&(&1 > 0))
+    |> Enum.each(fn i ->
+      query_options = %{
+        "startkey" => i,
+        "startkey_docid" => i,
+        limit: 10,
+        descending: true
+      }
+
+      result = query(db_name, query_function, nil, query_options)
+      assert result["total_rows"] === length(docs)
+      assert length(result["rows"]) === 10
+      assert result["offset"] === length(docs) - i - 1
+      Enum.each(0..9, &assert(Enum.at(result["rows"], &1)["key"] === i - &1))
+    end)
+  end
+
+  @tag :with_db
+  test "descending=false parameter should just be ignored", context do
+    db_name = context[:db_name]
+
+    docs = make_docs(0..99)
+    bulk_save(db_name, docs)
+
+    query_function = "function(doc) { emit(doc.integer, null); }"
+
+    0..99
+    |> Enum.filter(fn number -> rem(number, 10) === 0 end)
+    |> Enum.each(fn i ->
+      query_options = %{
+        "start_key" => i,
+        "start_key_docid" => i,
+        limit: 10,
+        descending: false
+      }
+
+      result = query(db_name, query_function, nil, query_options)
+      assert result["total_rows"] === length(docs)
+      assert length(result["rows"]) === 10
+      assert result["offset"] === i
+      Enum.each(0..9, &assert(Enum.at(result["rows"], &1)["key"] === &1 + i))
+    end)
+  end
+
+  @tag :with_db
+  test "endkey document id", context do
+    db_name = context[:db_name]
+
+    docs = make_docs(0..99)
+    bulk_save(db_name, docs)
+
+    query_function = "function(doc) { emit(null, null); }"
+
+    query_options = %{
+      "startkey" => :null,
+      "startkey_docid" => 1,
+      "endkey" => :null,
+      "endkey_docid" => 40,
+    }
+
+    result = query(db_name, query_function, nil, query_options)
+    test_end_key_doc_id(result, docs)
+  end
+
+  @tag :with_db
+  test "endkey document id, but with end_key_doc_id alias", context do
+    db_name = context[:db_name]
+
+    docs = make_docs(0..99)
+    bulk_save(db_name, docs)
+
+    query_function = "function(doc) { emit(null, null); }"
+
+    query_options = %{
+      "start_key" => :null,
+      "start_key_doc_id" => 1,
+      "end_key" => :null,
+      "end_key_doc_id" => 40,
+    }
+
+    result = query(db_name, query_function, nil, query_options)
+    test_end_key_doc_id(result, docs)
+  end
+
+  defp test_end_key_doc_id(query_result, docs) do
+    assert length(query_result["rows"]) === 35
+    assert query_result["total_rows"] === length(docs)
+    assert query_result["offset"] === 1
+    assert Enum.at(query_result["rows"], 0)["id"] === "1"
+    assert Enum.at(query_result["rows"], 1)["id"] === "10"
+    assert Enum.at(query_result["rows"], 2)["id"] === "11"
+    assert Enum.at(query_result["rows"], 3)["id"] === "12"
+    assert Enum.at(query_result["rows"], 4)["id"] === "13"
+    assert Enum.at(query_result["rows"], 5)["id"] === "14"
+    assert Enum.at(query_result["rows"], 6)["id"] === "15"
+    assert Enum.at(query_result["rows"], 7)["id"] === "16"
+    assert Enum.at(query_result["rows"], 8)["id"] === "17"
+    assert Enum.at(query_result["rows"], 9)["id"] === "18"
+    assert Enum.at(query_result["rows"], 10)["id"] === "19"
+    assert Enum.at(query_result["rows"], 11)["id"] === "2"
+    assert Enum.at(query_result["rows"], 12)["id"] === "20"
+    assert Enum.at(query_result["rows"], 13)["id"] === "21"
+    assert Enum.at(query_result["rows"], 14)["id"] === "22"
+    assert Enum.at(query_result["rows"], 15)["id"] === "23"
+    assert Enum.at(query_result["rows"], 16)["id"] === "24"
+    assert Enum.at(query_result["rows"], 17)["id"] === "25"
+    assert Enum.at(query_result["rows"], 18)["id"] === "26"
+    assert Enum.at(query_result["rows"], 19)["id"] === "27"
+    assert Enum.at(query_result["rows"], 20)["id"] === "28"
+    assert Enum.at(query_result["rows"], 21)["id"] === "29"
+    assert Enum.at(query_result["rows"], 22)["id"] === "3"
+    assert Enum.at(query_result["rows"], 23)["id"] === "30"
+    assert Enum.at(query_result["rows"], 24)["id"] === "31"
+    assert Enum.at(query_result["rows"], 25)["id"] === "32"
+    assert Enum.at(query_result["rows"], 26)["id"] === "33"
+    assert Enum.at(query_result["rows"], 27)["id"] === "34"
+    assert Enum.at(query_result["rows"], 28)["id"] === "35"
+    assert Enum.at(query_result["rows"], 29)["id"] === "36"
+    assert Enum.at(query_result["rows"], 30)["id"] === "37"
+    assert Enum.at(query_result["rows"], 31)["id"] === "38"
+    assert Enum.at(query_result["rows"], 32)["id"] === "39"
+    assert Enum.at(query_result["rows"], 33)["id"] === "4"
+    assert Enum.at(query_result["rows"], 34)["id"] === "40"
+  end
+end
diff --git a/test/javascript/tests/view_pagination.js b/test/javascript/tests/view_pagination.js
index df5390eb3..6da5f8d48 100644
--- a/test/javascript/tests/view_pagination.js
+++ b/test/javascript/tests/view_pagination.js
@@ -10,6 +10,8 @@
 // License for the specific language governing permissions and limitations under
 // the License.
 
+couchTests.elixir = true;
+
 couchTests.view_pagination = function(debug) {
     var db_name = get_random_db_name();
     var db = new CouchDB(db_name, {"X-Couch-Full-Commit":"false"});