from channels import Group
from channels.sessions import channel_session
import random
from .models import Player, Group as OtreeGroup, Constants
import json
import time


def ws_connect(message, group_name):
    Group(group_name).add(message.reply_channel)



# Connected to websocket.receive
def ws_message(message, group_name):
    group_id = group_name[5:]
    jsonmessage = json.loads(message.content['text'])
    mygroup = OtreeGroup.objects.get(id=group_id)
    curbuyer_id_in_group = jsonmessage['id_in_group']
    mygroup.price += 10
    mygroup.buyer = curbuyer_id_in_group
    now = time.time()
    for g in mygroup.get_players():
        if g.id_in_group == curbuyer_id_in_group:
            g.in_or_out = 0
            g.save()
    inmembers = [x.in_or_out for x in mygroup.get_players()]
    allmembers = [x.id_in_group for x in mygroup.get_players()]
    mygroup.auctionenddate = now + Constants.extra_time
    mygroup.save()
    time_left = round(mygroup.auctionenddate - now)
    textforgroup = json.dumps({
                                "price": mygroup.price,
                                "time_left": time_left,
                                "winner": curbuyer_id_in_group,
                                "buyer": curbuyer_id_in_group,
                                "allmembers": allmembers,
                                "inmembers": inmembers,
                                })
    Group(group_name).send({
        "text": textforgroup,
    })


# Connected to websocket.disconnect
def ws_disconnect(message, group_name):
    Group(group_name).discard(message.reply_channel)