From d0218deb88922dfd1733d06793750b1b6740efb4 Mon Sep 17 00:00:00 2001
From: Feng <ery.lee@gmail.com>
Date: Wed, 28 Sep 2016 22:43:58 +0800
Subject: [PATCH] Add hooks: session.created, session.terminated

---
 src/emqttd_session.erl | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/emqttd_session.erl b/src/emqttd_session.erl
index 85701e249..b6276ab85 100644
--- a/src/emqttd_session.erl
+++ b/src/emqttd_session.erl
@@ -235,6 +235,7 @@ init([CleanSess, {ClientId, Username}, ClientPid]) ->
             collect_interval  = get_value(collect_interval, SessEnv, 0),
             timestamp         = os:timestamp()},
     emqttd_sm:reg_session(ClientId, CleanSess, sess_info(Session)),
+    emqttd:run_hooks('session.created', [ClientId, Username]),
     %% Start statistics
     {ok, start_collector(Session), hibernate}.
 
@@ -519,7 +520,8 @@ handle_info(expired, Session) ->
 handle_info(Info, Session) ->
     ?UNEXPECTED_INFO(Info, Session).
 
-terminate(_Reason, #session{client_id = ClientId}) ->
+terminate(Reason, #session{client_id = ClientId, username = Username}) ->
+    emqttd:run_hooks('session.terminated', [ClientId, Username, Reason]),
     emqttd:subscriber_down(ClientId),
     emqttd_sm:unreg_session(ClientId).