diff --git a/turbo/api.py b/turbo/api.py
new file mode 100644
index 0000000..0afe0ed
--- /dev/null
+++ b/turbo/api.py
@@ -0,0 +1,133 @@
+#This is an example that uses the websockets api to know when a prompt execution is done
+#Once the prompt execution is done it downloads the images using the /history endpoint
+import os
+import websocket #NOTE: websocket-client (https://github.com/websocket-client/websocket-client)
+import uuid
+import json
+import urllib.request
+import urllib.parse
+from flask import Flask, request, jsonify, render_template, session, abort
+from flask_socketio import SocketIO, join_room, leave_room,send, emit
+import secrets
+
+from PIL import Image
+import io
+import base64
+
+server_address = "127.0.0.1:8188"
+client_id = str(uuid.uuid4())
+
+def queue_prompt(prompt):
+ p = {"prompt": prompt, "client_id": client_id}
+ data = json.dumps(p).encode('utf-8')
+ req = urllib.request.Request("http://{}/prompt".format(server_address), data=data)
+ return json.loads(urllib.request.urlopen(req).read())
+
+def get_image(filename, subfolder, folder_type):
+ data = {"filename": filename, "subfolder": subfolder, "type": folder_type}
+ url_values = urllib.parse.urlencode(data)
+ with urllib.request.urlopen("http://{}/view?{}".format(server_address, url_values)) as response:
+ return response.read()
+
+def get_history(prompt_id):
+ with urllib.request.urlopen("http://{}/history/{}".format(server_address, prompt_id)) as response:
+ return json.loads(response.read())
+
+def get_images(ws, prompt):
+ prompt_id = queue_prompt(prompt)['prompt_id']
+ output_images = {}
+ while True:
+ out = ws.recv()
+ if isinstance(out, str):
+ message = json.loads(out)
+ if message['type'] == 'executing':
+ data = message['data']
+ if data['node'] is None and data['prompt_id'] == prompt_id:
+ break #Execution is done
+ else:
+ continue #previews are binary data
+
+ history = get_history(prompt_id)[prompt_id]
+ for o in history['outputs']:
+ for node_id in history['outputs']:
+ node_output = history['outputs'][node_id]
+ if 'images' in node_output:
+ images_output = []
+ for image in node_output['images']:
+ image_data = get_image(image['filename'], image['subfolder'], image['type'])
+ images_output.append(image_data)
+ output_images[node_id] = images_output
+
+ return output_images
+
+prompt={}
+with open('./workflow_api_motionctrl_turbo.json') as fr:
+ prompt = json.load(fr)
+
+ws = websocket.WebSocket()
+ws.connect("ws://{}/ws?clientId={}".format(server_address, client_id))
+
+#Commented out code to display the output images:
+
+# for node_id in images:
+# for image_data in images[node_id]:
+# from PIL import Image
+# import io
+# image = Image.open(io.BytesIO(image_data))
+# image.show()
+
+app = Flask(__name__, template_folder=os.path.abspath('.'), static_folder='assets')
+app.secret_key = secrets.token_hex(16)
+
+socketio = SocketIO(app, cors_allowed_origins='*')
+connected_sids = set() # 存放已连接的客户端
+
+#后端程序
+lockroom='None'
+@socketio.on('connect')
+def on_connect():
+ connected_sids.add(request.sid)
+ print(f'{request.sid} 已连接')
+ socketio.start_background_task(background_thread_heartbeat)
+
+@socketio.on('disconnect')
+def on_disconnect():
+ connected_sids.remove(request.sid)
+ print(f'{request.sid} 已断开')
+
+@socketio.on('message')
+def handle_message(message):
+ """收消息"""
+ print(f'message:{request.sid} {message}')
+ json.loads(message)
+
+@socketio.on('camera_poses')
+def handle_message(camera_poses):
+ print(f'camera_poses:{request.sid} {camera_poses}')
+ prompt["60"]["inputs"]["camera"] = camera_poses["camera_poses"]
+ images = get_images(ws, prompt)
+ for node_id in images:
+ for image_data in images[node_id]:
+ b64img=base64.b64encode(image_data).decode('utf-8')
+ socketio.emit('server_response',{'b64img':b64img}, to=camera_poses["roomid"])
+
+@socketio.on('server_reconnect')
+def server_reconnect(message):
+ print(f'server_reconnect:{request.sid} {message}')
+ join_room(message['roomid'])
+
+def background_thread_heartbeat():
+ global lockroom
+ while True:
+ socketio.emit('server_response',{'lockroom':lockroom})
+ socketio.sleep(5)
+
+
+@app.route('/')
+def index():
+ session['user'] = None
+ return render_template('index.html')
+
+if __name__ == '__main__':
+ socketio.run(app, host='0.0.0.0', port=5017, debug=True)
+ #app.run(host='0.0.0.0', port=5017)
\ No newline at end of file
diff --git a/turbo/dist/index.html b/turbo/dist/index.html
new file mode 100644
index 0000000..1867f75
--- /dev/null
+++ b/turbo/dist/index.html
@@ -0,0 +1,22 @@
+
+
+
+
+
+ CAMERA MOTION DESIGNER
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+