verse
dbb3362c1ff3
plugins/smacks.lua

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

Software / code / verse

Comparison

plugins/smacks.lua @ 324:dbb3362c1ff3

plugins.smacks: Don't try to reconnect on gracefull stream closure
author Kim Alvefur <zash@zash.se>
date Sun, 10 Feb 2013 02:54:01 +0100
parent 321:369d4638d775
child 326:f657ed8f464e
comparison
equal deleted inserted replaced
323:5bf3b13edb80 324:dbb3362c1ff3
42 stream:connect(stream.connect_host or stream.host, stream.connect_port or 5222); 42 stream:connect(stream.connect_host or stream.host, stream.connect_port or 5222);
43 end); 43 end);
44 return true; 44 return true;
45 end 45 end
46 end 46 end
47
48 -- Graceful shutdown
49 local function on_close()
50 stream.resumption_token = nil;
51 stream:unhook("disconnected", on_disconnect);
52 end
47 53
48 local function handle_sm_command(stanza) 54 local function handle_sm_command(stanza)
49 if stanza.name == "r" then -- Request for acks for stanzas we received 55 if stanza.name == "r" then -- Request for acks for stanzas we received
50 stream:debug("Ack requested... acking %d handled stanzas", handled_stanza_count); 56 stream:debug("Ack requested... acking %d handled stanzas", handled_stanza_count);
51 stream:send(verse.stanza("a", { xmlns = xmlns_sm, h = tostring(handled_stanza_count) })); 57 stream:send(verse.stanza("a", { xmlns = xmlns_sm, h = tostring(handled_stanza_count) }));
65 stream.smacks = true; 71 stream.smacks = true;
66 72
67 -- Catch stanzas 73 -- Catch stanzas
68 stream:hook("stanza", incoming_stanza); 74 stream:hook("stanza", incoming_stanza);
69 stream:hook("outgoing", outgoing_stanza); 75 stream:hook("outgoing", outgoing_stanza);
70 76
71 if stanza.attr.id then 77 if stanza.attr.id then
72 stream.resumption_token = stanza.attr.id; 78 stream.resumption_token = stanza.attr.id;
79 stream:hook("closed", on_close, 100);
73 stream:hook("disconnected", on_disconnect, 100); 80 stream:hook("disconnected", on_disconnect, 100);
74 end 81 end
75 elseif stanza.name == "resumed" then 82 elseif stanza.name == "resumed" then
76 local new_ack = tonumber(stanza.attr.h); 83 local new_ack = tonumber(stanza.attr.h);
77 if new_ack > last_ack then 84 if new_ack > last_ack then