Neon.lua

-- >>> Neon.lua - Main file for the Neon Multiplexing Alerts Server

-- local cqcore = require("cqueues")
local signal = require("cqueues.signal")

local options = require("lib.options")
local refs = require("lib.refs")
-- local server = require("lib.server")
-- local client = require("lib.client")

-- Blocks and handles CTRL-C interrupt signal (for graceful shutdown)
local _catchSIGINT = function(callback, ...)
	-- TODO: If parameter, then use the signal handler else stop immediately
	-- ....maybe? standalone vs OBS shutdown sequences look quite different
	signal.block(signal.SIGINT)

	local listener = signal.listen(signal.SIGINT)
	listener:wait()
	signal.unblock(signal.SIGINT)
	
	print("\nBegin manual server shutdown")
	if type(callback) == "function" then
		callback(...)
	end
end

-- TODO: *Actual* arg parsing (implement this in lib/options)
local clientMode = (arg[1] == "client")
local controller = refs.controller
if clientMode then
	local cargs = nil -- serverObj
	local clientObj = client.new(controller, cargs)

	clientObj:load("localhost")
	-- TODO: This will need to become the client handler logic
	controller:wrap(clientObj.app, clientObj, "test")

	-- controller:wrap(clientObj.app, server, nil)
else 
	local sargs = {
		timeout = 10,
		directory = "overlay",
		logging = true,
	}
	local serverObj = server.new(controller, sargs)
	
	controller:wrap(serverObj.loop, serverObj)
	controller:wrap(_catchSIGINT, serverObj.stop, serverObj)
end

assert(controller:loop())
print("Server shutdown successful")