#!/usr/bin/env python
# -*- coding: utf-8 -*-
import sys, os, time
sys.path.insert(0,"lib")
from itty import itty
from werkzeug.contrib.cache import SimpleCache
from simplejson import dumps as dump_json

"""
def data(name):
    if name in (
            "solarDaten.tempKollektor", 
            "solarDaten.tempWarmwasserSolar",
            "betriebsdatenRegler1.boilerTemperatur",
            "betriebsdatenRegler1.kesselTemperatur",
            "betriebsdatenRegler1.aussenTemperatur",
            "betriebsdatenFeuerungsautomat.brauchwasserSollwert", 
            "betriebsdatenFeuerungsautomat.kesselSollwertTemperatur"):
        m = Code('''
            function () {
                emit(parseInt(this.time/900)*900000, {sum: this.values[field], count:1});
            }''')
        r = Code('''
            function (key, values) {
                var n = { sum:0, count:0 };
                for (var i = 0; i<values.length; i++) {
                    n.sum += values[i].sum;
                    n.count += values[i].count;
                };
                return n;
            }''')
        f = Code('''
            function (who,r) {
                r.avg = r.sum/r.count;
                return r;
            }''')
        q={
            "name":name.split(".")[0],
            "time":{"$gt": ( time.time() - (72*3600))},
        }
        fs=["name", "values.%s"%name.split(".")[1]]
        s={
            "field":name.split(".")[1],
            }
        print "query q=%s fs=%s s=%s" % (q,fs,s)
        collection.ensure_index([('time',pymongo.ASCENDING),('name',pymongo.ASCENDING)])
        data = collection.map_reduce(m,r,query=q,finalize=f,fields=fs,scope=s).find().sort('time',pymongo.ASCENDING)
        return map(lambda it: [it['_id'], it['value']['avg']], data)
    elif name in (
            "betriebsdatenFeuerungsautomat.betriebszustand.reduced",
            "solarDaten.solarPumpe.reduced"):
        pName = name.split(".")[0]
        pField = name.split(".")[1]
        q={
            "name":pName,
            "time":{"$gt":(time.time()-(72*3600))}
        }
        fs=["values.%s"%pField, "time"]
        collection.ensure_index([('time',pymongo.ASCENDING),('name',pymongo.ASCENDING)])
        data=collection.find(q,fields=fs).sort('time', pymongo.ASCENDING)
        #TODO.map(Code('''function(it) { return [it.time, it.values.betriebszustand]; }'''))
        data=map(lambda it: [it['time']*1000, it['values'][pField]], data)

        #Fast die ände auf einen Eintrag pro Änderung zusammen
        def reduce(data):
            prev = None
            for item in data:
                if item[1] != prev:
                    prev = item[1]
                    yield item

        return list(reduce(data))
    else:
        return []
"""


@itty.get("/")
def index(req):
    filename=os.path.join(os.path.dirname(__file__), "static", "index.html")
    return open(filename,"r").read()

json_cache = SimpleCache(default_timeout=20)
@itty.get('/json/<name>')
def json(req,name):
    value = json_cache.get(name)
    if value is None:
        value = deny.Response(dump_json(dict(map(lambda r: (r, {"label":r, "data":data(r)}), name.split(",")))), mimetype='application/json')
        json_cache.set(name, value)
    return value

@itty.get("/static/(?P<filename>.+)")
def static(request,filename):
    file = itty.static_file(filename, root=os.path.join(os.path.dirname(__file__), 'static'))
    return itty.Response(file, content_type=itty.content_type(file))

if __name__ == '__main__':
    sys.exit(itty.run_itty(host="0.0.0.0",port=5000))