mmfd

#!/bin/sh /etc/rc.common

USE_PROCD=1
START=50
DAEMON=/usr/sbin/mmfd
SOCKET=/var/run/mmfd.sock

waitforsocket() {
	while ! echo "get_neighbours" | uc $SOCKET
	do
		sleep 1
		echo "waiting for successful socket connection for mmfd"
	done
}


start_service() {
	local interfaces
	interfaces=$(for dev in $(gluon-list-mesh-interfaces); do echo " -i $dev"; done)

	procd_open_instance
	# shellcheck disable=SC2086
	procd_set_param command "$DAEMON" -s "$SOCKET" $interfaces
	procd_set_param respawn "${respawn_threshold:-60}" "${respawn_timeout:-1}" "${respawn_retry:-0}"
	procd_set_param stderr 1
	procd_set_param stdout 1
	procd_close_instance
}

mmfd_get_interfaces() {
	echo get_meshifs | uc $SOCKET | jsonfilter -e "@.mesh_interfaces[@]"
}

mmfd_has_interface() {
	mmfd_get_interfaces | grep -qxF "$1"
}

addif() {
	echo "add_meshif $1" | uc $SOCKET
}

delif() {
	echo "del_meshif $1" | uc $SOCKET
}

reload_service() {
	waitforsocket

	for i in $(ubus call network.interface dump | jsonfilter -e "@.interface[@.proto='gluon_mesh' && @.up=true].device")
	do
		if ! mmfd_has_interface "$i"; then
			addif "$i"
		fi
	done

	for i in $(mmfd_get_interfaces)
	do
		if ! ubus call network.interface dump | jsonfilter -e "@.interface[@.proto='gluon_mesh' && @.up=true].device" | grep -qxF "$i"; then
			delif "$i"
		fi
	done
}

service_triggers() {
	local script name
	# shellcheck disable=SC2154
	script=$(readlink "$initscript")
	name=$(basename "${script:-$initscript}")

	procd_open_trigger
	procd_add_raw_trigger "interface.*" 0 "/etc/init.d/$name" reload
	procd_close_trigger
}