import type {RPC as RPCType} from './types.js';
import {WS} from './lib/conn.js';
import {RPC} from './lib/rpc.js';

const broadcastList = -1, broadcastAdd = -2, broadcastRename = -3, broadcastRemove = -4, broadcastAddRedirect = -5, broadcastAddCommand = -6, broadcastModifyRedirect = -7, broadcastModifyCommand = -8, broadcastRemoveRedirect = -9, broadcastRemoveCommand = -10, broadcastStartRedirect = -11, broadcastStartCommand = -12, broadcastStopRedirect = -13, broadcastStopCommand = -14, broadcastCommandStopped = -15, broadcastCommandError = -16;

export const rpc = {} as Readonly<RPCType>;

export default (url: string) => WS(url).then(ws => {
	const arpc = new RPC(ws);
	Object.freeze(Object.assign(rpc, Object.fromEntries([
		([
			["waitList",           broadcastList],
			["waitAdd",            broadcastAdd],
			["waitRename",         broadcastRename],
			["waitRemove",         broadcastRemove],
			["waitAddRedirect",    broadcastAddRedirect],
			["waitAddCommand",     broadcastAddCommand],
			["waitModifyRedirect", broadcastModifyRedirect],
			["waitModifyCommand",  broadcastModifyCommand],
			["waitRemoveRedirect", broadcastRemoveRedirect],
			["waitRemoveCommand",  broadcastRemoveCommand],
			["waitStartRedirect",  broadcastStartRedirect],
			["waitStartCommand",   broadcastStartCommand],
			["waitStopRedirect",   broadcastStopRedirect],
			["waitStopCommand",    broadcastStopCommand],
			["waitCommandStopped", broadcastCommandStopped],
			["waitCommandError",   broadcastCommandError]
		] as [string, number][]).map(([wait, id]) => [wait, () => arpc.subscribe(id)]),
		[
			"add",
			"rename",
			"remove",
			"addRedirect",
			"addCommand",
			"modifyRedirect",
			"modifyCommand",
			"removeRedirect",
			"removeCommand",
			"startRedirect",
			"startCommand",
			"stopRedirect",
			"stopCommand",
			"getCommandPorts"
		].map(ep => [ep, arpc.request.bind(arpc, ep)])
	].flat()) as RPCType))
});