aboutsummaryrefslogtreecommitdiffstats
path: root/src/cdapbroker_app.erl
blob: 13256b0e49e7e3d35d0b40a73aaba991dd43cfe6 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
% ============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.

%%%-------------------------------------------------------------------
%% @doc cdapbroker public API
%% @end
%%%-------------------------------------------------------------------

-module(cdapbroker_app).

-behaviour(application).

%% Application callbacks
-export([start/2, stop/1]).

%for application state
-include("application.hrl").
-define(SC(L), util:concat(L)).

%%====================================================================
%% API
%%====================================================================

start(_StartType, _StartArgs) ->
    %starting inets to make request calls
    inets:start(),
    %from the HTTPC page: 
    %"If the scheme https is used, the SSL application must be started. 
    ssl:start(),

    %EELF hello
    audit:info("Audit log initlized"),
    metrics:info("Metrics log initlized"),
    error:info("Error log initlized"),

    %fail fast; check all failure conditions first
    PE = util:get_platform_envs_and_config(),
    case PE of 
        [] -> %crash and burn. Need to exit else supervisor will restart this endlessly.  
          exit("fatal error, either HOSTNAME or CONSUL_HOST or CONFIG_BINDING_SERVICE is not set as an env variable");
        [_, ConsulURL, CDAPUrl, BoundConfigMap] ->
          try
              S = dict:new(),
              S1 = dict:store("consulurl", ConsulURL, S),
              S2 = dict:store("configmap", BoundConfigMap, S1),
              State = dict:store("cdapurl", CDAPUrl, S2),
              
              %initialize database
              ok = util:initialize_database(),

              %print out currently registered apps at startup
              lager:info("Currently installed apps: ~p~n", [util:get_all_appnames_from_db()]),
              
              %start the REST server
              leptus:start_listener(http, [{'_', [{resource_handler, State}]}], [{port, 7777}, {ip, {0,0,0,0}}]),
                      
              %start the supervisor
              lager:info("Starting supervisor"),
              cdapbroker_sup:start_link()
        catch Class:Reason ->
            lager:error("~nError Stacktrace:~s", [lager:pr_stacktrace(erlang:get_stacktrace(), {Class, Reason})]),
            exit(Reason)
        end
    end.

%%--------------------------------------------------------------------
stop(_State) ->
    %need to make sure there are no pending transcations in RAM not written to disk yet on shutdown.
    %Two hard problems in CS, this is one of then...
    lager:info("Stop recieved."),
    case mnesia:sync_log() of 
        ok -> ok;
        {error, Reason} ->
            lager:error(io_lib:format("While stopping, MNESIA could not by syncd due to: ~s. This means on bootup the database may be in a bad state!!", [Reason])),
            notok
    end.