verse
73d4eb93657b
plugins/ping.lua

Find changesets by keywords by author, files, the commit message, revision number or hash, or revset expression.

Software / code / verse

Comparison

plugins/ping.lua @ 457:73d4eb93657b

Update to use util.id for random ids instead of counters (thanks Zash)
author Matthew Wild <mwild1@gmail.com>
date Thu, 16 Mar 2023 11:41:52 +0000
parent 393:69229fa1d24f
child 490:6b2f31da9610
comparison
equal deleted inserted replaced
456:6a65142052c8 457:73d4eb93657b
1 local verse = require "verse"; 1 local verse = require "verse";
2 local gettime = require"socket".gettime; 2 local gettime = require"socket".gettime;
3 local new_id = require "util.id".short;
3 4
4 local xmlns_ping = "urn:xmpp:ping"; 5 local xmlns_ping = "urn:xmpp:ping";
5 6
6 function verse.plugins.ping(stream) 7 function verse.plugins.ping(stream)
7 function stream:ping(jid, callback) 8 function stream:ping(jid, callback)
8 local t = gettime(); 9 local t = gettime();
9 stream:send_iq(verse.iq{ to = jid, type = "get" }:tag("ping", { xmlns = xmlns_ping }), 10 local id = new_id();
11 local ping = verse.iq{ id = id, to = jid, type = "get" }:tag("ping", { xmlns = xmlns_ping });
12 stream:send_iq(ping,
10 function (reply) 13 function (reply)
11 if reply.attr.type == "error" then 14 if reply.attr.type == "error" then
12 local type, condition, text = reply:get_error(); 15 local type, condition, text = reply:get_error();
13 if condition ~= "service-unavailable" and condition ~= "feature-not-implemented" then 16 if condition ~= "service-unavailable" and condition ~= "feature-not-implemented" then
14 callback(nil, jid, { type = type, condition = condition, text = text }); 17 callback(nil, jid, { type = type, condition = condition, text = text });
15 return; 18 return;
16 end 19 end
17 end 20 end
18 callback(gettime()-t, jid); 21 callback(gettime()-t, jid);
19 end); 22 end);
23 return id;
20 end 24 end
21 stream:hook("iq/"..xmlns_ping, function(stanza) 25 stream:hook("iq/"..xmlns_ping, function(stanza)
22 return stream:send(verse.reply(stanza)); 26 return stream:send(verse.reply(stanza));
23 end); 27 end);
24 return true; 28 return true;