refactoring to rest app to help breakup api code into smaller files
This commit is contained in:
parent
2593d97cab
commit
1d73f28248
12 changed files with 886 additions and 796 deletions
42
webapp/websocket_routes.py
Normal file
42
webapp/websocket_routes.py
Normal file
|
@ -0,0 +1,42 @@
|
|||
from flask.ext.socketio import SocketIO, emit
|
||||
|
||||
from core import logger
|
||||
|
||||
socketio = None
|
||||
|
||||
|
||||
def register(app):
|
||||
global socketio
|
||||
socketio = SocketIO(app)
|
||||
|
||||
@socketio.on("connect")
|
||||
def websocket_connect():
|
||||
logger.info("websocket client connected")
|
||||
|
||||
@socketio.on("disconnect")
|
||||
def websocket_disconnect():
|
||||
logger.info("websocket client disconnected")
|
||||
|
||||
|
||||
def broadcast_event(event):
|
||||
socketio.emit("event", {
|
||||
"node": event.node,
|
||||
"event_type": event.event_type,
|
||||
"name": event.name,
|
||||
"data": event.data,
|
||||
"time": event.time,
|
||||
"session": event.session
|
||||
})
|
||||
|
||||
|
||||
def broadcast_node(node):
|
||||
socketio.emit("node", {
|
||||
"id": node.id,
|
||||
"name": node.name,
|
||||
"model": node.model,
|
||||
"position": {
|
||||
"x": node.x_position,
|
||||
"y": node.y_position,
|
||||
},
|
||||
"services": node.services.split("|"),
|
||||
})
|
Loading…
Add table
Add a link
Reference in a new issue