b4af85f405
Major refactoring of octoprint.server.util (divided into smaller submodules), extended Tornado to allow for request-specific max content lengths, introduced settings parameters to configure maximum upload size, maximum request body size and file suffixes See #455
61 lines
No EOL
1.9 KiB
Python
61 lines
No EOL
1.9 KiB
Python
# coding=utf-8
|
|
from __future__ import absolute_import
|
|
|
|
__author__ = "Gina Häußge <osd@foosel.net>"
|
|
__license__ = 'GNU Affero General Public License http://www.gnu.org/licenses/agpl.html'
|
|
__copyright__ = "Copyright (C) 2014 The OctoPrint Project - Released under terms of the AGPLv3 License"
|
|
|
|
from flask import request, make_response, jsonify
|
|
|
|
from octoprint.server import printer, NO_CONTENT
|
|
from octoprint.server.util.flask import restricted_access
|
|
from octoprint.server.api import api
|
|
import octoprint.util as util
|
|
|
|
|
|
@api.route("/job", methods=["POST"])
|
|
@restricted_access
|
|
def controlJob():
|
|
if not printer.isOperational():
|
|
return make_response("Printer is not operational", 409)
|
|
|
|
valid_commands = {
|
|
"start": [],
|
|
"restart": [],
|
|
"pause": [],
|
|
"cancel": []
|
|
}
|
|
|
|
command, data, response = util.getJsonCommandFromRequest(request, valid_commands)
|
|
if response is not None:
|
|
return response
|
|
|
|
activePrintjob = printer.isPrinting() or printer.isPaused()
|
|
|
|
if command == "start":
|
|
if activePrintjob:
|
|
return make_response("Printer already has an active print job, did you mean 'restart'?", 409)
|
|
printer.startPrint()
|
|
elif command == "restart":
|
|
if not printer.isPaused():
|
|
return make_response("Printer does not have an active print job or is not paused", 409)
|
|
printer.startPrint()
|
|
elif command == "pause":
|
|
if not activePrintjob:
|
|
return make_response("Printer is neither printing nor paused, 'pause' command cannot be performed", 409)
|
|
printer.togglePausePrint()
|
|
elif command == "cancel":
|
|
if not activePrintjob:
|
|
return make_response("Printer is neither printing nor paused, 'cancel' command cannot be performed", 409)
|
|
printer.cancelPrint()
|
|
return NO_CONTENT
|
|
|
|
|
|
@api.route("/job", methods=["GET"])
|
|
def jobState():
|
|
currentData = printer.getCurrentData()
|
|
return jsonify({
|
|
"job": currentData["job"],
|
|
"progress": currentData["progress"],
|
|
"state": currentData["state"]["text"]
|
|
}) |