print_queue.py 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842
  1. """API routes for print queue management."""
  2. import json
  3. import logging
  4. import zipfile
  5. from datetime import datetime, timezone
  6. from pathlib import Path
  7. import defusedxml.ElementTree as ET
  8. from fastapi import APIRouter, Depends, HTTPException, Query
  9. from sqlalchemy import and_, func, or_, select
  10. from sqlalchemy.ext.asyncio import AsyncSession
  11. from sqlalchemy.orm import selectinload
  12. from backend.app.core.auth import RequirePermissionIfAuthEnabled, require_ownership_permission
  13. from backend.app.core.config import settings
  14. from backend.app.core.database import get_db
  15. from backend.app.core.permissions import Permission
  16. from backend.app.models.archive import PrintArchive
  17. from backend.app.models.library import LibraryFile
  18. from backend.app.models.print_queue import PrintQueueItem
  19. from backend.app.models.printer import Printer
  20. from backend.app.models.user import User
  21. from backend.app.schemas.print_queue import (
  22. PrintQueueBulkUpdate,
  23. PrintQueueBulkUpdateResponse,
  24. PrintQueueItemCreate,
  25. PrintQueueItemResponse,
  26. PrintQueueItemUpdate,
  27. PrintQueueReorder,
  28. )
  29. from backend.app.services.notification_service import notification_service
  30. from backend.app.utils.printer_models import normalize_printer_model, normalize_printer_model_id
  31. from backend.app.utils.threemf_tools import extract_filament_usage_from_3mf
  32. logger = logging.getLogger(__name__)
  33. router = APIRouter(prefix="/queue", tags=["queue"])
  34. def _extract_filament_types_from_3mf(file_path: Path, plate_id: int | None = None) -> list[str]:
  35. """Extract unique filament types from a 3MF file.
  36. Args:
  37. file_path: Path to the 3MF file
  38. plate_id: Optional plate index to filter for (for multi-plate files)
  39. Returns:
  40. List of unique filament types (e.g., ["PLA", "PETG"])
  41. """
  42. types: set[str] = set()
  43. try:
  44. with zipfile.ZipFile(file_path, "r") as zf:
  45. if "Metadata/slice_info.config" not in zf.namelist():
  46. return []
  47. content = zf.read("Metadata/slice_info.config").decode()
  48. root = ET.fromstring(content)
  49. if plate_id is not None:
  50. # Find the plate element with matching index
  51. for plate_elem in root.findall(".//plate"):
  52. plate_index = None
  53. for meta in plate_elem.findall("metadata"):
  54. if meta.get("key") == "index":
  55. try:
  56. plate_index = int(meta.get("value", "0"))
  57. except ValueError:
  58. pass # Skip plate with unparseable index
  59. break
  60. if plate_index == plate_id:
  61. for filament_elem in plate_elem.findall("filament"):
  62. filament_type = filament_elem.get("type", "")
  63. used_g = filament_elem.get("used_g", "0")
  64. try:
  65. used_grams = float(used_g)
  66. except (ValueError, TypeError):
  67. used_grams = 0
  68. if used_grams > 0 and filament_type:
  69. types.add(filament_type)
  70. break
  71. else:
  72. # No plate_id specified - extract all filaments with used_g > 0
  73. for filament_elem in root.findall(".//filament"):
  74. filament_type = filament_elem.get("type", "")
  75. used_g = filament_elem.get("used_g", "0")
  76. try:
  77. used_grams = float(used_g)
  78. except (ValueError, TypeError):
  79. used_grams = 0
  80. if used_grams > 0 and filament_type:
  81. types.add(filament_type)
  82. except Exception as e:
  83. logger.warning("Failed to extract filament types from %s: %s", file_path, e)
  84. return sorted(types)
  85. def _extract_print_time_from_3mf(file_path: Path, plate_id: int | None = None) -> int | None:
  86. """Extract print time (prediction) from a 3MF file.
  87. Args:
  88. file_path: Path to the 3MF file
  89. plate_id: Optional plate index to filter for (for multi-plate files)
  90. Returns:
  91. Print time in seconds, or None if not found
  92. """
  93. try:
  94. with zipfile.ZipFile(file_path, "r") as zf:
  95. if "Metadata/slice_info.config" not in zf.namelist():
  96. return None
  97. content = zf.read("Metadata/slice_info.config").decode()
  98. root = ET.fromstring(content)
  99. if plate_id is not None:
  100. for plate_elem in root.findall(".//plate"):
  101. plate_index = None
  102. for meta in plate_elem.findall("metadata"):
  103. if meta.get("key") == "index":
  104. try:
  105. plate_index = int(meta.get("value", "0"))
  106. except ValueError:
  107. pass # Skip plate with unparseable index
  108. break
  109. if plate_index == plate_id:
  110. for meta in plate_elem.findall("metadata"):
  111. if meta.get("key") == "prediction":
  112. try:
  113. return int(meta.get("value", "0"))
  114. except ValueError:
  115. return None
  116. break
  117. else:
  118. plate_elem = root.find(".//plate")
  119. if plate_elem is not None:
  120. for meta in plate_elem.findall("metadata"):
  121. if meta.get("key") == "prediction":
  122. try:
  123. return int(meta.get("value", "0"))
  124. except ValueError:
  125. return None
  126. except Exception as e:
  127. logger.warning("Failed to extract print time from %s: %s", file_path, e)
  128. return None
  129. def _enrich_response(item: PrintQueueItem) -> PrintQueueItemResponse:
  130. """Add nested archive/printer/library_file info to response."""
  131. # Parse ams_mapping from JSON string BEFORE model_validate
  132. ams_mapping_parsed = None
  133. if item.ams_mapping:
  134. try:
  135. ams_mapping_parsed = json.loads(item.ams_mapping)
  136. except json.JSONDecodeError:
  137. ams_mapping_parsed = None
  138. # Parse required_filament_types from JSON string
  139. required_filament_types_parsed = None
  140. if item.required_filament_types:
  141. try:
  142. required_filament_types_parsed = json.loads(item.required_filament_types)
  143. except json.JSONDecodeError:
  144. required_filament_types_parsed = None
  145. # Parse filament_overrides from JSON string
  146. filament_overrides_parsed = None
  147. if item.filament_overrides:
  148. try:
  149. filament_overrides_parsed = json.loads(item.filament_overrides)
  150. except json.JSONDecodeError:
  151. filament_overrides_parsed = None
  152. # Create response with parsed ams_mapping
  153. item_dict = {
  154. "id": item.id,
  155. "printer_id": item.printer_id,
  156. "target_model": item.target_model,
  157. "target_location": item.target_location,
  158. "required_filament_types": required_filament_types_parsed,
  159. "filament_overrides": filament_overrides_parsed,
  160. "waiting_reason": item.waiting_reason,
  161. "archive_id": item.archive_id,
  162. "library_file_id": item.library_file_id,
  163. "position": item.position,
  164. "scheduled_time": item.scheduled_time,
  165. "require_previous_success": item.require_previous_success,
  166. "auto_off_after": item.auto_off_after,
  167. "manual_start": item.manual_start,
  168. "ams_mapping": ams_mapping_parsed,
  169. "plate_id": item.plate_id,
  170. "bed_levelling": item.bed_levelling,
  171. "flow_cali": item.flow_cali,
  172. "vibration_cali": item.vibration_cali,
  173. "layer_inspect": item.layer_inspect,
  174. "timelapse": item.timelapse,
  175. "use_ams": item.use_ams,
  176. "status": item.status,
  177. "started_at": item.started_at,
  178. "completed_at": item.completed_at,
  179. "error_message": item.error_message,
  180. "created_at": item.created_at,
  181. # User tracking (Issue #206)
  182. "created_by_id": item.created_by_id,
  183. "created_by_username": item.created_by.username if item.created_by else None,
  184. }
  185. response = PrintQueueItemResponse(**item_dict)
  186. if item.archive:
  187. response.archive_name = item.archive.print_name or item.archive.filename
  188. response.archive_thumbnail = item.archive.thumbnail_path
  189. response.print_time_seconds = item.archive.print_time_seconds
  190. response.filament_used_grams = item.archive.filament_used_grams
  191. if item.plate_id:
  192. archive_path = settings.base_dir / item.archive.file_path
  193. if archive_path.exists():
  194. plate_time = _extract_print_time_from_3mf(archive_path, item.plate_id)
  195. plate_weight = sum(f["used_g"] for f in extract_filament_usage_from_3mf(archive_path, item.plate_id))
  196. if plate_time is not None:
  197. response.print_time_seconds = plate_time
  198. if plate_weight > 0:
  199. response.filament_used_grams = plate_weight
  200. if item.library_file:
  201. response.library_file_name = (
  202. item.library_file.file_metadata.get("print_name") if item.library_file.file_metadata else None
  203. )
  204. if not response.library_file_name:
  205. response.library_file_name = item.library_file.filename
  206. response.library_file_thumbnail = item.library_file.thumbnail_path
  207. # Get print time from library file metadata if no archive
  208. if not item.archive and item.library_file.file_metadata:
  209. response.print_time_seconds = item.library_file.file_metadata.get("print_time_seconds")
  210. response.filament_used_grams = item.library_file.file_metadata.get("filament_used_grams")
  211. if item.plate_id:
  212. lib_path = Path(item.library_file.file_path)
  213. library_file_path = lib_path if lib_path.is_absolute() else settings.base_dir / item.library_file.file_path
  214. if library_file_path.exists():
  215. plate_time = _extract_print_time_from_3mf(library_file_path, item.plate_id)
  216. plate_weight = sum(
  217. f["used_g"] for f in extract_filament_usage_from_3mf(library_file_path, item.plate_id)
  218. )
  219. if plate_time is not None:
  220. response.print_time_seconds = plate_time
  221. if plate_weight > 0:
  222. response.filament_used_grams = plate_weight
  223. if item.printer:
  224. response.printer_name = item.printer.name
  225. return response
  226. @router.get("/", response_model=list[PrintQueueItemResponse])
  227. async def list_queue(
  228. printer_id: int | None = Query(None, description="Filter by printer (-1 for unassigned)"),
  229. status: str | None = Query(None, description="Filter by status"),
  230. target_model: str | None = Query(
  231. None, description="Filter by target model (also includes model-based items when combined with printer_id)"
  232. ),
  233. db: AsyncSession = Depends(get_db),
  234. _: User | None = RequirePermissionIfAuthEnabled(Permission.QUEUE_READ),
  235. ):
  236. """List all queue items, optionally filtered by printer or status."""
  237. query = (
  238. select(PrintQueueItem)
  239. .options(
  240. selectinload(PrintQueueItem.archive),
  241. selectinload(PrintQueueItem.printer),
  242. selectinload(PrintQueueItem.library_file),
  243. selectinload(PrintQueueItem.created_by),
  244. )
  245. .order_by(PrintQueueItem.printer_id.nulls_first(), PrintQueueItem.position)
  246. )
  247. if printer_id is not None:
  248. if printer_id == -1:
  249. # Special value: filter for unassigned items
  250. query = query.where(PrintQueueItem.printer_id.is_(None))
  251. else:
  252. # Resolve effective model: prefer explicit param, fall back to printer's DB model.
  253. # This ensures model-based "Any X" items are returned even when the frontend
  254. # doesn't send target_model (e.g. printer.model is NULL on the client side).
  255. effective_model = target_model
  256. if not effective_model:
  257. printer_row = (
  258. await db.execute(select(Printer.model).where(Printer.id == printer_id))
  259. ).scalar_one_or_none()
  260. effective_model = printer_row
  261. if effective_model:
  262. # Include both printer-specific items AND model-based (unassigned) items
  263. query = query.where(
  264. or_(
  265. PrintQueueItem.printer_id == printer_id,
  266. and_(
  267. PrintQueueItem.printer_id.is_(None),
  268. func.lower(PrintQueueItem.target_model) == effective_model.lower(),
  269. ),
  270. )
  271. )
  272. else:
  273. query = query.where(PrintQueueItem.printer_id == printer_id)
  274. elif target_model:
  275. query = query.where(func.lower(PrintQueueItem.target_model) == target_model.lower())
  276. if status:
  277. query = query.where(PrintQueueItem.status == status)
  278. result = await db.execute(query)
  279. items = result.scalars().all()
  280. return [_enrich_response(item) for item in items]
  281. @router.post("/", response_model=PrintQueueItemResponse)
  282. async def add_to_queue(
  283. data: PrintQueueItemCreate,
  284. db: AsyncSession = Depends(get_db),
  285. current_user: User | None = RequirePermissionIfAuthEnabled(Permission.QUEUE_CREATE),
  286. ):
  287. """Add an item to the print queue."""
  288. # Normalize target_model (e.g., "Bambu Lab X1E" / "C13" -> "X1E")
  289. target_model_norm = None
  290. if data.target_model:
  291. target_model_norm = (
  292. normalize_printer_model(data.target_model)
  293. or normalize_printer_model_id(data.target_model)
  294. or data.target_model
  295. )
  296. # Validate that either archive_id or library_file_id is provided
  297. if not data.archive_id and not data.library_file_id:
  298. raise HTTPException(400, "Either archive_id or library_file_id must be provided")
  299. # Cannot specify both printer_id and target_model
  300. if data.printer_id and target_model_norm:
  301. raise HTTPException(400, "Cannot specify both printer_id and target_model")
  302. # Validate printer exists (if assigned)
  303. if data.printer_id is not None:
  304. result = await db.execute(select(Printer).where(Printer.id == data.printer_id))
  305. if not result.scalar_one_or_none():
  306. raise HTTPException(400, "Printer not found")
  307. # Validate target_model has active printers
  308. if target_model_norm:
  309. result = await db.execute(
  310. select(Printer).where(Printer.model == target_model_norm).where(Printer.is_active == True) # noqa: E712
  311. )
  312. if not result.scalars().first():
  313. raise HTTPException(400, f"No active printers for model: {target_model_norm}")
  314. # Validate archive exists (if provided) and get it for filament extraction
  315. archive = None
  316. if data.archive_id:
  317. result = await db.execute(select(PrintArchive).where(PrintArchive.id == data.archive_id))
  318. archive = result.scalar_one_or_none()
  319. if not archive:
  320. raise HTTPException(400, "Archive not found")
  321. # Validate library file exists (if provided) and get it for filament extraction
  322. library_file = None
  323. if data.library_file_id:
  324. result = await db.execute(select(LibraryFile).where(LibraryFile.id == data.library_file_id))
  325. library_file = result.scalar_one_or_none()
  326. if not library_file:
  327. raise HTTPException(400, "Library file not found")
  328. # Extract filament types for model-based assignment (used by scheduler for validation)
  329. required_filament_types = None
  330. if target_model_norm:
  331. # Get file path from archive or library file
  332. file_path = None
  333. if archive:
  334. file_path = settings.base_dir / archive.file_path
  335. elif library_file:
  336. lib_path = Path(library_file.file_path)
  337. file_path = lib_path if lib_path.is_absolute() else settings.base_dir / library_file.file_path
  338. if file_path and file_path.exists():
  339. filament_types = _extract_filament_types_from_3mf(file_path, data.plate_id)
  340. if filament_types:
  341. required_filament_types = json.dumps(filament_types)
  342. logger.info("Extracted filament types for model-based queue: %s", filament_types)
  343. # If filament overrides are provided, update required_filament_types to match override types
  344. filament_overrides_json = None
  345. if data.filament_overrides and target_model_norm:
  346. filament_overrides_json = json.dumps(data.filament_overrides)
  347. # Update required_filament_types from overrides so scheduler validates against overridden types
  348. override_types = sorted({o["type"] for o in data.filament_overrides if "type" in o})
  349. if override_types:
  350. # Merge with existing types (overrides may only cover some slots)
  351. existing_types = set(json.loads(required_filament_types)) if required_filament_types else set()
  352. # Replace types for overridden slots, keep others
  353. all_types = existing_types | set(override_types)
  354. required_filament_types = json.dumps(sorted(all_types))
  355. # Get next position for this printer (or for unassigned/model-based items)
  356. if data.printer_id is not None:
  357. result = await db.execute(
  358. select(func.max(PrintQueueItem.position))
  359. .where(PrintQueueItem.printer_id == data.printer_id)
  360. .where(PrintQueueItem.status == "pending")
  361. )
  362. else:
  363. # For unassigned/model-based items, get max position across all unassigned
  364. result = await db.execute(
  365. select(func.max(PrintQueueItem.position))
  366. .where(PrintQueueItem.printer_id.is_(None))
  367. .where(PrintQueueItem.status == "pending")
  368. )
  369. max_pos = result.scalar() or 0
  370. item = PrintQueueItem(
  371. printer_id=data.printer_id,
  372. target_model=target_model_norm,
  373. target_location=data.target_location,
  374. required_filament_types=required_filament_types,
  375. filament_overrides=filament_overrides_json,
  376. archive_id=data.archive_id,
  377. library_file_id=data.library_file_id,
  378. scheduled_time=data.scheduled_time,
  379. require_previous_success=data.require_previous_success,
  380. auto_off_after=data.auto_off_after,
  381. manual_start=data.manual_start,
  382. ams_mapping=json.dumps(data.ams_mapping) if data.ams_mapping else None,
  383. plate_id=data.plate_id,
  384. bed_levelling=data.bed_levelling,
  385. flow_cali=data.flow_cali,
  386. vibration_cali=data.vibration_cali,
  387. layer_inspect=data.layer_inspect,
  388. timelapse=data.timelapse,
  389. use_ams=data.use_ams,
  390. position=max_pos + 1,
  391. status="pending",
  392. created_by_id=current_user.id if current_user else None,
  393. )
  394. db.add(item)
  395. await db.commit()
  396. await db.refresh(item)
  397. # Load relationships for response
  398. await db.refresh(item, ["archive", "printer", "library_file", "created_by"])
  399. source_name = f"archive {data.archive_id}" if data.archive_id else f"library file {data.library_file_id}"
  400. target_desc = data.printer_id or (f"model {target_model_norm}" if target_model_norm else "unassigned")
  401. logger.info("Added %s to queue for %s", source_name, target_desc)
  402. # MQTT relay - publish queue job added
  403. try:
  404. from backend.app.services.mqtt_relay import mqtt_relay
  405. await mqtt_relay.on_queue_job_added(
  406. job_id=item.id,
  407. filename=item.archive.filename if item.archive else "",
  408. printer_id=item.printer_id,
  409. printer_name=item.printer.name if item.printer else None,
  410. )
  411. except Exception:
  412. pass # Don't fail queue add if MQTT fails
  413. # Send notification for job added
  414. try:
  415. job_name = (
  416. item.archive.filename
  417. if item.archive
  418. else item.library_file.filename
  419. if item.library_file
  420. else f"Job #{item.id}"
  421. )
  422. job_name = job_name.replace(".gcode.3mf", "").replace(".3mf", "")
  423. target = (
  424. item.printer.name if item.printer else (f"Any {item.target_model}" if target_model_norm else "Unassigned")
  425. )
  426. await notification_service.on_queue_job_added(
  427. job_name=job_name,
  428. target=target,
  429. db=db,
  430. printer_id=item.printer_id,
  431. printer_name=item.printer.name if item.printer else None,
  432. )
  433. except Exception:
  434. pass # Don't fail queue add if notification fails
  435. return _enrich_response(item)
  436. @router.patch("/bulk", response_model=PrintQueueBulkUpdateResponse)
  437. async def bulk_update_queue_items(
  438. data: PrintQueueBulkUpdate,
  439. db: AsyncSession = Depends(get_db),
  440. auth_result: tuple[User | None, bool] = Depends(
  441. require_ownership_permission(
  442. Permission.QUEUE_UPDATE_ALL,
  443. Permission.QUEUE_UPDATE_OWN,
  444. )
  445. ),
  446. ):
  447. """Bulk update multiple queue items with the same values.
  448. Only pending items can be updated. Non-pending items are skipped.
  449. Items not owned by the user are also skipped (unless user has *_all permission).
  450. """
  451. user, can_modify_all = auth_result
  452. if not data.item_ids:
  453. raise HTTPException(400, "No item IDs provided")
  454. # Get fields to update (exclude item_ids and unset fields)
  455. update_data = data.model_dump(exclude={"item_ids"}, exclude_unset=True)
  456. if not update_data:
  457. raise HTTPException(400, "No fields to update")
  458. # Validate printer_id if being changed
  459. if "printer_id" in update_data and update_data["printer_id"] is not None:
  460. result = await db.execute(select(Printer).where(Printer.id == update_data["printer_id"]))
  461. if not result.scalar_one_or_none():
  462. raise HTTPException(400, "Printer not found")
  463. # Fetch all items
  464. result = await db.execute(select(PrintQueueItem).where(PrintQueueItem.id.in_(data.item_ids)))
  465. items = result.scalars().all()
  466. updated_count = 0
  467. skipped_count = 0
  468. for item in items:
  469. if item.status != "pending":
  470. skipped_count += 1
  471. continue
  472. # Ownership check
  473. if not can_modify_all and item.created_by_id != user.id:
  474. skipped_count += 1
  475. continue
  476. for field, value in update_data.items():
  477. setattr(item, field, value)
  478. updated_count += 1
  479. await db.commit()
  480. logger.info("Bulk updated %s queue items, skipped %s", updated_count, skipped_count)
  481. return PrintQueueBulkUpdateResponse(
  482. updated_count=updated_count,
  483. skipped_count=skipped_count,
  484. message=f"Updated {updated_count} items"
  485. + (f", skipped {skipped_count} non-pending/not-owned" if skipped_count else ""),
  486. )
  487. @router.get("/{item_id}", response_model=PrintQueueItemResponse)
  488. async def get_queue_item(
  489. item_id: int,
  490. db: AsyncSession = Depends(get_db),
  491. _: User | None = RequirePermissionIfAuthEnabled(Permission.QUEUE_READ),
  492. ):
  493. """Get a specific queue item."""
  494. result = await db.execute(
  495. select(PrintQueueItem)
  496. .options(
  497. selectinload(PrintQueueItem.archive),
  498. selectinload(PrintQueueItem.printer),
  499. selectinload(PrintQueueItem.library_file),
  500. selectinload(PrintQueueItem.created_by),
  501. )
  502. .where(PrintQueueItem.id == item_id)
  503. )
  504. item = result.scalar_one_or_none()
  505. if not item:
  506. raise HTTPException(404, "Queue item not found")
  507. return _enrich_response(item)
  508. @router.patch("/{item_id}", response_model=PrintQueueItemResponse)
  509. async def update_queue_item(
  510. item_id: int,
  511. data: PrintQueueItemUpdate,
  512. db: AsyncSession = Depends(get_db),
  513. auth_result: tuple[User | None, bool] = Depends(
  514. require_ownership_permission(
  515. Permission.QUEUE_UPDATE_ALL,
  516. Permission.QUEUE_UPDATE_OWN,
  517. )
  518. ),
  519. ):
  520. """Update a queue item."""
  521. user, can_modify_all = auth_result
  522. result = await db.execute(select(PrintQueueItem).where(PrintQueueItem.id == item_id))
  523. item = result.scalar_one_or_none()
  524. if not item:
  525. raise HTTPException(404, "Queue item not found")
  526. # Ownership check
  527. if not can_modify_all:
  528. if item.created_by_id != user.id:
  529. raise HTTPException(403, "You can only update your own queue items")
  530. if item.status != "pending":
  531. raise HTTPException(400, "Can only update pending items")
  532. update_data = data.model_dump(exclude_unset=True)
  533. # Normalize target_model if being updated
  534. if "target_model" in update_data and update_data["target_model"]:
  535. update_data["target_model"] = (
  536. normalize_printer_model(update_data["target_model"])
  537. or normalize_printer_model_id(update_data["target_model"])
  538. or update_data["target_model"]
  539. )
  540. # Cannot specify both printer_id and target_model
  541. new_printer_id = update_data.get("printer_id", item.printer_id)
  542. new_target_model = update_data.get("target_model", item.target_model)
  543. if new_printer_id and new_target_model:
  544. raise HTTPException(400, "Cannot specify both printer_id and target_model")
  545. # Validate new printer_id if being changed (and not None)
  546. if "printer_id" in update_data and update_data["printer_id"] is not None:
  547. result = await db.execute(select(Printer).where(Printer.id == update_data["printer_id"]))
  548. if not result.scalar_one_or_none():
  549. raise HTTPException(400, "Printer not found")
  550. # Validate target_model has active printers
  551. if "target_model" in update_data and update_data["target_model"]:
  552. result = await db.execute(
  553. select(Printer).where(Printer.model == update_data["target_model"]).where(Printer.is_active == True) # noqa: E712
  554. )
  555. if not result.scalars().first():
  556. raise HTTPException(400, f"No active printers for model: {update_data['target_model']}")
  557. # Serialize ams_mapping to JSON for TEXT column storage
  558. if "ams_mapping" in update_data:
  559. update_data["ams_mapping"] = json.dumps(update_data["ams_mapping"]) if update_data["ams_mapping"] else None
  560. # Serialize filament_overrides to JSON for TEXT column storage
  561. if "filament_overrides" in update_data:
  562. update_data["filament_overrides"] = (
  563. json.dumps(update_data["filament_overrides"]) if update_data["filament_overrides"] else None
  564. )
  565. for field, value in update_data.items():
  566. setattr(item, field, value)
  567. await db.commit()
  568. await db.refresh(item, ["archive", "printer", "library_file", "created_by"])
  569. logger.info("Updated queue item %s", item_id)
  570. return _enrich_response(item)
  571. @router.delete("/{item_id}")
  572. async def delete_queue_item(
  573. item_id: int,
  574. db: AsyncSession = Depends(get_db),
  575. auth_result: tuple[User | None, bool] = Depends(
  576. require_ownership_permission(
  577. Permission.QUEUE_DELETE_ALL,
  578. Permission.QUEUE_DELETE_OWN,
  579. )
  580. ),
  581. ):
  582. """Remove an item from the queue."""
  583. user, can_modify_all = auth_result
  584. result = await db.execute(select(PrintQueueItem).where(PrintQueueItem.id == item_id))
  585. item = result.scalar_one_or_none()
  586. if not item:
  587. raise HTTPException(404, "Queue item not found")
  588. # Ownership check
  589. if not can_modify_all:
  590. if item.created_by_id != user.id:
  591. raise HTTPException(403, "You can only delete your own queue items")
  592. if item.status == "printing":
  593. raise HTTPException(400, "Cannot delete item that is currently printing")
  594. await db.delete(item)
  595. await db.commit()
  596. logger.info("Deleted queue item %s", item_id)
  597. return {"message": "Queue item deleted"}
  598. @router.post("/reorder")
  599. async def reorder_queue(
  600. data: PrintQueueReorder,
  601. db: AsyncSession = Depends(get_db),
  602. _: User | None = RequirePermissionIfAuthEnabled(Permission.QUEUE_UPDATE_ALL),
  603. ):
  604. """Bulk update positions for queue items."""
  605. for reorder_item in data.items:
  606. result = await db.execute(select(PrintQueueItem).where(PrintQueueItem.id == reorder_item.id))
  607. item = result.scalar_one_or_none()
  608. if item and item.status == "pending":
  609. item.position = reorder_item.position
  610. await db.commit()
  611. logger.info("Reordered %s queue items", len(data.items))
  612. return {"message": f"Reordered {len(data.items)} items"}
  613. @router.post("/{item_id}/cancel")
  614. async def cancel_queue_item(
  615. item_id: int,
  616. db: AsyncSession = Depends(get_db),
  617. auth_result: tuple[User | None, bool] = Depends(
  618. require_ownership_permission(
  619. Permission.QUEUE_UPDATE_ALL,
  620. Permission.QUEUE_UPDATE_OWN,
  621. )
  622. ),
  623. ):
  624. """Cancel a pending queue item."""
  625. user, can_modify_all = auth_result
  626. result = await db.execute(select(PrintQueueItem).where(PrintQueueItem.id == item_id))
  627. item = result.scalar_one_or_none()
  628. if not item:
  629. raise HTTPException(404, "Queue item not found")
  630. # Ownership check
  631. if not can_modify_all:
  632. if item.created_by_id != user.id:
  633. raise HTTPException(403, "You can only cancel your own queue items")
  634. if item.status not in ("pending",):
  635. raise HTTPException(400, f"Cannot cancel item with status '{item.status}'")
  636. item.status = "cancelled"
  637. item.completed_at = datetime.now(timezone.utc)
  638. await db.commit()
  639. logger.info("Cancelled queue item %s", item_id)
  640. return {"message": "Queue item cancelled"}
  641. @router.post("/{item_id}/stop")
  642. async def stop_queue_item(
  643. item_id: int,
  644. db: AsyncSession = Depends(get_db),
  645. _: User | None = RequirePermissionIfAuthEnabled(Permission.QUEUE_UPDATE_ALL),
  646. ):
  647. """Stop an actively printing queue item."""
  648. import asyncio
  649. from backend.app.models.smart_plug import SmartPlug
  650. from backend.app.services.printer_manager import printer_manager
  651. from backend.app.services.tasmota import tasmota_service
  652. result = await db.execute(select(PrintQueueItem).where(PrintQueueItem.id == item_id))
  653. item = result.scalar_one_or_none()
  654. if not item:
  655. raise HTTPException(404, "Queue item not found")
  656. if item.status != "printing":
  657. raise HTTPException(400, f"Can only stop items that are printing, current status: '{item.status}'")
  658. # Capture values we need for background task
  659. printer_id = item.printer_id
  660. auto_off_after = item.auto_off_after
  661. # Try to send stop command to printer
  662. stop_sent = False
  663. try:
  664. stop_sent = printer_manager.stop_print(printer_id)
  665. if not stop_sent:
  666. logger.warning("stop_print returned False for printer %s - printer may not be connected", printer_id)
  667. except Exception as e:
  668. logger.error("Error sending stop command for queue item %s: %s", item_id, e)
  669. # Update queue item status regardless - if printer is off, print is already stopped
  670. item.status = "cancelled"
  671. item.completed_at = datetime.now(timezone.utc)
  672. item.error_message = "Stopped by user" if stop_sent else "Stopped by user (printer was offline)"
  673. await db.commit()
  674. # Get smart plug info if auto-off is enabled
  675. plug_ip = None
  676. if auto_off_after:
  677. result = await db.execute(select(SmartPlug).where(SmartPlug.printer_id == printer_id))
  678. plug = result.scalar_one_or_none()
  679. if plug and plug.enabled:
  680. plug_ip = plug.ip_address
  681. logger.info("Stopped printing queue item %s (stop command sent: %s)", item_id, stop_sent)
  682. # Schedule background task for cooldown + power off
  683. if plug_ip:
  684. async def cooldown_and_poweroff():
  685. logger.info("Auto-off: Waiting for printer %s to cool down before power off...", printer_id)
  686. await printer_manager.wait_for_cooldown(printer_id, target_temp=50.0, timeout=600)
  687. # Re-fetch plug since we're in a new async context
  688. from backend.app.core.database import async_session
  689. async with async_session() as new_db:
  690. result = await new_db.execute(select(SmartPlug).where(SmartPlug.printer_id == printer_id))
  691. plug = result.scalar_one_or_none()
  692. if plug and plug.enabled:
  693. logger.info("Auto-off: Powering off printer %s", printer_id)
  694. await tasmota_service.turn_off(plug)
  695. asyncio.create_task(cooldown_and_poweroff())
  696. return {"message": "Print stopped" if stop_sent else "Queue item cancelled (printer was offline)"}
  697. @router.post("/{item_id}/start")
  698. async def start_queue_item(
  699. item_id: int,
  700. db: AsyncSession = Depends(get_db),
  701. _: User | None = RequirePermissionIfAuthEnabled(Permission.QUEUE_UPDATE_OWN),
  702. ):
  703. """Manually start a staged (manual_start) queue item.
  704. This clears the manual_start flag so the scheduler will pick it up,
  705. or starts immediately if the printer is ready.
  706. """
  707. result = await db.execute(
  708. select(PrintQueueItem)
  709. .options(selectinload(PrintQueueItem.archive), selectinload(PrintQueueItem.printer))
  710. .where(PrintQueueItem.id == item_id)
  711. )
  712. item = result.scalar_one_or_none()
  713. if not item:
  714. raise HTTPException(404, "Queue item not found")
  715. if item.status != "pending":
  716. raise HTTPException(400, f"Can only start pending items, current status: '{item.status}'")
  717. # Clear manual_start flag so scheduler picks it up
  718. item.manual_start = False
  719. await db.commit()
  720. await db.refresh(item, ["archive", "printer", "library_file", "created_by"])
  721. logger.info("Manually started queue item %s (cleared manual_start flag)", item_id)
  722. return _enrich_response(item)