from flask import render_template, request, send_from_directory
from app import app, sio, send_queue, recv_queue
import time

import threading

@app.route('/')
@app.route('/index')
def index():
    return render_template('index.html',
                           title='F16 Group1')

@app.route('/static/<path:path>')
def send_static(path):
    return send_from_directory('static', path)

connections = set()

@sio.on('connect', namespace='/spawn')
def connect(sid, environ):
    print("connect ", sid)
    connections.add(sid)

@sio.on('spawn', namespace='/spawn')
def message(sid, data):
    print("message ", data)
    send_queue.put(('spawn', data))

@sio.on('ready', namespace='/spawn')
def ready(sid):
    sio.emit('fish state', fish_state, room=sid, namespace='/spawn')

@sio.on('disconnect', namespace='/spawn')
def disconnect(sid):
    print('disconnect', sid)
    connections.remove(sid)

fish_state = {
        'jellyfish': 0,
        'dolphin': 0,
        'boat': 0,
        'nemo': 0,
        'dory': 0,
        'whale': 0,
        'eel': 0,
        'stingray': 0,
        'shark': 0
}

def recv_events():
    while True:
        event = recv_queue.get()
        if event[0] == 'enable image':
            fish_state[event[1]['name']] = 1
        elif event[0] == 'disable image':
            fish_state[event[1]['name']] = 0

        sio.emit('fish state', fish_state, namespace='/spawn')


thread = sio.start_background_task(recv_events)