mirror of
https://github.com/processone/ejabberd
synced 2025-10-03 17:59:31 +02:00
Fix previous commit
This commit is contained in:
parent
cebdb87387
commit
4e014b4c5c
1 changed files with 13 additions and 27 deletions
|
@ -57,41 +57,27 @@ depends(_Host, _Opts) ->
|
||||||
-spec log_user_send({stanza(), ejabberd_c2s:state()}) -> {stanza(), ejabberd_c2s:state()}.
|
-spec log_user_send({stanza(), ejabberd_c2s:state()}) -> {stanza(), ejabberd_c2s:state()}.
|
||||||
log_user_send({Packet, C2SState}) ->
|
log_user_send({Packet, C2SState}) ->
|
||||||
From = xmpp:get_from(Packet),
|
From = xmpp:get_from(Packet),
|
||||||
To = xmpp:get_to(Packet),
|
log_packet(Packet, From#jid.lserver),
|
||||||
log_packet(From, To, Packet, From#jid.lserver),
|
|
||||||
{Packet, C2SState}.
|
{Packet, C2SState}.
|
||||||
|
|
||||||
-spec log_user_receive({stanza(), ejabberd_c2s:state()}) -> {stanza(), ejabberd_c2s:state()}.
|
-spec log_user_receive({stanza(), ejabberd_c2s:state()}) -> {stanza(), ejabberd_c2s:state()}.
|
||||||
log_user_receive({Packet, C2SState}) ->
|
log_user_receive({Packet, C2SState}) ->
|
||||||
From = xmpp:get_from(Packet),
|
|
||||||
To = xmpp:get_to(Packet),
|
To = xmpp:get_to(Packet),
|
||||||
log_packet(From, To, Packet, To#jid.lserver),
|
log_packet(Packet, To#jid.lserver),
|
||||||
{Packet, C2SState}.
|
{Packet, C2SState}.
|
||||||
|
|
||||||
-spec log_packet(jid(), jid(), stanza(), binary()) -> ok.
|
-spec log_packet(stanza(), binary()) -> ok.
|
||||||
log_packet(From, To, Packet, Host) ->
|
log_packet(Packet, Host) ->
|
||||||
Loggers = gen_mod:get_module_opt(Host, ?MODULE, loggers,
|
Loggers = gen_mod:get_module_opt(Host, ?MODULE, loggers,
|
||||||
fun(L) ->
|
mod_opt_type(loggers), []),
|
||||||
lists:map(
|
ForwardedMsg = #message{from = jid:make(Host),
|
||||||
fun(S) ->
|
id = randoms:get_string(),
|
||||||
B = iolist_to_binary(S),
|
sub_els = [#forwarded{
|
||||||
N = jid:nameprep(B),
|
xml_els = [xmpp:encode(Packet)]}]},
|
||||||
if N /= error ->
|
lists:foreach(
|
||||||
N
|
fun(Logger) ->
|
||||||
end
|
ejabberd_router:route(xmpp:set_to(ForwardedMsg, jid:make(Logger)))
|
||||||
end, L)
|
end, Loggers).
|
||||||
end, []),
|
|
||||||
ServerJID = jid:make(Host),
|
|
||||||
FixedPacket = xmpp:set_from_to(Packet, From, To),
|
|
||||||
lists:foreach(fun (Logger) ->
|
|
||||||
ejabberd_router:route(ServerJID,
|
|
||||||
jid:make(Logger),
|
|
||||||
#xmlel{name = <<"route">>,
|
|
||||||
attrs = [],
|
|
||||||
children =
|
|
||||||
[FixedPacket]})
|
|
||||||
end,
|
|
||||||
Loggers).
|
|
||||||
|
|
||||||
mod_opt_type(loggers) ->
|
mod_opt_type(loggers) ->
|
||||||
fun (L) ->
|
fun (L) ->
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue