diff options
Diffstat (limited to 'src/consul_interface_tests.erl')
| -rw-r--r-- | src/consul_interface_tests.erl | 88 |
1 files changed, 88 insertions, 0 deletions
diff --git a/src/consul_interface_tests.erl b/src/consul_interface_tests.erl new file mode 100644 index 0000000..cefa1fe --- /dev/null +++ b/src/consul_interface_tests.erl @@ -0,0 +1,88 @@ +% ============LICENSE_START======================================================= +% org.onap.dcae +% ================================================================================ +% Copyright (c) 2017 AT&T Intellectual Property. All rights reserved. +% ================================================================================ +% 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. +% ============LICENSE_END========================================================= +% +% ECOMP is a trademark and service mark of AT&T Intellectual Property. + +-module(consul_interface_tests). +-include_lib("eunit/include/eunit.hrl"). + +-import(consul_interface, [ + consul_get_service/3, + consul_read_kv/3, + consul_get_configuration/3, + consul_get_preferences/3, + consul_bind_config/3 + ]). + +consul_bind_config_test() -> + try meck:new(httpabs, [passthrough]) catch _:_ -> ok end, + try meck:new(util, [passthrough]) catch _:_ -> ok end, + FakeReturn = {[{<<"i am here">>, <<"my son">>}]}, + meck:expect(util, resolve_cbs, fun(_XER, _ConsulURL) -> "http://666.666.666.666:10000" end), %dont try to test the consul part here + meck:expect(httpabs, get, fun(_XER, URL) -> case URL of + "http://666.666.666.666:10000/service_component/salvationnotfound" -> {404, ""}; + "http://666.666.666.666:10000/service_component/salvation" -> {200, jiffy:encode(FakeReturn)} + end end), + ?assert(consul_bind_config("", "salvation", "") == {200, FakeReturn}), + ?assert(consul_bind_config("", "salvationnotfound", "") == {404, ""}), + meck:unload(httpabs), + meck:unload(util). + +consul_read_kv_test() -> + try meck:new(httpabs, [passthrough]) catch _:_ -> ok end, + Val = base64:encode("salvation"), + FakeReturn = jiffy:encode([{[{<<"Value">>, Val}]}]), + meck:expect(httpabs, get, fun(_XER, URL) -> case URL of + "http://666.666.666.666:666/v1/kv/salvationnotfound" -> {404, ""}; + "http://666.666.666.666:666/v1/kv/salvation" -> {200, FakeReturn} + end end), + ?assert(consul_read_kv("", <<"salvation">>, "http://666.666.666.666:666") == {200, <<"salvation">>}), + ?assert(consul_read_kv("", <<"salvationnotfound">>, "http://666.666.666.666:666") == {404, ""}), + meck:unload(httpabs). + +consul_get_configuration_preferences_test() -> + try meck:new(httpabs, [passthrough]) catch _:_ -> ok end, + Val = base64:encode(jiffy:encode({[{<<"iam">>, <<"thebestestjson">>}]})), + FakeReturn = jiffy:encode([{[{<<"Value">>, Val}]}]), + meck:expect(httpabs, get, fun(_XER, URL) -> case URL of + "http://666.666.666.666:666/v1/kv/salvationnotfound" -> {404, ""}; + "http://666.666.666.666:666/v1/kv/salvation" -> {200, FakeReturn}; + "http://666.666.666.666:666/v1/kv/salvation:preferences" -> {200, FakeReturn}; + "http://666.666.666.666:666/v1/kv/salvationnotfound:preferences" -> {404, ""} + end end), + ?assert(consul_get_configuration("", <<"salvation">>, "http://666.666.666.666:666") == {200, #{<<"iam">>=><<"thebestestjson">>}}), + ?assert(consul_get_configuration("", <<"salvationnotfound">>, "http://666.666.666.666:666") == {404, ""}), + ?assert(consul_get_preferences("", <<"salvation">>, "http://666.666.666.666:666") == {200, #{<<"iam">>=><<"thebestestjson">>}}), + ?assert(consul_get_preferences("", <<"salvationnotfound">>, "http://666.666.666.666:666") == {404, ""}), + + meck:unload(httpabs). + +consul_get_service_test() -> + try meck:new(httpabs, [passthrough]) catch _:_ -> ok end, + FakeConfig = jiffy:encode({[{<<"your key">>, <<"sir">>}]}), + meck:expect(httpabs, get, fun(_XER, URL) -> case URL of + "http://666.666.666.666:666/v1/catalog/service/salvationnotfound" -> {404, ""}; + "http://666.666.666.666:666/v1/catalog/service/salvation" -> {200, FakeConfig} + end end), + ?assert(consul_get_service("", <<"salvation">>, "http://666.666.666.666:666") == #{<<"your key">> => <<"sir">>}), + ?assertException(error, {badmatch,{404,[]}}, consul_get_service("", <<"salvationnotfound">>, "http://666.666.666.666:666")), + meck:unload(httpabs). + + + + |