Mercurial > prosody-modules
view mod_audit_status/mod_audit_status.lua @ 5951:d6a695abb33c
mod_ping_muc: Delay ping a configurable amount of time
If a server is restarting, checking immediately before it has a chance
to complete its restart and get ready would often fail, preventing the
possibility of transparent restarts as supported by Prosody's mod_muc.
Reconnecting immediately when a connection is closed for being idle, or
because the remote server is trying to reclaim some resources, is also
counter-productive as the connection may fail.
Also, if there is some Internet routing problem affecting s2s, it may
help to wait a bit before checking, in case the problem resolved itself
in the mean time.
author | Kim Alvefur <zash@zash.se> |
---|---|
date | Sun, 11 Aug 2024 16:10:24 +0200 |
parents | bd0abf821cef |
children |
line wrap: on
line source
module:depends("audit"); local st = require "util.stanza"; -- Suppress warnings about module:audit() -- luacheck: ignore 143/module local heartbeat_interval = module:get_option_number("audit_status_heartbeat_interval", 60); local store = module:open_store(nil, "keyval+"); -- This is global, to make it available to other modules crashed = false; --luacheck: ignore 131/crashed module:hook_global("server-started", function () local recorded_status = store:get(); if recorded_status and recorded_status.status == "started" then module:audit(nil, "server-crashed", { timestamp = recorded_status.heartbeat }); crashed = true; end module:audit(nil, "server-started"); store:set_key(nil, "status", "started"); end); module:hook_global("server-stopped", function () module:audit(nil, "server-stopped", { custom = { prosody.shutdown_reason and st.stanza("note"):text(prosody.shutdown_reason); }; }); store:set_key(nil, "status", "stopped"); end); if heartbeat_interval then local async = require "util.async"; local heartbeat_writer = async.runner(function (timestamp) store:set_key(nil, "heartbeat", timestamp); end); module:add_timer(0, function () heartbeat_writer:run(os.time()); return heartbeat_interval; end); end