#!/usr/bin/python3 -d # Copyright (c) 2020 Johannes Findeisen # # Permission is hereby granted, free of charge, to any person obtaining a copy # of this software and associated documentation files (the "Software"), to deal # in the Software without restriction, including without limitation the rights # to use, copy, modify, merge, publish, distribute, sublicense, and/or sell # copies of the Software, and to permit persons to whom the Software is furnished # to do so, subject to the following conditions: # # The above copyright notice and this permission notice (including the next # paragraph) shall be included in all copies or substantial portions of the # Software. # # THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR # IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS # FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS # OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, # WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF # OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. import argparse import json # import logging # import logging.handlers import sys import time from uplink.uplink import Uplink # Version format: MAJOR.FEATURE.FIXES __version__ = "0.4.0-development" # TODO: CHECK ALL ERROR HANDLING!!! # TODO: Implement logging # TODO: Implement CLI output messages # TODO: IDEA: Implement a small webserver inline to get statistics and graphs over the network? Or maybe better as a # separate daemon # TODO: Make use of more args passed to the script # TODO: Implement a speedtest that will also run regularly but in an individual interval def parse_args(): parser = argparse.ArgumentParser( description="uplink is a tool to monitor the link status of AVM FRITZ!Box Cable and DSL based routers.", epilog="uplink is not some program expecting uplinks to work!", prog="uplink") parser.add_argument("config", metavar="CONFIGFILE", help="the configfile to use") mode = parser.add_mutually_exclusive_group() mode.add_argument("-c", "--cron", default=False, dest="cron", action="store_true", help="cron mode executes the script only once without loop (default: false)") mode.add_argument("-d", "--daemon", default=False, dest="daemon", action="store_true", help="run as native daemon (default: false)") mode.add_argument("-f", "--foreground", default=False, dest="foreground", action="store_true", help="run looped in foreground (default: false)") parser.add_argument("-i", "--interval", type=int, help="poll interval in seconds. this overrides config file " "settings. (default: 60)") """ parser.add_argument("-b", "--database", metavar="DATABASE", help="database to use") parser.add_argument("-u", "--user", type=str, help="database username") parser.add_argument("-p", "--password", type=str, help="database password") parser.add_argument("-l", "--logfile", metavar="FILE", help="logfile to use") parser.add_argument("-c", "--log-count", default=5, type=int, help="maximum number of logfiles in rotation (default: 5)") parser.add_argument("-m", "--log-size", default=10485760, type=int, help="maximum logfile size in bytes (default: 10485760)") parser.add_argument("-s", "--stdout", default=False, dest="stdout", action="store_true", help="log to stdout") output = parser.add_mutually_exclusive_group() output.add_argument("-q", "--quiet", action="store_const", dest="log_level", const=logging.ERROR, help="output only errors") output.add_argument("-w", "--warning", action="store_const", dest="log_level", const=logging.WARNING, help="output warnings") output.add_argument("-v", "--verbose", action="store_const", dest="log_level", const=logging.INFO, help="output info messages") output.add_argument("-d", "--debug", action="store_const", dest="log_level", const=logging.DEBUG, help="output debug messages") output.set_defaults(loglevel=logging.ERROR) """ parser.add_argument("--version", action="version", version="%(prog)s " + str(__version__)) return parser.parse_args() if __name__ == "__main__": args = parse_args() # TODO: Read --version argument and print program version; then exit. # TODO: Cleanup config.json and only define what really is needed config_path = args.config try: with open(config_path, 'r') as configfile: config_data = configfile.read() _config = json.loads(config_data) except "OSError, PermissionDenied, RuntimeError, ValueError" as err: # TODO: Replace all lines like this with generic Python logging print(str("Uplink: Configuration Error!" + err)) sys.exit(1) try: _config["interval"] except KeyError: # interval not configured in configuration; using default value _config["interval"] = 60 if args.interval: # interval set in args is overriding configuration and default _config["interval"] = args.interval uplink = Uplink("/tmp/uplink.pid", _config) if args.cron: for i in range(len(_config["uplinks"])): uplink.get_data(_config, i) elif args.daemon: uplink.start() elif args.foreground: while True: for i in range(len(_config["uplinks"])): uplink.get_data(_config, i) # TODO: print data formatted to STDOUT time.sleep(_config["interval"]) else: print("uplink: error: no run mode selected; use --cron (-c), --daemon (-d) or --foreground (-f) to run uplink. " "use --help for more information")