Comparison

util.adminstream: Expose session events (specifically "disconnected") Currently there is no way to get this info and perform cleanup tasks.

comparison

equal deleted inserted replaced

-:899453f11f50
+:b1b931d5fee8
 		end;
 	};
 end
 local function new_server(sessions, stanza_handler)
-	local listeners = {};
+	local s = {
+		events = events.new();
-	function listeners.onconnect(conn)
+		listeners = {};
+	};
+	function s.listeners.onconnect(conn)
 		log("debug", "New connection");
 		local session = sessionlib.new("admin");
 		sessionlib.set_id(session);
 		sessionlib.set_logger(session);
 		sessionlib.set_conn(session, conn);
 		end
 		sessions[conn] = session;
 	end
-	function listeners.onincoming(conn, data)
+	function s.listeners.onincoming(conn, data)
 		local session = sessions[conn];
 		if session then
 			session.data(data);
 		end
 	end
-	function listeners.ondisconnect(conn, err)
+	function s.listeners.ondisconnect(conn, err)
 		local session = sessions[conn];
 		if session then
 			session.log("info", "Admin client disconnected: %s", err or "connection closed");
 			session.conn = nil;
 			sessions[conn]  = nil;
-		end
+			s.events.fire_event("disconnected", { session = session });
-	end
+		end
+	end
-	function listeners.onreadtimeout(conn)
+	function s.listeners.onreadtimeout(conn)
 		return conn:send(" ");
 	end
-	return {
+	return s;
-		listeners = listeners;
-	};
 end
 local function new_client()
 	local client = {
 		type = "client";