aboutsummaryrefslogtreecommitdiff
path: root/src/mod_client_state.erl
blob: 3c046d77621ba7e8d6019caa3a6c27c6b870cd84 (plain) (blame)
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
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
%%%----------------------------------------------------------------------
%%% File    : mod_client_state.erl
%%% Author  : Holger Weiss <holger@zedat.fu-berlin.de>
%%% Purpose : Filter stanzas sent to inactive clients (XEP-0352)
%%% Created : 11 Sep 2014 by Holger Weiss <holger@zedat.fu-berlin.de>
%%%
%%%
%%% ejabberd, Copyright (C) 2014-2016   ProcessOne
%%%
%%% This program is free software; you can redistribute it and/or
%%% modify it under the terms of the GNU General Public License as
%%% published by the Free Software Foundation; either version 2 of the
%%% License, or (at your option) any later version.
%%%
%%% This program is distributed in the hope that it will be useful,
%%% but WITHOUT ANY WARRANTY; without even the implied warranty of
%%% MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
%%% General Public License for more details.
%%%
%%% You should have received a copy of the GNU General Public License along
%%% with this program; if not, write to the Free Software Foundation, Inc.,
%%% 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
%%%
%%%----------------------------------------------------------------------

-module(mod_client_state).
-author('holger@zedat.fu-berlin.de').
-protocol({xep, 85, '2.1'}).
-protocol({xep, 352, '0.1'}).

-behavior(gen_mod).

-export([start/2, stop/1, add_stream_feature/2,
	 filter_presence/2, filter_chat_states/2,
	 mod_opt_type/1]).

-include("ejabberd.hrl").
-include("logger.hrl").
-include("jlib.hrl").

start(Host, Opts) ->
    QueuePresence = gen_mod:get_opt(queue_presence, Opts,
				    fun(true) -> true;
				       (false) -> false
				    end, true),
    DropChatStates = gen_mod:get_opt(drop_chat_states, Opts,
				     fun(true) -> true;
				        (false) -> false
				     end, true),
    if QueuePresence; DropChatStates ->
	   ejabberd_hooks:add(c2s_post_auth_features, Host, ?MODULE,
			      add_stream_feature, 50),
	   if QueuePresence ->
		  ejabberd_hooks:add(csi_filter_stanza, Host, ?MODULE,
				     filter_presence, 50);
	      true -> ok
	   end,
	   if DropChatStates ->
		  ejabberd_hooks:add(csi_filter_stanza, Host, ?MODULE,
				     filter_chat_states, 50);
	      true -> ok
	   end;
       true -> ok
    end,
    ok.

stop(Host) ->
    ejabberd_hooks:delete(csi_filter_stanza, Host, ?MODULE,
			  filter_presence, 50),
    ejabberd_hooks:delete(csi_filter_stanza, Host, ?MODULE,
			  filter_chat_states, 50),
    ejabberd_hooks:delete(c2s_post_auth_features, Host, ?MODULE,
			  add_stream_feature, 50),
    ok.

add_stream_feature(Features, _Host) ->
    Feature = #xmlel{name = <<"csi">>,
		     attrs = [{<<"xmlns">>, ?NS_CLIENT_STATE}],
		     children = []},
    [Feature | Features].

filter_presence(_Action, #xmlel{name = <<"presence">>, attrs = Attrs}) ->
    case xml:get_attr(<<"type">>, Attrs) of
      {value, Type} when Type /= <<"unavailable">> ->
	  ?DEBUG("Got important presence stanza", []),
	  {stop, send};
      _ ->
	  ?DEBUG("Got availability presence stanza", []),
	  {stop, queue}
    end;
filter_presence(Action, _Stanza) -> Action.

filter_chat_states(_Action, #xmlel{name = <<"message">>} = Stanza) ->
    case jlib:is_standalone_chat_state(Stanza) of
      true ->
	  ?DEBUG("Got standalone chat state notification", []),
	  {stop, drop};
      false ->
	  ?DEBUG("Got message stanza", []),
	  {stop, send}
    end;
filter_chat_states(Action, _Stanza) -> Action.

mod_opt_type(drop_chat_states) ->
    fun (true) -> true;
	(false) -> false
    end;
mod_opt_type(queue_presence) ->
    fun (true) -> true;
	(false) -> false
    end;
mod_opt_type(_) -> [drop_chat_states, queue_presence].