luci-app-pbr: initial commit

Depends on https://github.com/openwrt/packages/pull/19763

Signed-off-by: Stan Grishin <stangri@melmac.ca>

1 files changed, 313 insertions, 0 deletions

diff --git a/applications/luci-app-pbr/htdocs/luci-static/resources/pbr/status.js b/applications/luci-app-pbr/htdocs/luci-static/resources/pbr/status.js
new file mode 100644
index 0000000000..8cd36bca7c
--- /dev/null
+++ b/applications/luci-app-pbr/htdocs/luci-static/resources/pbr/status.js
@@ -0,0 +1,313 @@
+// Copyright 2022 Stan Grishin <stangri@melmac.ca>
+// This code wouldn't have been possible without help from [@vsviridov](https://github.com/vsviridov)
+
+"require ui";
+"require rpc";
+"require uci";
+"require form";
+"require baseclass";
+
+var pkg = {
+	get Name() {
+		return "pbr";
+	},
+	get URL() {
+		return "https://docs.openwrt.melmac.net/" + pkg.Name + "/";
+	},
+};
+
+var getGateways = rpc.declare({
+	object: "luci." + pkg.Name,
+	method: "getGateways",
+	params: ["name"],
+});
+
+var getInitList = rpc.declare({
+	object: "luci." + pkg.Name,
+	method: "getInitList",
+	params: ["name"],
+});
+
+var getInitStatus = rpc.declare({
+	object: "luci." + pkg.Name,
+	method: "getInitStatus",
+	params: ["name"],
+});
+
+var getInterfaces = rpc.declare({
+	object: "luci." + pkg.Name,
+	method: "getInterfaces",
+	params: ["name"],
+});
+
+var getPlatformSupport = rpc.declare({
+	object: "luci." + pkg.Name,
+	method: "getPlatformSupport",
+	params: ["name"],
+});
+
+var _setInitAction = rpc.declare({
+	object: "luci." + pkg.Name,
+	method: "setInitAction",
+	params: ["name", "action"],
+	expect: { result: false },
+});
+
+var RPC = {
+	listeners: [],
+	on: function on(event, callback) {
+		var pair = { event: event, callback: callback }
+		this.listeners.push(pair);
+		return function unsubscribe() {
+			this.listeners = this.listeners.filter(function (listener) {
+				return listener !== pair;
+			});
+		}.bind(this);
+	},
+	emit: function emit(event, data) {
+		this.listeners.forEach(function (listener) {
+			if (listener.event === event) {
+				listener.callback(data);
+			}
+		});
+	},
+	getInitList: function getInitList(name) {
+		getInitList(name).then(function (result) {
+			this.emit('getInitList', result);
+		}.bind(this));
+	},
+	getInitStatus: function getInitStatus(name) {
+		getInitStatus(name).then(function (result) {
+			this.emit('getInitStatus', result);
+		}.bind(this));
+	},
+	getGateways: function getGateways(name) {
+		getGateways(name).then(function (result) {
+			this.emit('getGateways', result);
+		}.bind(this));
+	},
+	getPlatformSupport: function getPlatformSupport(name) {
+		getPlatformSupport(name).then(function (result) {
+			this.emit('getPlatformSupport', result);
+		}.bind(this));
+	},
+	getInterfaces: function getInterfaces(name) {
+		getInterfaces(name).then(function (result) {
+			this.emit('getInterfaces', result);
+		}.bind(this));
+	},
+	setInitAction: function setInitAction(name, action) {
+		_setInitAction(name, action).then(function (result) {
+			this.emit('setInitAction', result);
+		}.bind(this));
+	},
+}
+
+var status = baseclass.extend({
+	render: function () {
+		return Promise.all([
+			L.resolveDefault(getInitStatus(), {}),
+//			L.resolveDefault(getGateways(), {}),
+		]).then(function (data) {
+//			var replyStatus = data[0];
+//			var replyGateways = data[1];
+			var reply = data[0][pkg.Name];
+			var text;
+			var header = E('h2', {}, _("Policy Based Routing - Status"));
+			var statusTitle = E('label', { class: 'cbi-value-title' }, _("Service Status"));
+			if (reply.version) {
+				if (reply.running) {
+					if (reply.running_iptables) {
+						text = _("Running (version: %s using iptables)").format(reply.version);
+					}
+					else if (reply.running_nft) {
+						text = _("Running (version: %s using nft)").format(reply.version);
+					}
+					else {
+						text = _("Running (version: %s)").format(reply.version);
+					}
+				}
+				else {
+					if (reply.enabled) {
+						text = _("Stopped (version: %s)").format(reply.version);
+					}
+					else {
+						text = _("Stopped (Disabled)");
+					}
+				}
+			}
+			else {
+				text = _("Not installed or not found");
+			}
+			var statusText = E('div', {}, text);
+			var statusField = E('div', { class: 'cbi-value-field' }, statusText);
+			var statusDiv = E('div', { class: 'cbi-value' }, [statusTitle, statusField]);
+
+			var gatewaysDiv = [];
+			if (reply.gateways) {
+				var gatewaysTitle = E('label', { class: 'cbi-value-title' }, _("Service Gateways"));
+				text = _("The %s indicates default gateway. See the %sREADME%s for details.").format("<strong>✓</strong>",
+					"<a href=\"" + pkg.URL + "#a-word-about-default-routing \" target=\"_blank\">", "</a>")
+				var gatewaysDescr = E('div', { class: 'cbi-value-description' }, text);
+				var gatewaysText = E('div', {}, reply.gateways);
+				var gatewaysField = E('div', { class: 'cbi-value-field' }, [gatewaysText, gatewaysDescr]);
+				gatewaysDiv = E('div', { class: 'cbi-value' }, [gatewaysTitle, gatewaysField]);
+			}
+
+			var warningsDiv = [];
+			if (reply.warnings && reply.warnings.length) {
+				var textLabelsTable = {
+					warningResolverNotSupported: _("Resolver set (%s) is not supported on this system.").format(uci.get(pkg.Name, 'config', 'resolver_set')),
+					warningAGHVersionTooLow: _("Installed AdGuardHome (%s) doesn't support 'ipset_file' option."),
+					warningPolicyProcess: _("%s")
+				};
+				var warningsTitle = E('label', { class: 'cbi-value-title' }, _("Service Warnings"));
+				var text = "";
+				(reply.warnings).forEach(element => {
+					text += (textLabelsTable[element.id]).format(element.extra || ' ') + "<br />";
+				});
+				var warningsText = E('div', {}, text);
+				var warningsField = E('div', { class: 'cbi-value-field' }, warningsText);
+				warningsDiv = E('div', { class: 'cbi-value' }, [warningsTitle, warningsField]);
+			}
+
+			var errorsDiv = [];
+			if (reply.errors && reply.errors.length) {
+				var textLabelsTable = {
+					errorConfigValidation: _("Config (%s) validation failure!").format('/etc/config/' + pkg.Name),
+					errorNoIpFull: _("ip-full binary cannot be found!"),
+					errorNoIpset: _("Resolver set support (%s) requires ipset, but ipset binary cannot be found!").format(uci.get(pkg.Name, 'config', 'resolver_set')),
+					errorNoNft: _("Resolver set support (%s) requires nftables, but nft binary cannot be found!").format(uci.get(pkg.Name, 'config', 'resolver_set')),
+					errorResolverNotSupported: _("Resolver set (%s) is not supported on this system!").format(uci.get(pkg.Name, 'config', 'resolver_set')),
+					errorServiceDisabled: _("The %s service is currently disabled!").format(pkg.Name),
+					errorNoWanGateway: _("The %s service failed to discover WAN gateway!").format(pkg.Name),
+					errorIpsetNameTooLong: _("The ipset name '%s' is longer than allowed 31 characters!"),
+					errorNftsetNameTooLong: _("The nft set name '%s' is longer than allowed 31 characters!"),
+					errorUnexpectedExit: _("Unexpected exit or service termination: '%s'!"),
+					errorPolicyNoSrcDest: _("Policy '%s' has no source/destination parameters!"),
+					errorPolicyNoInterface: _("Policy '%s' has no assigned interface!"),
+					errorPolicyUnknownInterface: _("Policy '%s' has an unknown interface!"),
+					errorPolicyProcess: _("%s"),
+					errorFailedSetup: _("Failed to set up '%s'!"),
+					errorFailedReload: _("Failed to reload '%s'!"),
+					errorUserFileNotFound: _("Custom user file '%s' not found or empty!"),
+					ererrorUserFileSyntax: _("Syntax error in custom user file '%s'!"),
+					errorUserFileRunning: _("Error running custom user file '%s'!"),
+					errorUserFileNoCurl: _("Use of 'curl' is detected in custom user file '%s', but 'curl' isn't installed!"),
+					errorNoGateways: _("Failed to set up any gateway!")
+				};
+				var errorsTitle = E('label', { class: 'cbi-value-title' }, _("Service Errors"));
+				var text = "";
+				(reply.errors).forEach(element => {
+					text += (textLabelsTable[element.id]).format(element.extra || ' ') + "<br />";
+				});
+				var errorsText = E('div', {}, text);
+				var errorsField = E('div', { class: 'cbi-value-field' }, errorsText);
+				errorsDiv = E('div', { class: 'cbi-value' }, [errorsTitle, errorsField]);
+			}
+
+			var btn_gap = E('span', {}, '&#160;&#160;');
+			var btn_gap_long = E('span', {}, '&#160;&#160;&#160;&#160;&#160;&#160;&#160;&#160;');
+
+			var btn_start = E('button', {
+				'class': 'btn cbi-button cbi-button-apply',
+				disabled: true,
+				click: function (ev) {
+					ui.showModal(null, [
+						E('p', { 'class': 'spinning' }, _('Starting %s service').format(pkg.Name))
+					]);
+					return RPC.setInitAction(pkg.Name, 'start');
+				}
+			}, _('Start'));
+
+			var btn_action = E('button', {
+				'class': 'btn cbi-button cbi-button-apply',
+				disabled: true,
+				click: function (ev) {
+					ui.showModal(null, [
+						E('p', { 'class': 'spinning' }, _('Restarting %s service').format(pkg.Name))
+					]);
+					return RPC.setInitAction(pkg.Name, 'restart');
+				}
+			}, _('Restart'));
+
+			var btn_stop = E('button', {
+				'class': 'btn cbi-button cbi-button-reset',
+				disabled: true,
+				click: function (ev) {
+					ui.showModal(null, [
+						E('p', { 'class': 'spinning' }, _('Stopping %s service').format(pkg.Name))
+					]);
+					return RPC.setInitAction(pkg.Name, 'stop');
+				}
+			}, _('Stop'));
+
+			var btn_enable = E('button', {
+				'class': 'btn cbi-button cbi-button-apply',
+				disabled: true,
+				click: function (ev) {
+					ui.showModal(null, [
+						E('p', { 'class': 'spinning' }, _('Enabling %s service').format(pkg.Name))
+					]);
+					return RPC.setInitAction(pkg.Name, 'enable');
+				}
+			}, _('Enable'));
+
+			var btn_disable = E('button', {
+				'class': 'btn cbi-button cbi-button-reset',
+				disabled: true,
+				click: function (ev) {
+					ui.showModal(null, [
+						E('p', { 'class': 'spinning' }, _('Disabling %s service').format(pkg.Name))
+					]);
+					return RPC.setInitAction(pkg.Name, 'disable');
+				}
+			}, _('Disable'));
+
+			if (reply.enabled) {
+				btn_enable.disabled = true;
+				btn_disable.disabled = false;
+				if (reply.running) {
+					btn_start.disabled = true;
+					btn_action.disabled = false;
+					btn_stop.disabled = false;
+				}
+				else {
+					btn_start.disabled = false;
+					btn_action.disabled = true;
+					btn_stop.disabled = true;
+				}
+			}
+			else {
+				btn_start.disabled = true;
+				btn_action.disabled = true;
+				btn_stop.disabled = true;
+				btn_enable.disabled = false;
+				btn_disable.disabled = true;
+			}
+
+			var buttonsTitle = E('label', { class: 'cbi-value-title' }, _("Service Control"))
+			var buttonsText = E('div', {}, [btn_start, btn_gap, btn_action, btn_gap, btn_stop, btn_gap_long, btn_enable, btn_gap, btn_disable]);
+			var buttonsField = E('div', { class: 'cbi-value-field' }, buttonsText);
+			if (reply.version) {
+				var buttonsDiv = E('div', { class: 'cbi-value' }, [buttonsTitle, buttonsField]);
+			}
+			else {
+				var buttonsDiv = [];
+			}
+
+			return E('div', {}, [header, statusDiv, gatewaysDiv, warningsDiv, errorsDiv, buttonsDiv]);
+		});
+	},
+});
+
+RPC.on('setInitAction', function (reply) {
+	ui.hideModal();
+	location.reload();
+});
+
+return L.Class.extend({
+	status: status,
+	getInterfaces: getInterfaces,
+	getPlatformSupport: getPlatformSupport
+});