Chapril/xmpp.chapril.org-ejabberd
24
1
Fork 0
mirror of https://github.com/processone/ejabberd.git synced 2024-06-14 22:00:16 +02:00
Code Releases Activity

External Component Connection Hooks

Browse Source
This commit is contained in:
xmppjingle 2016-07-18 17:55:10 -03:00
parent 749033598d
commit fca2f24231
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/ejabberd_service.erl
View File

@ -224,8 +224,10 @@ wait_for_handshake({xmlstreamelement, El}, StateData) ->
fun (H) -> fun (H) ->
ejabberd_router:register_route(H, ?MYNAME), ejabberd_router:register_route(H, ?MYNAME),
?INFO_MSG("Route registered for service ~p~n", ?INFO_MSG("Route registered for service ~p~n",
[H]) [H]),
end, dict:fetch_keys(StateData#state.host_opts)), ejabberd_hooks:run(component_connected,
[H])
end, dict:fetch_keys(StateData#state.host_opts)),
{next_state, stream_established, StateData}; {next_state, stream_established, StateData};
_ -> _ ->
send_text(StateData, ?INVALID_HANDSHAKE_ERR), send_text(StateData, ?INVALID_HANDSHAKE_ERR),
@ -288,13 +290,19 @@ stream_established({xmlstreamelement, El}, StateData) ->
end, end,
{next_state, stream_established, StateData}; {next_state, stream_established, StateData};
stream_established({xmlstreamend, _Name}, StateData) -> stream_established({xmlstreamend, _Name}, StateData) ->
ejabberd_hooks:run(component_disconnected,
[StateData#state.host]),
{stop, normal, StateData}; {stop, normal, StateData};
stream_established({xmlstreamerror, _}, StateData) -> stream_established({xmlstreamerror, _}, StateData) ->
ejabberd_hooks:run(component_disconnected,
[StateData#state.host]),
send_text(StateData, send_text(StateData,
<<(?INVALID_XML_ERR)/binary, <<(?INVALID_XML_ERR)/binary,
(?STREAM_TRAILER)/binary>>), (?STREAM_TRAILER)/binary>>),
{stop, normal, StateData}; {stop, normal, StateData};
stream_established(closed, StateData) -> stream_established(closed, StateData) ->
ejabberd_hooks:run(component_disconnected,
[StateData#state.host]),
{stop, normal, StateData}. {stop, normal, StateData}.
%%---------------------------------------------------------------------- %%----------------------------------------------------------------------