FilesExpand file tree

 master

/

app.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

executable file

·

117 lines (91 loc) · 3.58 KB

 master

/

app.py

Copy path

Top

File metadata and controls

• Code
• Blame

executable file

·

117 lines (91 loc) · 3.58 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

# set async_mode to 'threading', 'eventlet', 'gevent' or 'gevent_uwsgi' to

# force a mode else, the best mode is selected automatically from what's

# installed

async_mode = None

import time

from flask import Flask, render_template

import socketio

sio = socketio.Server(logger=True, async_mode=async_mode)

app = Flask(__name__)

app.wsgi_app = socketio.Middleware(sio, app.wsgi_app)

app.config['SECRET_KEY'] = 'secret!'

thread = None

def background_thread():

"""Example of how to send server generated events to clients."""

count = 0

while True:

sio.sleep(10)

count += 1

sio.emit('my response', {'data': 'Server generated event'},

namespace='/test')

@app.route('/')

def index():

global thread

if thread is None:

thread = sio.start_background_task(background_thread)

return render_template('index.html')

@sio.on('my event', namespace='/test')

def test_message(sid, message):

sio.emit('my response', {'data': message['data']}, room=sid,

namespace='/test')

@sio.on('my broadcast event', namespace='/test')

def test_broadcast_message(sid, message):

sio.emit('my response', {'data': message['data']}, namespace='/test')

@sio.on('join', namespace='/test')

def join(sid, message):

sio.enter_room(sid, message['room'], namespace='/test')

sio.emit('my response', {'data': 'Entered room: ' + message['room']},

room=sid, namespace='/test')

@sio.on('leave', namespace='/test')

def leave(sid, message):

sio.leave_room(sid, message['room'], namespace='/test')

sio.emit('my response', {'data': 'Left room: ' + message['room']},

room=sid, namespace='/test')

@sio.on('close room', namespace='/test')

def close(sid, message):

sio.emit('my response',

{'data': 'Room ' + message['room'] + ' is closing.'},

room=message['room'], namespace='/test')

sio.close_room(message['room'], namespace='/test')

@sio.on('my room event', namespace='/test')

def send_room_message(sid, message):

sio.emit('my response', {'data': message['data']}, room=message['room'],

namespace='/test')

@sio.on('disconnect request', namespace='/test')

def disconnect_request(sid):

sio.disconnect(sid, namespace='/test')

@sio.on('connect', namespace='/test')

def test_connect(sid, environ):

sio.emit('my response', {'data': 'Connected', 'count': 0}, room=sid,

namespace='/test')

@sio.on('disconnect', namespace='/test')

def test_disconnect(sid):

print('Client disconnected')

if __name__ == '__main__':

if sio.async_mode == 'threading':

# deploy with Werkzeug

app.run(threaded=True)

elif sio.async_mode == 'eventlet':

# deploy with eventlet

import eventlet

import eventlet.wsgi

eventlet.wsgi.server(eventlet.listen(('', 5000)), app)

elif sio.async_mode == 'gevent':

# deploy with gevent

from gevent import pywsgi

try:

from geventwebsocket.handler import WebSocketHandler

websocket = True

except ImportError:

websocket = False

if websocket:

pywsgi.WSGIServer(('', 5000), app,

handler_class=WebSocketHandler).serve_forever()

else:

pywsgi.WSGIServer(('', 5000), app).serve_forever()

elif sio.async_mode == 'gevent_uwsgi':

print('Start the application through the uwsgi server. Example:')

print('uwsgi --http :5000 --gevent 1000 --http-websockets --master '

'--wsgi-file app.py --callable app')

else:

print('Unknown async_mode: ' + sio.async_mode)