1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
defmodule LotsOfDocsTest do
use CouchTestCase
@moduletag :lots_of_docs
@docs_range 0..499
@moduledoc """
Test saving a semi-large quanitity of documents and do some view queries.
This is a port of the lots_of_docs.js suite
"""
@tag :with_db
test "lots of docs with _all_docs", context do
db_name = context[:db_name]
@docs_range
|> create_docs()
|> Enum.chunk_every(100)
|> Enum.each(fn docs -> bulk_post(docs, db_name) end)
%{"rows" => rows, "total_rows" => total_rows} =
Couch.get("/#{db_name}/_all_docs").body
assert total_rows === Enum.count(@docs_range)
assert total_rows === Enum.count(rows)
@docs_range
|> Enum.map(fn i -> Integer.to_string(i) end)
|> Enum.sort()
|> Enum.with_index()
|> Enum.each(fn {value, index} ->
assert Map.fetch!(Enum.at(rows, index), "key") === value
end)
retry_until(fn ->
%{"rows" => desc_rows, "total_rows" => desc_total_rows} =
Couch.get(
"/#{db_name}/_all_docs",
query: %{:descending => true}
).body
assert desc_total_rows === Enum.count(@docs_range)
assert desc_total_rows === Enum.count(desc_rows)
@docs_range
|> Enum.map(fn i -> Integer.to_string(i) end)
|> Enum.sort()
|> Enum.reverse()
|> Enum.with_index()
|> Enum.each(fn {value, index} ->
assert Map.fetch!(Enum.at(desc_rows, index), "key") === value
end)
end)
end
@tag :with_db
test "lots of docs with a regular view", context do
db_name = context[:db_name]
@docs_range
|> create_docs()
|> Enum.chunk_every(100)
|> Enum.each(fn docs -> bulk_post(docs, db_name) end)
%{"rows" => rows, "total_rows" => total_rows} = query_view(db_name)
assert total_rows === Enum.count(rows)
assert total_rows === Enum.count(@docs_range)
Enum.each(@docs_range, fn i ->
assert Map.fetch!(Enum.at(rows, i), "key") === i
end)
%{"rows" => desc_rows, "total_rows" => desc_total_rows} =
query_view(db_name, "descending")
assert desc_total_rows === Enum.count(desc_rows)
assert desc_total_rows === Enum.count(@docs_range)
@docs_range
|> Enum.reverse()
|> Enum.with_index()
|> Enum.each(fn {value, index} ->
assert Map.fetch!(Enum.at(desc_rows, index), "key") === value
end)
end
defp query_view(db_name, sorting \\ "ascending") do
descending = if(sorting === "descending", do: true, else: false)
map_fun = "function(doc) { emit(doc.integer, null); }"
map_doc = %{:views => %{:view => %{:map => map_fun}}}
%{"rev" => rev} = Couch.put("/#{db_name}/_design/tempddoc", body: map_doc).body
response =
Couch.get(
"/#{db_name}/_design/tempddoc/_view/view",
query: %{:descending => descending}
).body
Couch.delete("/#{db_name}/_design/tempddoc?rev=#{rev}")
response
end
defp bulk_post(docs, db) do
resp = Couch.post("/#{db}/_bulk_docs", query: [w: 3], body: %{docs: docs})
assert resp.status_code == 201 and length(resp.body) == length(docs), """
Expected 201 and the same number of response rows as in request, but got
#{pretty_inspect(resp)}
"""
resp
end
end
|
