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
|
% Licensed under the Apache License, Version 2.0 (the "License"); you may not
% use this file except in compliance with the License. You may obtain a copy of
% the License at
%
% http://www.apache.org/licenses/LICENSE-2.0
%
% Unless required by applicable law or agreed to in writing, software
% distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
% WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
% License for the specific language governing permissions and limitations under
% the License.
-module(couch_db_doc_tests).
-include_lib("couch/include/couch_eunit.hrl").
-include_lib("couch/include/couch_db.hrl").
start() ->
test_util:start_couch([ioq]).
setup() ->
DbName = ?tempdb(),
config:set("couchdb", "stem_interactive_updates", "false", false),
{ok, Db} = couch_db:create(DbName, [?ADMIN_CTX]),
couch_db:close(Db),
DbName.
teardown(DbName) ->
ok = couch_server:delete(DbName, [?ADMIN_CTX]),
ok.
couch_db_doc_test_() ->
{
"CouchDB doc tests",
{
setup,
fun start/0, fun test_util:stop_couch/1,
{
foreach,
fun setup/0, fun teardown/1,
[
fun should_truncate_number_of_revisions/1,
fun should_raise_bad_request_on_invalid_rev/1
]
}
}
}.
should_truncate_number_of_revisions(DbName) ->
DocId = <<"foo">>,
Db = open_db(DbName),
couch_db:set_revs_limit(Db, 5),
Rev = create_doc(Db, DocId),
Rev10 = add_revisions(Db, DocId, Rev, 10),
{ok, [{ok, #doc{revs = {11, Revs}}}]} = open_doc_rev(Db, DocId, Rev10),
?_assertEqual(5, length(Revs)).
should_raise_bad_request_on_invalid_rev(DbName) ->
DocId = <<"foo">>,
InvalidRev1 = <<"foo">>,
InvalidRev2 = <<"a-foo">>,
InvalidRev3 = <<"1-xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx">>,
Expect = {bad_request, <<"Invalid rev format">>},
Db = open_db(DbName),
create_doc(Db, DocId),
[
{InvalidRev1,
?_assertThrow(Expect, add_revisions(Db, DocId, InvalidRev1, 1))},
{InvalidRev2,
?_assertThrow(Expect, add_revisions(Db, DocId, InvalidRev2, 1))},
{InvalidRev3,
?_assertThrow(Expect, add_revisions(Db, DocId, InvalidRev3, 1))}
].
open_db(DbName) ->
{ok, Db} = couch_db:open_int(DbName, [?ADMIN_CTX]),
Db.
create_doc(Db, DocId) ->
add_revision(Db, DocId, undefined).
open_doc_rev(Db0, DocId, Rev) ->
{ok, Db} = couch_db:reopen(Db0),
couch_db:open_doc_revs(Db, DocId, [couch_doc:parse_rev(Rev)], []).
add_revision(Db, DocId, undefined) ->
add_revision(Db, DocId, []);
add_revision(Db, DocId, Rev) when is_binary(Rev) ->
add_revision(Db, DocId, [{<<"_rev">>, Rev}]);
add_revision(Db0, DocId, Rev) ->
{ok, Db} = couch_db:reopen(Db0),
Doc = couch_doc:from_json_obj({[
{<<"_id">>, DocId},
{<<"value">>, DocId}
] ++ Rev}),
{ok, NewRev} = couch_db:update_doc(Db, Doc, []),
{ok, _} = couch_db:ensure_full_commit(Db),
couch_doc:rev_to_str(NewRev).
add_revisions(Db, DocId, Rev, N) ->
lists:foldl(fun(_, OldRev) ->
add_revision(Db, DocId, OldRev)
end, Rev, lists:seq(1, N)).
|
