Simple NiceHash Monitor

readme

This is a simple Python NiceHash script I created to monitor one BTC address & rig.  
The script can be modified to monitor more addresses or rigs.  
The script was made to run on Linux in Python 2.7.  

At a high level, it does the following:
1.Check to see if the application is already running
2.Query nicehash API to get the current sum of the btc/day profitibility rates for all algos
3.If the sum = 0, send an alert that the miner is off.
4.If the sum is below the min threshold set in the config, send an alert
5.Alert when back above the set threshold then exit script

The the script uses the IFTTT Maker chanel to do the alerting.  To configure and run:

1. Configure an IFTTT Maker applet. Name the event "nicehash".  Take note of your Maker service key.  
   I configured mine to send both a text and an email
2. Setup the config.py settings.  Add your BTC address and IFTTT key
3. Run nicehash_start.py (should probably configure through cron to run at regular intervals). 

config.py

#config
minProf= .001 #min profit for alert in BTC/Day
slowAlertTimer = 300 #min time for slow alert in seconds
offTimer = 0 #min time of off alert in seconds
btcAddress = "address goes here" #niceHash BTC address to monitor
iftttKey = "key goes here" #key from IFTTT Maker applet

nicehash.py

import config

try:

	import time
	import logging  
	import logging.handlers

	LEVEL = logging.DEBUG # Pick minimum level of reporting logging - debug OR info
	
	# Format to include when, who, where, what
	formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')

	# Name is module name
	logger = logging.getLogger(__name__)  
	logger.setLevel(LEVEL)

	# Create file size limit and file name
	handler = logging.handlers.RotatingFileHandler('debug.log', maxBytes=2000000, backupCount=10)  
	handler.setLevel(LEVEL)  
	handler.setFormatter(formatter)

	# Add handler to logger
	logger.addHandler(handler)  

	logger.debug("Starting app")

	def getProf():
		#query the nicehash API and sum the profitibility per day (in BTC)
		import json, requests

		url = 'https://api.nicehash.com/api'

		params = dict(
			method='stats.provider.ex',
			addr= btcAddress
		)

		resp = requests.get(url=url, params=params)
		stats = json.loads(resp.text)

		#print (stats["result"]["current"])
		totalProf = 0
		for i in stats["result"]["current"]:
			algoProf = float(i["profitability"])
			if "a" in i["data"][0]:
				#there is activity for this algo
				#to get the profitibility per day in BTC, multiply "a" rate by algo profitibility and add to total prof 
				totalProf = totalProf + algoProf * float(i["data"][0]["a"])
		logger.debug("current total profitibility in BTC/day is " + str(totalProf))
		return totalProf

	def sendAlert(message, alert):
		#trigger IFTTT event
		import requests
		report = {}
		report["value1"] = message
		requests.post("https://maker.ifttt.com/trigger/" + alert + "/with/key/" + iftttKey, data=report)
		
	timer = 0

	messagesSent = 0	

	while getProf() == 0:
		#looks like the miner is off, alert immediately
		logger.info("The miner is off")
		if timer >= offTimer and messagesSent == 0:
			#has been below the minProf for greater than the slow alert threshold setting, raise an alert
			sendAlert("NiceHash miner is off. Go fix it.","nicehash")
			messagesSent = 1
		time.sleep(30)
		timer = timer + 30

	while getProf() < minProf:
		#currently making less that min profitability setting
		#Check again every 30 seconds for 5 minutes
		if timer >= slowAlertTimer and messagesSent == 0:
			#has been below the minProf for greater than the slow alert threshold setting, raise an alert
			sendAlert("NiceHash is running slow.  Current rate is " + str(getProf()) + " BTC/Day","nicehash")
			messagesSent = 1
			logger.info("The miner has been slow for 5 minutes.  Current speed is "  + str(getProf()) + " BTC/Day")
		time.sleep(30)
		timer = timer + 30

	if messagesSent == 1:
		#if it got to this point with a messageSent=1, then it's had an issue and recovered, send recovery message	
		sendAlert("NiceHash is fast again.  Current rate is " + str(getProf()) + " BTC/Day.  It was down for " + str(timer / 60) + " mins","nicehash")
		logger.info("The miner is back to a normal speed.  Current speed is "  + str(getProf()) + " BTC/Day")
	
	logger.info("All is well.  Nicehash is running above expected rate :)  Closing.")
	#if the script ends without entering either while statement, then all is well, it should run again via cron
	
except Exception as e:
    logger.exception("something bad happened")  

nicehash_start.py

#this script checks to see if the proces already has a PID, and is actively running.
#Only start app if not already running

#/usr/bin/env python
import os
import sys
if os.access(os.path.expanduser("~/.lockfile.vestibular.lock"), os.F_OK):
        #if the lockfile is already there then check the PID number
        #in the lock file
        pidfile = open(os.path.expanduser("~/.lockfile.vestibular.lock"), "r")
        pidfile.seek(0)
        old_pid = pidfile.readline()
        # Now we check the PID from lock file matches to the current
        # process PID
        if os.path.exists("/proc/%s" % old_pid):
                print "You already have an instance of the program running"
                print "It is running as process %s," % old_pid
                sys.exit(1)
        else:
                print "File is there but the program is not running"
                print "Removing lock file for the: %s as it can be there because of the program last time it was run" % old_pid
                os.remove(os.path.expanduser("~/.lockfile.vestibular.lock"))

pidfile = open(os.path.expanduser("~/.lockfile.vestibular.lock"), "w")
pidfile.write("%s" % os.getpid())
pidfile.close()

import nicehash