Software / code / prosody-modules
Changeset
1696:efc1d674eac0
mod_log_slow_events: Log slow HTTP requests
| author | Matthew Wild <mwild1@gmail.com> |
|---|---|
| date | Tue, 05 May 2015 14:21:13 +0100 |
| parents | 1695:78b3b3add19c |
| children | 1697:27aa58ed3e2e |
| files | mod_log_slow_events/mod_log_slow_events.lua |
| diffstat | 1 files changed, 22 insertions(+), 2 deletions(-) [+] |
line wrap: on
line diff
--- a/mod_log_slow_events/mod_log_slow_events.lua Tue May 05 14:20:53 2015 +0100 +++ b/mod_log_slow_events/mod_log_slow_events.lua Tue May 05 14:21:13 2015 +0100 @@ -1,8 +1,9 @@ local time = require "socket".gettime; +local base64_decode = require "util.encodings".base64.decode; local max_seconds = module:get_option_number("log_slow_events_threshold", 0.5); -module:wrap_event(false, function (handlers, event_name, event_data) +function event_wrapper(handlers, event_name, event_data) local start = time(); local ret = handlers(event_name, event_data); local duration = time()-start; @@ -27,9 +28,28 @@ local stanza = event_data.stanza; if stanza then log_data("stanza", tostring(stanza)); + else + local request = event_data.request; + if request then + log_data("http_method", request.method); + log_data("http_path", request.path); + local auth = request.headers.authorization; + if auth then + local creds = auth:match("^Basic +(.+)$"); + if creds then + local user = string.match(base64_decode(creds) or "", "^([^:]+):"); + log_data("http_user", user); + end + end + end end end module:log("warn", "Slow event '%s' took %0.2fs: %s", event_name, duration, next(data) and table.concat(data, ", ") or "no recognised data"); end return ret; -end); +end + +module:wrap_event(false, event_wrapper); +local http_events = require "net.http.server"._events; +module:wrap_object_event(http_events, false, event_wrapper); +
