webserver.py

#!/usr/bin/env python

# author: brendan@shellshockcomputer.com.au

import ConfigParser
from bottle import route, install, run, template, static_file, response, PasteServer, post, get, request, debug
from bottle_sqlite import SQLitePlugin
import json
import urllib
import urllib2
import datetime
import math


config = ConfigParser.RawConfigParser()
config.read('config.ini')

install(SQLitePlugin(dbfile=(config.get("pool", "database"))))

@route('/api/btime')
def blocktime():
    response.headers['Cache-Control'] = 'public, max-age=100'
    payload = {
        'requestType': 'getForging',
        'secretPhrase': config.get("pool", "poolphrase")
    }
    opener = urllib2.build_opener(urllib2.HTTPHandler())
    data = urllib.urlencode(payload)
    forging = json.loads(opener.open(config.get("pool", "nhzhost")+'/nhz', data=data).read())
    getdl = forging["deadline"]
    dl = str(datetime.timedelta(seconds=getdl))
    return {'blocktime': dl}

@route('/api/accounts')
def apiaccounts(db):
    response.headers['Cache-Control'] = 'public, max-age=3600'
    getlastheight = db.execute("SELECT height FROM blocks ORDER BY timestamp DESC").fetchone()

    try:
        lastheight = getlastheight[0]
    except:
        lastheight = 0

    c = db.execute("SELECT ars, heightfrom, heightto, CAST(amount AS FLOAT)/100000000 AS amount FROM leased WHERE heightto > %s" % (lastheight)).fetchall()
    accounts = json.dumps( [dict(ix) for ix in c], separators=(',',':'))   
    return accounts

@route('/api/blocks')
def apiblocks(db):
    response.headers['Cache-Control'] = 'public, max-age=1800'
    c = db.execute("SELECT height, datetime(timestamp+1395526942, 'unixepoch', 'localtime') as timestamp, CAST(totalfee AS FLOAT)/100000000 AS totalfee FROM blocks WHERE totalfee > 0 ORDER BY timestamp DESC").fetchall()
    blocks = json.dumps( [dict(ix) for ix in c], separators=(',',':'))
    return blocks

@route('/api/leased')
def apileased():
    getaccounts = json.loads(urllib2.urlopen(config.get("pool", "nhzhost")+"/nhz?requestType=getAccount&account="+config.get("pool", "poolaccount")).read())

    try:
        leasebal = getaccounts['effectiveBalanceNHZ']
    except:
        leasebal = 0

    return {'blocktime': leasebal}

@route('/api/payouts')
def apipayouts(db):
    response.headers['Cache-Control'] = 'public, max-age=3600'
    c = db.execute("SELECT account, CAST(fee AS FLOAT)/100000000 AS fee, CAST(payment AS FLOAT)/100000000 AS payment FROM payouts DESC").fetchall()
    pays = json.dumps( [dict(ix) for ix in c], separators=(',',':'))
    return pays

@route('/api/paid')
def apipaid(db):
    response.headers['Cache-Control'] = 'public, max-age=3600'
    c = db.execute("SELECT  datetime(blocktime+1395526942, 'unixepoch', 'localtime') as blocktime, account, percentage, CAST(amount AS FLOAT)/100000000 AS amount FROM accounts WHERE paid>0 ORDER BY blocktime DESC").fetchall()   
    pays = json.dumps( [dict(ix) for ix in c], separators=(',',':'))
    return pays

@route('/api/unpaid')
def apiunpaid(db):
    response.headers['Cache-Control'] = 'public, max-age=3600'
    c = db.execute("SELECT datetime(blocktime+1395526942, 'unixepoch', 'localtime') as blocktime, account, percentage, CAST(amount AS FLOAT)/100000000 AS amount FROM accounts WHERE paid=0 ORDER BY blocktime DESC").fetchall()   
    pays = json.dumps( [dict(ix) for ix in c], separators=(',',':'))
    return pays
    
@route('/api/userunpaid/:user#NHZ-[0-9A-Z-]+#')
def apiuserunpaid(db, user):
    response.headers['Cache-Control'] = 'public, max-age=600'
    c = db.execute("SELECT datetime(blocktime+1395526942, 'unixepoch', 'localtime') as blocktime, percentage, CAST(amount AS FLOAT)/100000000 AS amount FROM accounts WHERE paid=0 and account LIKE ?", (user,)).fetchall()
    pays = json.dumps( [dict(ix) for ix in c], separators=(',',':'))
    return pays

@route('/api/userpaid/:user#NHZ-[0-9A-Z-]+#')
def apiuserpaid(db, user):
    response.headers['Cache-Control'] = 'public, max-age=600'
    c = db.execute("SELECT datetime(blocktime+1395526942, 'unixepoch', 'localtime') as blocktime, percentage, CAST(amount AS FLOAT)/100000000 AS amount FROM accounts WHERE paid>0 and account LIKE ?", (user,)).fetchall()
    pays = json.dumps( [dict(ix) for ix in c], separators=(',',':'))
    return pays
            
