From 2a11239c1e425a994126354a37f4a0e36929eaa3 Mon Sep 17 00:00:00 2001 From: n07070 Date: Tue, 19 May 2026 10:52:23 +0200 Subject: [PATCH 01/21] Add new dependencies for brother ql printers --- poetry.lock | 34 ++++++++++++++++++++++++++++++++-- pyproject.toml | 1 + 2 files changed, 33 insertions(+), 2 deletions(-) diff --git a/poetry.lock b/poetry.lock index 8a06036..e0ad45a 100644 --- a/poetry.lock +++ b/poetry.lock @@ -75,6 +75,25 @@ files = [ {file = "blinker-1.9.0.tar.gz", hash = "sha256:b4ce2265a7abece45e7cc896e98dbebe6cead56bcf805a3d23136d145f5445bf"}, ] +[[package]] +name = "brother-ql-inventree" +version = "1.3" +description = "Python package to talk to Brother QL label printers" +optional = false +python-versions = "*" +groups = ["main"] +files = [ + {file = "brother_ql_inventree-1.3-py3-none-any.whl", hash = "sha256:0f7e0d78bae04f44bcfe1010ed0d99f98d5b4db1d6179da242d5bd52bb0c9ea4"}, + {file = "brother_ql_inventree-1.3.tar.gz", hash = "sha256:24335ca5f4b3444c692698b599459a7e6c4bd036dd580074c63d39382914fca3"}, +] + +[package.dependencies] +attrs = "*" +click = "*" +packbits = "*" +pillow = ">=10.0.0" +pyusb = "*" + [[package]] name = "certifi" version = "2026.4.22" @@ -974,6 +993,17 @@ files = [ {file = "packaging-26.2.tar.gz", hash = "sha256:ff452ff5a3e828ce110190feff1178bb1f2ea2281fa2075aadb987c2fb221661"}, ] +[[package]] +name = "packbits" +version = "0.6" +description = "PackBits encoder/decoder" +optional = false +python-versions = "*" +groups = ["main"] +files = [ + {file = "packbits-0.6.tar.gz", hash = "sha256:bc6b370bb34e04ac8cfa835e06c0484380affc6d593adb8009dd6c0f7bfff034"}, +] + [[package]] name = "pep8" version = "1.7.1" @@ -1852,5 +1882,5 @@ h11 = ">=0.16.0,<1" [metadata] lock-version = "2.1" -python-versions = ">=3.13" -content-hash = "3a8909800e4977eaaac71770d29b53b450a233fe7ddde5e8bb158c151428ed7e" +python-versions = ">=3.14" +content-hash = "18e1a5c8b085aa639b665279856f9e3c51a734a6a8d1d4dd135ca7e4f67e86ae" diff --git a/pyproject.toml b/pyproject.toml index 04fd0ae..cb9a044 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -42,6 +42,7 @@ dependencies = [ "python-escpos (>=3.1,<4.0)", "pep8 (>=1.7.1,<2.0.0)", "pylint (>=4.0.5,<5.0.0)", + "brother-ql-inventree (>=1.3,<2.0)", ] [tool.poetry] From ee27c62d0fc208f490787fb1d5700dd0e2a6b514 Mon Sep 17 00:00:00 2001 From: n07070 Date: Tue, 19 May 2026 10:52:36 +0200 Subject: [PATCH 02/21] Add new functions for discovery and parsing of printers, WIP --- src/printer.py | 91 ++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 91 insertions(+) diff --git a/src/printer.py b/src/printer.py index 127c1ae..dd50584 100644 --- a/src/printer.py +++ b/src/printer.py @@ -1,5 +1,6 @@ # Importing the module to manage the connection to the printer. import escpos.printer as escp +import brother-ql-inventree from time import sleep, gmtime, strftime import os.path from PIL import Image, ImageEnhance, ImageOps @@ -286,3 +287,93 @@ def process_image(self, path): original_img.save(jpeg_path, format="JPEG", quality=95, optimize=True) return jpeg_path + +def discover_printers(): + """ + We try to find all the connected printers ( 0 or n ) to this system. + + For every type of supported printer, we try to autodiscover them. + + http://www.linux-usb.org/usb.ids A list of USB vendor IDs + + 04b8 Seiko Epson Corp. + 04f9 Brother Industries, Ltd + """ + +def find_and_parse_borther_ql_printer(): + + + ## We might be able to no use this because there is a `discover` command in https://github.com/pklaus/brother_ql#usage + + ## Code stolen from https://framagit.org/stickoeur/diagnostickoeur/-/blob/no-masters/printit.py?ref_type=heads + + """Find and parse Brother QL printer information.""" + + model_manager = ModelsManager() + + # Debug print to show we're searching + # print("Searching for Brother QL printer...") + + for backend_name in ["pyusb", "linux_kernel"]: + try: + #print(f"Trying backend: {backend_name}") + backend = backend_factory(backend_name) + available_devices = backend["list_available_devices"]() + #print(f"Found {len(available_devices)} devices with {backend_name} backend") + + for printer in available_devices: + #print(f"Found device: {printer}") + identifier = printer["identifier"] + parts = identifier.split("/") + + if len(parts) < 4: + #print(f"Skipping device with invalid identifier format: {identifier}") + continue + + protocol = parts[0] + device_info = parts[2] + serial_number = parts[3] + + try: + vendor_id, product_id = device_info.split(":") + except ValueError: + #print(f"Invalid device info format: {device_info}") + continue + + # Default model + model = "QL-570" + + # Try to match product ID to determine actual model + try: + product_id_int = int(product_id, 16) + for m in model_manager.iter_elements(): + if m.product_id == product_id_int: + model = m.identifier + break + #print(f"Matched printer model: {model}") + except ValueError: + #print(f"Invalid product ID format: {product_id}") + continue + + printer_info = { + "identifier": identifier, + "backend": backend_name, + "model": model, + "protocol": protocol, + "vendor_id": vendor_id, + "product_id": product_id, + "serial_number": serial_number, + } + #print(f"Found printer: {printer_info}") + return printer_info + + except Exception as e: + #print(f"Error with backend {backend_name}: {str(e)}") + continue + + print("No Brother QL printer found") + return None + + +def fint_and_parse_epson_printer(): + pass \ No newline at end of file From a06086521a41ccd362c3d4bcca2150cbf992b0e7 Mon Sep 17 00:00:00 2001 From: n07070 Date: Wed, 20 May 2026 13:29:23 +0200 Subject: [PATCH 03/21] Add new web route, restructure API route --- src/main.py | 104 +++++++++++++++++++++++++++++++++++++++++++++++----- 1 file changed, 95 insertions(+), 9 deletions(-) diff --git a/src/main.py b/src/main.py index d7695e4..7578262 100644 --- a/src/main.py +++ b/src/main.py @@ -98,6 +98,9 @@ app.config["TEMPLATES_AUTO_RELOAD"] = True # Printer connection # Uses the class defined in the printer.py file printer = Printer(app, 0x04B8, 0x0E28) +# printers = Printer(app) +# printers.discover_printers() +# printers.init() printer.init_printer() # Find out if we are running on a Raspberry Pi @@ -141,6 +144,86 @@ def webcam(): app.logger.debug("Loading webcam interface") return render_template("webcam.html") +@app.route("/web/print/sms", methods=["POST"]) +@limiter.limit("6/minute", override_defaults=False) +def web_print_sms(): + """Prints a short message on a printer""" + app.logger.debug("Printing an sms via web method") + + try: + txt = request.form["txt"] + except werkzeug.exceptions.BadRequestKeyError as e: + app.logger.error("Whoops, we are missing the txt input field. : %s ", str(e)) + flash("Whoops, no forms submitted or missing signature : %s", str(e)) + return redirect(url_for("index")) + + try: + # comment: We try to get a signature + sign = request.form["signature"] + except werkzeug.exceptions.BadRequestKeyError as e: + app.logger.warning( + "No signature found for this print, using default signature.", str(e) + ) + sign = configuration_file["defaults"]["signature"] + + try: + web.print_sms(txt, sign) + except Exception as e: + app.logger.error("Whoops, we could not print an SMS because : %s ", str(e)) + flash("Whoops, we could not print an SMS because : %s ", str(e)) + return redirect(url_for("index")) + + # end try + flash("The SMS has been printed !") + return redirect(url_for("index")) + + +@app.route("/web/print/img") +@limiter.limit("1/second", override_defaults=False) +def web_print_img(): + """Prints an image on a printer""" + app.logger.debug("Printing an image with web method") + + try: + # comment: We try to get a signature + sign = request.form["signature"] + except werkzeug.exceptions.BadRequestKeyError as e: + app.logger.warning( + "No signature found for this print, using default signature.", str(e) + ) + sign = configuration_file["defaults"]["signature"] + + if request.method == "POST": + # check if the post request has the file part + if "img" not in request.files: + app.logger.error("Whoops, no images submitted : %s ", str(e)) + app.logger.error("Error getting the files : %s", str(e)) + flash("Whoops, no images submitted : %s", str(e)) + return redirect(url_for("index")) + + file = request.files["img"] + # If the user does not select a file, the browser submits an + # empty file without a filename. + if file.filename == "": + app.logger.error("Submitted file has no filename !") + flash("Submitted file has no filename !") + return redirect(url_for("index")) + + try: + app.logger.debug("Sending the image to the printer.") + web.print_image(file, sign) + except Exception as e: + app.logger.error("The image could not be printed because : %s ", str(e)) + flash("The image could not be printed because : %s ", str(e)) + return redirect(url_for("index")) + + else: + app.logger.error("Method not allowed, please POST") + flash("Method not allowed, please POST") + return redirect(url_for("index")) + + flash("Picture printed !") + return redirect(url_for("index")) # API routes # The api has the following methods @@ -168,9 +251,7 @@ def api_print_sms(): txt = request.form["txt"] except werkzeug.exceptions.BadRequestKeyError as e: app.logger.error("Whoops, we are missing the txt input field. : %s ", str(e)) - flash("Whoops, no forms submitted or missing signature : %s", str(e)) - return redirect(url_for("index")) - + return str(e), 400 try: # comment: We try to get a signature sign = request.form["signature"] @@ -179,10 +260,13 @@ def api_print_sms(): "No signature found for this print, using default signature.", str(e) ) sign = configuration_file["defaults"]["signature"] - - web.print_sms(txt, sign) - return redirect(url_for("index")) - + try: + # comment: We try to print the SMS + web.print_sms(txt, sign) + except Exception as e: + return str(e), 500 + # end try + return "OK", 200 @app.route("/api/print/img", methods=["POST"]) @limiter.limit("6/minute", override_defaults=False) @@ -244,12 +328,14 @@ def camera_picture(): return jsonify({"message": "No camera present"}), 500 +## Authentification + @app.route("/login") @limiter.limit("1/second", override_defaults=False) def login_page(): """Unsued, logins""" # web.login(username,password) - return redirect(url_for("index")) + return redirect(url_for("index")), 501 @app.route("/logout") @@ -257,7 +343,7 @@ def login_page(): def logout_page(): """Unused, logout""" # web.logout(username, password) - return redirect(url_for("index")) + return redirect(url_for("index")), 501 @app.errorhandler(429) From 3f915a1b25ed445bc6a6b165a375327612ae99f6 Mon Sep 17 00:00:00 2001 From: n07070 Date: Wed, 20 May 2026 16:34:01 +0200 Subject: [PATCH 04/21] Fix error flashing and transmission --- src/main.py | 115 +++++++++++++++++++++---------------------------- src/printer.py | 29 +++++++++---- src/web.py | 66 ++++++++++++++++------------ 3 files changed, 107 insertions(+), 103 deletions(-) diff --git a/src/main.py b/src/main.py index 7578262..a161b0c 100644 --- a/src/main.py +++ b/src/main.py @@ -85,7 +85,7 @@ except PermissionError: exit(77) # Output the config file -if os.getenv("LIPY_DEBUG") is True: +if os.getenv("FLASK_DEBUG"): pprint.pprint(configuration_file) # We define the app module used by Flask @@ -154,7 +154,7 @@ def web_print_sms(): txt = request.form["txt"] except werkzeug.exceptions.BadRequestKeyError as e: app.logger.error("Whoops, we are missing the txt input field. : %s ", str(e)) - flash("Whoops, no forms submitted or missing signature : %s", str(e)) + flash("Whoops, no forms submitted or missing signature : " + str(e), 'error') return redirect(url_for("index")) try: @@ -170,15 +170,15 @@ def web_print_sms(): web.print_sms(txt, sign) except Exception as e: app.logger.error("Whoops, we could not print an SMS because : %s ", str(e)) - flash("Whoops, we could not print an SMS because : %s ", str(e)) + flash("Whoops, we could not print an SMS because :" + str(e), 'error') return redirect(url_for("index")) # end try - flash("The SMS has been printed !") + flash("The SMS has been printed !", 'info') return redirect(url_for("index")) -@app.route("/web/print/img") +@app.route("/web/print/img", methods=["POST"]) @limiter.limit("1/second", override_defaults=False) def web_print_img(): """Prints an image on a printer""" @@ -193,36 +193,30 @@ def web_print_img(): ) sign = configuration_file["defaults"]["signature"] - if request.method == "POST": - # check if the post request has the file part - if "img" not in request.files: - app.logger.error("Whoops, no images submitted : %s ", str(e)) - app.logger.error("Error getting the files : %s", str(e)) - flash("Whoops, no images submitted : %s", str(e)) - return redirect(url_for("index")) - - file = request.files["img"] - # If the user does not select a file, the browser submits an - # empty file without a filename. - if file.filename == "": - app.logger.error("Submitted file has no filename !") - flash("Submitted file has no filename !") - return redirect(url_for("index")) - - try: - app.logger.debug("Sending the image to the printer.") - web.print_image(file, sign) - except Exception as e: - app.logger.error("The image could not be printed because : %s ", str(e)) - flash("The image could not be printed because : %s ", str(e)) - return redirect(url_for("index")) - - else: - app.logger.error("Method not allowed, please POST") - flash("Method not allowed, please POST") + # check if the post request has the file part + if "img" not in request.files: + app.logger.error("Whoops, no images submitted : %s ", str(e)) + app.logger.error("Error getting the files : %s", str(e)) + flash("Whoops, no images submitted : " + str(e), 'error') return redirect(url_for("index")) - flash("Picture printed !") + file = request.files["img"] + # If the user does not select a file, the browser submits an + # empty file without a filename. + if file.filename == "": + app.logger.error("Submitted file has no filename !") + flash("Submitted file has no filename !", 'error') + return redirect(url_for("index")) + + try: + app.logger.debug("Sending the image to the printer.") + web.print_image(file, sign) + except Exception as e: + app.logger.error("The image could not be printed because : %s ", str(e)) + flash("The image could not be printed because : " + str(e), 'error') + return redirect(url_for("index")) + + flash("Picture printed !", 'info') return redirect(url_for("index")) # API routes @@ -246,7 +240,7 @@ def api_index(): @limiter.limit("6/minute", override_defaults=False) def api_print_sms(): """Prints a short message on a printer""" - app.logger.debug("Printing an sms") + app.logger.debug("Printing an sms via API") try: txt = request.form["txt"] except werkzeug.exceptions.BadRequestKeyError as e: @@ -257,7 +251,7 @@ def api_print_sms(): sign = request.form["signature"] except werkzeug.exceptions.BadRequestKeyError as e: app.logger.warning( - "No signature found for this print, using default signature.", str(e) + "No signature found for this print, using default signature. : %s", str(e) ) sign = configuration_file["defaults"]["signature"] try: @@ -272,51 +266,38 @@ def api_print_sms(): @limiter.limit("6/minute", override_defaults=False) def api_print_image(): """Prints an image on a printer""" - app.logger.debug("Printing an image") + app.logger.debug("Printing an image via API") try: # comment: We try to get a signature sign = request.form["signature"] except werkzeug.exceptions.BadRequestKeyError as e: app.logger.warning( - "No signature found for this print, using default signature.", str(e) + "No signature found for this print, using default signature. %s", str(e) ) sign = configuration_file["defaults"]["signature"] - if request.method == "POST": - # check if the post request has the file part - if "img" not in request.files: - app.logger.error("Whoops, no images submitted : %s ", str(e)) - app.logger.error("Error getting the files : %s", str(e)) - flash("Whoops, no images submitted : %s", str(e)) - return redirect(url_for("index")) + # check if the post request has the file part + if "img" not in request.files: + app.logger.error("Whoops, no images submitted.") + return "No image submitted", 400 - file = request.files["img"] - # If the user does not select a file, the browser submits an - # empty file without a filename. - if file.filename == "": - app.logger.error("Submitted file has no filename !") - flash("Submitted file has no filename !") - return redirect(url_for("index")) + file = request.files["img"] + # If the user does not select a file, the browser submits an + # empty file without a filename. + if file.filename == "": + app.logger.error("Submitted file has no filename !") + return "Submitted file has no filename !", 400 - try: - app.logger.debug("Sending the image to the printer.") - web.print_image(file, sign) - except Exception as e: - app.logger.error("The image could not be printed because : %s ", str(e)) - flash("The image could not be printed because : %s ", str(e)) - return redirect(url_for("index")) + try: + app.logger.debug("Sending the image to the printer.") + web.print_image(file, sign) + except Exception as e: + return str(e), 500 - else: - app.logger.error("Method not allowed") - flash("Method not allowed") - return redirect(url_for("index")) + return "OK", 200 - flash("Picture printed ! ") - return redirect(url_for("index")) - - -@app.route("/api/camera/picture") +@app.route("/api/camera/picture", methods=["GET"]) def camera_picture(): """Returns a picture taken by the camera""" if RASPBERRY_PI_CONNECTED: diff --git a/src/printer.py b/src/printer.py index dd50584..c94c275 100644 --- a/src/printer.py +++ b/src/printer.py @@ -1,6 +1,6 @@ # Importing the module to manage the connection to the printer. -import escpos.printer as escp -import brother-ql-inventree +import escpos.printer +import brother_ql from time import sleep, gmtime, strftime import os.path from PIL import Image, ImageEnhance, ImageOps @@ -47,7 +47,7 @@ class Printer(object): case 0: self.app.logger.error("Printer has no more paper, aborting...") self.printer.close() - raise Exception("No more paper in the printer") + raise RuntimeError("No more paper in the printer") case 1: self.app.logger.warning( "Printer needs paper to be changed very soon ! " @@ -60,17 +60,21 @@ class Printer(object): def init_printer(self): # Is the printer online ? Is the communication with the printer successfull ? - waiting_elapsed = 30 + if os.getenv("FLASK_DEBUG"): + waiting_elapsed = 1 + else: + waiting_elapsed = 10 + self.app.logger.debug("Waiting for printer to get online...") while not self.ready: try: # This also calls open(), which we need to close() # or else the device will appear as busy. - p = escp.Usb(self.device_id, self.vendor_id, 0, profile="TM-P80") + p = escpos.printer.Usb(self.device_id, self.vendor_id, 0, profile="TM-P80") except Exception as e: self.app.logger.error( - "The USB device is not plugged in, trying again : " + str(e) + "The USB device is not plugged in, trying again %s : %s",waiting_elapsed, str(e) ) pass @@ -79,6 +83,8 @@ class Printer(object): self.ready = True self.app.logger.debug("Printer online !") except Exception as e: + self.app.logger.error("Error while getting the printer online %s : %s",waiting_elapsed, str(e) + ) pass sleep(1) @@ -149,6 +155,7 @@ class Printer(object): self.printer.close() except Exception as e: self.app.logger.error("Unable to print because : " + str(e)) + raise RuntimeError("Unable to print a SMS, the printer couldn't do it.") from e self.app.logger.info("Printed text") return True @@ -194,9 +201,14 @@ class Printer(object): os.remove(path) self.app.logger.debug("Removed image : " + str(path)) except Exception as e: - self.printer.close() self.app.logger.error(str(e)) - return False + raise RuntimeError("Could not print the picture") from e + finally: + try: + self.printer.close() + except Exception as e: + self.app.logger.error(str(e)) + raise RuntimeError("Could not close the printer connexion. ") from e self.app.logger.info("Printed a picture") return True @@ -285,6 +297,7 @@ def process_image(self, path): # Convert to JPEG and save jpeg_path = os.path.splitext(path)[0] + "_processed.jpg" original_img.save(jpeg_path, format="JPEG", quality=95, optimize=True) + app.logger.debug("Processed and saved image.") return jpeg_path diff --git a/src/web.py b/src/web.py index 7c70beb..a40d09b 100644 --- a/src/web.py +++ b/src/web.py @@ -6,51 +6,63 @@ import os class Web(object): - """docstring for web.""" + """Web is the class that gets all of the information from web calls ( API and Web page ) and provides checks before sending stuff to printing""" def __init__(self, app, printer): super(Web).__init__() self.printer = printer self.app = app - def print_sms(self, texte, sign: str): - # TODO: verify the texte before printing it here ? + def print_sms(self, texte, sign: str) -> bool: + """ + Get text and a signature, prints the text and cuts after that. + """ self.app.logger.debug("Printing : " + str(texte) + " from " + str(sign)) try: self.printer.print_sms(texte, sign) self.printer.cut() except Exception as e: self.app.logger.error(e) - flash("Error while printing the SMS : " + str(e)) + raise RuntimeError("Could not print SMS, " + str(e)) from e - flash("You message " + str(texte) + " has been printed :)") + return True - def print_image(self, image, sign): - self.app.logger.debug("Uploading file") + def print_image(self, image, sign: str) -> bool: + """ + Get an image and a signature, prints the image and cuts after that. + """ try: - self.app.logger.debug("Uploading file from " + str(sign)) - if self.upload_file(image): - self.app.logger.debug("File has been uploaded, printing...") - self.printer.print_img( - os.path.join( - self.app.config["UPLOAD_FOLDER"], - secure_filename(image.filename), - ), - sign=sign, - process=True, - ) - self.printer.cut() + self.upload_file(image) except Exception as e: self.app.logger.error(e) - flash("Could not upload file." + str(e)) + raise RuntimeError("Could not upload file") from e - flash("Your image has been printed :)") + self.app.logger.debug("File has been uploaded, printing...") - def login(username: str, password: str) -> bool: - pass - def logout(username: str, password: str) -> bool: - pass + try: + self.printer.print_img( + os.path.join( + self.app.config["UPLOAD_FOLDER"], + secure_filename(image.filename), + ), + sign=sign, + process=True, + ) + self.printer.cut() + except Exception as e: + raise RuntimeError("Could not print file") from e + + self.app.logger.debug("Image printed and cut !") + return True + + def login(self, username: str, password: str) -> bool: + """Not implemented""" + return + + def logout(self, username: str, password: str) -> bool: + """Not implemented""" + return def allowed_file(self, filename) -> bool: self.app.logger.debug("Is the filename allowed ?") @@ -67,10 +79,8 @@ class Web(object): self.app.logger.debug("File valid") try: image.save(os.path.join(self.app.config["UPLOAD_FOLDER"], filename)) - self.app.logger.debug("File saved") except Exception as e: - self.app.logger.error("Could not save file") - flash(str(e), "error") + self.app.logger.error("Could not save file %s", e) return False self.app.logger.debug( From e926ee916332ee6715c5371646e2968b82b1122d Mon Sep 17 00:00:00 2001 From: n07070 Date: Wed, 20 May 2026 16:34:33 +0200 Subject: [PATCH 05/21] Update printing routes for the form --- src/templates/index.html | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/templates/index.html b/src/templates/index.html index 3a3c181..1eeb467 100644 --- a/src/templates/index.html +++ b/src/templates/index.html @@ -5,7 +5,7 @@

