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
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
% 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(cpse_test_purge_seqs).
-compile(export_all).
-include_lib("eunit/include/eunit.hrl").
-include_lib("couch/include/couch_db.hrl").
setup_each() ->
{ok, Db} = cpse_util:create_db(),
couch_db:name(Db).
teardown_each(DbName) ->
ok = couch_server:delete(DbName, []).
cpse_increment_purge_seq_on_complete_purge(DbName) ->
{ok, Rev1} = cpse_util:save_doc(DbName, {[{'_id', foo1}, {vsn, 1.1}]}),
{ok, Rev2} = cpse_util:save_doc(DbName, {[{'_id', foo2}, {vsn, 1.2}]}),
cpse_util:assert_db_props(?MODULE, ?LINE, DbName, [
{doc_count, 2},
{del_doc_count, 0},
{update_seq, 2},
{purge_seq, 0},
{purge_infos, []}
]),
PurgeInfos1 = [
{cpse_util:uuid(), <<"foo1">>, [Rev1]}
],
{ok, [{ok, PRevs1}]} = cpse_util:purge(DbName, PurgeInfos1),
?assertEqual([Rev1], PRevs1),
cpse_util:assert_db_props(?MODULE, ?LINE, DbName, [
{doc_count, 1},
{del_doc_count, 0},
{update_seq, 3},
{purge_seq, 1},
{purge_infos, PurgeInfos1}
]),
PurgeInfos2 = [
{cpse_util:uuid(), <<"foo2">>, [Rev2]}
],
{ok, [{ok, PRevs2}]} = cpse_util:purge(DbName, PurgeInfos2),
?assertEqual([Rev2], PRevs2),
cpse_util:assert_db_props(?MODULE, ?LINE, DbName, [
{doc_count, 0},
{del_doc_count, 0},
{update_seq, 4},
{purge_seq, 2},
{purge_infos, PurgeInfos1 ++ PurgeInfos2}
]).
cpse_increment_purge_multiple_times(DbName) ->
{ok, Rev1} = cpse_util:save_doc(DbName, {[{'_id', foo1}, {vsn, 1.1}]}),
{ok, Rev2} = cpse_util:save_doc(DbName, {[{'_id', foo2}, {vsn, 1.2}]}),
cpse_util:assert_db_props(?MODULE, ?LINE, DbName, [
{doc_count, 2},
{del_doc_count, 0},
{update_seq, 2},
{purge_seq, 0},
{purge_infos, []}
]),
PurgeInfos1 = [
{cpse_util:uuid(), <<"foo1">>, [Rev1]},
{cpse_util:uuid(), <<"foo2">>, [Rev2]}
],
{ok, [{ok, PRevs1}, {ok, PRevs2}]} = cpse_util:purge(DbName, PurgeInfos1),
?assertEqual([Rev1], PRevs1),
?assertEqual([Rev2], PRevs2),
cpse_util:assert_db_props(?MODULE, ?LINE, DbName, [
{doc_count, 0},
{del_doc_count, 0},
{update_seq, 3},
{purge_seq, 2},
{purge_infos, PurgeInfos1}
]).
cpse_increment_purge_seq_on_partial_purge(DbName) ->
{ok, Rev1} = cpse_util:save_doc(DbName, {[{'_id', foo1}, {vsn, <<"1.1">>}]}),
Update = {[
{'_id', foo1},
{'_rev', couch_doc:rev_to_str({1, [couch_hash:md5_hash(<<"1.2">>)]})},
{vsn, <<"1.2">>}
]},
{ok, [_Rev2]} = cpse_util:save_docs(DbName, [Update], [replicated_changes]),
cpse_util:assert_db_props(?MODULE, ?LINE, DbName, [
{doc_count, 1},
{del_doc_count, 0},
{update_seq, 2},
{purge_seq, 0},
{purge_infos, []}
]),
PurgeInfos1 = [
{cpse_util:uuid(), <<"foo1">>, [Rev1]}
],
{ok, [{ok, PRevs1}]} = cpse_util:purge(DbName, PurgeInfos1),
?assertEqual([Rev1], PRevs1),
cpse_util:assert_db_props(?MODULE, ?LINE, DbName, [
{doc_count, 1},
{del_doc_count, 0},
{update_seq, 3},
{purge_seq, 1},
{purge_infos, PurgeInfos1}
]).
|
