diff options
Diffstat (limited to 'main.lua')
| -rw-r--r-- | main.lua | 4 |
1 files changed, 4 insertions, 0 deletions
@@ -5,6 +5,7 @@ local pprint = require'pprint' local config = require'config' local Channel = require'channel' local Log = require 'log' +local Store = require 'store' local pylon_classes = { irc = require'irc.pylon', @@ -22,6 +23,7 @@ function Wilson.make(cls, conf) busses={}, cq = cqueues.new(), log = Log('(toplevel)',tlc.loglevel or 'info'), + store = Store(), }, Wilson) for name, pylon_conf in pairs(conf.pylon) do pylon_conf.name = name @@ -54,6 +56,7 @@ end function Wilson.deliver(self, message) local bus = self:_find_bus(assert(message.source_channel)) if bus then + self.store:store(message) for _, dest_channel in ipairs(bus) do if message.source_channel ~= dest_channel then self.log:debug(message.source_channel, "-->", dest_channel, message) @@ -67,6 +70,7 @@ function Wilson.run(self) self.cq:wrap(pylon.run, pylon) self.log("now running pylon", pylonname) end + self.cq:wrap(self.store.run, self.store) self.log:loop(self.cq) end |