From 9817d011f0b9dc01a768614bf7cf05760d0c8797 Mon Sep 17 00:00:00 2001
From: jbruce12000 <jbruce12000@gmail.com>
Date: Fri, 21 Dec 2018 14:01:02 -0500
Subject: [PATCH] - adding api support at /api to run a schedule

---
 kiln-controller.py | 41 +++++++++++++++++++++++++++++++++++++++--
 1 file changed, 39 insertions(+), 2 deletions(-)

diff --git a/kiln-controller.py b/kiln-controller.py
index 765bdb1..874491c 100755
--- a/kiln-controller.py
+++ b/kiln-controller.py
@@ -8,9 +8,11 @@ import json
 import bottle
 import gevent
 import geventwebsocket
+#from bottle import post, get
 from gevent.pywsgi import WSGIServer
 from geventwebsocket.handler import WebSocketHandler
 
+
 try:
     sys.dont_write_bytecode = True
     import config
@@ -35,11 +37,46 @@ app = bottle.Bottle()
 oven = Oven()
 ovenWatcher = OvenWatcher(oven)
 
-
 @app.route('/')
 def index():
     return bottle.redirect('/picoreflow/index.html')
 
+@app.post('/api')
+def handle_api():
+    log.info("/api is alive")
+    log.info(bottle.request.json)
+
+    # run a kiln schedule
+    if bottle.request.json['cmd'] == 'run':
+        wanted = bottle.request.json['profile']
+        log.info('api requested run of profile = %s' % wanted)
+
+        # get the wanted profile/kiln schedule
+        profile = find_profile(wanted)
+        if profile is None:
+            return { "success" : False, "error" : "profile %s not found" % wanted }
+
+        # FIXME juggling of json should happen in the Profile class
+        profile_json = json.dumps(profile)
+        profile = Profile(profile_json)
+        oven.run_profile(profile)
+        ovenWatcher.record(profile)
+    return { "success" : True }
+
+def find_profile(wanted):
+    '''
+    given a wanted profile name, find it and return the parsed
+    json profile object or None.
+    '''
+    #load all profiles from disk
+    profiles = get_profiles()
+    json_profiles = json.loads(profiles)
+
+    # find the wanted profile
+    for profile in json_profiles:
+        if profile['name'] == wanted:
+            return profile
+    return None
 
 @app.route('/picoreflow/:filename#.*#')
 def send_static(filename):
@@ -108,7 +145,7 @@ def handle_storage():
                 msgdict = {}
 
             if message == "GET":
-                log.info("GET command recived")
+                log.info("GET command received")
                 wsock.send(get_profiles())
             elif msgdict.get("cmd") == "DELETE":
                 log.info("DELETE command received")