riak_test/tests/ts_cluster_riak_shell_regression_log.erl
John R. Daily 4744eecd47 Faster/cleaner remove_last/1 per Andrei
converting ts_util calls to new ts library calls

modified ts_setup:create_bucket_type

more test updating

Replace ts_util with ts_setup, ts_ops and ts_data
2016-11-04 16:19:30 -06:00

57 lines
2.0 KiB
Erlang

%% -------------------------------------------------------------------
%%
%% Copyright (c) 2016 Basho Technologies, Inc.
%%
%% This file is provided to you 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(ts_cluster_riak_shell_regression_log).
-behavior(riak_test).
-include_lib("eunit/include/eunit.hrl").
-export([confirm/0]).
-define(DONT_INCREMENT_PROMPT, false).
-define(LOG_FILE, "priv/riak_shell/riak_shell_regression1.log").
%% we cant run the test in this process as it receives various messages
%% and the running test interprets then as being messages to the shell
confirm() ->
Nodes = ts_setup:start_cluster(3),
_Conn = ts_setup:conn(Nodes),
lager:info("Built a cluster of ~p~n", [Nodes]),
Self = self(),
_Pid = spawn_link(fun() -> load_log_file(Self) end),
Got1 = riak_shell_test_util:loop(),
Result = ts_data:assert("Regression Log", pass, Got1),
ts_data:results([
Result
]),
pass.
load_log_file(Pid) ->
State = riak_shell_test_util:shell_init(),
lager:info("~n~nLoad the log -------------------------", []),
Cmds = [
{{match, "No Regression Errors."},
ts_data:flat_format("regression_log \"~s\";", [?LOG_FILE])}
],
Result = riak_shell_test_util:run_commands(Cmds, State,
?DONT_INCREMENT_PROMPT),
lager:info("~n~n------------------------------------------------------", []),
Pid ! Result.