sumo_db

%%% @doc This module is in charge of the event management.
%%%
%%% Copyright 2012 Inaka <hello@inaka.net>
%%%
%%% 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.
%%% @end
%%% @copyright Inaka <hello@inaka.net>
%%%
-module(sumo_event).
-author("Marcelo Gornstein <marcelog@gmail.com>").
-github("https://github.com/inaka").
-license("Apache License 2.0").

%%% API
-export([dispatch/2, dispatch/3]).

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

%% @doc Dispatch an event through gen_event:notify/2.
-spec dispatch(sumo:schema_name(), term()) -> ok.
dispatch(DocName, Event) ->
  dispatch(DocName, Event, []).

%% @doc Dispatch an event through gen_event:notify/2.
-spec dispatch(sumo:schema_name(), term(), term()) -> ok.
dispatch(DocName, Event, Args) ->
  case get_event_manager(DocName) of
    undefined    -> ok;
    EventManager -> gen_event:notify(EventManager, {DocName, Event, Args})
  end.

%%%=============================================================================
%%% Internal functions
%%%=============================================================================

%% @doc Returns the name of the event manager configured for the given
%% doc, or undefined.
-spec get_event_manager(DocName) -> Res when
  DocName :: sumo:schema_name(),
  Res     :: undefined | atom()| {atom(), term()}.
get_event_manager(DocName) ->
  {ok, Docs} = application:get_env(sumo_db, events),
  case Docs of
    undefined ->
      undefined;
    EventManagers ->
      case sumo_utils:keyfind(DocName, EventManagers) of
        undefined -> undefined;
        Name      -> Name
      end
  end.