From 29f5b7caf296e531b9fb97f98ca1d25df522f382 Mon Sep 17 00:00:00 2001 From: jesopo Date: Sat, 22 Jun 2019 22:22:50 +0100 Subject: [PATCH] add deferred_read.py, to defer parsing of *some* lines until after 001 --- modules/deferred_read.py | 23 +++++++++++++++++++++++ 1 file changed, 23 insertions(+) create mode 100644 modules/deferred_read.py diff --git a/modules/deferred_read.py b/modules/deferred_read.py new file mode 100644 index 00000000..c891e860 --- /dev/null +++ b/modules/deferred_read.py @@ -0,0 +1,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"]) +