Print a short message

-
+

@@ -18,7 +18,7 @@

Print an image

- +

From c5a8019fbebd0409d8a662a81fd9c2d6a50f8b5d Mon Sep 17 00:00:00 2001 From: n07070 Date: Wed, 20 May 2026 16:34:45 +0200 Subject: [PATCH 06/21] Add an alert if the webcam print fails --- src/static/js/webcam.js | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/static/js/webcam.js b/src/static/js/webcam.js index 6464273..db9e8ce 100644 --- a/src/static/js/webcam.js +++ b/src/static/js/webcam.js @@ -255,7 +255,12 @@ function print_picture(data){ // headers:{ // 'Content-Type': 'multipart/form-data' // } - }).then(function(response) { console.log('Success:', response); } , true) + }).then(function(response) { + console.log('Reponse:', response); + if(response.status != 200 ){ + alert("The picture could not be printed be : " + response.statusText) + } + } , true) .catch(error => console.error('Error:', error), false); } From cb3e0d900f33a6228b26d36a4e390d713b9752ec Mon Sep 17 00:00:00 2001 From: n07070 Date: Wed, 20 May 2026 16:34:57 +0200 Subject: [PATCH 07/21] Update numpy --- poetry.lock | 146 ++++++++++++++++++++++++++-------------------------- 1 file changed, 73 insertions(+), 73 deletions(-) diff --git a/poetry.lock b/poetry.lock index e0ad45a..b0092ef 100644 --- a/poetry.lock +++ b/poetry.lock @@ -886,84 +886,84 @@ files = [ [[package]] name = "numpy" -version = "2.4.5" +version = "2.4.6" description = "Fundamental package for array computing in Python" optional = false python-versions = ">=3.11" groups = ["main"] files = [ - {file = "numpy-2.4.5-cp311-cp311-macosx_10_9_x86_64.whl", hash = "sha256:3176dc8ff71dbb593606f91a69ad0c3cd3303c7eb546af477370ab9edf760288"}, - {file = "numpy-2.4.5-cp311-cp311-macosx_11_0_arm64.whl", hash = "sha256:1811150e5148f5a01a7cc282cb2f489b4a3050a773e173adb480e507bad3a3d7"}, - {file = "numpy-2.4.5-cp311-cp311-macosx_14_0_arm64.whl", hash = "sha256:0d63a780070871210853ba01e90b88f9b85cf2abf63a7f143d5127189265ddf6"}, - {file = "numpy-2.4.5-cp311-cp311-macosx_14_0_x86_64.whl", hash = "sha256:0c6919cefafb3b76cd46a89dbb203bf1dd95529d2a6d09fef2d325d95d6a79d8"}, - {file = "numpy-2.4.5-cp311-cp311-manylinux_2_27_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:d51efede1e58e8b11877536a5518f60e318d8ff69b89ad7b38ee5e431b24d772"}, - {file = "numpy-2.4.5-cp311-cp311-manylinux_2_27_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:07ce7e74da92d7c71b5df157b9758bcdd53d7fea10602154de3afd2b3ddc34dd"}, - {file = "numpy-2.4.5-cp311-cp311-musllinux_1_2_aarch64.whl", hash = "sha256:d7828234a13185effb34979e146f9921f2a65dfbbe215e6dbb57d6478fc8e059"}, - {file = "numpy-2.4.5-cp311-cp311-musllinux_1_2_x86_64.whl", hash = "sha256:f96083adc3dfc1bbf778f2c79654d88115fa07074c97cb724fe9508f12d91c55"}, - {file = "numpy-2.4.5-cp311-cp311-win32.whl", hash = "sha256:4ed78c904a638b6e5d7cd4db90c06fca5fc6ec2f28d258305368f454a50e79cf"}, - {file = "numpy-2.4.5-cp311-cp311-win_amd64.whl", hash = "sha256:079b0fad6f2899b23c5da89792b5409d2d83fc83e8bd5c2299cc9c397a264864"}, - {file = "numpy-2.4.5-cp311-cp311-win_arm64.whl", hash = "sha256:d6c78e260b53affe9b395a9d54fc61f101f9521c4d9452c7e9e3718b19e2215b"}, - {file = "numpy-2.4.5-cp312-cp312-macosx_10_13_x86_64.whl", hash = "sha256:654fb8674b61b1c4bd568f944d13a908566fdcb0d797303521d4149d16da05ef"}, - {file = "numpy-2.4.5-cp312-cp312-macosx_11_0_arm64.whl", hash = "sha256:4cd9f6fa7ce10dc4627f2bb81dd9075dab67e94632e04c2b638e12575ddaa862"}, - {file = "numpy-2.4.5-cp312-cp312-macosx_14_0_arm64.whl", hash = "sha256:4f5bc96d35d94e4ceab8b38a92241b4611e95dc44e63b9f1fa2a331858ee3507"}, - {file = "numpy-2.4.5-cp312-cp312-macosx_14_0_x86_64.whl", hash = "sha256:4bb33e900ee81730ad77a258965134aa8ceac805124f7e5229347beda4b8d0aa"}, - {file = "numpy-2.4.5-cp312-cp312-manylinux_2_27_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:32f8f852273ef32b291201ac2a2c97629c4a1ee8632bb670e3443eaa09fc2e72"}, - {file = "numpy-2.4.5-cp312-cp312-manylinux_2_27_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:685681e956fc8dcb75adc6ff26694e1dfd738b24bd8d4696c51ca0110157f912"}, - {file = "numpy-2.4.5-cp312-cp312-musllinux_1_2_aarch64.whl", hash = "sha256:6f64dd84b277a737eb59513f6b9bb6195bf41ab11941ef15b2562dbab43fa8ef"}, - {file = "numpy-2.4.5-cp312-cp312-musllinux_1_2_x86_64.whl", hash = "sha256:b42d9496f79e3a728192f05a42d86e36163217b7cdecb3813d0028a0aa6b72d7"}, - {file = "numpy-2.4.5-cp312-cp312-win32.whl", hash = "sha256:86d980970f5110595ca14855768073b08585fc1acc36895de303e039e7dee4a5"}, - {file = "numpy-2.4.5-cp312-cp312-win_amd64.whl", hash = "sha256:3333dba6a4e611d666f69e177ba8fe4140366ff681a5feb2374d3fd4fff3acb6"}, - {file = "numpy-2.4.5-cp312-cp312-win_arm64.whl", hash = "sha256:4593d197270b894efeb538dcbe227e4bcf1c77f88c4c6bf933ead812cfaa4453"}, - {file = "numpy-2.4.5-cp313-cp313-macosx_10_13_x86_64.whl", hash = "sha256:1ef248460b645c102026b82337cc4e88231909c66dd77b59ec6d6cac7e44f277"}, - {file = "numpy-2.4.5-cp313-cp313-macosx_11_0_arm64.whl", hash = "sha256:4603622bdcdbf8dccb1d9d5b21d16a7aa4e473ae6c8e14048d846fd4ca2907a0"}, - {file = "numpy-2.4.5-cp313-cp313-macosx_14_0_arm64.whl", hash = "sha256:6c18d49c67689c562854b53fdc433b93e47c12952aa6fa6d59f185e1a5992419"}, - {file = "numpy-2.4.5-cp313-cp313-macosx_14_0_x86_64.whl", hash = "sha256:b1c663ddc641f4192e90511bec61a09bc231e3bbdb996cdc6edbcaa0e528d685"}, - {file = "numpy-2.4.5-cp313-cp313-manylinux_2_27_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:93793222b524f692f12b2f8752ce8b1d9d9125b2bfd5dbf0fb69c92c5e1ce86c"}, - {file = "numpy-2.4.5-cp313-cp313-manylinux_2_27_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:1616bde34b2bcba2fa9bde06217ce00da4f3d1bdfb264d54525a99e8fe170d83"}, - {file = "numpy-2.4.5-cp313-cp313-musllinux_1_2_aarch64.whl", hash = "sha256:09d7d97da1c2c62f4818b3e150a57572ff8dcf1cf5ac501aac832ffd4ebd9566"}, - {file = "numpy-2.4.5-cp313-cp313-musllinux_1_2_x86_64.whl", hash = "sha256:2d68d0b355ab2e39fe0de59001d7151dfdbbb880ef67baeed806661e03df5097"}, - {file = "numpy-2.4.5-cp313-cp313-win32.whl", hash = "sha256:fe28b64777ddfa0eca9b5f51474034ebe3dcb8324f48f27b28f479085673ae33"}, - {file = "numpy-2.4.5-cp313-cp313-win_amd64.whl", hash = "sha256:fb4a6c9c537d6ccec9cc4aeae4261bd3cc79b070c67ddc0646f5b1c07fddde42"}, - {file = "numpy-2.4.5-cp313-cp313-win_arm64.whl", hash = "sha256:6d7df2da2e7ea0624a43aa368104b3a3ce14aae98ad4bb2c9a93fecef76f1c97"}, - {file = "numpy-2.4.5-cp313-cp313t-macosx_11_0_arm64.whl", hash = "sha256:2a235607a18df941760a695927051af4b1cd5d3ee85840d0e2af816785771feb"}, - {file = "numpy-2.4.5-cp313-cp313t-macosx_14_0_arm64.whl", hash = "sha256:58dcf64969d870f36bc7fbd557d2617e997db7dc06261b6e3327148ea460d0a4"}, - {file = "numpy-2.4.5-cp313-cp313t-macosx_14_0_x86_64.whl", hash = "sha256:235f54b0156274d8fa3155db3ed6d2f401c7e8f3367c90db0a12f02a58fde6ed"}, - {file = "numpy-2.4.5-cp313-cp313t-manylinux_2_27_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:ef3b5bb65437a3555c648e706475db01c645559ca80dc8b03e4f202ea757e0d6"}, - {file = "numpy-2.4.5-cp313-cp313t-manylinux_2_27_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:7f09a7e5f017d7098c66522097c96257411c9620c0926212200d66bc8cee3976"}, - {file = "numpy-2.4.5-cp313-cp313t-musllinux_1_2_aarch64.whl", hash = "sha256:993a88d8fdd8554466a8765cd8bacd97ba56b70ca6b0a04bcdca77f5afed4222"}, - {file = "numpy-2.4.5-cp313-cp313t-musllinux_1_2_x86_64.whl", hash = "sha256:84f58bed609b5669f5ad3d597901a4f1f86ee5b3c3708aaa55f05b4fe6e0f656"}, - {file = "numpy-2.4.5-cp313-cp313t-win32.whl", hash = "sha256:7200c58f3f933ca61e66346667dcc8510bb111995e9ce15398a731e6a4afa4bb"}, - {file = "numpy-2.4.5-cp313-cp313t-win_amd64.whl", hash = "sha256:c26c71080d35db5002102f5d9ff614d45de02aa1f7802943e691e063e5ee93bc"}, - {file = "numpy-2.4.5-cp313-cp313t-win_arm64.whl", hash = "sha256:2caa576d1707b275cba1aeb60a5c50daa6fa2a3f28ecb08123bc05fd439005db"}, - {file = "numpy-2.4.5-cp314-cp314-macosx_10_15_x86_64.whl", hash = "sha256:889ca2c072315de638a5194a772aa1fa2df92bdd6175f6a222d4784040424b61"}, - {file = "numpy-2.4.5-cp314-cp314-macosx_11_0_arm64.whl", hash = "sha256:89e89304fb1f8c3f0ecfa4a7d48f311dd79771336a940e920159d643d1307e77"}, - {file = "numpy-2.4.5-cp314-cp314-macosx_14_0_arm64.whl", hash = "sha256:144fcc5a3a17679b2b82543b4a2d8dd29937230a7af13232b5f753872feb6361"}, - {file = "numpy-2.4.5-cp314-cp314-macosx_14_0_x86_64.whl", hash = "sha256:398bb16772b265b9fa5c07b07072646ea97137c10ffb62a9a087b277fc825c29"}, - {file = "numpy-2.4.5-cp314-cp314-manylinux_2_27_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:fb352e7b8876da1249e72254736d6c58c505fa4e58a3d7e30efca241ca9ca9ce"}, - {file = "numpy-2.4.5-cp314-cp314-manylinux_2_27_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:7341b08ff8124d7353939778e2707b8732d03c78c1c30e0815aba2dacbe1245a"}, - {file = "numpy-2.4.5-cp314-cp314-musllinux_1_2_aarch64.whl", hash = "sha256:deb01226f012539f3945261ffe1c10aec081a0fa0a5c925419933c70f3ae2d23"}, - {file = "numpy-2.4.5-cp314-cp314-musllinux_1_2_x86_64.whl", hash = "sha256:d888bdf7335f76878c3c7b264ac1ff089863e211ec81249f9fb5795c2183dc25"}, - {file = "numpy-2.4.5-cp314-cp314-win32.whl", hash = "sha256:15f90d1256e9b2320aff24fde44815b787ab6d7c49a1a11bfd8138b321c5f080"}, - {file = "numpy-2.4.5-cp314-cp314-win_amd64.whl", hash = "sha256:4bd2cd4ef9c0afa87de73723c0a33c0edff62143e1432917458e26d3d195d87f"}, - {file = "numpy-2.4.5-cp314-cp314-win_arm64.whl", hash = "sha256:db304568c650e9d7039744d3575d0d287754debb2057d7c7b8cdfdc2c487a957"}, - {file = "numpy-2.4.5-cp314-cp314t-macosx_11_0_arm64.whl", hash = "sha256:6de2883e0d2c63eae1bab1a84b390dca74aabb3d20ea1f5d58f360853c83abf3"}, - {file = "numpy-2.4.5-cp314-cp314t-macosx_14_0_arm64.whl", hash = "sha256:06760fe73ae5005008748d182de612c733542af3cde063d532cd2127561b27be"}, - {file = "numpy-2.4.5-cp314-cp314t-macosx_14_0_x86_64.whl", hash = "sha256:4b51a01745cb04cc19278482207444b4d30728ce91c28d27a3bfae5fc6ff24c7"}, - {file = "numpy-2.4.5-cp314-cp314t-manylinux_2_27_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:9a05636d7937d0936f271e5ba957fa8d746b5be3c2025caa1a2508f4fe521d40"}, - {file = "numpy-2.4.5-cp314-cp314t-manylinux_2_27_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:14b86f56048ed09c3bbe48962a7dff077c2fd3274f8cf981800f3b38eac49cc3"}, - {file = "numpy-2.4.5-cp314-cp314t-musllinux_1_2_aarch64.whl", hash = "sha256:130d58151c4db23e9fa860b84784e219a3aa3e030acc88a493ea37006c4dfd4c"}, - {file = "numpy-2.4.5-cp314-cp314t-musllinux_1_2_x86_64.whl", hash = "sha256:d475afc8cbe935ff5944f753d863bba774d7f4e1feaaa4102901e3e053ca5963"}, - {file = "numpy-2.4.5-cp314-cp314t-win32.whl", hash = "sha256:27f4a6dc26353a860b348961b9aa9e009835688b435cfa105e873b8dc2c726f5"}, - {file = "numpy-2.4.5-cp314-cp314t-win_amd64.whl", hash = "sha256:76ac6e90f5e226011c88f9b7040a4bcae612518bc7e9adc127e697a13b28ad1a"}, - {file = "numpy-2.4.5-cp314-cp314t-win_arm64.whl", hash = "sha256:7c392e2c1bf596701d3c6832be7567eab5d5b0a13865036c33365ee097d37f8b"}, - {file = "numpy-2.4.5-pp311-pypy311_pp73-macosx_10_15_x86_64.whl", hash = "sha256:6bf0bfc1c2e1db972e30b6cd3d4861f477f3af908b27799b239dc3cbe3eb4b95"}, - {file = "numpy-2.4.5-pp311-pypy311_pp73-macosx_11_0_arm64.whl", hash = "sha256:73d664413fb97229149c4711ef56531a6fe8c15c1c2626b0bbe497b84c287e70"}, - {file = "numpy-2.4.5-pp311-pypy311_pp73-macosx_14_0_arm64.whl", hash = "sha256:b35bee5ef99e8d227a07829bee2e864fcb65f7c157646fcd8ec8b4b45dd8b88f"}, - {file = "numpy-2.4.5-pp311-pypy311_pp73-macosx_14_0_x86_64.whl", hash = "sha256:02981d0fc9f9ce147643d552966d47f329a02f7ecb3b113e84207242f20dfa83"}, - {file = "numpy-2.4.5-pp311-pypy311_pp73-manylinux_2_27_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:0e63caf31a1df06338ae63d999f7a33a675ced62eea9c9b02db4b1c1f45cff38"}, - {file = "numpy-2.4.5-pp311-pypy311_pp73-manylinux_2_27_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:d8fc52b85a7b45e474be53eddf08e006d22e381a4e41bcde8e4aa08da0e7d198"}, - {file = "numpy-2.4.5-pp311-pypy311_pp73-win_amd64.whl", hash = "sha256:40c71d50a4da1a7c317af419461052d3911a5770bfc5fd55baf52cc45e7a2c20"}, - {file = "numpy-2.4.5.tar.gz", hash = "sha256:ca670567a5683b7c1670ec03e0ddd5862e10934e92a70751d68d7b7b74ca7f9f"}, + {file = "numpy-2.4.6-cp311-cp311-macosx_10_9_x86_64.whl", hash = "sha256:0280e0356c0829a18d9de1cb7eee50ec22ca639878d7240307ca0943d73cd2c4"}, + {file = "numpy-2.4.6-cp311-cp311-macosx_11_0_arm64.whl", hash = "sha256:110f8b71aacb688ec69062bb7f6938a0f8acb01b7c1c4beb453c65b6d234584d"}, + {file = "numpy-2.4.6-cp311-cp311-macosx_14_0_arm64.whl", hash = "sha256:4cfe66903cc32a9921a6733d96b19bb6abf310397581bbad89c228f5abaf0ee8"}, + {file = "numpy-2.4.6-cp311-cp311-macosx_14_0_x86_64.whl", hash = "sha256:8155154c7c691289fe18f510b5d4657c68c67989f293f0535a91360392ff6538"}, + {file = "numpy-2.4.6-cp311-cp311-manylinux_2_27_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:0ab0a9c4ffb1a6d95ef519fe4247dba8eb6b18ad93999f76b7f657039acabd47"}, + {file = "numpy-2.4.6-cp311-cp311-manylinux_2_27_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:89cd468399cfd2504718f0ba50e410dca55a170b61a02ad92bb18c8a65186e93"}, + {file = "numpy-2.4.6-cp311-cp311-musllinux_1_2_aarch64.whl", hash = "sha256:c2d37ab77531417474168eb79d6d80b14f821a966818505d03013d0833edb7a8"}, + {file = "numpy-2.4.6-cp311-cp311-musllinux_1_2_x86_64.whl", hash = "sha256:f407cb6b8e9d6d8c626bc73c945db1706035af8fd632295547bf1c9e46d092d6"}, + {file = "numpy-2.4.6-cp311-cp311-win32.whl", hash = "sha256:ddea102b48f9e339f3948bf22040944184627a30fdf7f858667673b9c5f033c8"}, + {file = "numpy-2.4.6-cp311-cp311-win_amd64.whl", hash = "sha256:1e254a00cdf42b1e4d5b3d68d33af63268d41340d8885df2ab6470f2e1500147"}, + {file = "numpy-2.4.6-cp311-cp311-win_arm64.whl", hash = "sha256:ed9749eef4cbd126da3dc1d6bcb3a57f5eb7ac6a6484146bdbf743f552dfc577"}, + {file = "numpy-2.4.6-cp312-cp312-macosx_10_13_x86_64.whl", hash = "sha256:001fbb8e08d942dd57599e781f2472269ee7f2755fae407b4f67b2f0b17da3f1"}, + {file = "numpy-2.4.6-cp312-cp312-macosx_11_0_arm64.whl", hash = "sha256:ebfb099f8dcf083deef3ac1ca4c1503f387cf76296fcb3816b66f5ecb5f54fdb"}, + {file = "numpy-2.4.6-cp312-cp312-macosx_14_0_arm64.whl", hash = "sha256:3213d622a0283a39a93d188f3cf72b26862df52fbb4ca3697f51705016523d41"}, + {file = "numpy-2.4.6-cp312-cp312-macosx_14_0_x86_64.whl", hash = "sha256:357cc07a6d7b0b182ff02249616a03742827ebb1277546b5c7cd7f7620a45698"}, + {file = "numpy-2.4.6-cp312-cp312-manylinux_2_27_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:5f9fb9157b4ce2971008323afe46053787b526ef624fea915b261468a8421a0f"}, + {file = "numpy-2.4.6-cp312-cp312-manylinux_2_27_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:90f9849678c75fe7afa2d348ac842c168b0a4d3d61919687216dfc547976d853"}, + {file = "numpy-2.4.6-cp312-cp312-musllinux_1_2_aarch64.whl", hash = "sha256:c1a2af6c6ef86344a6b0db6b97834208bf598db514f2b155042439b62605601a"}, + {file = "numpy-2.4.6-cp312-cp312-musllinux_1_2_x86_64.whl", hash = "sha256:e5805d5a22fd19c8ccff10a9561f9df94436b0545619ea579db2d3c35294bce2"}, + {file = "numpy-2.4.6-cp312-cp312-win32.whl", hash = "sha256:e3eeb0aabd6bd5ce64faae67e9935203a6991b4bc2a485a767fbafb2c5125f45"}, + {file = "numpy-2.4.6-cp312-cp312-win_amd64.whl", hash = "sha256:d8e8286dd7cea7895157318d1b91cdacac64c479f3cbc8dce548331728484751"}, + {file = "numpy-2.4.6-cp312-cp312-win_arm64.whl", hash = "sha256:4081eb135ac24158bd51cdfbef16f1c64df7063b1143f24731387137c092bec8"}, + {file = "numpy-2.4.6-cp313-cp313-macosx_10_13_x86_64.whl", hash = "sha256:511dbaf848decaaaf4b4ca48032619fb3138710c4bf7da7617765edad1ef96b0"}, + {file = "numpy-2.4.6-cp313-cp313-macosx_11_0_arm64.whl", hash = "sha256:bf162abab1c1a736333192707cef898e735a5ca00f38f27eeedf44b39d9e85eb"}, + {file = "numpy-2.4.6-cp313-cp313-macosx_14_0_arm64.whl", hash = "sha256:043191bfa8eab18c776647b62723ac9dddece59743b13f49b2016094129c2b3f"}, + {file = "numpy-2.4.6-cp313-cp313-macosx_14_0_x86_64.whl", hash = "sha256:6180d8b35af935aed8ece3a85e0a43f87393ae0ac87c8d2c8bd2c993f7270ef3"}, + {file = "numpy-2.4.6-cp313-cp313-manylinux_2_27_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:72fbe16c6fac95aedf5937fa873445cec2110be35d8a4e9433d7501fd98dae6b"}, + {file = "numpy-2.4.6-cp313-cp313-manylinux_2_27_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:a7830bab239b79cda9c08c2da014761cafb48da6150e1da17ac06283f43b6089"}, + {file = "numpy-2.4.6-cp313-cp313-musllinux_1_2_aarch64.whl", hash = "sha256:ef4aea96ce4d3b074422cb4f2f64e216bf9e213004bb58ecfdf50ea02ea8eb9a"}, + {file = "numpy-2.4.6-cp313-cp313-musllinux_1_2_x86_64.whl", hash = "sha256:dfa20cc6ca228e6b155b11da03825975ce66aea520985dbbddf0f2a5a495c605"}, + {file = "numpy-2.4.6-cp313-cp313-win32.whl", hash = "sha256:56b39e5e0622a09a25bf5baf62f4bcf0cb8a41ae6e2819cf49bbc5a74c083f91"}, + {file = "numpy-2.4.6-cp313-cp313-win_amd64.whl", hash = "sha256:c4fc99836233ea196540b17ab0983aff60ed07941751930f5f4d05bc3b3b7359"}, + {file = "numpy-2.4.6-cp313-cp313-win_arm64.whl", hash = "sha256:a7c711e21628b52034bb5ab8d1bce291f752fcc5e92accc615778acee1ff4778"}, + {file = "numpy-2.4.6-cp313-cp313t-macosx_11_0_arm64.whl", hash = "sha256:112b06a867b235ef466ed3508ddf0238050df9c727cafb5301ac385b899189a1"}, + {file = "numpy-2.4.6-cp313-cp313t-macosx_14_0_arm64.whl", hash = "sha256:eaf7fa2de5c0be8ae6ff8e9bea2ccd725e980541244521d8d4b5f3354a27babe"}, + {file = "numpy-2.4.6-cp313-cp313t-macosx_14_0_x86_64.whl", hash = "sha256:7265a2f3d436e54ef9f2b52b5c937e6be778781bd97a590319d7348f1c1ca997"}, + {file = "numpy-2.4.6-cp313-cp313t-manylinux_2_27_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:f74a575920ab21fe304421a3fc28793d82e299cae9eccb37084e9fc7f3617c20"}, + {file = "numpy-2.4.6-cp313-cp313t-manylinux_2_27_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:ede83e07a75dd06bc501566c1eca2afc0d61677c1472ac9ad93fdee6e638a48d"}, + {file = "numpy-2.4.6-cp313-cp313t-musllinux_1_2_aarch64.whl", hash = "sha256:68bb27509ac1b9a3443094260f6326150663b06abe40b73a2f81160623da5b67"}, + {file = "numpy-2.4.6-cp313-cp313t-musllinux_1_2_x86_64.whl", hash = "sha256:a0df0043bdb289bde1f62da130d20df23d58b45429f752bc7a8fc5325a225ecd"}, + {file = "numpy-2.4.6-cp313-cp313t-win32.whl", hash = "sha256:29a287e0cf63ff528da061de6b9f64a4618da591ca1046aafc54062e40ca7eab"}, + {file = "numpy-2.4.6-cp313-cp313t-win_amd64.whl", hash = "sha256:25c692919ac5a01f170a3bfcd62d745b24fd095c353d50812637d6fcab442e75"}, + {file = "numpy-2.4.6-cp313-cp313t-win_arm64.whl", hash = "sha256:1e978ec1e8bd0e0e4de6bb75de9d30cbb74db6b6a2bb727618613703ca0167dd"}, + {file = "numpy-2.4.6-cp314-cp314-macosx_10_15_x86_64.whl", hash = "sha256:06ca2f61ec4385a07a6977c55ba998a4466c123642b4a32694d3128fce18c079"}, + {file = "numpy-2.4.6-cp314-cp314-macosx_11_0_arm64.whl", hash = "sha256:38efbc8de75c7a0fc1ac190162d892787f3f47b57cc291231aafee36b80982b7"}, + {file = "numpy-2.4.6-cp314-cp314-macosx_14_0_arm64.whl", hash = "sha256:d581b735e177fdcdce6fed8e7e8880a3fb6ee4e3653a3ac6af01c6f4c03effc5"}, + {file = "numpy-2.4.6-cp314-cp314-macosx_14_0_x86_64.whl", hash = "sha256:0a041d3d761dc3c35cc56ce0351506a02bcbc25f7b169f652435141a17db9096"}, + {file = "numpy-2.4.6-cp314-cp314-manylinux_2_27_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:40fdc1ae7125e518ea98e53e69a4ebc27e1fd50510c47b7ea130cf21e5e1d42b"}, + {file = "numpy-2.4.6-cp314-cp314-manylinux_2_27_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:a2c306dea656c12c68f51f4cea133cbe78ca7435eb28c735eac1d3ebe73be6e8"}, + {file = "numpy-2.4.6-cp314-cp314-musllinux_1_2_aarch64.whl", hash = "sha256:33111801a01c12a8a1e3721f0a9232f8cfc8ae2c6b7098167e6f623c6073f402"}, + {file = "numpy-2.4.6-cp314-cp314-musllinux_1_2_x86_64.whl", hash = "sha256:ae506e6902902557576a26ff33eda8695e7ecb3cb36c3b573a0765dee114ebdb"}, + {file = "numpy-2.4.6-cp314-cp314-win32.whl", hash = "sha256:aaf159caa35993cb1f56fb9b8e4610d35758e7ca005412eb1daa856a78c9c4b1"}, + {file = "numpy-2.4.6-cp314-cp314-win_amd64.whl", hash = "sha256:b507f5c4c1d508876d1819b6bf9a49d365b96320b5d4993426b33a23ca4b8261"}, + {file = "numpy-2.4.6-cp314-cp314-win_arm64.whl", hash = "sha256:6f41ae150c4e32db4f3310cdaf64b1593a03dbabe29eec77fc9b50fe64061df6"}, + {file = "numpy-2.4.6-cp314-cp314t-macosx_11_0_arm64.whl", hash = "sha256:ece3d2cfe132e7d51f44a832b303895e6f2d499c5e74dfbdb06ee246147a304a"}, + {file = "numpy-2.4.6-cp314-cp314t-macosx_14_0_arm64.whl", hash = "sha256:e3e5193ef5a3dc73bceee50f7fdc2c90dbb76c42df8d8fae3d1067a583df579e"}, + {file = "numpy-2.4.6-cp314-cp314t-macosx_14_0_x86_64.whl", hash = "sha256:17f9ade344e7d9b464a084d69bcf18fc691cb1db67c62ed80820bf4926d78f0e"}, + {file = "numpy-2.4.6-cp314-cp314t-manylinux_2_27_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:9cd5ffd25db4e7ba6a375693b3fc0fc1791ec636c17db3720da19bde7180ec43"}, + {file = "numpy-2.4.6-cp314-cp314t-manylinux_2_27_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:7d92c3819208a60205a12a245c91ad70cb0a85336659b19b834205573ac8456e"}, + {file = "numpy-2.4.6-cp314-cp314t-musllinux_1_2_aarch64.whl", hash = "sha256:e85b752a1e912b70eaad4fafbd4d1238007ab221de2009b9a2f5ae7461239895"}, + {file = "numpy-2.4.6-cp314-cp314t-musllinux_1_2_x86_64.whl", hash = "sha256:29cb7f67d10b479ff07c17d33e39f78c07f71c40ef30d63c153d340e96cd3fb4"}, + {file = "numpy-2.4.6-cp314-cp314t-win32.whl", hash = "sha256:260a5d70215b61ab4fadf5c7baacd64821842975eea312125ed3c39a6391b063"}, + {file = "numpy-2.4.6-cp314-cp314t-win_amd64.whl", hash = "sha256:81a1cca95ed5bb92aa8b10dd2cdc9a0d3853a50fad926c28b5d7e8ea54389627"}, + {file = "numpy-2.4.6-cp314-cp314t-win_arm64.whl", hash = "sha256:0c9136e14ed34a9e343a31c533d78a9813a69a3148332bce5e9821cb2f996e66"}, + {file = "numpy-2.4.6-pp311-pypy311_pp73-macosx_10_15_x86_64.whl", hash = "sha256:55cced7c52e981362f708ad635198e97a752dfba412cc03c23bbf3bd8d5cd662"}, + {file = "numpy-2.4.6-pp311-pypy311_pp73-macosx_11_0_arm64.whl", hash = "sha256:d6da64deb6b8ed903e7560180a92f2d804ee1ba5eeb849ac2748b8c1aba1f6d7"}, + {file = "numpy-2.4.6-pp311-pypy311_pp73-macosx_14_0_arm64.whl", hash = "sha256:68a5124b13fa6cc2086764a20005d30bc0548146f7f5322f02fce212ca14317f"}, + {file = "numpy-2.4.6-pp311-pypy311_pp73-macosx_14_0_x86_64.whl", hash = "sha256:948424b06129ce883307e8cff868c31396d8dc7630a59c61d70d98dbe70f222c"}, + {file = "numpy-2.4.6-pp311-pypy311_pp73-manylinux_2_27_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:5dbbdb29840ca3d91ee0fece42fc29278886d908280bfec0a5846c6f901a3eb0"}, + {file = "numpy-2.4.6-pp311-pypy311_pp73-manylinux_2_27_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:8ad03c0965fb3c692200e74d458ca28c1dbb4ce96f9a479a8aa041ad5fabca02"}, + {file = "numpy-2.4.6-pp311-pypy311_pp73-win_amd64.whl", hash = "sha256:2803abfebfc990042cd494d8ce2d5f82e9d847af6d35ec486923aa19dbad5e73"}, + {file = "numpy-2.4.6.tar.gz", hash = "sha256:f3a3570c4a2a16746ac2c31a7c7c7b0c186b95ce902e33db6f28094ed7387dda"}, ] [[package]] From a38088bd058a56d963e5b1bad0d230379f7249b8 Mon Sep 17 00:00:00 2001 From: n07070 Date: Thu, 21 May 2026 02:33:12 +0200 Subject: [PATCH 08/21] Add task objects --- src/task.py | 88 +++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 88 insertions(+) create mode 100644 src/task.py diff --git a/src/task.py b/src/task.py new file mode 100644 index 0000000..84a255c --- /dev/null +++ b/src/task.py @@ -0,0 +1,88 @@ +# Here we define the types of tasks +# We are using Abstract Base Classes, +# like this we can define types of tasks ( text, images, ... ) +# that all work with the same basic options + +# The tasks are going to be injected into a Queue. +# It's a usefull way of storing information in our +# program, while making sure that things are indeed printed. +# It's also a way to prevent two concurrent connexions creating +# a access conflict on a single printer, like two people wanting +# to print at the same time. + +# We can also delay and store printing tasks until a printer becomes +# available if none is online. + +from abc import ABC, abstractmethod +## See https://docs.python.org/3/library/abc.html to learn more about this + +# from dataclasses import dataclass +from enum import Enum +import uuid + +## You can expand this if you want to take other types of tasks into account +class TaskType(Enum): + TEXT = "text" + IMAGE = "image" + CUT = "cut" + + +class PrintTask(ABC): + """ + A print task holds information about what we are looking to print. + """ + def __init__(self, task_type): + self.task_id = self._generate_id() + self.task_type = task_type + self.status = "pending" # pending, processing, completed, failed + + print("Created a new " + str(self.task_type) + " with ID " + self.task_id) + + @abstractmethod + def get_print_data(self): + """Return data formatted for printer""" + pass + + def _generate_id(self): + # Generate unique task ID + return str(uuid.uuid4()) + + +class TextTask(PrintTask): + """ + This tasks represents a texte content, and it's signature. + """ + def __init__(self, content, signature): + super().__init__(TaskType.TEXT) + self.content = content + self.signature = signature + + def get_print_data(self): + return { "txt": self.content, "sign": self.signature } + +class ImageTask(PrintTask): + """ + This tasks represents a image content ( in the form of it's path ), and it's signature. + """ + def __init__(self, image_path, signature, process): + super().__init__(TaskType.IMAGE) + self.image_path = image_path + self.signature = signature + self.process = process + + def get_print_data(self): + # Return image data in printer-compatible format + return { "img": self.image_path, "sign": self.signature, "process" : self.process } + +class CutTask(PrintTask): + """ + This class activates the cutter on the printer if it exists + """ + + def __init__(self): + super().__init__(TaskType.CUT) + + # There is no print data, + # the task existence in itself is indication of what to do + def get_print_data(self): + return None \ No newline at end of file From 42bf6d64966aaa38708536b144cc4a6a0b2ade97 Mon Sep 17 00:00:00 2001 From: n07070 Date: Thu, 21 May 2026 02:33:25 +0200 Subject: [PATCH 09/21] Add printing queue objects --- src/print_queue.py | 127 +++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 127 insertions(+) create mode 100644 src/print_queue.py diff --git a/src/print_queue.py b/src/print_queue.py new file mode 100644 index 0000000..88b3ba7 --- /dev/null +++ b/src/print_queue.py @@ -0,0 +1,127 @@ +# This class has the method by which we manage the Tasks +# It's a printing queue, so we need to add, remove and get information on where +# the queue is + +from collections import deque + +# Because actually printing and adding new print job requests happen at +# diffrent times, the print queue is managed by it's own thread. +import threading + +from datetime import datetime +from task import TaskType, CutTask + +class PrintQueue: + """ + A Double-ended Queue to manage the printing Tasks + """ + def __init__(self, app): + self.app = app + self._queue = deque() + self._lock = threading.Lock() + self._completed_tasks = {} # Store completed task info + self._task_counter = 0 + self.app.logger.debug("Created a new PrintQueue") + + def __len__(self) -> int: + return len(self._queue) + + def enqueue(self, task): + """Add task to right of the queue and return position""" + with self._lock: + try: + self.app.logger.info("Add task %s to queue ", task.task_id) + self._queue.append(task) + position = self._queue.index(task) + # We return the current position of the task if it was added + self.app.logger.debug("Added a new task %s to the queue at position %s", task.task_id, position) + return position + except Exception as e: + self.app.logger.error("Could not add a task to the queue : %s ", e) + raise e + + def dequeue(self): + """Remove and return next task ( from the left of the queue ) (thread-safe)""" + with self._lock: + return self._queue.popleft() if len(self._queue) > 0 else None + + def get_position(self, task): + """Get current position of task in queue (1-indexed)""" + with self._lock: + if task.task_id in self._completed_tasks: + return None # Task already completed + + try: + # Try to get the position of a Task + return self._queue.index(task) + except ValueError as e: + raise e + # end try + + def is_empty(self): + """Check if queue is empty""" + with self._lock: + self.app.logger.debug("Checking if queue is empty") + return len(self._queue) == 0 + + def get_queue_state(self): + """Return current queue state""" + with self._lock: + self.app.logger.debug("Return current queue state") + return [{"task_id": t.task_id, "status": t.status} for t in self._queue] + + def get_status(self, task_id): + """Get full status info for a task""" + with self._lock: + + if task_id in self._completed_tasks: + return self._completed_tasks[task_id] + + # Check in queue if it exists + for index, task in enumerate(self._queue): + if task.task_id == task_id: + # Depending on it's type, we return more info + if task.task_type == TaskType.IMAGE: + return { + "task_id": task_id, + "status": task.status, + "type" : task.task_type, + "position": index, + "in_queue": True, + "content" : task.content, + "signature": task.signature + } + + if task.task_type == TaskType.TEXT: + return { + "task_id": task_id, + "status": task.status, + "type" : task.task_type, + "position": index, + "in_queue": True, + "image_path" : str(task.image_path), + "signature" : task.signature, + "process" : str(task.process) + } + + if task.task_type == TaskType.CUT: + return { + "task_id": task_id, + "status": task.status, + "type" : task.task_type, + "position": index, + "in_queue": True + } + + return None + + def mark_completed(self, task_id, task_status): + """Mark task as completed and remove from queue""" + with self._lock: + self._completed_tasks[task_id] = { + "task_id": task_id, + "status": task_status, + "position": None, + "in_queue": False, + "completed_at": datetime.now().isoformat() + } \ No newline at end of file From 9dee67c3339fbb5384f1238a41389acef8189d78 Mon Sep 17 00:00:00 2001 From: n07070 Date: Thu, 21 May 2026 02:33:40 +0200 Subject: [PATCH 10/21] Add worker class --- src/worker.py | 111 ++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 111 insertions(+) create mode 100644 src/worker.py diff --git a/src/worker.py b/src/worker.py new file mode 100644 index 0000000..5efc936 --- /dev/null +++ b/src/worker.py @@ -0,0 +1,111 @@ +# This is the main printing thread +# As explained in the task file, this is where we command +# printing to happen. + +import threading +import time +from task import TaskType + +class PrintWorker(threading.Thread): + def __init__(self, app, print_queue, printer, socketio=None): + super().__init__(daemon=True) + self.app = app + self.print_queue = print_queue + self.printer = printer + self.socketio = socketio # Optional + self.running = True + self.state = "idle" # idle, printing, dead, drinking-a-beer + + self.app.logger.debug("Ho great, I'm alive... I'm ready to work another day...") + + def run(self): + """Background thread that processes queue items""" + self.app.logger.info("Worker started working.") + while True: + if not self.running: + time.sleep(0.2) + continue + + # TODO: This could be improved to simply no start + # the while loop as long as the printer is not ready. + # and maybe get out of it when the printer is not ready anymore ? + if not self.printer.ready: + self.app.logger.debug("Waiting for the printer to be ready...") + time.sleep(1) + continue + + try: + task = self.print_queue.dequeue() + except Exception as e: + self.app.logger.error("Could not get a new task ! %s ", str(e)) + raise RuntimeError("We could not get a new task because " + str(e)) from e + + if task: + try: + self.app.logger.info("Got a new task") + self.app.logger.debug("Got task %s", task.task_id) + self.state = "printing" + task.status = "processing" + self._emit_status(task.task_id, "processing") + + print_data = task.get_print_data() + try: + self.printer.print_task(task.task_type, print_data) + except Exception as e: + self.app.logger.error("Could not print : %s", str(e)) + raise e + + task.status = "completed" + self.print_queue.mark_completed(task.task_id, "completed") + self._emit_status(task.task_id, "completed") + + except Exception as e: + task.status = "failed" + self.print_queue.mark_completed(task.task_id, "failed") + self._emit_status(task.task_id, "failed", error=str(e)) + print(f"Print task {task.task_id} failed: {e}") + else: + # When they are no new tasks to handle, we put the thread to sleep. + self.state = "idle" + time.sleep(0.1) + + def _emit_status(self, task_id, status, error=None): + """Emit status update via Socket.IO if available""" + if not self.socketio: + return + + room = f"task_{task_id}" + data = { + "task_id": task_id, + "status": status, + "position": None # Task no longer in queue + } + + if error: + data["error"] = error + + self.socketio.emit('task_status', data, room=room) + + def stop_worker(self): + """ + Give the worker a break + """ + self.state = "drinking-a-beer" + self.running = False + + def start_worker(self): + """ + Get the worker back to it + """ + self.state = "idle" + self.running = True + + def current_state(self): + """ + Return the worker state + """ + return { + "is_running": self.running, + "queue_size": len(self.print_queue), + "state" : self.state + } \ No newline at end of file From e8ec9b74c05ed236cf208d88854a4ba70e4e74d1 Mon Sep 17 00:00:00 2001 From: n07070 Date: Thu, 21 May 2026 02:33:51 +0200 Subject: [PATCH 11/21] Restructure web class to use print queue and tasks --- src/web.py | 86 +++++++++++++++++++++++++++++++----------------------- 1 file changed, 50 insertions(+), 36 deletions(-) diff --git a/src/web.py b/src/web.py index a40d09b..6aba3f2 100644 --- a/src/web.py +++ b/src/web.py @@ -1,16 +1,16 @@ -from flask import Flask, request, flash +from flask import flash from werkzeug.utils import secure_filename -from printer import Printer import time import os +from task import TextTask, ImageTask, CutTask class Web(object): """Web is the class that gets all of the information from web calls ( API and Web page ) and provides checks before sending stuff to printing""" - def __init__(self, app, printer): + def __init__(self, app, print_queue): super(Web).__init__() - self.printer = printer + self.print_queue = print_queue self.app = app def print_sms(self, texte, sign: str) -> bool: @@ -18,13 +18,19 @@ class Web(object): Get text and a signature, prints the text and cuts after that. """ self.app.logger.debug("Printing : " + str(texte) + " from " + str(sign)) + try: - self.printer.print_sms(texte, sign) - self.printer.cut() + # We create two new tasks and add them directly to the queue + # TODO: this might need to be improved because + # !! there is no garantee !! that both the SMS task and the Cut task + # are added back to back, another task could be + # inserted between the two. + sms = self.print_queue.enqueue(TextTask(content=texte, signature=sign)) + cut = self.print_queue.enqueue(CutTask()) except Exception as e: self.app.logger.error(e) - raise RuntimeError("Could not print SMS, " + str(e)) from e - + raise RuntimeError("Could not add SMS to queue, " + str(e)) from e + self.app.logger.info("Added two new tasks at position %s and %s", sms, cut ) return True def print_image(self, image, sign: str) -> bool: @@ -32,28 +38,28 @@ class Web(object): Get an image and a signature, prints the image and cuts after that. """ try: - self.upload_file(image) + file_uploaded = self.upload_file(image) except Exception as e: self.app.logger.error(e) raise RuntimeError("Could not upload file") from e - self.app.logger.debug("File has been uploaded, printing...") - - - try: - self.printer.print_img( - os.path.join( + if file_uploaded: + self.app.logger.debug("File has been uploaded, printing...") + try: + img = self.print_queue.enqueue(ImageTask(os.path.join( self.app.config["UPLOAD_FOLDER"], secure_filename(image.filename), ), - sign=sign, - process=True, - ) - self.printer.cut() - except Exception as e: - raise RuntimeError("Could not print file") from e + signature=sign, + process=True)) + + cut = self.print_queue.enqueue(CutTask()) + except Exception as e: + raise RuntimeError("Could not add IMG to queue" + str(e)) from e + + self.app.logger.info("Added two new tasks at position %s and %s", img, cut ) + - self.app.logger.debug("Image printed and cut !") return True def login(self, username: str, password: str) -> bool: @@ -74,20 +80,28 @@ class Web(object): def upload_file(self, image) -> bool: self.app.logger.debug("Validating file") - if image and self.allowed_file(image.filename): - filename = secure_filename(image.filename) - self.app.logger.debug("File valid") - try: - image.save(os.path.join(self.app.config["UPLOAD_FOLDER"], filename)) - except Exception as e: - self.app.logger.error("Could not save file %s", e) - return False + if image: + if self.allowed_file(image.filename): + filename = secure_filename(image.filename) + self.app.logger.debug("File valid") + try: + image.save(os.path.join(self.app.config["UPLOAD_FOLDER"], filename)) + except OSError as e: + self.app.logger.error("Could not save file %s", e) + return False - self.app.logger.debug( - "File saved to " - + str(os.path.join(self.app.config["UPLOAD_FOLDER"], filename)) - ) - return True + self.app.logger.debug( + "File saved to " + + str(os.path.join(self.app.config["UPLOAD_FOLDER"], filename)) + ) + return True + else: + self.app.logger.error("Could not save file because the filename is forbidden") + return False else: - self.app.logger.error("Could not save file " + str(filename)) + self.app.logger.error("Could not save file, it seems to be null ? : " + str(filename)) return False + + def get_queue_state(self): + """Return current queue state""" + return self.print_queue.get_queue_state() From c50922790dfef412ce45b919a1789fdf48f9dfdf Mon Sep 17 00:00:00 2001 From: n07070 Date: Thu, 21 May 2026 02:34:12 +0200 Subject: [PATCH 12/21] Restructure main class to activate worker and use tasks, print queue, update Printer --- src/main.py | 47 +++++++++++++++++++++++---- src/printer.py | 86 +++++++++++++++++++++++++++++++------------------- 2 files changed, 94 insertions(+), 39 deletions(-) diff --git a/src/main.py b/src/main.py index a161b0c..2341c30 100644 --- a/src/main.py +++ b/src/main.py @@ -23,6 +23,7 @@ import sys import os # For VARS from the shell. import pprint # To pretty print JSON import toml # Used for the config file parsing +import threading from flask import ( Flask, request, @@ -39,11 +40,15 @@ from flask_limiter.util import get_remote_address from printer import Printer # The wrapper for the printer class from raspberry import Raspberry # The Raspberry pi control Class from web import Web # Wrapper for the web routes and API +from print_queue import PrintQueue +from worker import PrintWorker -# Variables +# We create the main Flask object app = Flask(__name__) -socketio = SocketIO(app) +socketio = SocketIO(app, cors_allowed_origins="*") + +# Global variables ALLOWED_EXTENSIONS = {"png", "jpg", "jpeg", "gif", "webp"} # Load the configuration file @@ -116,18 +121,21 @@ rpi = Raspberry( RASPBERRY_PI_CONNECTED = rpi.is_raspberry_pi() +# Queue creation +print_queue = PrintQueue(app) # Web & API routes +web = Web(app, print_queue) -web = Web(app, printer) - -if __name__ == "__main__": - app.run(debug=True, use_reloader=False, host="0.0.0.0", ssl_context="adhoc") +# Start worker thread +worker = PrintWorker(app, print_queue, printer, socketio) +worker.start() limiter = Limiter( get_remote_address, app=app, default_limits=["1500 per day", "500 per hour"] ) +# General routes @app.route("/") @limiter.limit("1/second", override_defaults=False) @@ -144,6 +152,8 @@ def webcam(): app.logger.debug("Loading webcam interface") return render_template("webcam.html") +# Form treatement + @app.route("/web/print/sms", methods=["POST"]) @limiter.limit("6/minute", override_defaults=False) def web_print_sms(): @@ -299,7 +309,7 @@ def api_print_image(): @app.route("/api/camera/picture", methods=["GET"]) def camera_picture(): - """Returns a picture taken by the camera""" + """Returns a picture taken by the camera on a raspberry pi""" if RASPBERRY_PI_CONNECTED: try: return rpi.camera_picture() @@ -308,6 +318,26 @@ def camera_picture(): else: return jsonify({"message": "No camera present"}), 500 +@app.route('/api/queue', methods=["GET"]) +def api_queue_status(): + """API endpoint for entire queue""" + return jsonify(web.get_queue_state()) + +@app.route('/api/worker', methods=["GET"]) +def api_worker_state(): + """API endpoint to get the worker state""" + return jsonify(worker.current_state()) + +@app.route('/api/worker/start') +def api_worker_start(): + worker.start_worker() + return jsonify(worker.current_state()) + +@app.route('/api/worker/stop') +def api_worker_stop(): + worker.stop_worker() + return jsonify(worker.current_state()) + ## Authentification @@ -362,3 +392,6 @@ def camera_status(): socketio.emit("camera_status", True) else: socketio.emit("camera_status", False) + +if __name__ == "__main__": + app.run(debug=True, use_reloader=False, host="0.0.0.0", ssl_context="adhoc") diff --git a/src/printer.py b/src/printer.py index c94c275..73bab94 100644 --- a/src/printer.py +++ b/src/printer.py @@ -1,12 +1,11 @@ # Importing the module to manage the connection to the printer. import escpos.printer -import brother_ql +# import brother_ql from time import sleep, gmtime, strftime import os.path from PIL import Image, ImageEnhance, ImageOps import numpy as np - class Printer(object): """ # The connection is based on the ESC/POS library @@ -39,7 +38,9 @@ class Printer(object): self.usb_args["idProduct"] = self.vendor_id def check_paper(self) -> bool: - # Let's check paper status + """ + On printers that support it, we check that the printer has paper + """ self.app.logger.debug("Checking paper status...") self.printer.open(self.usb_args) status = self.printer.paper_status() @@ -58,10 +59,13 @@ class Printer(object): self.printer.close() def init_printer(self): + """ + Check if the printer online ? Is the communication with the printer successfull ? + """ - # Is the printer online ? Is the communication with the printer successfull ? + # TODO: This could happen directly when creating a new Printer class if os.getenv("FLASK_DEBUG"): - waiting_elapsed = 1 + waiting_elapsed = 15 else: waiting_elapsed = 10 @@ -122,10 +126,17 @@ class Printer(object): return True - def print_sms(self, msg, signature="", bold=False): + def _print_sms(self, msg, signature="", bold=False): + + if not isinstance(msg,str): + self.app.logger.error("It is not possible to print a " + str(type(msg)) + ", only strings.") + raise ValueError + + # We make sure that the signature is not something too goofy clean_msg = str(msg) + "\n" clean_signature = str(signature) + # Make checks on the size of the message being printed if len(clean_msg) > 4096: self.app.logger.warning( "Could not print message of this length: " + str(len(clean_msg)) @@ -146,6 +157,8 @@ class Printer(object): + ", needs to be below 256 caracters long." ) + # Do the actual printing + # We would pop the next element in the queue here, if it's a sms type try: self.printer.open(self.usb_args) self.printer.set(align="center", font="a", bold=bold) @@ -160,14 +173,14 @@ class Printer(object): self.app.logger.info("Printed text") return True - def print_img(self, path, sign="", center=True, process=False): - clean_signature = str(sign) + def _print_img(self, path, signature="", center=True, process=False): + clean_signature = str(signature) - if len(sign) > 256: + if len(signature) > 256: self.app.logger.warning( "Could not print signature of this length: " + str(len(clean_signature)) ) - raise Exception( + raise ValueError( "Could not print signature of this length :" + str(len(clean_signature)) + ", needs to be below 256 caracters long." @@ -175,7 +188,7 @@ class Printer(object): if not os.path.isfile(str(path)): self.app.logger.warning("File does not exist : " + str(path)) - raise Exception( + raise OSError( "The file path for this image :" + str(path) + " wasn't found. Please try again." @@ -186,34 +199,40 @@ class Printer(object): if process: try: self.app.logger.debug("Proccessing the image") - path = process_image(self, path) - except Exception as e: - self.app.logger.error(str(e)) - return False + path = _process_image(self, path) + except RuntimeError as e: + self.app.logger.error("Error while processing the image, aborting print : %s",str(e)) + raise e else: self.app.logger.warning("Not proccessing the image") try: self.printer.open(self.usb_args) self.printer.image(path, center=center) + self.printer.textln(signature) self.printer.close() self.app.logger.debug("Printed an image : " + str(path)) - os.remove(path) - self.app.logger.debug("Removed image : " + str(path)) except Exception as e: self.app.logger.error(str(e)) raise RuntimeError("Could not print the picture") from e finally: + try: + os.remove(path) + except OSError as e: + raise e + + self.app.logger.debug("Removed image : " + str(path)) + try: self.printer.close() except Exception as e: - self.app.logger.error(str(e)) + self.app.logger.error("Could not close the printer connexion %s", str(e)) raise RuntimeError("Could not close the printer connexion. ") from e self.app.logger.info("Printed a picture") return True - def qr(self, content): + def _qr(self, content): try: self.printer.open(self.usb_args) self.printer.qr(content, center=True) @@ -226,7 +245,7 @@ class Printer(object): self.app.logger.info("Printed a QR") return True - def cut(self): + def _cut(self): try: self.printer.open(self.usb_args) self.printer.cut() @@ -239,8 +258,20 @@ class Printer(object): self.app.logger.info("Did a cut") return True + def print_task(self, task_type, data): + """Execute actual print based on task type""" + match (task_type.value): + case ("text"): + self._print_sms(data["txt"],signature=data["sign"]) + case ("image"): + self._print_img(data["img"], signature=data["sign"],process=data["process"]) + case ("cut"): + self._cut() + case _: + raise RuntimeError("This task type is not supported") -def process_image(self, path): + +def _process_image(self, path): brightness_factor = 1.5 # Used only if image is too dark brightness_threshold = 100 # Brightness threshold (0–255) contrast_factor = 0.6 # Less than 1.0 = lower contrast @@ -254,7 +285,7 @@ def process_image(self, path): original_img = original_img.convert("RGB") # Resize while maintaining aspect ratio - original_img.thumbnail((max_width, max_height), Image.LANCZOS) + original_img.thumbnail((max_width, max_height), Image.Resampling.LANCZOS) self.app.logger.debug("Resized the image") # # Convert to grayscale for dithering @@ -286,18 +317,10 @@ def process_image(self, path): # contrast_enhancer = ImageEnhance.Contrast(original_img) # original_img = contrast_enhancer.enhance(contrast_factor) - # Final resize check - if original_img.height > max_height: - raise ValueError("Image is too long, sorry! Keep it below 575×1000 pixels.") - self.app.logger.error( - "Image is too long, sorry! Keep it below 575×1000 pixels." - ) - return False - # Convert to JPEG and save jpeg_path = os.path.splitext(path)[0] + "_processed.jpg" original_img.save(jpeg_path, format="JPEG", quality=95, optimize=True) - app.logger.debug("Processed and saved image.") + self.app.logger.debug("Processed and saved image.") return jpeg_path @@ -387,6 +410,5 @@ def find_and_parse_borther_ql_printer(): print("No Brother QL printer found") return None - def fint_and_parse_epson_printer(): pass \ No newline at end of file From 2daafe28f2cc79aa90028c024610f01d5a9bb268 Mon Sep 17 00:00:00 2001 From: n07070 Date: Thu, 21 May 2026 02:57:27 +0200 Subject: [PATCH 13/21] Apply linting --- src/main.py | 54 ++++++++++++++++++------------- src/print_queue.py | 40 ++++++++++++++--------- src/printer.py | 81 +++++++++++++++++++++++++++++----------------- src/raspberry.py | 11 +++---- src/task.py | 47 ++++++++++++++++----------- src/user.py | 70 +++++++++++++++++++-------------------- src/web.py | 29 ++++++++++------- src/worker.py | 32 ++++++++---------- 8 files changed, 209 insertions(+), 155 deletions(-) diff --git a/src/main.py b/src/main.py index 2341c30..8999435 100644 --- a/src/main.py +++ b/src/main.py @@ -23,7 +23,6 @@ import sys import os # For VARS from the shell. import pprint # To pretty print JSON import toml # Used for the config file parsing -import threading from flask import ( Flask, request, @@ -43,7 +42,6 @@ from web import Web # Wrapper for the web routes and API from print_queue import PrintQueue from worker import PrintWorker - # We create the main Flask object app = Flask(__name__) socketio = SocketIO(app, cors_allowed_origins="*") @@ -87,7 +85,7 @@ except FileExistsError: app.logger.debug("Directory %s already exists.", UPLOAD_FOLDER) except PermissionError: app.logger.error("Permission denied: Unable to create %s", UPLOAD_FOLDER) - exit(77) + sys.exit(77) # Output the config file if os.getenv("FLASK_DEBUG"): @@ -137,6 +135,7 @@ limiter = Limiter( # General routes + @app.route("/") @limiter.limit("1/second", override_defaults=False) def index(): @@ -152,8 +151,10 @@ def webcam(): app.logger.debug("Loading webcam interface") return render_template("webcam.html") + # Form treatement + @app.route("/web/print/sms", methods=["POST"]) @limiter.limit("6/minute", override_defaults=False) def web_print_sms(): @@ -164,7 +165,7 @@ def web_print_sms(): txt = request.form["txt"] except werkzeug.exceptions.BadRequestKeyError as e: app.logger.error("Whoops, we are missing the txt input field. : %s ", str(e)) - flash("Whoops, no forms submitted or missing signature : " + str(e), 'error') + flash("Whoops, no forms submitted or missing signature : " + str(e), "error") return redirect(url_for("index")) try: @@ -172,23 +173,23 @@ def web_print_sms(): sign = request.form["signature"] except werkzeug.exceptions.BadRequestKeyError as e: app.logger.warning( - "No signature found for this print, using default signature.", str(e) + "No signature found for this print, using default signature : %s ", str(e) ) sign = configuration_file["defaults"]["signature"] try: web.print_sms(txt, sign) - except Exception as e: + except RuntimeError as e: app.logger.error("Whoops, we could not print an SMS because : %s ", str(e)) - flash("Whoops, we could not print an SMS because :" + str(e), 'error') + flash("Whoops, we could not print an SMS because :" + str(e), "error") return redirect(url_for("index")) # end try - flash("The SMS has been printed !", 'info') + flash("The SMS has been printed !", "info") return redirect(url_for("index")) -@app.route("/web/print/img", methods=["POST"]) +@app.route("/web/print/img", methods=["POST"]) @limiter.limit("1/second", override_defaults=False) def web_print_img(): """Prints an image on a printer""" @@ -199,7 +200,7 @@ def web_print_img(): sign = request.form["signature"] except werkzeug.exceptions.BadRequestKeyError as e: app.logger.warning( - "No signature found for this print, using default signature.", str(e) + "No signature found for this print, using default signature : %s", str(e) ) sign = configuration_file["defaults"]["signature"] @@ -207,7 +208,7 @@ def web_print_img(): if "img" not in request.files: app.logger.error("Whoops, no images submitted : %s ", str(e)) app.logger.error("Error getting the files : %s", str(e)) - flash("Whoops, no images submitted : " + str(e), 'error') + flash("Whoops, no images submitted : " + str(e), "error") return redirect(url_for("index")) file = request.files["img"] @@ -215,20 +216,21 @@ def web_print_img(): # empty file without a filename. if file.filename == "": app.logger.error("Submitted file has no filename !") - flash("Submitted file has no filename !", 'error') + flash("Submitted file has no filename !", "error") return redirect(url_for("index")) try: app.logger.debug("Sending the image to the printer.") web.print_image(file, sign) - except Exception as e: + except RuntimeError as e: app.logger.error("The image could not be printed because : %s ", str(e)) - flash("The image could not be printed because : " + str(e), 'error') + flash("The image could not be printed because : " + str(e), "error") return redirect(url_for("index")) - flash("Picture printed !", 'info') + flash("Picture printed !", "info") return redirect(url_for("index")) + # API routes # The api has the following methods # api/print/{sms,img,letter,qr,barcode} @@ -267,11 +269,12 @@ def api_print_sms(): try: # comment: We try to print the SMS web.print_sms(txt, sign) - except Exception as e: + except RuntimeError as e: return str(e), 500 # end try return "OK", 200 + @app.route("/api/print/img", methods=["POST"]) @limiter.limit("6/minute", override_defaults=False) def api_print_image(): @@ -302,38 +305,43 @@ def api_print_image(): try: app.logger.debug("Sending the image to the printer.") web.print_image(file, sign) - except Exception as e: + except RuntimeError as e: return str(e), 500 return "OK", 200 + @app.route("/api/camera/picture", methods=["GET"]) def camera_picture(): """Returns a picture taken by the camera on a raspberry pi""" if RASPBERRY_PI_CONNECTED: try: return rpi.camera_picture() - except Exception as e: + except RuntimeError as e: return jsonify({"message": "Error getting the stream : " + e}), 500 else: return jsonify({"message": "No camera present"}), 500 -@app.route('/api/queue', methods=["GET"]) + +@app.route("/api/queue", methods=["GET"]) def api_queue_status(): """API endpoint for entire queue""" return jsonify(web.get_queue_state()) -@app.route('/api/worker', methods=["GET"]) + +@app.route("/api/worker", methods=["GET"]) def api_worker_state(): """API endpoint to get the worker state""" return jsonify(worker.current_state()) -@app.route('/api/worker/start') + +@app.route("/api/worker/start") def api_worker_start(): worker.start_worker() return jsonify(worker.current_state()) -@app.route('/api/worker/stop') + +@app.route("/api/worker/stop") def api_worker_stop(): worker.stop_worker() return jsonify(worker.current_state()) @@ -341,6 +349,7 @@ def api_worker_stop(): ## Authentification + @app.route("/login") @limiter.limit("1/second", override_defaults=False) def login_page(): @@ -393,5 +402,6 @@ def camera_status(): else: socketio.emit("camera_status", False) + if __name__ == "__main__": app.run(debug=True, use_reloader=False, host="0.0.0.0", ssl_context="adhoc") diff --git a/src/print_queue.py b/src/print_queue.py index 88b3ba7..766a322 100644 --- a/src/print_queue.py +++ b/src/print_queue.py @@ -1,6 +1,8 @@ -# This class has the method by which we manage the Tasks -# It's a printing queue, so we need to add, remove and get information on where -# the queue is +""" +This class has the method by which we manage the Tasks +It's a printing queue, so we need to add, remove and get information on where +the queue is +""" from collections import deque @@ -9,12 +11,14 @@ from collections import deque import threading from datetime import datetime -from task import TaskType, CutTask +from task import TaskType + class PrintQueue: """ A Double-ended Queue to manage the printing Tasks """ + def __init__(self, app): self.app = app self._queue = deque() @@ -34,7 +38,11 @@ class PrintQueue: self._queue.append(task) position = self._queue.index(task) # We return the current position of the task if it was added - self.app.logger.debug("Added a new task %s to the queue at position %s", task.task_id, position) + self.app.logger.debug( + "Added a new task %s to the queue at position %s", + task.task_id, + position, + ) return position except Exception as e: self.app.logger.error("Could not add a task to the queue : %s ", e) @@ -85,32 +93,32 @@ class PrintQueue: return { "task_id": task_id, "status": task.status, - "type" : task.task_type, + "type": task.task_type, "position": index, "in_queue": True, - "content" : task.content, - "signature": task.signature + "content": task.content, + "signature": task.signature, } if task.task_type == TaskType.TEXT: return { "task_id": task_id, "status": task.status, - "type" : task.task_type, + "type": task.task_type, "position": index, "in_queue": True, - "image_path" : str(task.image_path), - "signature" : task.signature, - "process" : str(task.process) + "image_path": str(task.image_path), + "signature": task.signature, + "process": str(task.process), } if task.task_type == TaskType.CUT: return { "task_id": task_id, "status": task.status, - "type" : task.task_type, + "type": task.task_type, "position": index, - "in_queue": True + "in_queue": True, } return None @@ -123,5 +131,5 @@ class PrintQueue: "status": task_status, "position": None, "in_queue": False, - "completed_at": datetime.now().isoformat() - } \ No newline at end of file + "completed_at": datetime.now().isoformat(), + } diff --git a/src/printer.py b/src/printer.py index 73bab94..fc1f148 100644 --- a/src/printer.py +++ b/src/printer.py @@ -1,10 +1,14 @@ + +# import brother_ql +from time import sleep +import os.path + +from PIL import Image, ImageEnhance +import numpy as np + # Importing the module to manage the connection to the printer. import escpos.printer -# import brother_ql -from time import sleep, gmtime, strftime -import os.path -from PIL import Image, ImageEnhance, ImageOps -import numpy as np + class Printer(object): """ @@ -75,10 +79,14 @@ class Printer(object): try: # This also calls open(), which we need to close() # or else the device will appear as busy. - p = escpos.printer.Usb(self.device_id, self.vendor_id, 0, profile="TM-P80") + p = escpos.printer.Usb( + self.device_id, self.vendor_id, 0, profile="TM-P80" + ) except Exception as e: self.app.logger.error( - "The USB device is not plugged in, trying again %s : %s",waiting_elapsed, str(e) + "The USB device is not plugged in, trying again %s : %s", + waiting_elapsed, + str(e), ) pass @@ -87,7 +95,10 @@ class Printer(object): self.ready = True self.app.logger.debug("Printer online !") except Exception as e: - self.app.logger.error("Error while getting the printer online %s : %s",waiting_elapsed, str(e) + self.app.logger.error( + "Error while getting the printer online %s : %s", + waiting_elapsed, + str(e), ) pass @@ -128,8 +139,10 @@ class Printer(object): def _print_sms(self, msg, signature="", bold=False): - if not isinstance(msg,str): - self.app.logger.error("It is not possible to print a " + str(type(msg)) + ", only strings.") + if not isinstance(msg, str): + self.app.logger.error( + "It is not possible to print a " + str(type(msg)) + ", only strings." + ) raise ValueError # We make sure that the signature is not something too goofy @@ -168,7 +181,9 @@ class Printer(object): self.printer.close() except Exception as e: self.app.logger.error("Unable to print because : " + str(e)) - raise RuntimeError("Unable to print a SMS, the printer couldn't do it.") from e + raise RuntimeError( + "Unable to print a SMS, the printer couldn't do it." + ) from e self.app.logger.info("Printed text") return True @@ -201,7 +216,9 @@ class Printer(object): self.app.logger.debug("Proccessing the image") path = _process_image(self, path) except RuntimeError as e: - self.app.logger.error("Error while processing the image, aborting print : %s",str(e)) + self.app.logger.error( + "Error while processing the image, aborting print : %s", str(e) + ) raise e else: self.app.logger.warning("Not proccessing the image") @@ -226,7 +243,9 @@ class Printer(object): try: self.printer.close() except Exception as e: - self.app.logger.error("Could not close the printer connexion %s", str(e)) + self.app.logger.error( + "Could not close the printer connexion %s", str(e) + ) raise RuntimeError("Could not close the printer connexion. ") from e self.app.logger.info("Printed a picture") @@ -261,11 +280,13 @@ class Printer(object): def print_task(self, task_type, data): """Execute actual print based on task type""" match (task_type.value): - case ("text"): - self._print_sms(data["txt"],signature=data["sign"]) - case ("image"): - self._print_img(data["img"], signature=data["sign"],process=data["process"]) - case ("cut"): + case "text": + self._print_sms(data["txt"], signature=data["sign"]) + case "image": + self._print_img( + data["img"], signature=data["sign"], process=data["process"] + ) + case "cut": self._cut() case _: raise RuntimeError("This task type is not supported") @@ -324,6 +345,7 @@ def _process_image(self, path): return jpeg_path + def discover_printers(): """ We try to find all the connected printers ( 0 or n ) to this system. @@ -336,8 +358,8 @@ def discover_printers(): 04f9 Brother Industries, Ltd """ -def find_and_parse_borther_ql_printer(): +def find_and_parse_borther_ql_printer(): ## We might be able to no use this because there is a `discover` command in https://github.com/pklaus/brother_ql#usage @@ -352,18 +374,18 @@ def find_and_parse_borther_ql_printer(): for backend_name in ["pyusb", "linux_kernel"]: try: - #print(f"Trying backend: {backend_name}") + # print(f"Trying backend: {backend_name}") backend = backend_factory(backend_name) available_devices = backend["list_available_devices"]() - #print(f"Found {len(available_devices)} devices with {backend_name} backend") + # print(f"Found {len(available_devices)} devices with {backend_name} backend") for printer in available_devices: - #print(f"Found device: {printer}") + # print(f"Found device: {printer}") identifier = printer["identifier"] parts = identifier.split("/") if len(parts) < 4: - #print(f"Skipping device with invalid identifier format: {identifier}") + # print(f"Skipping device with invalid identifier format: {identifier}") continue protocol = parts[0] @@ -373,7 +395,7 @@ def find_and_parse_borther_ql_printer(): try: vendor_id, product_id = device_info.split(":") except ValueError: - #print(f"Invalid device info format: {device_info}") + # print(f"Invalid device info format: {device_info}") continue # Default model @@ -386,9 +408,9 @@ def find_and_parse_borther_ql_printer(): if m.product_id == product_id_int: model = m.identifier break - #print(f"Matched printer model: {model}") + # print(f"Matched printer model: {model}") except ValueError: - #print(f"Invalid product ID format: {product_id}") + # print(f"Invalid product ID format: {product_id}") continue printer_info = { @@ -400,15 +422,16 @@ def find_and_parse_borther_ql_printer(): "product_id": product_id, "serial_number": serial_number, } - #print(f"Found printer: {printer_info}") + # print(f"Found printer: {printer_info}") return printer_info except Exception as e: - #print(f"Error with backend {backend_name}: {str(e)}") + # print(f"Error with backend {backend_name}: {str(e)}") continue print("No Brother QL printer found") return None + def fint_and_parse_epson_printer(): - pass \ No newline at end of file + pass diff --git a/src/raspberry.py b/src/raspberry.py index d6b932d..772ea46 100644 --- a/src/raspberry.py +++ b/src/raspberry.py @@ -1,13 +1,12 @@ -from flask_socketio import SocketIO -from gpiozero import Button, LED, DigitalOutputDevice -from time import sleep, gmtime, strftime -from PIL import Image import io # To check if we are on a Raspberry Pi import subprocess import os +from time import sleep, gmtime, strftime +from flask_socketio import SocketIO +from gpiozero import Button, LED, DigitalOutputDevice +from PIL import Image - -class Raspberry(object): +class Raspberry(): """ This class will manage three things : - Connecting to a USB webcam diff --git a/src/task.py b/src/task.py index 84a255c..a55baad 100644 --- a/src/task.py +++ b/src/task.py @@ -1,27 +1,33 @@ -# Here we define the types of tasks -# We are using Abstract Base Classes, -# like this we can define types of tasks ( text, images, ... ) -# that all work with the same basic options +""" +Here we define the types of tasks +We are using Abstract Base Classes, +like this we can define types of tasks ( text, images, ... ) +that all work with the same basic options -# The tasks are going to be injected into a Queue. -# It's a usefull way of storing information in our -# program, while making sure that things are indeed printed. -# It's also a way to prevent two concurrent connexions creating -# a access conflict on a single printer, like two people wanting -# to print at the same time. - -# We can also delay and store printing tasks until a printer becomes -# available if none is online. +The tasks are going to be injected into a Queue. +It's a usefull way of storing information in our +program, while making sure that things are indeed printed. +It's also a way to prevent two concurrent connexions creating +a access conflict on a single printer, like two people wanting +to print at the same time. +We can also delay and store printing tasks until a printer becomes +available if none is online. +""" from abc import ABC, abstractmethod + ## See https://docs.python.org/3/library/abc.html to learn more about this # from dataclasses import dataclass from enum import Enum import uuid + ## You can expand this if you want to take other types of tasks into account class TaskType(Enum): + """ + The different tasks supported by the printers + """ TEXT = "text" IMAGE = "image" CUT = "cut" @@ -31,6 +37,7 @@ class PrintTask(ABC): """ A print task holds information about what we are looking to print. """ + def __init__(self, task_type): self.task_id = self._generate_id() self.task_type = task_type @@ -41,10 +48,10 @@ class PrintTask(ABC): @abstractmethod def get_print_data(self): """Return data formatted for printer""" - pass + def _generate_id(self): - # Generate unique task ID + # Generate unique task ID return str(uuid.uuid4()) @@ -52,18 +59,21 @@ class TextTask(PrintTask): """ This tasks represents a texte content, and it's signature. """ + def __init__(self, content, signature): super().__init__(TaskType.TEXT) self.content = content self.signature = signature def get_print_data(self): - return { "txt": self.content, "sign": self.signature } + return {"txt": self.content, "sign": self.signature} + class ImageTask(PrintTask): """ This tasks represents a image content ( in the form of it's path ), and it's signature. """ + def __init__(self, image_path, signature, process): super().__init__(TaskType.IMAGE) self.image_path = image_path @@ -72,7 +82,8 @@ class ImageTask(PrintTask): def get_print_data(self): # Return image data in printer-compatible format - return { "img": self.image_path, "sign": self.signature, "process" : self.process } + return {"img": self.image_path, "sign": self.signature, "process": self.process} + class CutTask(PrintTask): """ @@ -85,4 +96,4 @@ class CutTask(PrintTask): # There is no print data, # the task existence in itself is indication of what to do def get_print_data(self): - return None \ No newline at end of file + return None diff --git a/src/user.py b/src/user.py index a09b875..037d17a 100644 --- a/src/user.py +++ b/src/user.py @@ -1,41 +1,41 @@ -class User(object): - """docstring for User.""" +# class User(object): +# """docstring for User.""" - def __init__(self, arg): - super(User, self).__init__() - self.arg = arg +# def __init__(self, arg): +# super(User, self).__init__() +# self.arg = arg -# @app.route('/login', methods=['POST','GET']) -# @limiter.limit("100 per minute", error_message=error_handler_limiter) -def login(): - if request.method == "POST": - if not session.get("logged_in"): - if request.form["username"] and request.form["password"]: - # Get the json - with open("users.json") as f: - users_file = json.load(f) - for user in users_file["users"]: - if users_file["users"][user] == request.form["password"]: - session["logged_in"] = True - session["user"] = request.form["username"] +# # @app.route('/login', methods=['POST','GET']) +# # @limiter.limit("100 per minute", error_message=error_handler_limiter) +# def login(): +# if request.method == "POST": +# if not session.get("logged_in"): +# if request.form["username"] and request.form["password"]: +# # Get the json +# with open("users.json") as f: +# users_file = json.load(f) +# for user in users_file["users"]: +# if users_file["users"][user] == request.form["password"]: +# session["logged_in"] = True +# session["user"] = request.form["username"] - if not session.get("logged_in"): - flash("Mot de passe ou pseudo invalide.", "danger") - return redirect(url_for("login")) - else: - return redirect(url_for("display_index_page")) - else: - flash("Incorrect logins") - return render_template("password.html") - else: - return render_template("password.html") - else: - return render_template("password.html") +# if not session.get("logged_in"): +# flash("Mot de passe ou pseudo invalide.", "danger") +# return redirect(url_for("login")) +# else: +# return redirect(url_for("display_index_page")) +# else: +# flash("Incorrect logins") +# return render_template("password.html") +# else: +# return render_template("password.html") +# else: +# return render_template("password.html") -@app.route("/logout") -def logout(): - session["logged_in"] = False - flash("Tu est déconnecté", "info") - return redirect(url_for("login")) +# @app.route("/logout") +# def logout(): +# session["logged_in"] = False +# flash("Tu est déconnecté", "info") +# return redirect(url_for("login")) diff --git a/src/web.py b/src/web.py index 6aba3f2..e039462 100644 --- a/src/web.py +++ b/src/web.py @@ -30,7 +30,7 @@ class Web(object): except Exception as e: self.app.logger.error(e) raise RuntimeError("Could not add SMS to queue, " + str(e)) from e - self.app.logger.info("Added two new tasks at position %s and %s", sms, cut ) + self.app.logger.info("Added two new tasks at position %s and %s", sms, cut) return True def print_image(self, image, sign: str) -> bool: @@ -46,19 +46,22 @@ class Web(object): if file_uploaded: self.app.logger.debug("File has been uploaded, printing...") try: - img = self.print_queue.enqueue(ImageTask(os.path.join( - self.app.config["UPLOAD_FOLDER"], - secure_filename(image.filename), - ), - signature=sign, - process=True)) + img = self.print_queue.enqueue( + ImageTask( + os.path.join( + self.app.config["UPLOAD_FOLDER"], + secure_filename(image.filename), + ), + signature=sign, + process=True, + ) + ) cut = self.print_queue.enqueue(CutTask()) except Exception as e: raise RuntimeError("Could not add IMG to queue" + str(e)) from e - self.app.logger.info("Added two new tasks at position %s and %s", img, cut ) - + self.app.logger.info("Added two new tasks at position %s and %s", img, cut) return True @@ -96,10 +99,14 @@ class Web(object): ) return True else: - self.app.logger.error("Could not save file because the filename is forbidden") + self.app.logger.error( + "Could not save file because the filename is forbidden" + ) return False else: - self.app.logger.error("Could not save file, it seems to be null ? : " + str(filename)) + self.app.logger.error( + "Could not save file, it seems to be null ? : " + str(filename) + ) return False def get_queue_state(self): diff --git a/src/worker.py b/src/worker.py index 5efc936..5e5410f 100644 --- a/src/worker.py +++ b/src/worker.py @@ -4,7 +4,7 @@ import threading import time -from task import TaskType + class PrintWorker(threading.Thread): def __init__(self, app, print_queue, printer, socketio=None): @@ -14,7 +14,7 @@ class PrintWorker(threading.Thread): self.printer = printer self.socketio = socketio # Optional self.running = True - self.state = "idle" # idle, printing, dead, drinking-a-beer + self.state = "idle" # idle, printing, dead, drinking-a-beer self.app.logger.debug("Ho great, I'm alive... I'm ready to work another day...") @@ -22,23 +22,17 @@ class PrintWorker(threading.Thread): """Background thread that processes queue items""" self.app.logger.info("Worker started working.") while True: - if not self.running: + if not self.running or not self.printer.ready: time.sleep(0.2) continue - # TODO: This could be improved to simply no start - # the while loop as long as the printer is not ready. - # and maybe get out of it when the printer is not ready anymore ? - if not self.printer.ready: - self.app.logger.debug("Waiting for the printer to be ready...") - time.sleep(1) - continue - try: task = self.print_queue.dequeue() except Exception as e: self.app.logger.error("Could not get a new task ! %s ", str(e)) - raise RuntimeError("We could not get a new task because " + str(e)) from e + raise RuntimeError( + "We could not get a new task because " + str(e) + ) from e if task: try: @@ -51,7 +45,7 @@ class PrintWorker(threading.Thread): print_data = task.get_print_data() try: self.printer.print_task(task.task_type, print_data) - except Exception as e: + except RuntimeError as e: self.app.logger.error("Could not print : %s", str(e)) raise e @@ -59,7 +53,7 @@ class PrintWorker(threading.Thread): self.print_queue.mark_completed(task.task_id, "completed") self._emit_status(task.task_id, "completed") - except Exception as e: + except RuntimeError as e: task.status = "failed" self.print_queue.mark_completed(task.task_id, "failed") self._emit_status(task.task_id, "failed", error=str(e)) @@ -78,18 +72,19 @@ class PrintWorker(threading.Thread): data = { "task_id": task_id, "status": status, - "position": None # Task no longer in queue + "position": None, # Task no longer in queue } if error: data["error"] = error - self.socketio.emit('task_status', data, room=room) + self.socketio.emit("task_status", data, room=room) def stop_worker(self): """ Give the worker a break """ + self.app.logger.debug("Giving the worker a break") self.state = "drinking-a-beer" self.running = False @@ -97,6 +92,7 @@ class PrintWorker(threading.Thread): """ Get the worker back to it """ + self.app.logger.debug("Time to work !") self.state = "idle" self.running = True @@ -107,5 +103,5 @@ class PrintWorker(threading.Thread): return { "is_running": self.running, "queue_size": len(self.print_queue), - "state" : self.state - } \ No newline at end of file + "state": self.state, + } From 3b640dc54997472e86eb281c6006dce189ceaaa4 Mon Sep 17 00:00:00 2001 From: n07070 Date: Fri, 22 May 2026 10:43:09 +0200 Subject: [PATCH 14/21] Add comments about the code structure --- README.md | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/README.md b/README.md index ed7c1d8..7031657 100644 --- a/README.md +++ b/README.md @@ -79,6 +79,16 @@ Your contributions are very much welcome ! You can either request an account on Please also say if you had a printer to test your code, and which printer you've been using. +### Code structure + +The app is written about the Flask framework. You can start by looking at the code in the `src/` folder, in the `main.py` file. There, you will see that a few classes are initialized. In general, they are two parts to the program : + +The Web pages and the API, which are the user-facing parts. This is with what the users will interact, and define how the program is going to be used. The web pages are renderer from the `include/` folder where Jinj2 templates are defined. + +The Worker and Printer Queue are the internal parts. When a new thing needs to be printed, usually sent from the Web or API interfaces, a new Task in the type of the document is created, and added to a print queue. Then, a Worker thread looks up the state of the queue every so often and picks jobs to execute on the printers connected to the system. + +The last part of the program is the Raspberry Pi class, that handles to Photomaton mode, which handles button presses, and LED indicator and a flash. + ### Linting If you want to contribute code, please make sure to lint the project before commiting. This helps the code keep a general structure, and avoids some commons erros and mistakes. From 0c8c40098c3a30a16d83c3e312ac0b6c29731977 Mon Sep 17 00:00:00 2001 From: n07070 Date: Fri, 22 May 2026 10:43:38 +0200 Subject: [PATCH 15/21] Add docstring & comments, remove dead code --- src/main.py | 23 +++++++++++------------ 1 file changed, 11 insertions(+), 12 deletions(-) diff --git a/src/main.py b/src/main.py index 8999435..e68399a 100644 --- a/src/main.py +++ b/src/main.py @@ -101,9 +101,6 @@ app.config["TEMPLATES_AUTO_RELOAD"] = True # Printer connection # Uses the class defined in the printer.py file printer = Printer(app, 0x04B8, 0x0E28) -# printers = Printer(app) -# printers.discover_printers() -# printers.init() printer.init_printer() # Find out if we are running on a Raspberry Pi @@ -122,20 +119,19 @@ RASPBERRY_PI_CONNECTED = rpi.is_raspberry_pi() # Queue creation print_queue = PrintQueue(app) -# Web & API routes +# Web & API management web = Web(app, print_queue) # Start worker thread worker = PrintWorker(app, print_queue, printer, socketio) worker.start() +# The rate limit limiter = Limiter( get_remote_address, app=app, default_limits=["1500 per day", "500 per hour"] ) # General routes - - @app.route("/") @limiter.limit("1/second", override_defaults=False) def index(): @@ -153,8 +149,6 @@ def webcam(): # Form treatement - - @app.route("/web/print/sms", methods=["POST"]) @limiter.limit("6/minute", override_defaults=False) def web_print_sms(): @@ -185,7 +179,7 @@ def web_print_sms(): return redirect(url_for("index")) # end try - flash("The SMS has been printed !", "info") + flash("The SMS has been added to the print queue !", "info") return redirect(url_for("index")) @@ -227,7 +221,7 @@ def web_print_img(): flash("The image could not be printed because : " + str(e), "error") return redirect(url_for("index")) - flash("Picture printed !", "info") + flash("Picture added to the print queue !", "info") return redirect(url_for("index")) @@ -296,8 +290,7 @@ def api_print_image(): return "No image submitted", 400 file = request.files["img"] - # If the user does not select a file, the browser submits an - # empty file without a filename. + # If the user submits an empty file without a filename. if file.filename == "": app.logger.error("Submitted file has no filename !") return "Submitted file has no filename !", 400 @@ -337,12 +330,18 @@ def api_worker_state(): @app.route("/api/worker/start") def api_worker_start(): + """ + Enable to worker. This starts to process the print queue. + """ worker.start_worker() return jsonify(worker.current_state()) @app.route("/api/worker/stop") def api_worker_stop(): + """ + Stops the print queue. This stops the processing of the print queue. + """ worker.stop_worker() return jsonify(worker.current_state()) From cba34744f6786742184a6e729bf00238d99e058f Mon Sep 17 00:00:00 2001 From: n07070 Date: Fri, 22 May 2026 10:58:26 +0200 Subject: [PATCH 16/21] Update raspberry pi class to print via the print queue --- src/raspberry.py | 43 ++++++++++++++++++++++++++----------------- 1 file changed, 26 insertions(+), 17 deletions(-) diff --git a/src/raspberry.py b/src/raspberry.py index 772ea46..a75b401 100644 --- a/src/raspberry.py +++ b/src/raspberry.py @@ -1,3 +1,11 @@ +""" +This class executes when we are on a raspberry Pi. + +It handles the press of a button via GPIO, +activates a flash and prints out the picture +that was taken via a USB Webcam. +""" + import io # To check if we are on a Raspberry Pi import subprocess import os @@ -5,6 +13,7 @@ from time import sleep, gmtime, strftime from flask_socketio import SocketIO from gpiozero import Button, LED, DigitalOutputDevice from PIL import Image +from task import TextTask, ImageTask, CutTask class Raspberry(): """ @@ -18,7 +27,7 @@ class Raspberry(): def __init__( self, - printer, + print_queue, app, socketio, button_gpio_port_number, @@ -26,7 +35,7 @@ class Raspberry(): flash_gpio_port_number, is_flash_present, ): - self.printer = printer + self.print_queue = print_queue self.socketio = socketio self.app = app @@ -37,9 +46,13 @@ class Raspberry(): self.image_path = self.app.config["UPLOAD_FOLDER"] + "/image.jpg" def is_raspberry_pi(self, raise_on_errors=False): + """ + Checking if we are on a Raspberry Pi by checking + information on the /proc/cpuinfo file + """ # Check if we are running on a raspberry pi try: - with io.open("/proc/cpuinfo", "r") as cpuinfo: + with io.open("/proc/cpuinfo", "r", encoding="utf-8") as cpuinfo: found = False for line in cpuinfo: if line.startswith("Hardware"): @@ -140,7 +153,7 @@ class Raspberry(): f"Unable to take a picture. Error: {e.stderr.decode()}" ) return False - except Exception as e: + except RuntimeError as e: # Catch any unexpected errors self.app.logger.error(f"Unexpected error while taking picture: {str(e)}") return False @@ -197,7 +210,7 @@ class Raspberry(): output_path = image_path # Overwrite the original image if no output path is given image.save(output_path) - except Exception as e: + except RuntimeError as e: self.app.logger.error(f"Error overlaying logo: {e}") return False @@ -224,7 +237,7 @@ class Raspberry(): image.save(output_path) - except Exception as e: + except RuntimeError as e: self.app.logger.error(f"Error cropping image to square: {e}") return False @@ -241,7 +254,7 @@ class Raspberry(): try: self.flash.on() self.take_picture() - except Exception as e: + except RuntimeError as e: self.app.logger.error( "Could not take a picture after the button press : " + str(e) ) @@ -250,15 +263,11 @@ class Raspberry(): self.app.logger.debug("Printing picture") self.led.on() self.crop_to_square(self.image_path) - self.printer.print_img("src/static/images/extase-club.png", process=True) - self.printer.print_img(self.image_path, process=True) - self.printer.print_sms("") - self.printer.print_sms("With Love From Société.Vide", signature="", bold=True) - self.printer.print_sms("Printed by LittlePrynter", signature="") - self.printer.print_sms("n07070.xyz", signature="") - self.printer.print_sms(strftime("%Y-%m-%d %H:%M", gmtime()), signature="") - self.printer.qr("https://n07070.xyz/articles/littleprynter") - self.printer.cut() + self.print_queue.enqueue(ImageTask(self.image_path,signature="",process=True)) + self.print_queue.enqueue(TextTask(content="Imprimé par LittlePrynter", signature="")) + time = strftime("%Y-%m-%d %H:%M", gmtime()) + self.print_queue.enqueue(TextTask(content=time, signature="")) + self.print_queue.enqueue(CutTask()) self.led.off() - self.app.logger.debug("Done printing picture") + self.app.logger.debug("Added a photomaton picture to the print queue") return True From bc035508cd106ade20c525a46572fe1cf7d4ce99 Mon Sep 17 00:00:00 2001 From: n07070 Date: Fri, 22 May 2026 10:58:41 +0200 Subject: [PATCH 17/21] Update line lenght of docstring --- src/web.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/web.py b/src/web.py index e039462..1d77974 100644 --- a/src/web.py +++ b/src/web.py @@ -6,7 +6,8 @@ from task import TextTask, ImageTask, CutTask class Web(object): - """Web is the class that gets all of the information from web calls ( API and Web page ) and provides checks before sending stuff to printing""" + """Web is the class that gets all of the information from web calls + ( API and Web page ) and provides checks before sending stuff to printing""" def __init__(self, app, print_queue): super(Web).__init__() From eb9e1ec200aca58bd33343decad4b75ea41ebdbb Mon Sep 17 00:00:00 2001 From: n07070 Date: Tue, 26 May 2026 23:50:00 +0200 Subject: [PATCH 18/21] Remove code meant for another branch ( brother-ql code ) --- src/printer.py | 91 -------------------------------------------------- 1 file changed, 91 deletions(-) diff --git a/src/printer.py b/src/printer.py index fc1f148..82fa990 100644 --- a/src/printer.py +++ b/src/printer.py @@ -344,94 +344,3 @@ def _process_image(self, path): self.app.logger.debug("Processed and saved image.") return jpeg_path - - -def discover_printers(): - """ - We try to find all the connected printers ( 0 or n ) to this system. - - For every type of supported printer, we try to autodiscover them. - - http://www.linux-usb.org/usb.ids A list of USB vendor IDs - - 04b8 Seiko Epson Corp. - 04f9 Brother Industries, Ltd - """ - - -def find_and_parse_borther_ql_printer(): - - ## We might be able to no use this because there is a `discover` command in https://github.com/pklaus/brother_ql#usage - - ## Code stolen from https://framagit.org/stickoeur/diagnostickoeur/-/blob/no-masters/printit.py?ref_type=heads - - """Find and parse Brother QL printer information.""" - - model_manager = ModelsManager() - - # Debug print to show we're searching - # print("Searching for Brother QL printer...") - - for backend_name in ["pyusb", "linux_kernel"]: - try: - # print(f"Trying backend: {backend_name}") - backend = backend_factory(backend_name) - available_devices = backend["list_available_devices"]() - # print(f"Found {len(available_devices)} devices with {backend_name} backend") - - for printer in available_devices: - # print(f"Found device: {printer}") - identifier = printer["identifier"] - parts = identifier.split("/") - - if len(parts) < 4: - # print(f"Skipping device with invalid identifier format: {identifier}") - continue - - protocol = parts[0] - device_info = parts[2] - serial_number = parts[3] - - try: - vendor_id, product_id = device_info.split(":") - except ValueError: - # print(f"Invalid device info format: {device_info}") - continue - - # Default model - model = "QL-570" - - # Try to match product ID to determine actual model - try: - product_id_int = int(product_id, 16) - for m in model_manager.iter_elements(): - if m.product_id == product_id_int: - model = m.identifier - break - # print(f"Matched printer model: {model}") - except ValueError: - # print(f"Invalid product ID format: {product_id}") - continue - - printer_info = { - "identifier": identifier, - "backend": backend_name, - "model": model, - "protocol": protocol, - "vendor_id": vendor_id, - "product_id": product_id, - "serial_number": serial_number, - } - # print(f"Found printer: {printer_info}") - return printer_info - - except Exception as e: - # print(f"Error with backend {backend_name}: {str(e)}") - continue - - print("No Brother QL printer found") - return None - - -def fint_and_parse_epson_printer(): - pass From 934f766cf3b25298eb26e411cacf22ca4550beb9 Mon Sep 17 00:00:00 2001 From: n07070 Date: Tue, 26 May 2026 23:53:26 +0200 Subject: [PATCH 19/21] Update waiting time, update Exceptions --- src/printer.py | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/src/printer.py b/src/printer.py index 82fa990..bbd0514 100644 --- a/src/printer.py +++ b/src/printer.py @@ -69,7 +69,7 @@ class Printer(object): # TODO: This could happen directly when creating a new Printer class if os.getenv("FLASK_DEBUG"): - waiting_elapsed = 15 + waiting_elapsed = 3 else: waiting_elapsed = 10 @@ -82,19 +82,18 @@ class Printer(object): p = escpos.printer.Usb( self.device_id, self.vendor_id, 0, profile="TM-P80" ) - except Exception as e: + except RuntimeError as e: self.app.logger.error( "The USB device is not plugged in, trying again %s : %s", waiting_elapsed, str(e), ) - pass try: if p.is_online(): self.ready = True self.app.logger.debug("Printer online !") - except Exception as e: + except RuntimeError as e: self.app.logger.error( "Error while getting the printer online %s : %s", waiting_elapsed, @@ -154,7 +153,7 @@ class Printer(object): self.app.logger.warning( "Could not print message of this length: " + str(len(clean_msg)) ) - raise Exception( + raise RuntimeError( "Could not print message of this length :" + str(len(clean_msg)) + ", needs to be below 4096 caracters long." @@ -164,7 +163,7 @@ class Printer(object): self.app.logger.warning( "Could not print signature of this length: " + str(len(clean_signature)) ) - raise Exception( + raise RuntimeError( "Could not print signature of this length :" + str(len(clean_signature)) + ", needs to be below 256 caracters long." @@ -256,7 +255,7 @@ class Printer(object): self.printer.open(self.usb_args) self.printer.qr(content, center=True) self.printer.close() - except Exception as e: + except RuntimeError as e: self.printer.close() self.app.logger.error(str(e)) return False From 8134c5e892f657bed86b6bae3b8ff4e74bb867e1 Mon Sep 17 00:00:00 2001 From: n07070 Date: Tue, 26 May 2026 23:56:55 +0200 Subject: [PATCH 20/21] Improve linting of printer class --- src/printer.py | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/src/printer.py b/src/printer.py index bbd0514..66a781f 100644 --- a/src/printer.py +++ b/src/printer.py @@ -1,4 +1,6 @@ - +""" +This class manages connexion to a Printer +""" # import brother_ql from time import sleep import os.path @@ -10,7 +12,7 @@ import numpy as np import escpos.printer -class Printer(object): +class Printer(): """ # The connection is based on the ESC/POS library @@ -31,7 +33,7 @@ class Printer(object): ready = False def __init__(self, app, device_id, vendor_id): - super(Printer, self).__init__() + super().__init__() self.app = app self.ready = False self.printer = None @@ -99,7 +101,6 @@ class Printer(object): waiting_elapsed, str(e), ) - pass sleep(1) waiting_elapsed -= 1 @@ -207,8 +208,8 @@ class Printer(object): + str(path) + " wasn't found. Please try again." ) - else: - self.app.logger.debug("Printing file from " + str(path)) + + self.app.logger.debug("Printing file from " + str(path)) if process: try: @@ -309,7 +310,8 @@ def _process_image(self, path): self.app.logger.debug("Resized the image") # # Convert to grayscale for dithering - # dithered_img = original_img.convert("L").convert("1") # Dithering using default method (Floyd–Steinberg) + # dithered_img = original_img.convert("L").convert("1") + # Dithering using default method (Floyd–Steinberg) # self.app.logger.debug("Dithered the image") # Compute brightness of original image (grayscale average) From bbfe1936da1353bcd06ebe9949cf4161b1912b85 Mon Sep 17 00:00:00 2001 From: n07070 Date: Tue, 26 May 2026 23:58:47 +0200 Subject: [PATCH 21/21] Remove unused import --- src/task.py | 1 - 1 file changed, 1 deletion(-) diff --git a/src/task.py b/src/task.py index a55baad..2962618 100644 --- a/src/task.py +++ b/src/task.py @@ -18,7 +18,6 @@ from abc import ABC, abstractmethod ## See https://docs.python.org/3/library/abc.html to learn more about this -# from dataclasses import dataclass from enum import Enum import uuid