Munin contributed plugins

nanopool_ - Munin plugin to monitor nanopool ethereum user data.

=head1 CONFIGURATION

[nanopool_*]

        - Copy to /usr/share/munin/plugins

        - Create symlinks in /etc/munin/plugins to nanopool_<graph type>_<account_address>,

          e.g. ln -s /usr/share/munin/plugins/nanopool_ /etc/munin/plugins/nanopool_hashrate_0x1234567890abcdef1234567890

          Please use the account address in the format "0x<address>".

        - To enable graphs, link to one or more of the graph types available

        - Then restart munin-node

Graph types and their links:

        balance: link to nanopool_balance           Show current balance

        hashrate: link to nanopool_hashrate         Show current calculated hashrate

        avghashrate: link to nanopool_avghashrate   Show average hashrate of last hour

        worker: link to nanopool_worker             Show worker data

Thanks to the authors of other Python munin plugins. I've used some of

them as inspiring example.

1.0.0

#%# capabilities=suggest

=cut

from __future__ import print_function

    # Python 3

    from urllib.request import Request

    from urllib.request import urlopen

    # Python 2

    from urllib2 import Request

    from urllib2 import urlopen

def define_graph_types():

    graph_types = {

        "balance" : [

            {

                "title" : "Balance of {0}".format(account_address),

                "type" : "GAUGE",

                "args" : "--base 1000 -l 0",

                "fields" : ["ETH"],

                "scale": "no",

                "info": "Balance in ETH"

            }

        ],

        "hashrate" : [

            {

                "title" : "Hashrate of {0}".format(account_address),

                "type" : "GAUGE",

                "args" : "--base 1000 -l 0",

                "fields" : ["hashrate"],

                "info": "Current Calculated Hashrate in Mh/s"

            }

        ],

        "avghashrate" : [

            {

                "title" : "Average Hashrate of {0}".format(account_address),

                "type" : "GAUGE",

                "args" : "--base 1000 -l 0",

                "fields" : ["avg_hashrate"],

                "info": "Average Hashrate of last hour in Mh/s"

            }

        ],

        "worker" : [

            {

                "title" : "Worker"

            }

        ]

    }

    return graph_types

    url = "https://api.nanopool.org/v1/eth/user/{0}".format(account_address)

    # this fake is necessary to get values, otherwise the request ends in a 403 error

    req.add_header('User-Agent', 'Nozilla/5.0')

    try:

        txt = urlopen(req).read()

    except Exception as err:

        # there could be different exceptions like ValueError, URLError, HTTPError

        print("API request error: {0}". format(err), file=sys.stderr)

        exit(1)

    worker_data = sorted(data["data"]["workers"], key=lambda element: element["id"])

    print("multigraph worker_hashrate_{0}".format(account_address))

    print("graph_title Hashrate in Mh/s per worker ({0})".format(account_address))

        worker_name = "_".join(val["id"].split())

        print("worker_{0}_hashrate.label {1}".format(worker_name, str(val["id"])))

        print("worker_{0}_hashrate.type GAUGE".format(worker_name))

        print("worker_{0}_hashrate.info Hashrate of worker '{1}'".format(worker_name, str(val["id"])))

        print("worker_{0}_hashrate.min 0".format(worker_name))

        print("worker_{0}_hashrate.draw LINE1".format(worker_name))

    for val in worker_data:

        print("")

        worker_name = "_".join(val["id"].split())

        print("multigraph worker_hashrate_{0}.worker_{1}".format(account_address, worker_name))

        print("graph_title Hashrate in Mh/s of worker {0}".format(worker_name))

        print("graph_args --base 1000 -l 0")

        print("graph_vlabel Mh/s")

        print("graph_category other")

        print("graph_scale no")

        print("whashrate.label hashrate")

        print("whashrate.type GAUGE")

        print("whashrate.info Hashrate of worker {0}".format(str(val["id"])))

        print("whashrate.min 0")

        print("whashrate.draw LINE1")

    print("multigraph worker_shares_{0}".format(account_address))

    print("graph_title Number of accepted shares ({0})".format(account_address))

        worker_name = "_".join(val["id"].split())

        print("worker_{0}_shares.label {1} ".format(worker_name, str(val["id"])))

        print("worker_{0}_shares.type COUNTER".format(worker_name))

        print("worker_{0}_shares.info Accepted shares of worker '{1}'".format(worker_name, str(val["id"])))

        print("worker_{0}_shares.min 0".format(worker_name))

        print("worker_{0}_shares.draw LINE1".format(worker_name))

    for val in worker_data:

        worker_name = "_".join(val["id"].split())

        print("")

        print("multigraph worker_shares_{0}.worker_{1}".format(account_address, worker_name))

        print("graph_title Number of accepted shares {0}".format(worker_name))

        print("graph_args --base 1000 -l 0")

        print("graph_vlabel Shares per ${graph_period}")

        print("graph_category other")

        print("graph_scale no")

        print("graph_period minute")

        print("wshares.label shares")

        print("wshares.type COUNTER")

        print("wshares.info Accepted shares of worker '{0}'".format(str(val["id"])))

        print("wshares.min 0")

        print("wshares.draw LINE1")

    worker_data = sorted(data["data"]["workers"], key=lambda element: element["id"])

    print("multigraph worker_hashrate_{0}".format(account_address))

        worker_name = "_".join(val["id"].split())

        print("worker_{0}_hashrate.value {1}".format(worker_name, str(val["hashrate"])))

    for val in worker_data:

        print("")

        worker_name = "_".join(val["id"].split())

        print("multigraph worker_hashrate_{0}.worker_{1}".format(account_address, worker_name))

        print("whashrate.value {0}".format(str(val["hashrate"])))

    print("")

    print("multigraph worker_shares_{0}".format(account_address))

        worker_name = "_".join(val["id"].split())

        print("worker_{0}_shares.value {1}".format(worker_name, str(val["rating"])))

    for val in worker_data:

        worker_name = "_".join(val["id"].split())

        print("")

        print("multigraph worker_shares_{0}.worker_{1}".format(account_address, worker_name))

        print("wshares.value {0} ".format(str(val["rating"])))

        print("Unknown graph type '{0}'".format(graph_type), file=sys.stderr)

        exit(1)

        print("graph_title {0}".format(item["title"]))

            print("graph_info {0}".format(item["info"]))

            print("graph_scale {0}".format(item["scale"]))

            print("graph_args {0}".format(item["args"]))

            print("{0}.label {1}".format(field, field))

            print("{0}.type {1}".format(field, item["type"]))

        print("ETH.value {0}".format(data['data']['balance']))

        print("hashrate.value {0}".format(data["data"]["hashrate"]))

        print("avg_hashrate.value {0}".format(data["data"]["avgHashrate"]["h1"]))

    else:

        pass

    try:

        graph_type, account_address = program.split("_")[1:]

    except ValueError:

        print("Please configure the plugin as described in the configuration section.")

        exit(1)

    GRAPH_TYPES = define_graph_types()

    if len(sys.argv) > 1 and sys.argv[1] == "autoconf":

        print("no")

    elif len(sys.argv) > 1 and sys.argv[1] == "config":

    elif len(sys.argv) > 1 and sys.argv[1] == "suggest":