blob: c891e8604f63c4d534cdea0eef39a60405ab62ff (
about) (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
from src import EventManager, ModuleManager, utils
# postpone parsing SOME lines until after 001
class Module(ModuleManager.BaseModule):
@utils.hook("new.server")
def new_server(self, event):
event["server"]._deferred_read = []
@utils.hook("raw.received.001", priority=EventManager.PRIORITY_LOW)
def on_001(self, event):
lines = event["server"]._deferred_read[:]
event["server"]._deferred_read.clear()
for line in lines:
self.events.on("raw.received").call(line=line,
server=event["server"])
@utils.hook("raw.received.mode", priority=EventManager.PRIORITY_HIGH)
def defer(self, event):
if not event["server"].connected:
event.eat()
event["server"]._deferred_read.append(event["line"])
|
