File

+
−local verse = require "verse";
+
−local gettime = require"socket".gettime;
+
−local new_id = require "prosody.util.id".short;
+
−
+
−local xmlns_ping = "urn:xmpp:ping";
+
−
+
−function verse.plugins.ping(stream)
+
−	function stream:ping(jid, callback)
+
−		local t = gettime();
+
−		local id = new_id();
+
−		local ping = verse.iq{ id = id, to = jid, type = "get" }:tag("ping", { xmlns = xmlns_ping });
+
−		stream:send_iq(ping,
+
−			function (reply)
+
−				if reply.attr.type == "error" then
+
−					local type, condition, text = reply:get_error();
+
−					if condition ~= "service-unavailable" and condition ~= "feature-not-implemented" then
+
−						callback(nil, jid, { type = type, condition = condition, text = text });
+
−						return;
+
−					end
+
−				end
+
−				callback(gettime()-t, jid);
+
−			end);
+
−		return id;
+
−	end
+
−	stream:hook("iq/"..xmlns_ping, function(stanza)
+
−		return stream:send(verse.reply(stanza));
+
−	end);
+
−	return true;
+
−end