implement rudimentary message storing systemstore

1 files changed, 4 insertions, 0 deletions

diff --git a/main.lua b/main.lua
index 2d46f70..4efa82e 100644
--- a/main.lua
+++ b/main.lua
@@ -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