From af8cd453bf63bea136d2b4a71c783ef5542a05ed Mon Sep 17 00:00:00 2001
From: rebecca <ubq323@ubq323.website>
Date: Thu, 17 Sep 2026 22:13:53 +0100
Subject: implement rudimentary message storing system

---
 main.lua | 4 ++++
 1 file changed, 4 insertions(+)

(limited to 'main.lua')

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
 
-- 
cgit v1.2.3