summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPaul J. Davis <paul.joseph.davis@gmail.com>2018-05-01 10:03:36 -0500
committerPaul J. Davis <paul.joseph.davis@gmail.com>2018-05-01 10:03:36 -0500
commit56b6bf7fa1e8bf3b59b08d6a7a06ee6e600b5756 (patch)
tree7b3870d03188d032bd184628038becf2261c02f8
parent97d836e57f6161c0a99a7e910ec00d78ee0823ed (diff)
downloadcouchdb-56b6bf7fa1e8bf3b59b08d6a7a06ee6e600b5756.tar.gz
[SQUERGE] Fix eunit tests
-rw-r--r--src/couch/src/test_engine_fold_purge_infos.erl40
-rw-r--r--src/couch/test/couch_db_purge_seqs_tests.erl7
2 files changed, 37 insertions, 10 deletions
diff --git a/src/couch/src/test_engine_fold_purge_infos.erl b/src/couch/src/test_engine_fold_purge_infos.erl
index 71d088925..3422e0581 100644
--- a/src/couch/src/test_engine_fold_purge_infos.erl
+++ b/src/couch/src/test_engine_fold_purge_infos.erl
@@ -99,19 +99,27 @@ cet_id_rev_repeated() ->
Actions2 = [
{purge, {<<"foo">>, Rev1}}
],
+
{ok, Db3} = test_engine_util:apply_actions(Db2, Actions2),
- PurgedIdRevs0 = [{<<"foo">>, [Rev1]}],
{ok, PurgedIdRevs1} = couch_db_engine:fold_purge_infos(
Db3, 0, fun fold_fun/2, [], []),
- ?assertEqual(PurgedIdRevs0, PurgedIdRevs1),
+ ExpectedPurgedIdRevs1 = [
+ {<<"foo">>, [Rev1]}
+ ],
+
+ ?assertEqual(ExpectedPurgedIdRevs1, lists:reverse(PurgedIdRevs1)),
?assertEqual(1, couch_db_engine:get_purge_seq(Db3)),
% purge the same Id,Rev when the doc still exists
{ok, Db4} = test_engine_util:apply_actions(Db3, Actions2),
{ok, PurgedIdRevs2} = couch_db_engine:fold_purge_infos(
Db4, 0, fun fold_fun/2, [], []),
- ?assertEqual(PurgedIdRevs0, PurgedIdRevs2),
- ?assertEqual(1, couch_db_engine:get_purge_seq(Db4)),
+ ExpectedPurgedIdRevs2 = [
+ {<<"foo">>, [Rev1]},
+ {<<"foo">>, [Rev1]}
+ ],
+ ?assertEqual(ExpectedPurgedIdRevs2, lists:reverse(PurgedIdRevs2)),
+ ?assertEqual(2, couch_db_engine:get_purge_seq(Db4)),
[FDI2] = couch_db_engine:open_docs(Db4, [<<"foo">>]),
PrevRev2 = test_engine_util:prev_rev(FDI2),
@@ -120,14 +128,30 @@ cet_id_rev_repeated() ->
{purge, {<<"foo">>, Rev2}}
],
{ok, Db5} = test_engine_util:apply_actions(Db4, Actions3),
- PurgedIdRevs00 = [{<<"foo">>, [Rev1]}, {<<"foo">>, [Rev2]}],
+
+ {ok, PurgedIdRevs3} = couch_db_engine:fold_purge_infos(
+ Db5, 0, fun fold_fun/2, [], []),
+ ExpectedPurgedIdRevs3 = [
+ {<<"foo">>, [Rev1]},
+ {<<"foo">>, [Rev1]},
+ {<<"foo">>, [Rev2]}
+ ],
+ ?assertEqual(ExpectedPurgedIdRevs3, lists:reverse(PurgedIdRevs3)),
+ ?assertEqual(3, couch_db_engine:get_purge_seq(Db5)),
% purge the same Id,Rev when the doc was completely purged
{ok, Db6} = test_engine_util:apply_actions(Db5, Actions3),
- {ok, PurgedIdRevs3} = couch_db_engine:fold_purge_infos(
+
+ {ok, PurgedIdRevs4} = couch_db_engine:fold_purge_infos(
Db6, 0, fun fold_fun/2, [], []),
- ?assertEqual(PurgedIdRevs00, lists:reverse(PurgedIdRevs3)),
- ?assertEqual(2, couch_db_engine:get_purge_seq(Db6)).
+ ExpectedPurgedIdRevs4 = [
+ {<<"foo">>, [Rev1]},
+ {<<"foo">>, [Rev1]},
+ {<<"foo">>, [Rev2]},
+ {<<"foo">>, [Rev2]}
+ ],
+ ?assertEqual(ExpectedPurgedIdRevs4, lists:reverse(PurgedIdRevs4)),
+ ?assertEqual(4, couch_db_engine:get_purge_seq(Db6)).
fold_fun({_PSeq, _UUID, Id, Revs}, Acc) ->
diff --git a/src/couch/test/couch_db_purge_seqs_tests.erl b/src/couch/test/couch_db_purge_seqs_tests.erl
index 214d5b1db..dda23f300 100644
--- a/src/couch/test/couch_db_purge_seqs_tests.erl
+++ b/src/couch/test/couch_db_purge_seqs_tests.erl
@@ -21,10 +21,12 @@ setup() ->
{ok, _Db} = create_db(DbName),
DbName.
+
teardown(DbName) ->
delete_db(DbName),
ok.
+
couch_db_purge_seqs_test_() ->
{
"Couch_db purge_seqs",
@@ -51,6 +53,7 @@ couch_db_purge_seqs() ->
]
}.
+
test_update_seq_bounce(DbName) ->
?_test(
begin
@@ -99,7 +102,7 @@ test_update_seq_inc_on_complete_purge(DbName) ->
),
{ok, Db3} = couch_db:reopen(Db2),
- ?assertEqual(2, couch_db_engine:get_update_seq(Db3)),
+ ?assertEqual(3, couch_db_engine:get_update_seq(Db3)),
?assertEqual([], PRevs),
@@ -111,7 +114,7 @@ test_update_seq_inc_on_complete_purge(DbName) ->
?assertEqual([Rev], PRevs2),
{ok, Db4} = couch_db:reopen(Db3),
- ?assertEqual(3, couch_db_engine:get_update_seq(Db4))
+ ?assertEqual(4, couch_db_engine:get_update_seq(Db4))
end).