import json
import hmac
import hashlib
import zlib
import binascii
import logging
import asyncio

import aiohttp

import config
from utils import L,D,EX,W,E
import utils

class Uploader(object):
    def __init__(self, server):
        self.server = server

    @asyncio.coroutine
    def run(self):
        # wait for the first read
        yield from asyncio.sleep(5)
        while True:
            yield from self.do()
            yield from self.server.sleep(config.UPLOAD_SLEEP)

    def get_tosend(self, readings):
        tosend = {}

        tosend['fridge_on'] = self.server.fridge.is_on()

        tosend['now'] = self.server.now()
        tosend['readings'] = readings

        tosend['wort_name'] = self.server.wort_name
        tosend['fridge_name'] = self.server.wort_name

        tosend['current_params'] = dict(self.server.params)

        tosend['start_time'] = self.server.start_time
        tosend['uptime'] = utils.uptime()

        return tosend

    @asyncio.coroutine
    def send(self, tosend):
        js = json.dumps(tosend)
        if self.server.test_mode():
            D("Would upload %s to %s" % (js, config.UPDATE_URL))
            return
        js_enc = binascii.b2a_base64(zlib.compress(js.encode()))
        mac = hmac.new(config.HMAC_KEY.encode(), js_enc, hashlib.sha1).hexdigest()
        send_data = {'data': js_enc, 'hmac': mac}
        r = yield from asyncio.wait_for(aiohttp.request('post', config.UPDATE_URL, data=send_data), 60)
        result = yield from asyncio.wait_for(r.text(), 60)
        if result != 'OK':
            raise Exception("Server returned %s" % result)

    @asyncio.coroutine
    def do(self):
        readings = self.server.take_readings()
        try:
            tosend = self.get_tosend(readings)
            nreadings = len(readings)
            yield from self.send(tosend)
            readings = None
            D("Sent updated %d readings" % nreadings)
        except Exception as e:
            E("Error in uploader: %s" % str(e))
        finally:
            if readings is not None:
                self.server.pushfront(readings)