mod_log_ringbuffer: Detach event handlers on logging reload (thanks Menel)
Otherwise the global event handlers accumulate, one added each time
logging is reoladed, and each invocation of the signal or event triggers
one dump of each created ringbuffer.
-- Log common stats to statsd
--
-- Copyright (C) 2014 Daurnimator
--
-- This module is MIT/X11 licensed.
local socket = require "socket"
local iterators = require "util.iterators"
local jid = require "util.jid"
local bare_sessions = prosody.bare_sessions;
local options = module:get_option("statsd") or {}
-- Create UDP socket to statsd server
local sock = socket.udp()
sock:setpeername(options.hostname or "127.0.0.1", options.port or 8125)
-- Metrics are namespaced by ".", and separated by newline
function clean(s) return (s:gsub("[%.:\n]", "_")) end
-- A 'safer' send function to expose
function send(s) return sock:send(s) end
-- prefix should end in "."
local prefix = (options.prefix or "prosody") .. "."
if not options.no_host then
prefix = prefix .. clean(module.host) .. "."
end
-- Track users as they bind/unbind
-- count bare sessions every time, as we have no way to tell if it's a new bare session or not
module:hook("resource-bind", function(event)
send(prefix.."bare_sessions:"..iterators.count(pairs(bare_sessions)).."|g")
send(prefix.."full_sessions:+1|g")
end, 1)
module:hook("resource-unbind", function(event)
send(prefix.."bare_sessions:"..iterators.count(pairs(bare_sessions)).."|g")
send(prefix.."full_sessions:-1|g")
end, 1)
-- Track MUC occupants as they join/leave
module:hook("muc-occupant-joined", function(event)
send(prefix.."n_occupants:+1|g")
local room_node = jid.split(event.room.jid)
send(prefix..clean(room_node)..".occupants:+1|g")
end)
module:hook("muc-occupant-left", function(event)
send(prefix.."n_occupants:-1|g")
local room_node = jid.split(event.room.jid)
send(prefix..clean(room_node)..".occupants:-1|g")
end)
-- Misc other MUC
module:hook("muc-broadcast-message", function(event)
send(prefix.."broadcast-message:1|c")
local room_node = jid.split(event.room.jid)
send(prefix..clean(room_node)..".broadcast-message:1|c")
end)
module:hook("muc-invite", function(event)
-- Total count
send(prefix.."invite:1|c")
local room_node = jid.split(event.room.jid)
-- Counts per room
send(prefix..clean(room_node)..".invite:1|c")
-- Counts per recipient
send(prefix..clean(event.stanza.attr.to)..".invited:1|c")
end)
module:hook("muc-decline", function(event)
-- Total count
send(prefix.."decline:1|c")
local room_node = jid.split(event.room.jid)
-- Counts per room
send(prefix..clean(room_node)..".decline:1|c")
-- Counts per sender
send(prefix..clean(event.incoming.attr.from)..".declined:1|c")
end)