local cqueues = require 'cqueues'
local Queue = require 'queue'

-- commonality between the different pylon classes
-- they can "inherit" from this

local BasePylon = {}

function BasePylon.check_config(self, vars)
	for x in vars:gmatch"%S+" do
		assert(self[x], "missing conf field "..x)
	end
end

function BasePylon.run(self)
	self.cq = cqueues.new()
	self:_connect()
	self.cq:wrap(self.recving, self)
	self.cq:wrap(self.sending, self)
	print(self.pylon_type, self.cq:loop())
end

function BasePylon.post(self, dest_channel, message)
	self.inbox:enqueue(dest_channel, message)
end

function BasePylon.log(self, ...)
	if self.debug then
		print(self.name, ...)
	end
end

local function subclass(pylon_type)
	local Subclass = {}
	setmetatable(Subclass, {__index=BasePylon})
	Subclass.pylon_type = pylon_type

	Subclass.make = function(wilson, conf)
		local self = setmetatable(conf, {__index=Subclass})
		for k,v in pairs {
			wilson = wilson,
			inbox = Queue.make(),
		} do self[k] = v end

		self:init(wilson, conf)
		return self
	end

	return Subclass
end

return {
	BasePylon = BasePylon,
	subclass = subclass,
}