diff options
Diffstat (limited to 'src/couch_index/test/eunit/couch_index_ddoc_updated_tests.erl')
| -rw-r--r-- | src/couch_index/test/eunit/couch_index_ddoc_updated_tests.erl | 86 |
1 files changed, 51 insertions, 35 deletions
diff --git a/src/couch_index/test/eunit/couch_index_ddoc_updated_tests.erl b/src/couch_index/test/eunit/couch_index_ddoc_updated_tests.erl index 0e23adf91..7bee8baae 100644 --- a/src/couch_index/test/eunit/couch_index_ddoc_updated_tests.erl +++ b/src/couch_index/test/eunit/couch_index_ddoc_updated_tests.erl @@ -15,7 +15,6 @@ -include_lib("couch/include/couch_eunit.hrl"). -include_lib("couch/include/couch_db.hrl"). - start() -> fake_index(), Ctx = test_util:start_couch([mem3, fabric]), @@ -23,56 +22,68 @@ start() -> ok = fabric:create_db(DbName, [?ADMIN_CTX]), {Ctx, DbName}. - stop({Ctx, DbName}) -> meck:unload(test_index), ok = fabric:delete_db(DbName, [?ADMIN_CTX]), DbDir = config:get("couchdb", "database_dir", "."), WaitFun = fun() -> - filelib:fold_files(DbDir, <<".*", DbName/binary, "\.[0-9]+.*">>, - true, fun(_F, _A) -> wait end, ok) + filelib:fold_files( + DbDir, + <<".*", DbName/binary, "\.[0-9]+.*">>, + true, + fun(_F, _A) -> wait end, + ok + ) end, ok = test_util:wait(WaitFun), test_util:stop_couch(Ctx), ok. - ddoc_update_test_() -> { "Check ddoc update actions", { setup, - fun start/0, fun stop/1, + fun start/0, + fun stop/1, fun check_all_indexers_exit_on_ddoc_change/1 } }. - check_all_indexers_exit_on_ddoc_change({_Ctx, DbName}) -> ?_test(begin - [DbShard1 | RestDbShards] = lists:map(fun(Sh) -> - {ok, ShardDb} = couch_db:open(mem3:name(Sh), []), - ShardDb - end, mem3:local_shards(mem3:dbname(DbName))), + [DbShard1 | RestDbShards] = lists:map( + fun(Sh) -> + {ok, ShardDb} = couch_db:open(mem3:name(Sh), []), + ShardDb + end, + mem3:local_shards(mem3:dbname(DbName)) + ), % create a DDoc on Db1 DDocID = <<"idx_name">>, - DDocJson = couch_doc:from_json_obj({[ - {<<"_id">>, DDocID}, - {<<"value">>, 1} - ]}), + DDocJson = couch_doc:from_json_obj( + {[ + {<<"_id">>, DDocID}, + {<<"value">>, 1} + ]} + ), {ok, _Rev} = couch_db:update_doc(DbShard1, DDocJson, []), {ok, DbShard} = couch_db:reopen(DbShard1), {ok, DDoc} = couch_db:open_doc( - DbShard, DDocID, [ejson_body, ?ADMIN_CTX]), + DbShard, DDocID, [ejson_body, ?ADMIN_CTX] + ), DbShards = [DbShard | RestDbShards], N = length(DbShards), % run couch_index process for each shard database ok = meck:reset(test_index), - lists:foreach(fun(ShardDb) -> - couch_index_server:get_index(test_index, ShardDb, DDoc) - end, DbShards), + lists:foreach( + fun(ShardDb) -> + couch_index_server:get_index(test_index, ShardDb, DDoc) + end, + DbShards + ), IndexesBefore = get_indexes_by_ddoc(DDocID, N), ?assertEqual(N, length(IndexesBefore)), @@ -81,17 +92,20 @@ check_all_indexers_exit_on_ddoc_change({_Ctx, DbName}) -> ?assertEqual(N, length(AliveBefore)), % update ddoc - DDocJson2 = couch_doc:from_json_obj({[ - {<<"_id">>, DDocID}, - {<<"value">>, 2}, - {<<"_rev">>, couch_doc:rev_to_str(DDoc#doc.revs)} - ]}), + DDocJson2 = couch_doc:from_json_obj( + {[ + {<<"_id">>, DDocID}, + {<<"value">>, 2}, + {<<"_rev">>, couch_doc:rev_to_str(DDoc#doc.revs)} + ]} + ), {ok, _} = couch_db:update_doc(DbShard, DDocJson2, []), % assert that all index processes exit after ddoc updated ok = meck:reset(test_index), couch_index_server:handle_db_event( - couch_db:name(DbShard), {ddoc_updated, DDocID}, {st, ""}), + couch_db:name(DbShard), {ddoc_updated, DDocID}, {st, ""} + ), ok = meck:wait(N, test_index, init, ['_', '_'], 5000), IndexesAfter = get_indexes_by_ddoc(DDocID, 0), @@ -103,7 +117,6 @@ check_all_indexers_exit_on_ddoc_change({_Ctx, DbName}) -> ok end). - fake_index() -> ok = meck:new([test_index], [non_strict]), ok = meck:expect(test_index, init, fun(Db, DDoc) -> @@ -124,11 +137,11 @@ fake_index() -> end), ok = meck:expect(test_index, shutdown, ['_'], ok). - get_indexes_by_ddoc(DDocID, N) -> Indexes = test_util:wait(fun() -> Indxs = ets:match_object( - couchdb_indexes_by_db, {'$1', {DDocID, '$2'}}), + couchdb_indexes_by_db, {'$1', {DDocID, '$2'}} + ), case length(Indxs) == N of true -> Indxs; @@ -136,10 +149,13 @@ get_indexes_by_ddoc(DDocID, N) -> wait end end), - lists:foldl(fun({DbName, {_DDocID, Sig}}, Acc) -> - case ets:lookup(couchdb_indexes_by_sig, {DbName, Sig}) of - [{_, Pid}] -> [Pid|Acc]; - _ -> Acc - end - end, [], Indexes). - + lists:foldl( + fun({DbName, {_DDocID, Sig}}, Acc) -> + case ets:lookup(couchdb_indexes_by_sig, {DbName, Sig}) of + [{_, Pid}] -> [Pid | Acc]; + _ -> Acc + end + end, + [], + Indexes + ). |