summaryrefslogtreecommitdiff
path: root/src/dreyfus/test/dreyfus_blacklist_await_test.erl
diff options
context:
space:
mode:
Diffstat (limited to 'src/dreyfus/test/dreyfus_blacklist_await_test.erl')
-rw-r--r--src/dreyfus/test/dreyfus_blacklist_await_test.erl76
1 files changed, 0 insertions, 76 deletions
diff --git a/src/dreyfus/test/dreyfus_blacklist_await_test.erl b/src/dreyfus/test/dreyfus_blacklist_await_test.erl
deleted file mode 100644
index 28a5e7f30..000000000
--- a/src/dreyfus/test/dreyfus_blacklist_await_test.erl
+++ /dev/null
@@ -1,76 +0,0 @@
-% 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(dreyfus_blacklist_await_test).
-
--include_lib("couch/include/couch_db.hrl").
--include_lib("dreyfus/include/dreyfus.hrl").
--include_lib("eunit/include/eunit.hrl").
-
--define(DDOC_ID, <<"_design/black_list_doc">>).
--define(INDEX_NAME, <<"my_index">>).
--define(DBNAME, <<"mydb">>).
--define(TIMEOUT, 1000).
-
-start() ->
- test_util:start_couch([dreyfus]).
-
-stop(_) ->
- test_util:stop_couch([dreyfus]).
-
-setup() ->
- ok = meck:new(couch_log),
- ok = meck:expect(couch_log, notice, fun(_Fmt, _Args) ->
- ?debugFmt(_Fmt, _Args)
- end).
-
-teardown(_) ->
- ok = meck:unload(couch_log).
-
-dreyfus_blacklist_await_test_() ->
- {
- "dreyfus black_list_doc await tests",
- {
- setup,
- fun start/0, fun stop/1,
- {
- foreach,
- fun setup/0, fun teardown/1,
- [
- fun do_not_await_1/0
- ]
- }
- }
- }.
-
-do_not_await_1() ->
- ok = meck:new(dreyfus_index, [passthrough]),
- Denied = lists:flatten([?b2l(?DBNAME), ".", "black_list_doc", ".",
- "my_index"]),
- config:set("dreyfus_blacklist", Denied, "true"),
- dreyfus_test_util:wait_config_change(Denied, "true"),
- Index = #index{dbname=?DBNAME, name=?INDEX_NAME, ddoc_id=?DDOC_ID},
- State = create_state(?DBNAME, Index, nil, nil, []),
- Msg = "Index Blocked from Updating - db: ~p, ddocid: ~p name: ~p",
- Return = wait_log_message(Msg, fun() ->
- {noreply, NewState} = dreyfus_index:handle_call({await, 1},
- self(), State)
- end),
- ?assertEqual(Return, ok).
-
-wait_log_message(Fmt, Fun) ->
- ok = meck:reset(couch_log),
- Fun(),
- ok = meck:wait(couch_log, '_', [Fmt, '_'], 5000).
-
-create_state(DbName, Index, UPid, IPid, WList) ->
- {state, DbName, Index, UPid, IPid, WList}.