notifications support for channels

Changelog.md

@@ -9,6 +9,7 @@
   * Notification support.
   * Added channels concept. Write only transports.
   * Twitter channel added.
+  * Notification support for channels.
 
 ## Ybot-0.3.3 --> released
 

src/channel/twitter/ybot_twitter_client.erl

@@ -37,7 +37,7 @@ start_link(Consumer, ConsumerSecret, AccessToken, AccessTokenSecret) ->
 -spec send_message(TwitterClient :: pid(), Messsage :: string()) -> ok.
 send_message(TwitterClient, Messsage) ->
     % send message
-    gen_server:cast(TwitterClient, {send_message, Messsage}).
+    gen_server:cast(TwitterClient, {send_message, "", Messsage}).
 
 init([Consumer, ConsumerSecret, AccessToken, AccessTokenSecret]) ->
     % init interanal state
@@ -47,7 +47,7 @@ init([Consumer, ConsumerSecret, AccessToken, AccessTokenSecret]) ->
 handle_call(_Request, _From, State) ->
     {reply, ignored, State}.
 
-handle_cast({send_message, Messsage}, State) ->
+handle_cast({send_message, _From, Messsage}, State) ->
     Consumer = {binary_to_list(State#state.consumer, binary_to_list(State#state.consumer_secret), hmac_sha1)},
     % update twitter status
     oauth:post("https://api.twitter.com/1/statuses/update.json", [{"status", Messsage}], Consumer, 

src/ybot_manager.erl

@@ -74,6 +74,10 @@ handle_call({get_plugin, PluginName}, _From, State) ->
 handle_call(get_transports, _From, State) ->
     {reply, State#state.transports, State};
 
+%% @doc get channels info
+handle_call(get_channels, _From, State) ->
+    {reply, State#state.channels, State};
+
 %% @doc get all runned transports pid
 handle_call(get_runnned_transports, _From, State) ->
     % Return all runned transports

src/ybot_notification_handler.erl

@@ -56,6 +56,21 @@ handle_cast({init_handler, {PluginName, TranportsList, Timeout}, NotificationDir
                                                    end
                                                end,
                                                gen_server:call(ybot_manager, get_transports))),
+
+    % Get necessary channels
+    Channels = lists:flatten(lists:map(fun(Channel) ->
+                                           % Check is notification for this channel or not 
+                                           IsChannel = lists:member(element(1, Channel), TranportsList),
+                                           case IsChannel of
+                                               true ->
+                                                   element(2, Channel);
+                                               false ->
+                                                   []
+                                            end
+                                       end,
+                                       gen_server:call(ybot_manager, get_channels))),
+    % Make transports list
+    Transports = lists:append(RunnedTransports, Channels),
     % Get plugin file with extension
     [PluginWithExt | _] = filelib:wildcard(atom_to_list(PluginName) ++ "*", NotificationDir),
     % Get lang
@@ -65,7 +80,7 @@ handle_cast({init_handler, {PluginName, TranportsList, Timeout}, NotificationDir
     % start notifications
     erlang:send_after(Timeout * 1000, self(), execute),
     % return
-    {noreply, State#state{transports = RunnedTransports, lang = Lang, timeout = Timeout * 1000, plugin_path = PluginPath}};
+    {noreply, State#state{transports = Transports, lang = Lang, timeout = Timeout * 1000, plugin_path = PluginPath}};
 
 handle_cast(_Msg, State) ->
     {noreply, State}.

ybot.config

@@ -119,7 +119,7 @@
             %
             {notification, 
                 [ % {plugin name :: atom(), [transport list :: atom()], timeout_in_seconds :: integer()} 
-                  {ackbar, [irc], 60}
+                  {ackbar, [irc, twitter], 60}
                 ]
             },