1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
# coding: utf-8
# BlackSmith mark.2
# exp_name = "alive_keeper" # /code.py v.x8
# Id: 16~8c
# Code © (2011-2013) by WitcherGeralt [alkorgun@gmail.com]
class expansion_temp(expansion):
def __init__(self, name):
expansion.__init__(self, name)
def alive_keeper(self):
def alive_keeper_answer(disp, stanza):
if stanza:
Clients[get_disp(disp)].aKeeper = itypes.Number()
while VarCache["alive"]:
sleep(120)
thrIds = ithr.getNames()
for disp_str, disp in Clients.iteritems():
if not hasattr(disp, "aKeeper"):
disp.aKeeper = itypes.Number()
if disp.aKeeper > 2:
disp.aKeeper = itypes.Number()
thrName = "%s-%s" % (sBase[13], disp_str)
if thrName in thrIds:
for thr in ithr.enumerate():
if thrName == thr.getName():
thr.kill()
try:
composeThr(connectAndDispatch, thrName, (disp_str,)).start()
except ithr.error:
delivery(AnsBase[28] % (disp_str))
except Exception:
collectExc(ithr.Thread.start)
elif expansions.has_key(self.name):
disp.aKeeper.plus()
iq = xmpp.Iq(sBase[10], to = "%s/%s" % (disp_str, GenResource))
iq.addChild(sBase[16], namespace = xmpp.NS_PING)
iq.setID("Bs-i%d" % Info["outiq"].plus())
CallForResponse(disp_str, iq, alive_keeper_answer)
del iq
else:
raise ithr.ThrKill("exit")
del thrIds
def conf_alive_keeper(self):
def conf_alive_keeper_answer(disp, stanza, conf):
if Chats.has_key(conf):
if xmpp.isErrorNode(stanza):
if eCodes[6] == stanza.getErrorCode():
Chats[conf].aKeeper = itypes.Number()
else:
Chats[conf].aKeeper = itypes.Number()
while VarCache["alive"]:
sleep(360)
thrIds = ithr.getNames()
for conf in Chats.itervalues():
if not (online(conf.disp) and conf.IamHere):
continue
if not hasattr(conf, "aKeeper"):
conf.aKeeper = itypes.Number()
if conf.aKeeper > 2:
conf.aKeeper = itypes.Number()
TimerName = ejoinTimerName(conf.name)
if TimerName not in thrIds:
try:
composeTimer(180, ejoinTimer, TimerName, (conf.name,)).start()
except ithr.error:
pass
except Exception:
collectExc(ithr.Thread.start)
elif expansions.has_key(self.name):
conf.aKeeper.plus()
iq = xmpp.Iq(sBase[10], to = "%s/%s" % (conf.name, conf.nick))
iq.addChild(sBase[18], namespace = xmpp.NS_PING)
iq.setID("Bs-i%d" % Info["outiq"].plus())
CallForResponse(conf.disp, iq, conf_alive_keeper_answer, {"conf": conf.name})
del iq
else:
raise ithr.ThrKill("exit")
del thrIds
def start_keepers(self):
Name1 = self.alive_keeper.__name__
Name2 = self.conf_alive_keeper.__name__
for thr in ithr.enumerate():
if thr.name.startswith((Name1, Name2)):
thr.kill()
composeThr(self.alive_keeper, Name1).start()
composeThr(self.conf_alive_keeper, Name2).start()
handlers = ((start_keepers, "02si"),)
|
