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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
import os, select, sys, threading, time, traceback
import EventManager, IRCServer, ModuleManager, Timer
class Bot(object):
def __init__(self):
self.lock = threading.Lock()
self.database = None
self.config = None
self.bot_directory = os.path.dirname(os.path.realpath(__file__))
self.servers = {}
self.running = True
self.poll = select.epoll()
self.modules = ModuleManager.ModuleManager(self)
self.events = EventManager.EventHook(self)
self.timers = []
self.last_ping = None
def add_server(self, id, hostname, port, password, ipv4, tls,
nickname, username, realname, connect=False):
new_server = IRCServer.Server(id, hostname, port, password,
ipv4, tls, nickname, username, realname, self)
self.servers[new_server.fileno()] = new_server
if connect:
self.connect(new_server)
def connect(self, server):
try:
server.connect()
except:
sys.stderr.write("Failed to connect to %s\n" % str(server))
traceback.print_exc()
return False
self.poll.register(server.fileno(), select.EPOLLOUT)
return True
def connect_all(self):
for server in self.servers.values():
self.connect(server)
def add_timer(self, function, delay, *args, **kwargs):
timer = Timer.Timer(function, delay, *args, **kwargs)
timer.set_started_time()
self.timers.append(timer)
def next_timer(self):
next = None
for timer in self.timers:
time_left = timer.time_left()
if not next or time_left < next:
next = time_left
return next or 30
def call_timers(self):
for timer in self.timers[:]:
if timer.due():
timer.call()
if timer.done():
self.timers.remove(timer)
def register_read(self, server):
self.poll.modify(server.fileno(), select.EPOLLIN)
def register_write(self, server):
self.poll.modify(server.fileno(), select.EPOLLOUT)
def register_both(self, server):
self.poll.modify(server.fileno(),
select.EPOLLIN|select.EPOLLOUT)
def since_last_read(self, server):
return time.time()-server.last_read
def disconnect(self, server):
self.poll.unregister(server.fileno())
del self.servers[server.fileno()]
def reconnect(self, server):
IRCServer.Server.__init__(server)
if self.connect(server):
self.servers[server.fileno()] = server
def run(self):
while self.running:
self.lock.acquire()
events = self.poll.poll(self.next_timer())
self.call_timers()
for fd, event in events:
if fd in self.servers:
server = self.servers[fd]
if event & select.EPOLLIN:
lines = server.read()
for line in lines:
print(line)
server.parse_line(line)
elif event & select.EPOLLOUT:
server._send()
self.register_read(server)
elif event & select.EPULLHUP:
print("hangup")
if not self.last_ping or time.time()-self.last_ping >= 60:
for server in self.servers.values():
server.send_ping()
self.last_ping = time.time()
for server in list(self.servers.values()):
if server.last_read and self.since_last_read(server
) > 160:
print("pingout from %s" % str(server))
server.disconnect()
if not server.connected:
self.disconnect(server)
reconnect_delay = self.config.get("reconnect-delay", 10)
self.add_timer(self.reconnect, reconnect_delay, server)
print("disconnected from %s, reconnecting in %d seconds" % (
str(server), reconnect_delay))
elif server.waiting_send():
self.register_both(server)
self.lock.release()
|
