Greatly increase unit tests

Issue-ID: DCAEGEN2-99
Change-Id: I03b62d8a54b8a6eb443f5ce648a92ff1f9953ade
Signed-off-by: Tommy Carpenter <tommy@research.att.com>

1 files changed, 149 insertions, 11 deletions

diff --git a/src/cdap_interface_tests.erl b/src/cdap_interface_tests.erl
index 37926a6..c1d1e6c 100644
--- a/src/cdap_interface_tests.erl
+++ b/src/cdap_interface_tests.erl
@@ -6,9 +6,9 @@
 % 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.
@@ -21,14 +21,152 @@
 -module(cdap_interface_tests).
 -include_lib("eunit/include/eunit.hrl").
 
+-import(cdap_interface, [
+           get_cdap_gui_port_from_version/1,
+           map_appname/1,
+           get_cdap_cluster_version/2,
+           form_stream_url_from_streamname/3,
+           form_service_json_from_service_tuple/4,
+           get_app_preferences/4,
+           get_app_config/4,
+           get_pipeline_healthcheck/5
+          ]).
+
+get_pipeline_healthcheck_test() ->
+    FakeReturn = jiffy:encode({[{<<"status">>, <<"SCHEDULED">>}]}),
+    try meck:new(httpabs, [passthrough]) catch _:_ -> ok end,
+    %notfound
+    meck:expect(httpabs, get, fun(_XER, URL) -> case URL of
+                                  "http://666.666.666.666:666/v3/namespaces/testns/apps/1234app/schedules/dataPipelineSchedule/status"  -> {200, FakeReturn};
+                                   "http://666.666.666.666:666/v3/namespaces/testns/apps/1234appNOTFOUND/schedules/dataPipelineSchedule/status" -> {404, ""}
+                              end end),
+    ?assert(get_pipeline_healthcheck("", "1234%%%%^@#$%@#$%#$^@$.appNOTFOUND", "testns", "http://666.666.666.666:666", 666) == 400),
+
+    %bad status
+    FakeReturnBadStatus = jiffy:encode({[{<<"status">>, <<"nosoupforyou">>}]}),
+    meck:expect(httpabs, get, fun(_XER, URL) -> case URL of
+                                  "http://666.666.666.666:666/v3/namespaces/testns/apps/1234app/schedules/dataPipelineSchedule/status"  -> {200, FakeReturnBadStatus}
+                              end end),
+    ?assert(get_pipeline_healthcheck("", "1234%%%%^@#$%@#$%#$^@$.app", "testns", "http://666.666.666.666:666", 666) == 400),
+
+     %good status but no status endpoint
+     meck:expect(httpabs, get, fun(_XER, URL) -> case URL of
+                                   "http://666.666.666.666:666/v3/namespaces/testns/apps/1234app/schedules/dataPipelineSchedule/status"  -> {200, FakeReturn};
+                                   "http://666.666.666.666:666/v3/namespaces/testns/apps/1234app/workflows/DataPipelineWorkflow/runs?limit=666" -> {404, ""}
+                               end end),
+    ?assert(get_pipeline_healthcheck("", "1234%%%%^@#$%@#$%#$^@$.app", "testns", "http://666.666.666.666:666", 666) == 404),
+
+    %good status but a bad malformed inner
+    MalformedRuns = jiffy:encode([
+                            {[{<<"nostatus">>, <<"foryou">>}]},
+                            {[{<<"status">>, <<"RUNNING">>}]}
+                           ]),
+    meck:expect(httpabs, get, fun(_XER, URL) -> case URL of
+                                   "http://666.666.666.666:666/v3/namespaces/testns/apps/1234app/schedules/dataPipelineSchedule/status"  -> {200, FakeReturn};
+                                   "http://666.666.666.666:666/v3/namespaces/testns/apps/1234app/workflows/DataPipelineWorkflow/runs?limit=666" -> {200, MalformedRuns}
+                              end end),
+
+    ?assert(get_pipeline_healthcheck("", "1234%%%%^@#$%@#$%#$^@$.app", "testns", "http://666.666.666.666:666", 666) == 400),
+
+    %good status but a not good inner
+    BadRuns = jiffy:encode([
+                            {[{<<"status">>, <<"FAILED">>}]},
+                            {[{<<"status">>, <<"RUNNING">>}]}
+                           ]),
+    meck:expect(httpabs, get, fun(_XER, URL) -> case URL of
+                                  "http://666.666.666.666:666/v3/namespaces/testns/apps/1234app/schedules/dataPipelineSchedule/status"  -> {200, FakeReturn};
+                                  "http://666.666.666.666:666/v3/namespaces/testns/apps/1234app/workflows/DataPipelineWorkflow/runs?limit=666" -> {200, BadRuns}
+                              end end),
+    ?assert(get_pipeline_healthcheck("", "1234%%%%^@#$%@#$%#$^@$.app", "testns", "http://666.666.666.666:666", 666) == 400),
+
+    %two running
+    TwoRunning = jiffy:encode([
+                            {[{<<"status">>, <<"RUNNING">>}]},
+                            {[{<<"status">>, <<"COMPLETED">>}]},
+                            {[{<<"status">>, <<"RUNNING">>}]}
+                           ]),
+    meck:expect(httpabs, get, fun(_XER, URL) -> case URL of
+                                  "http://666.666.666.666:666/v3/namespaces/testns/apps/1234app/schedules/dataPipelineSchedule/status"  -> {200, FakeReturn};
+                                  "http://666.666.666.666:666/v3/namespaces/testns/apps/1234app/workflows/DataPipelineWorkflow/runs?limit=666" -> {200, TwoRunning}
+                              end end),
+    ?assert(get_pipeline_healthcheck("", "1234%%%%^@#$%@#$%#$^@$.app", "testns", "http://666.666.666.666:666", 666) == 400),
+
+    %all good
+     %good status but a not good inner
+    GoodRuns = jiffy:encode([
+                            {[{<<"status">>, <<"COMPLETED">>}]},
+                            {[{<<"status">>, <<"RUNNING">>}]},
+                            {[{<<"status">>, <<"COMPLETED">>}]}
+                           ]),
+    meck:expect(httpabs, get, fun(_XER, URL) -> case URL of
+                                  "http://666.666.666.666:666/v3/namespaces/testns/apps/1234app/schedules/dataPipelineSchedule/status"  -> {200, FakeReturn};
+                                  "http://666.666.666.666:666/v3/namespaces/testns/apps/1234app/workflows/DataPipelineWorkflow/runs?limit=666" -> {200, GoodRuns}
+                              end end),
+    ?assert(get_pipeline_healthcheck("", "1234%%%%^@#$%@#$%#$^@$.app", "testns", "http://666.666.666.666:666", 666) == 200),
+
+    meck:unload(httpabs).
+
+
+
+get_app_config_test() ->
+    FakeReturn = jiffy:encode({[{<<"configuration">>, {[{<<"welcome">>, <<"toeternity">>}]}}]}),
+    try meck:new(httpabs, [passthrough]) catch _:_ -> ok end,
+    meck:expect(httpabs, get, fun(_XER, URL) ->
+                                  case URL of
+                                      "http://666.666.666.666:666/v3/namespaces/testns/apps/1234app"  -> {200, FakeReturn};
+                                      "http://666.666.666.666:666/v3/namespaces/testns/apps/1234appNOTFOUND" -> {404, ""}
+                                  end
+                              end),
+    ?assert(get_app_config("", "1234%%%%^@#$%@#$%#$^@$.app", "testns", "http://666.666.666.666:666") ==
+             {200, #{<<"welcome">> => <<"toeternity">>}}),
+    ?assert(get_app_config("", "1234%%%%^@#$%@#$%#$^@$.appNOTFOUND", "testns", "http://666.666.666.666:666") == {404, ""}),
+    meck:unload(httpabs).
+
+get_app_preferences_test() ->
+    FakeReturn = jiffy:encode({[{<<"welcome">>, <<"toeternity">>}]}),
+    try meck:new(httpabs, [passthrough]) catch _:_ -> ok end,
+    meck:expect(httpabs, get, fun(_XER, URL) ->
+                                  case URL of
+                                      "http://666.666.666.666:666/v3/namespaces/testns/apps/1234app/preferences"  -> {200, FakeReturn};
+                                      "http://666.666.666.666:666/v3/namespaces/testns/apps/1234appNOTFOUND/preferences" -> {404, ""}
+                                  end
+                              end),
+    ?assert(get_app_preferences("", "1234%%%%^@#$%@#$%#$^@$.app", "testns", "http://666.666.666.666:666") ==
+             {200, #{<<"welcome">> => <<"toeternity">>}}),
+    ?assert(get_app_preferences("", "1234%%%%^@#$%@#$%#$^@$.appNOTFOUND", "testns", "http://666.666.666.666:666") == {404, ""}),
+    meck:unload(httpabs).
+
+form_service_json_from_service_tuple_test() ->
+    ?assert(form_service_json_from_service_tuple(<<"amazin@)#$%@#)$%gapp">>, "amazingns", "http://666.666.666.666:666", {"seeme", "feelme", "PUT"})
+           == {[{<<"url">> ,<<"http://666.666.666.666:666/v3/namespaces/amazingns/apps/amazingapp/services/seeme/methods/feelme">>},
+                {<<"method">>, "PUT"}]}).
+
+form_stream_url_from_streamname_test() ->
+    ?assert(form_stream_url_from_streamname("666.666.666.666:666", "thevoid", "souls") == <<"666.666.666.666:666/v3/namespaces/thevoid/streams/souls">>).
+
 get_cdap_gui_port_from_version_test() ->
-    ?assert(9999 == cdap_interface:get_cdap_gui_port_from_version("3.0.0")),
-    ?assert(9999 == cdap_interface:get_cdap_gui_port_from_version("3.10.0")),
-    ?assert(9999 == cdap_interface:get_cdap_gui_port_from_version("3.0.10")),
-    ?assert(9999 == cdap_interface:get_cdap_gui_port_from_version("3.10.10")),
-    ?assert(11011 == cdap_interface:get_cdap_gui_port_from_version(<<"4.0.0">>)),
-    ?assert(11011 == cdap_interface:get_cdap_gui_port_from_version(<<"4.10.0">>)),
-    ?assert(11011 == cdap_interface:get_cdap_gui_port_from_version(<<"4.0.10">>)),
-    ?assert(11011 == cdap_interface:get_cdap_gui_port_from_version(<<"4.10.10">>)),
-    ?assert(<<"UNKNOWN CDAP VERSION">> == cdap_interface:get_cdap_gui_port_from_version("5.0.0")).
+    ?assert(9999 == get_cdap_gui_port_from_version("3.0.0")),
+    ?assert(9999 == get_cdap_gui_port_from_version("3.10.0")),
+    ?assert(9999 == get_cdap_gui_port_from_version("3.0.10")),
+    ?assert(9999 == get_cdap_gui_port_from_version("3.10.10")),
+    ?assert(11011 == get_cdap_gui_port_from_version(<<"4.0.0">>)),
+    ?assert(11011 == get_cdap_gui_port_from_version(<<"4.10.0">>)),
+    ?assert(11011 == get_cdap_gui_port_from_version(<<"4.0.10">>)),
+    ?assert(11011 == get_cdap_gui_port_from_version(<<"4.10.10">>)),
+    ?assert(<<"UNKNOWN CDAP VERSION">> == get_cdap_gui_port_from_version("5.0.0")).
+
+map_appname_test() ->
+    ?assert(map_appname(<<"foo">>) == <<"foo">>),
+    ?assert(map_appname(<<"fo.o">>) == <<"foo">>),
+    ?assert(map_appname(<<"f_oo">>) == <<"foo">>),
+    ?assert(map_appname(<<"._*#$%#*%$$#@#foo">>) == <<"foo">>).
+
+get_cdap_cluster_version_test() ->
+    FakeReturn = jiffy:encode({[{<<"version">>, <<"4.0.3">>}]}),
+    try meck:new(httpabs, [passthrough]) catch _:_ -> ok end,
+    meck:expect(httpabs, get, fun(_XER, _URL) -> {200, FakeReturn} end),
+    ?assert(get_cdap_cluster_version("","") == <<"4.0.3">>),
+    meck:expect(httpabs, get, fun(_XER, _URL) -> {404, ""} end),
+    ?assert(get_cdap_cluster_version("","") == <<"UNKNOWN CDAP VERSION">>),
+    meck:unload(httpabs).