Built out the REST API example a bit futher.

examples/rest.py

@@ -1,44 +1,105 @@
 """
 Example of using pycirculate with a simple Flask RESTful API.
+
+Make sure to send requests with the HTTP header "Content-Type: application/json".
 """
-from flask import Flask, request
+from flask import Flask, request, jsonify, abort, make_response
 from pycirculate.anova import AnovaController
-import json
+import logging
+import sys
+
 app = Flask(__name__)
 
 ANOVA_MAC_ADDRESS = "78:A5:04:38:B3:FA"
 
+
+# Error handlers
+
+@app.errorhandler(400)
+def bad_request(error):
+    return make_response(jsonify({'error': 'Bad request.'}), 400)
+
+@app.errorhandler(404)
+def not_found(error):
+    return make_response(jsonify({'error': 'Not found.'}), 404)
+
+@app.errorhandler(500)
+def server_error(error):
+    return make_response(jsonify({'error': 'Server error.'}), 500)
+
+def make_error(status_code, message, sub_code=None, action=None, **kwargs):
+    """
+    Error with custom message.
+    """
+    data = {
+        'status': status_code,
+        'message': message,
+    }
+    if action:
+        data['action'] = action
+    if sub_code:
+        data['sub_code'] = sub_code
+    data.update(kwargs)
+    response = jsonify(data)
+    response.status_code = status_code
+    return response
+
+# REST endpoints
+
 @app.route('/', methods=["GET"])
 def index():
-    with AnovaController(ANOVA_MAC_ADDRESS) as ctrl:
-        output = {"anova_status": ctrl.anova_status()}
+    try:
+        with AnovaController(ANOVA_MAC_ADDRESS) as ctrl:
+            output = {"anova_status": ctrl.anova_status()}
+    except Exception as exc:
+        app.logger.error(exc)
+        return make_error(500, "{0}: {1}".format(repr(exc), str(exc)))
 
-    return json.dumps(output)
+    return jsonify(output)
 
 @app.route('/temp', methods=["GET"])
 def get_temp():
-    with AnovaController(ANOVA_MAC_ADDRESS) as ctrl:
-        output = {"current_temp": ctrl.read_temp()}
+    try:
+        with AnovaController(ANOVA_MAC_ADDRESS) as ctrl:
+            output = {"current_temp": ctrl.read_temp(), "set_temp": ctrl.read_set_temp(), "unit": ctrl.read_unit(),}
+    except Exception as exc:
+        app.logger.error(exc)
+        return make_error(500, "{0}: {1}".format(repr(exc), str(exc)))
 
-    return json.dumps(output)
+    return jsonify(output)
 
 @app.route('/temp', methods=["POST"])
 def set_temp():
-    # using standard form posts right now, might want to switch to json
-    temp = request.form['temp']
-    print temp
+    try:
+        temp = request.get_json()['temp']
+    except (KeyError, TypeError):
+        abort(400)
     temp = float(temp)
     with AnovaController(ANOVA_MAC_ADDRESS) as ctrl:
-        output = {"current_temp": ctrl.set_temp(temp)}
+        output = {"set_temp": ctrl.set_temp(temp)}
 
-    return json.dumps(output)
+    return jsonify(output)
 
 @app.route('/stop', methods=["POST"])
 def stop_anova():
     with AnovaController(ANOVA_MAC_ADDRESS) as ctrl:
         output = {"status": ctrl.stop_anova()}
 
-    return json.dumps(output)
+    return jsonify(output)
+
+@app.route('/start', methods=["POST"])
+def start_anova():
+    with AnovaController(ANOVA_MAC_ADDRESS) as ctrl:
+        output = {"status": ctrl.start_anova()}
+
+    return jsonify(output)
 
 if __name__ == '__main__':
+    # Setup logging
+    handler = logging.StreamHandler(sys.stdout)
+    handler.setLevel(logging.INFO)
+    formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
+    handler.setFormatter(formatter)
+    app.logger.addHandler(handler)
+
     app.run(host='0.0.0.0')

requirements.txt

@@ -1 +1,2 @@
 bluepy==1.0.3
+flask==0.10.1