mineschwifty.py

#!/usr/bin/python
from __future__ import print_function
import yaml
import requests

f = open('mineschwifty.yml')
config = yaml.safe_load(f)

# state file. contains the key of the current coin
s = open(config['statefilename'], 'a+')
s.seek(0)
current_state = s.read()
s.close()
if current_state == '':
    current_state = 'nothing'

sortbuffer_val = 0
sortbuffer_key = ''

def escalate(message):
    #todo: bullet message? email?
    print('ESC: %s'%(message))

def control_miner(coin, command):
    print('EXEC: %s'%(config['coins'][coin][command]))
    #exec(config['coins'][coin][command]);

def get_profit_index(key, coin):
    """sort the coin by profit"""
    global sortbuffer_key, sortbuffer_val
    # hack-adi-hack, das dollarsign muss weg :-)
    profit_val = float(coin['profit'][1:])
    if profit_val > sortbuffer_val:
        sortbuffer_key = key
        sortbuffer_val = profit_val
    return sortbuffer_key, sortbuffer_val


for i in (config['coins']):
    params = dict(
        hr=config['coins'][i]['hashrate'],
        p=config['coins'][i]['powerwall'],
        cost=config['powercost']
    )
    try:
        resp = requests.get(url=config.get('url')+str(config['coins'][i]['index'])+'.json', params=params)
        get_profit_index(i, resp.json())
    except Exception as e:
        escalate('warning: failed to fetch wtm-data for %s (%s).'%(i,str(e)))


if sortbuffer_key != current_state:
    print(sortbuffer_key, sortbuffer_val)
    #if we know the current miner, we stop it
    if current_state in config['coins']:
        control_miner(current_state,'command_stop')
    else:
        #try to stop all possible miners..
        for c in config['coins']:
            control_miner(c,'command_stop')

    #then we start the new miner if we have a profitable currency
    if sortbuffer_val > 0:
        escalate('mining: switched from %s to %s at aprox. $%0.2f'%(current_state,sortbuffer_key,sortbuffer_val));
        control_miner(sortbuffer_key,'command_start')
        current_state = sortbuffer_key
    else:
        escalate('not mining: no profitable currency found');
        current_state = 'nothing'
    s = open(config['statefilename'], 'w+')
    s.write(current_state)
    s.close()
f.close()