motorola_sb6141

#!/usr/bin/env python3

# This plugin graphs the following values of the Motorola SB6141 cable
# modem:
#
# * upstream and downstream power levels
# * downstream signal to noise ratio
# * downstream signal statistics (codeword counts)
#
# The values are retrieved from the cable modem's status web pages at
# 192.168.100.1. So, this plugin must be installed on a munin node
# which can access those pages.
#
# To install, place this plugin in the node's plugins directory,
# /etc/munin/plugins and restart munin-node.
#
# Developed and tested with firmware SB_KOMODO-1.0.6.16-SCM00-NOSH
# (build time Feb 16 2016 11:28:04), hardware version 7.0, boot
# version PSPU-Boot(25CLK) 1.0.12.18m3.
#
# Requires the multigraph and dirtyconfig capabilities available in
# munin 2.0 and newer.
#
# Copyright © 2016 Kenyon Ralph <kenyon@kenyonralph.com>
#
# This program is free software. It comes without any warranty, to the
# extent permitted by applicable law. You can redistribute it and/or
# modify it under the terms of the Do What The Fuck You Want To Public
# License, Version 2, as published by Sam Hocevar. See
# http://www.wtfpl.net/ for more details.
#
# The latest version of this plugin can be found in the munin contrib
# repository at https://github.com/munin-monitoring/contrib. Issues
# with this plugin may be reported there. Patches accepted through the
# normal github process of forking the repository and submitting a
# pull request with your commits.

import html.parser
import urllib.request
import sys

class MotorolaHTMLParser(html.parser.HTMLParser):
    def __init__(self):
        html.parser.HTMLParser.__init__(self)
        self.signaldatapage = list()
        self.downstream_channels = list()
        self.downstream_SNRs = list()
        self.downstream_powers = list()
        self.upstream_channels = list()
        self.upstream_powers = list()
        self.unerrored_codewords = list()
        self.correctable_codewords = list()
        self.uncorrectable_codewords = list()

    def handle_data(self, data):
        data = data.strip()
        if data != '': self.signaldatapage.append(data)

    def process(self):
        # first and last elements are just javascript
        del self.signaldatapage[0]
        del self.signaldatapage[-1]

        di = iter(self.signaldatapage)

        element = next(di)
        while element != 'Channel ID': element = next(di)

        while element != 'Frequency':
            element = next(di)
            if element != 'Frequency': self.downstream_channels.append(element)

        while element != 'Signal to Noise Ratio': element = next(di)

        while element != 'Downstream Modulation':
            element = next(di)
            if element != 'Downstream Modulation': self.downstream_SNRs.append(element.split()[0])

        while element != 'The Downstream Power Level reading is a             snapshot taken at the time this page was requested. Please             Reload/Refresh this Page for a new reading': element = next(di)

        while element != 'Upstream':
            element = next(di)
            if element != 'Upstream': self.downstream_powers.append(element.split()[0])

        while element != 'Channel ID': element = next(di)

        while element != 'Frequency':
            element = next(di)
            if element != 'Frequency': self.upstream_channels.append(element)

        while element != 'Power Level': element = next(di)

        while element != 'Upstream Modulation':
            element = next(di)
            if element != 'Upstream Modulation': self.upstream_powers.append(element.split()[0])

        while element != 'Total Unerrored Codewords': element = next(di)

        while element != 'Total Correctable Codewords':
            element = next(di)
            if element != 'Total Correctable Codewords': self.unerrored_codewords.append(element)

        while element != 'Total Uncorrectable Codewords':
            element = next(di)
            if element != 'Total Uncorrectable Codewords': self.correctable_codewords.append(element)

        while True:
            try:
                element = next(di)
                self.uncorrectable_codewords.append(element)
            except StopIteration:
                break

def main():
    if len(sys.argv) != 2 or sys.argv[1] != 'config':
        print('Error: plugin designed for the dirtyconfig protocol, must be run with the config argument')
        sys.exit(1)

    parser = MotorolaHTMLParser()
    for line in urllib.request.urlopen("http://192.168.100.1/cmSignalData.htm"):
        parser.feed(line.decode())
    parser.process()

    print('multigraph motorola_sb6141_power')
    print('graph_title Motorola SB6141 Cable Modem Power')
    print('graph_vlabel Signal Strength (dBmV)')
    print('graph_info This graph shows the downstream and upstream power reported by a Motorola SB6141 cable modem.')
    print('graph_category network')
    for c, p in zip(parser.downstream_channels, parser.downstream_powers):
        print('ds_power_{0}.label Channel {0} Downstream Power'.format(c))
        print('ds_power_{0}.type GAUGE'.format(c))
        print('ds_power_{0}.value {1}'.format(c, p))
    for c, p in zip(parser.upstream_channels, parser.upstream_powers):
        print('us_power_{0}.label Channel {0} Upstream Power'.format(c))
        print('us_power_{0}.type GAUGE'.format(c))
        print('us_power_{0}.value {1}'.format(c, p))

    print('multigraph motorola_sb6141_snr')
    print('graph_title Motorola SB6141 Cable Modem SNR')
    print('graph_vlabel Signal-to-Noise Ratio (dB)')
    print('graph_info This graph shows the downstream signal-to-noise ratio reported by a Motorola SB6141 cable modem.')
    print('graph_category network')
    for c, snr in zip(parser.downstream_channels, parser.downstream_SNRs):
        print('snr_chan_{0}.label Channel {0} SNR'.format(c))
        print('snr_chan_{0}.type GAUGE'.format(c))
        print('snr_chan_{0}.value {1}'.format(c, snr))

    print('multigraph motorola_sb6141_codewords')
    print('graph_title Motorola SB6141 Cable Modem Codewords')
    print('graph_vlabel Codewords/${graph_period}')
    print('graph_info This graph shows the downstream codeword rates reported by a Motorola SB6141 cable modem.')
    print('graph_category network')
    for c, unerr in zip(parser.downstream_channels, parser.unerrored_codewords):
        print('unerr_chan_{0}.label Channel {0} Unerrored Codewords'.format(c))
        print('unerr_chan_{0}.type DERIVE'.format(c))
        print('unerr_chan_{0}.min 0'.format(c))
        print('unerr_chan_{0}.value {1}'.format(c, unerr))
    for c, corr in zip(parser.downstream_channels, parser.correctable_codewords):
        print('corr_chan_{0}.label Channel {0} Correctable Codewords'.format(c))
        print('corr_chan_{0}.type DERIVE'.format(c))
        print('corr_chan_{0}.min 0'.format(c))
        print('corr_chan_{0}.value {1}'.format(c, corr))
    for c, uncorr in zip(parser.downstream_channels, parser.uncorrectable_codewords):
        print('uncorr_chan_{0}.label Channel {0} Uncorrectable Codewords'.format(c))
        print('uncorr_chan_{0}.type DERIVE'.format(c))
        print('uncorr_chan_{0}.min 0'.format(c))
        print('uncorr_chan_{0}.value {1}'.format(c, uncorr))

if __name__ == "__main__":
    main()