# First arg always left|right. No need for guards b/c this is private function.
direction=$1
shift
# create fifo for collecting event stream
temp=$(mktemp -d kak-niri-XXXXXX)
fifo="$temp/fifo"
mkfifo "$fifo"
# register func to cleanup fifo
cleanup() {
	rm -rf "$temp"
}
trap cleanup EXIT INT TERM
# read event stream to fifo
niri msg -j event-stream >"$fifo" &
stream_pid=$!
# register timeout fallback
(
	sleep 3
	kill "$!" 2>/dev/null
	kill "$stream_pid" 2>/dev/null
) >/dev/null 2>&1 </dev/null &
watchdog_pid=$!

# safely quote arguments for passing to new terminal
kakquote() {
	set -- "$*" ""
	while [ "${1#*\'}" != "$1" ]; do
		set -- "${1#*\'}" "$2${1%%\'*}''"
	done
	printf "'%s' " "$2$1"
}
# loop over args and quote all
quoted_args=''
for arg in "$@"; do
	quoted_args="$quoted_args$(kakquote "$arg")"
done
# run this block async to avoid user-facing lag
{
    # track when new window is ready
	ready=false
	# read lines of event stream from fifo
	#   Note: each line is one event.
	#   We wait for the event that indicates stream is initialized,
	#   then we spawn the new terminal window. The next WindowOpenedOrChanged
	#   event immediately after running niri-terminal-window SHOULD be
	#   the event for this window, but it's not guaranteed. There is a very,
	#   very tiny window for a race condition here. Unfortunately, I don't
	#   believe we have a good way to handle it because there's no way to
	#   know the window's ID before it's spawned. This may be a good job for
	#   the Ostrich algorithm (https://en.wikipedia.org/wiki/Ostrich_algorithm)
	while IFS= read -r line; do
	    # each line is a JSON object
		case "$line" in
		# this line means stream is initialized
		*"OverviewOpenedOrClosed"*)
		    # guard to avoid spawning terminal twice
			if [ "$ready" = false ]; then
				ready=true
				# spawn terminal with command
				printf 'niri-terminal-window %s' "$quoted_args" >"$kak_command_fifo"
			fi
			;;
		# newly opened window is now available to act on
		*"WindowOpenedOrChanged"*)
		    # only operate if window isn't floating
		    # This accursed incantation is to access the JSON field
		    # without depending on jq.
			if expr "${line}" : '.*"is_floating":[[:space:]]*false.*' \
				>/dev/null; then
				# handle new window being unfocused
				if expr "${line}" : '.*"is_focused":[[:space:]]*false.*' \
					>/dev/null; then
					# extract the window ID
					# (POSIX compliant JSON parsing is ugly, sorry)
					id="$(echo "$line" | sed -n 's/.*"id":[[:space:]]*\([0-9][0-9]*\).*/\1/p')"
					# focus the new window
					niri msg action focus-window --id "$id"
				fi
				# consume the new window in specified direction
				niri msg action consume-or-expel-window-${direction}
			fi
			# close the stream reader and timeout watchdog
			kill "$stream_pid"
			wait "$stream_pid" 2>/dev/null
			kill "$watchdog_pid" 2>/dev/null
			exit 0
			;;
		esac
	done <"$fifo"
} >/dev/null 2>&1 </dev/null &