Last active
March 4, 2016 21:28
-
-
Save BlackstoneEngineering/a051655f8325a41bd161 to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| from flask_socketio import SocketIO, emit,send,join_room, leave_room # socket-io library | |
| from flask import Flask # web.py framework for hosting webpages | |
| import mbed_connector_api # mbed Device Connector library | |
| import pybars # use to fill in handlebar templates | |
| from base64 import standard_b64decode as b64decode | |
| app = Flask(__name__) | |
| app.config['SECRET_KEY'] = 'secret!' | |
| socketio = SocketIO(app) | |
| token = "ChangeMe" # replace with your API token | |
| connector = mbed_connector_api.connector(token) | |
| @app.route('/') | |
| def index(): | |
| # get list of endpoints, for each endpoint get the pattern (/3201/0/5853) value | |
| epList = connector.getEndpoints().result | |
| for index in range(len(epList)): | |
| print "Endpoint Found: ",epList[index]['name'] | |
| e = connector.getResourceValue(epList[index]['name'],"/3201/0/5853") | |
| while not e.isDone(): | |
| None | |
| epList[index]['blinkPattern'] = e.result | |
| print "Endpoint List :",epList | |
| # fill out html using handlebar template | |
| handlebarJSON = {'endpoints':epList} | |
| comp = pybars.Compiler() | |
| source = unicode(open("./views/index.hbs",'r').read()) | |
| template = comp.compile(source) | |
| return "".join(template(handlebarJSON)) | |
| @socketio.on('connect') | |
| def connect(): | |
| print('connect ') | |
| join_room('room') | |
| @socketio.on('disconnect') | |
| def disconnect(): | |
| print('Disconnect') | |
| leave_room('room') | |
| @socketio.on('subscribe_to_presses') | |
| def subscribeToPresses(data): | |
| # Subscribe to all changes of resource /3200/0/5501 (button presses) | |
| print('subscribe_to_presses: ',data) | |
| e = connector.putResourceSubscription(data['endpointName'],'/3200/0/5501') | |
| while not e.isDone(): | |
| None | |
| if e.error: | |
| print("Error: ",e.error.errType, e.error.error, e.raw_data) | |
| else: | |
| print("Subscribed Successfully!") | |
| emit('subscribed-to-presses') | |
| @socketio.on('unsubscribe_to_presses') | |
| def unsubscribeToPresses(data): | |
| print('unsubscribe_to_presses: ',data) | |
| e = connector.deleteResourceSubscription(data['endpointName'],'/3200/0/5501') | |
| while not e.isDone(): | |
| None | |
| if e.error: | |
| print("Error: ",e.error.errType, e.error.error, e.raw_data) | |
| else: | |
| print("Unsubscribed Successfully!") | |
| emit('unsubscribed-to-presses',{"endpointName":data['endpointName'],"value":'True'}) | |
| @socketio.on('get_presses') | |
| def getPresses(data): | |
| # Read data from GET resource /3200/0/5501 (num button presses) | |
| print("get_presses ",data) | |
| e = connector.getResourceValue(data['endpointName'],'/3200/0/5501') | |
| while not e.isDone(): | |
| None | |
| if e.error: | |
| print("Error: ",e.error.errType, e.error.error, e.raw_data) | |
| else: | |
| data_to_emit = {"endpointName":data['endpointName'],"value":e.result} | |
| print data_to_emit | |
| emit('presses', data_to_emit) | |
| @socketio.on('update_blink_pattern') | |
| def updateBlinkPattern(data): | |
| # Set data on PUT resource /3201/0/5853 (pattern of LED blink) | |
| print('update_blink_pattern ',data) | |
| e = connector.putResourceValue(data['endpointName'],'/3201/0/5853',data['blinkPattern']) | |
| while not e.isDone(): | |
| None | |
| if e.error: | |
| print("Error: ",e.error.errType, e.error.error, e.raw_data) | |
| @socketio.on('blink') | |
| def blink(data): | |
| # Trigger POST resource /3201/0/5850 (start blinking LED) | |
| print('blink: ',data) | |
| e = connector.postResource(data['endpointName'],'/3201/0/5850') | |
| while not e.isDone(): | |
| None | |
| if e.error: | |
| print("Error: ",e.error.errType, e.error.error, e.raw_data) | |
| # 'notifications' are routed here, handle subscriptions and update webpage | |
| def notificationHandler(data): | |
| global socketio | |
| print "\r\nNotification Data Received : %s" %data['notifications'] | |
| notifications = data['notifications'] | |
| for thing in notifications: | |
| stuff = {"endpointName":thing["ep"],"value":b64decode(thing["payload"])} | |
| print stuff | |
| socketio.emit('presses',stuff,room='room') | |
| if __name__ == "__main__": | |
| connector.deleteAllSubscriptions() | |
| connector.startLongPolling() # start long polling connector.mbed.com | |
| connector.setHandler('notifications', notificationHandler) # send 'notifications' to the notificationHandler FN | |
| socketio.run(app,host='0.0.0.0', port=8080) |
Author
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Found the issue:
socketio = SocketIO(app,async_mode='threading')