1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
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='/music')
def connect_music(sid, environ):
print("connect_music", sid)
@sio.on('disconnect', namespace='/music')
def disconnect_music(sid):
print("disconnect_music", sid)
current_background_music = None
@sio.on('ready', namespace='/music')
def ready_music(sid):
sio.emit('background', {'id': current_background_music}, room=sid, namespace='/music')
@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.emit('effect', {'id': data['type']}, namespace='/music');
@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
sio.emit('fish state', fish_state, namespace='/spawn')
elif event[0] == 'disable image':
fish_state[event[1]['name']] = 0
sio.emit('fish state', fish_state, namespace='/spawn')
elif event[0] == 'background music':
print "****** background music ", event[1]
sio.emit('background', {'id': event[1]}, namespace='/music');
current_background_music = event[1];
elif event[0] == 'effect music':
sio.emit('effect', {'id': event[1]}, namespace='/music');
thread = sio.start_background_task(recv_events)
|