@route('/')
def default(db):
    response.headers['Cache-Control'] = 'public, max-age=3600'
    poolaccount = config.get("pool", "poolaccountrs")
    poolfee = config.get("pool", "feePercent")
    payoutlimit = config.get("pool", "payoutlimit")
    c = db.execute("SELECT ars, heightto, CAST(amount AS FLOAT)/100000000 AS amount FROM leased ORDER BY heightfrom DESC limit 10")
    result = c.fetchall()
    e = db.execute("SELECT height, datetime(timestamp+1395526942, 'unixepoch', 'localtime') as timestamp, CAST(totalfee AS FLOAT)/100000000 AS totalfee FROM blocks ORDER BY timestamp DESC limit 10")
    block = e.fetchall()
    cunpaid = db.execute("SELECT sum(amount) FROM accounts WHERE paid=0").fetchone()
    for r in cunpaid:
        try:
            unpaid = math.trunc(float(r)/100000000)
        except TypeError:
            unpaid = 0
    getaccounts = json.loads(urllib2.urlopen(config.get("pool", "nhzhost")+"/nhz?requestType=getAccount&account="+config.get("pool", "poolaccount")).read())
    try:
        leasebal = getaccounts['effectiveBalanceNHZ']
    except KeyError:
        leasebal = 0
        
    output = template('default', pa=poolaccount, fee=poolfee, rows=result, blocks=block, nhzb=leasebal, payoutlimit=payoutlimit, unpaid=unpaid)
    return output

@route('/static/:path#.+#', name='static')
def static(path):
    response.headers['Cache-Control'] = 'public, max-age=2592000'
    return static_file(path, root='static')

@route('/favicon.ico')
def get_favicon():
    response.headers['Cache-Control'] = 'public, max-age=2592000'
    return static('favicon.ico')

@route('/getting_started')
def getting_started():
    response.headers['Cache-Control'] = 'public, max-age=43200'
    output = template('gettingstarted')
    return output

@route('/accounts')
def accounts(db):
    response.headers['Cache-Control'] = 'public, max-age=43200'   
    output = template('accounts')
    return output

@route('/blocks')
def blocks(db):
    response.headers['Cache-Control'] = 'public, max-age=43200'
    output = template('blocks')
    return output

@route('/payouts')
def payouts(db):
    response.headers['Cache-Control'] = 'public, max-age=43200'   
    output = template('payouts')
    return output

@route('/unpaid')
def unpaid(db):
    response.headers['Cache-Control'] = 'public, max-age=43200'
    cunpaid = db.execute("SELECT sum(amount) FROM accounts WHERE paid=0").fetchone()
    for e in cunpaid:
        try:
            unpaid = float(e)/100000000
        except TypeError:
            unpaid = 0
       
    output = template('unpaid', unpaid=unpaid)
    return output

@route('/paid')
def paid(db):
    response.headers['Cache-Control'] = 'public, max-age=43200'            
    cpaid = db.execute("SELECT sum(amount) FROM accounts WHERE paid>0").fetchone()
    for d in cpaid:
        try:
            paid = float(d)/100000000
        except TypeError:
            paid = 0

    output = template('paid', paid=paid)
    return output

@get('/user')
def user(db):
    aid = request.GET.get('username')
    user=aid
    cpaid = db.execute("SELECT sum(amount) FROM accounts WHERE paid>0 and account LIKE ?", (user,)).fetchone()
    for d in cpaid:
        try:
            paid = float(d)/100000000
        except TypeError:
            paid = 0
        
    cunpaid = db.execute("SELECT sum(amount) FROM accounts WHERE paid=0 and account LIKE ?", (user,)).fetchone()
    for e in cunpaid:
        try:
            unpaid = float(e)/100000000
        except TypeError:
            unpaid = 0
        
    output = template('user', user=user, aid=aid, paid=paid, unpaid=unpaid)
    return output


@post('/user')
def user(db):
    aid = request.forms.get('username')
    user=aid
    cpaid = db.execute("SELECT sum(amount) FROM accounts WHERE paid>0 and account LIKE ?", (user,)).fetchone()
    for d in cpaid:
        try:
            paid = float(d)/100000000
        except TypeError:
            paid = 0
        
    cunpaid = db.execute("SELECT sum(amount) FROM accounts WHERE paid=0 and account LIKE ?", (user,)).fetchone()
    for e in cunpaid:
        try:
            unpaid = float(e)/100000000
        except TypeError:
            unpaid = 0
        
    output = template('user', user=user, aid=aid, paid=paid, unpaid=unpaid)
    return output
        
#debug(True)    
run(server=PasteServer, port=config.get("pool", "port"), host='0.0.0.0')