init.lua

---@diagnostic disable: trailing-space
io.stdout:setvbuf"line"
table.unpack = table.unpack or unpack
local luv = require"luv"
local Heartstrings = require"Moonrise.Heartstrings"
local Census = require"Census"
local Routines = require"Routines"

---@param SourceName string?
---@param SinkName string?
---@param Program string?
---@param ... string
local function Main(EmitterPort, SourceName, SinkName, Program, ...)
	EmitterPort = tonumber(EmitterPort) or error"Provide port for local ProcessEventEmitter"
	if InputName and (InputName:lower() == "nil") then
		InputName = nil
	end
	if OutputName and (OutputName:lower() == "nil") then
		OutputName = nil
	end
	assert(Program, "Supply Program to launch")
	
	---@class AutoAudioRouter.SharedData: Census.SharedData
	local SharedData = {
		Exited = false;
		Process = nil;
		Subprocess = {};
		Thread = {};
	}
	local ProcessIO = {
		Out = Heartstrings.Pipe();
		Error = Heartstrings.Pipe();
	}
	local AudioChangesBox = Heartstrings.Mailbox()
	local _, Controller = Heartstrings.Orchestra{
		--{Body = Routines.luvLoop};
		{
			Body = Routines.Monitor.Audio.Changes;
			Arguments = {AudioChangesBox};
		};
		{
			Body = Routines.Monitor.Audio.Ports;
			Arguments = {SharedData, AudioChangesBox, "Input", SinkName};
		};
		{
			Body = Routines.Monitor.Audio.Ports;
			Arguments = {SharedData, AudioChangesBox, "Output", SourceName};
		};
		{
			Body = Census;
			Arguments = {
				SharedData, EmitterPort, 
				Program, {
					IO = ProcessIO;
					Monitor = {
						Out = true;
						Error = true;
					};
				}, ...
			};
		};
	}
	
	local Sleeper = luv.new_timer()
	assert(Sleeper)
	local Step; function Step()
		Controller:step(0)
		Sleeper:stop()
		local Timeout = Controller:timeout()
		if Timeout == nil then Timeout = -1 else Timeout = Timeout * 1000 end
		Sleeper:start(Timeout, 0, Step)
	end
	local Timeout = Controller:timeout()
	if Timeout == nil then Timeout = -1 else Timeout = Timeout * 1000 end
	Sleeper:start(Timeout, 0, Step)
	local Poller = luv.new_poll(Controller:pollfd())
	assert(Poller)
	Poller:start("r", Step)
	local function Loop()
		while not SharedData.Exited do
			luv.run"once"
		end
		print"Goodbye"
	end
	return pcall(Loop)
end

return Main