diff options
3 files changed, 120 insertions, 0 deletions
diff --git a/applications/luci-app-statistics/htdocs/luci-static/resources/view/statistics/plugins/mqtt.js b/applications/luci-app-statistics/htdocs/luci-static/resources/view/statistics/plugins/mqtt.js new file mode 100644 index 0000000000..602a453c0b --- /dev/null +++ b/applications/luci-app-statistics/htdocs/luci-static/resources/view/statistics/plugins/mqtt.js @@ -0,0 +1,88 @@ +'use strict'; +'require baseclass'; +'require form'; + +return baseclass.extend({ + title: _('Mqtt Plugin Configuration'), + + addFormOptions: function(s) { + let o, ss; + + o = s.option(form.Flag, 'enable', _('Sends or receives data via mqtt')); + + o = s.option(form.SectionValue, '__blocks', form.GridSection, 'collectd_mqtt_block'); + o.depends('enable', '1'); + + ss = o.subsection; + ss.anonymous = true; + ss.addremove = true; + + o = ss.option(form.ListValue, 'blocktype', _('Type')); + o.value('Publish', _('Publish')); + o.value('Subscribe', _('Subscribe')); + o.default = 'Publish'; + + o = ss.option(form.Value, 'name', _('Name')); + o.optional = false; + o.rmempty = false; + + o = ss.option(form.Value, 'Host', _('Host')); + o.datatype = 'host'; + o.optional = false; + o.rmempty = false; + + o = ss.option(form.Value, 'Port', _('Port')); + o.datatype = 'port'; + o.optional = true; + + o = ss.option(form.Value, 'User', _('User')); + o.optional = true; + + o = ss.option(form.Value, 'Password', _('Password')); + o.password = true; + o.optional = true; + o.modalonly = true; + + o = ss.option(form.ListValue, 'Qos', _('QoS')); + o.value('0', _('0 - At most once')); + o.value('1', _('1 - At least once')); + o.value('2', _('2 - Exactly once')); + o.modalonly = true; + o.optional = true; + + o = ss.option(form.Value, 'Prefix', _('Prefix')); + o.depends('blocktype', 'Publish'); + o.optional = true; + o.modalonly = true; + + o = ss.option(form.ListValue, 'Retain', _('Retain')); + o.depends('blocktype', 'Publish'); + o.value('true', _('True')); + o.value('false', _('False')); + o.optional = true; + o.modalonly = true; + + o = ss.option(form.ListValue, 'StoreRates', _('StoreRates')); + o.depends('blocktype', 'Publish'); + o.value('true', _('True')); + o.value('false', _('False')); + o.modalonly = true; + o.optional = true; + + o = ss.option(form.ListValue, 'CleanSession', _('CleanSession')); + o.depends('blocktype', 'Subscribe'); + o.value('true', _('True')); + o.value('false', _('False')); + o.optional = true; + o.modalonly = true; + + o = ss.option(form.Value, 'Topic', _('Topic')); + o.depends('blocktype', 'Subscribe'); + o.optional = true; + o.modalonly = true; + }, + + configSummary: function(section) { + return _('Mqtt plugin enabled'); + } +}); diff --git a/applications/luci-app-statistics/root/usr/libexec/stat-genconfig b/applications/luci-app-statistics/root/usr/libexec/stat-genconfig index d60e1a69ed..1bf622d9c1 100755 --- a/applications/luci-app-statistics/root/usr/libexec/stat-genconfig +++ b/applications/luci-app-statistics/root/usr/libexec/stat-genconfig @@ -241,6 +241,33 @@ function config_network(c) { ; } +function config_mqtt(c) { + let str = ""; + + for (let k, s in sections) { + if (s['.type'] === 'collectd_mqtt_block') { + const isPublish = s['blocktype'] === 'Publish'; + + str += isPublish ? `\t<Publish "${s.name}">\n` : `\t<Subscribe "${s.name}">\n`; + + str += `\t\tHost "${s.Host}"\n`; + str += s['Port'] ? `\t\tPort ${s.Port}\n` : ''; + str += s['User'] ? `\t\tUser "${s.User}"\n` : ''; + str += s['Password'] ? `\t\tPassword "${s.Password}"\n` : ''; + str += s['Qos'] ? `\t\tQos ${s.Qos}\n` : ''; + str += s['Prefix'] ? `\t\tPrefix ${s.Prefix}\n` : ''; + str += s['Retain'] ? `\t\tRetain ${s.Retain}\n` : ''; + str += s['StoreRates'] ? `\t\tRetain ${s.StoreRates}\n` : ''; + str += s['CleanSession'] ? `\t\tRetain ${s.CleanSession}\n` : ''; + str += s['Topic'] ? `\t\tTopic "${s.Topic}"\n` : ''; + + str += isPublish ? `\t</Publish>\n` : `\t</Subscribe>\n`; + } + } + + return str; +} + function section(plugin) { let config = sections[`collectd_${plugin}`] ?? sections.collectd; @@ -270,6 +297,7 @@ for (let filename in lsdir(plugin_dir)) { case 'iptables': plugins[name] = config_iptables; break; case 'curl': plugins[name] = config_curl; break; case 'network': plugins[name] = config_network; break; + case 'mqtt': plugins[name] = config_mqtt; break; default: plugins[name] = json(open(`${plugin_dir}/${filename}`))?.legend; } diff --git a/applications/luci-app-statistics/root/usr/share/luci/statistics/plugins/mqtt.json b/applications/luci-app-statistics/root/usr/share/luci/statistics/plugins/mqtt.json new file mode 100644 index 0000000000..ab86efb676 --- /dev/null +++ b/applications/luci-app-statistics/root/usr/share/luci/statistics/plugins/mqtt.json @@ -0,0 +1,4 @@ +{ + "title": "Mqtt", + "category": "output" +} |