Drucker wird in der App gewaehlt, nicht auf dem Pi
Deploy auf den Timer-Server / deploy (push) Successful in 20s
Deploy auf den Timer-Server / deploy (push) Successful in 20s
Das Einrichtungsskript fragte bisher am Pi, welcher Drucker bedient werden soll. Damit stand die Einstellung an einem Ort, an den man nur mit einem Terminal kommt - und ein zweiter Drucker am Pi bedeutete: Skript nochmal. Jetzt fragt die App den Pi, was angeschlossen ist, und der Bediener waehlt in den Einstellungen. Die Bruecke bekam dafuer /devices; sie liest die Klartextnamen aus dem sysfs, damit dort "EPSON TM-T88IV" steht und nicht "lp0" - bei zwei Druckern der Unterschied zwischen Wissen und Raten. Der gewaehlte Pfad geht bei jedem Auftrag im Kopf X-Print-Device mit. Die Bruecke haelt dazu bewusst keinen Zustand und das Skript schreibt kein PRINT_DEVICE mehr: es soll genau eine Stelle geben, die weiss, welcher Drucker gemeint ist, naemlich die, an der es bedient wird. Leer bleibt "automatisch" - das erste gefundene Geraet, zugleich der Rueckfall, wenn aus lp0 nach dem Umstecken ein lp1 geworden ist. Der Pfad kommt damit von aussen und wird an beiden Enden geprueft, in PUT /api/settings und noch einmal in der Bruecke. Eine Schranke, die nur an einem Ende steht, ist keine: ohne die Pruefung auf dem Pi liesse sich der Dienst dazu bringen, in eine beliebige Datei zu schreiben. Nebenbei: ein nicht bereiter Drucker meldete sich in der Oberflaeche als "HTTP 503". Das verriet niemandem, dass nur ein Stecker lose ist. Die 503 der Bruecke ist kein Protokollfehler, und ihr Rumpf sagt, was fehlt - der wird jetzt ausgewertet. Geprueft am echten Pi (Debian 13, TM-T88IV): Einrichtung ohne Rueckfrage, Geraeteliste mit Namen, ausdrueckliche Wahl, Druck darauf, Rueckkehr auf automatisch, Druck darauf. Dazu die Abweise: /etc/passwd und ein Pfad mit angehaengtem Befehl werden zurueckgewiesen, ein erlaubtes aber fehlendes /dev/usb/lp7 ergibt eine Meldung im Klartext. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
This commit is contained in:
1 parent
e68daee457
commit
0e8d826bce
10 files changed
+412
-104
No files matched your search
@@ -10,12 +10,21 @@ Geraet. Die Timer-App baut den Bon, der Pi druckt ihn nur noch.
|
||||
Bewusst nur Python-Standardbibliothek: auf dem Pi muss dafuer nichts
|
||||
nachinstalliert werden (kein pip, kein CUPS, kein node).
|
||||
|
||||
Welcher Drucker genommen wird, entscheidet die Timer-App: sie fragt ueber
|
||||
/devices ab, was angeschlossen ist, und schickt den gewaehlten Pfad bei jedem
|
||||
Auftrag im Kopf X-Print-Device mit. Dieser Dienst haelt dazu keinen Zustand -
|
||||
die Einstellung lebt an einer Stelle, naemlich dort, wo sie bedient wird.
|
||||
|
||||
Endpunkte
|
||||
GET /status Zustand des Druckers als JSON (fuer Health-Checks)
|
||||
GET /devices angeschlossene Drucker mit Klartextnamen (Token noetig)
|
||||
POST /print Rumpf = rohe ESC/POS-Bytes, wird 1:1 an den Drucker gereicht
|
||||
|
||||
/status und /print beachten den Kopf X-Print-Device. Fehlt er, wird das
|
||||
eingestellte Geraet genommen und sonst das erste gefundene.
|
||||
|
||||
Konfiguration ueber Umgebungsvariablen (siehe bondrucker.service):
|
||||
PRINT_DEVICE Geraetedatei, Standard /dev/usb/lp0
|
||||
PRINT_DEVICE Rueckfall, wenn die App nichts vorgibt; Standard /dev/usb/lp0
|
||||
PRINT_HOST Lausch-Adresse, Standard 0.0.0.0
|
||||
PRINT_PORT Lausch-Port, Standard 9100
|
||||
PRINT_TOKEN gemeinsames Geheimnis; leer = ohne Anmeldung (nur im LAN!)
|
||||
@@ -26,15 +35,21 @@ import glob
|
||||
import hmac
|
||||
import json
|
||||
import os
|
||||
import re
|
||||
import socketserver
|
||||
import sys
|
||||
import threading
|
||||
import time
|
||||
from http.server import BaseHTTPRequestHandler, ThreadingHTTPServer
|
||||
|
||||
VERSION = "1.1"
|
||||
VERSION = "1.2"
|
||||
|
||||
DEVICE = os.environ.get("PRINT_DEVICE", "/dev/usb/lp0")
|
||||
|
||||
# Welcher Drucker genommen wird, entscheidet die Timer-App und schickt es bei
|
||||
# jedem Auftrag mit. Der Pfad kommt damit von aussen - ohne diese Schranke
|
||||
# liesse sich der Dienst dazu bringen, in eine beliebige Datei zu schreiben.
|
||||
DEVICE_MUSTER = re.compile(r"^/dev/(usb/)?lp[0-9]{1,3}$")
|
||||
HOST = os.environ.get("PRINT_HOST", "0.0.0.0")
|
||||
PORT = int(os.environ.get("PRINT_PORT", "9100"))
|
||||
TOKEN = os.environ.get("PRINT_TOKEN", "").strip()
|
||||
@@ -52,21 +67,87 @@ def log(msg):
|
||||
print(msg, flush=True)
|
||||
|
||||
|
||||
def find_device():
|
||||
"""Konfiguriertes Geraet, sonst das erste vorhandene /dev/usb/lp*.
|
||||
def _lies(pfad):
|
||||
try:
|
||||
with open(pfad) as f:
|
||||
return f.read().strip()
|
||||
except OSError:
|
||||
return ""
|
||||
|
||||
Nach dem Aus- und Wiedereinstecken des USB-Kabels kann aus lp0 ein lp1
|
||||
werden. Ohne diesen Fallback druckt danach nichts mehr, bis jemand den
|
||||
Dienst anfasst.
|
||||
|
||||
def usb_name(geraet):
|
||||
"""Klartextname eines USB-Druckers, etwa "EPSON TM-T88IV".
|
||||
|
||||
Dahinter steckt ein Aufstieg im sysfs: die Geraetedatei zeigt auf die
|
||||
USB-Schnittstelle, die Bezeichnungen haengen aber am Geraet darueber.
|
||||
Ohne diesen Namen steht in der Auswahl nur "lp0" und "lp1" - bei zwei
|
||||
Druckern ist das Raten.
|
||||
"""
|
||||
basis = os.path.basename(geraet)
|
||||
start = "/sys/class/usbmisc/%s/device" % basis
|
||||
if not os.path.exists(start):
|
||||
start = "/sys/class/printer/%s/device" % basis
|
||||
if not os.path.exists(start):
|
||||
return ""
|
||||
|
||||
pfad = os.path.realpath(start)
|
||||
while pfad and pfad != "/":
|
||||
if os.path.isfile(os.path.join(pfad, "product")):
|
||||
name = _lies(os.path.join(pfad, "manufacturer")) + " " + \
|
||||
_lies(os.path.join(pfad, "product"))
|
||||
return " ".join(name.split())
|
||||
pfad = os.path.dirname(pfad)
|
||||
return ""
|
||||
|
||||
|
||||
def list_devices():
|
||||
"""Alle angeschlossenen Druckergeraete - die Auswahl fuer die Timer-App."""
|
||||
pfade = sorted(set(glob.glob("/dev/usb/lp*")) | set(glob.glob("/dev/lp*")))
|
||||
return [
|
||||
{
|
||||
"path": p,
|
||||
"name": usb_name(p),
|
||||
"writable": os.access(p, os.W_OK),
|
||||
}
|
||||
for p in pfade
|
||||
if DEVICE_MUSTER.match(p)
|
||||
]
|
||||
|
||||
|
||||
def find_device(requested=None):
|
||||
"""Welches Geraet bedient werden soll.
|
||||
|
||||
Mit Angabe: genau dieses, sofern der Pfad ueberhaupt ein Druckergeraet sein
|
||||
kann. Ohne Angabe das eingestellte, und wenn es das nicht gibt, das erste
|
||||
vorhandene - nach dem Aus- und Wiedereinstecken des USB-Kabels kann aus lp0
|
||||
naemlich ein lp1 werden, und ohne diesen Rueckfall druckt danach nichts
|
||||
mehr, bis jemand den Dienst anfasst.
|
||||
"""
|
||||
if requested:
|
||||
if not DEVICE_MUSTER.match(requested):
|
||||
raise ValueError("Unerlaubter Geraetepfad: %s" % requested)
|
||||
return requested
|
||||
if os.path.exists(DEVICE):
|
||||
return DEVICE
|
||||
found = sorted(glob.glob("/dev/usb/lp*"))
|
||||
return found[0] if found else None
|
||||
|
||||
|
||||
def device_status(token_accepted=None):
|
||||
dev = find_device()
|
||||
def device_status(token_accepted=None, requested=None):
|
||||
try:
|
||||
dev = find_device(requested)
|
||||
except ValueError as err:
|
||||
return {
|
||||
"ok": False,
|
||||
"version": VERSION,
|
||||
"tokenRequired": bool(TOKEN),
|
||||
"tokenAccepted": token_accepted,
|
||||
"device": requested,
|
||||
"deviceExists": False,
|
||||
"writable": False,
|
||||
"lastError": str(err),
|
||||
"lastPrintAt": _last_ok,
|
||||
}
|
||||
status = {
|
||||
"ok": False,
|
||||
"version": VERSION,
|
||||
@@ -79,23 +160,24 @@ def device_status(token_accepted=None):
|
||||
"tokenAccepted": token_accepted,
|
||||
"device": dev or DEVICE,
|
||||
"deviceConfigured": DEVICE,
|
||||
"deviceExists": dev is not None,
|
||||
"deviceRequested": requested or None,
|
||||
"deviceExists": dev is not None and os.path.exists(dev),
|
||||
"writable": False,
|
||||
"lastError": _last_error,
|
||||
"lastPrintAt": _last_ok,
|
||||
}
|
||||
if dev:
|
||||
if dev and os.path.exists(dev):
|
||||
status["writable"] = os.access(dev, os.W_OK)
|
||||
status["ok"] = status["writable"]
|
||||
return status
|
||||
|
||||
|
||||
def write_to_printer(data):
|
||||
def write_to_printer(data, requested=None):
|
||||
"""Schreibt einen Auftrag auf den Drucker. Wirft bei Fehlern OSError."""
|
||||
global _last_error, _last_ok
|
||||
|
||||
with _print_lock:
|
||||
dev = find_device()
|
||||
dev = find_device(requested)
|
||||
if dev is None:
|
||||
raise OSError("Kein Druckergeraet gefunden (/dev/usb/lp*). Kabel? Strom?")
|
||||
|
||||
@@ -133,16 +215,29 @@ class Handler(BaseHTTPRequestHandler):
|
||||
self.wfile.write(body)
|
||||
|
||||
def do_GET(self):
|
||||
if self.path.rstrip("/") in ("/status", "/health", ""):
|
||||
st = device_status(token_ok(self.headers.get("X-Print-Token")))
|
||||
pfad = self.path.split("?")[0].rstrip("/")
|
||||
|
||||
if pfad in ("/status", "/health", ""):
|
||||
st = device_status(
|
||||
token_ok(self.headers.get("X-Print-Token")),
|
||||
self.headers.get("X-Print-Device"),
|
||||
)
|
||||
self._send(200 if st["ok"] else 503, st)
|
||||
|
||||
elif pfad == "/devices":
|
||||
# Anders als /status mit Token: welche Geraete am Pi haengen, ist
|
||||
# zwar kein Geheimnis, aber auch keine Auskunft fuer jeden im Netz.
|
||||
if not token_ok(self.headers.get("X-Print-Token")):
|
||||
return self._send(403, {"ok": False, "error": "Token ungueltig"})
|
||||
self._send(200, {"ok": True, "devices": list_devices(), "fallback": find_device()})
|
||||
|
||||
else:
|
||||
self._send(404, {"ok": False, "error": "Unbekannter Pfad"})
|
||||
|
||||
def do_POST(self):
|
||||
global _last_error
|
||||
|
||||
if self.path.rstrip("/") != "/print":
|
||||
if self.path.split("?")[0].rstrip("/") != "/print":
|
||||
return self._send(404, {"ok": False, "error": "Unbekannter Pfad"})
|
||||
|
||||
if not token_ok(self.headers.get("X-Print-Token")):
|
||||
@@ -162,7 +257,10 @@ class Handler(BaseHTTPRequestHandler):
|
||||
data = self.rfile.read(length)
|
||||
|
||||
try:
|
||||
written = write_to_printer(data)
|
||||
written = write_to_printer(data, self.headers.get("X-Print-Device"))
|
||||
except ValueError as err:
|
||||
log("[abgelehnt] %s" % err)
|
||||
return self._send(400, {"ok": False, "error": str(err)})
|
||||
except OSError as err:
|
||||
_last_error = str(err)
|
||||
log(f"[fehler] {self.client_address[0]}: {err}")
|
||||
@@ -186,6 +284,8 @@ def main():
|
||||
st = device_status()
|
||||
log(f"Bondrucker-Bruecke {VERSION}")
|
||||
log(f" Geraet: {st['device']} (vorhanden: {st['deviceExists']}, beschreibbar: {st['writable']})")
|
||||
for g in list_devices():
|
||||
log(f" gefunden: {g['path']} {g['name']}")
|
||||
log(f" Lauscht: {HOST}:{PORT}")
|
||||
log(f" Token: {'gesetzt' if TOKEN else 'NICHT gesetzt - jeder im Netz darf drucken'}")
|
||||
|
||||
|
||||
Reference in new issue
Block a user