diff --git a/.last-branch b/.last-branch index 5831d0b..e6aed7e 100644 --- a/.last-branch +++ b/.last-branch @@ -1 +1 @@ -v20260119-08-autotask-disable-toggle-persist +v20260119-09-autotask-disabled-legacy-ticket-ui diff --git a/containers/backupchecks/src/backend/app/main/routes_run_checks.py b/containers/backupchecks/src/backend/app/main/routes_run_checks.py index fc467cf..e1ba9a5 100644 --- a/containers/backupchecks/src/backend/app/main/routes_run_checks.py +++ b/containers/backupchecks/src/backend/app/main/routes_run_checks.py @@ -35,7 +35,6 @@ from ..models import ( Override, User, ) -from ..ticketing_utils import ensure_internal_ticket_for_job, ensure_ticket_jobrun_links def _build_autotask_client_from_settings(): @@ -697,11 +696,15 @@ def run_checks_page(): } ) + settings = _get_or_create_settings() + autotask_enabled = bool(getattr(settings, "autotask_enabled", False)) + return render_template( "main/run_checks.html", rows=payload, is_admin=(get_active_role() == "admin"), include_reviewed=include_reviewed, + autotask_enabled=autotask_enabled, ) @@ -895,7 +898,16 @@ def api_run_checks_create_autotask_ticket(): if not run: return jsonify({"status": "error", "message": "Run not found."}), 404 - already_exists = bool(getattr(run, "autotask_ticket_id", None)) + # Idempotent: if already created, return existing linkage. + if getattr(run, "autotask_ticket_id", None): + return jsonify( + { + "status": "ok", + "ticket_id": int(run.autotask_ticket_id), + "ticket_number": getattr(run, "autotask_ticket_number", None) or "", + "already_exists": True, + } + ) job = Job.query.get(run.job_id) if not job: @@ -994,140 +1006,42 @@ def api_run_checks_create_autotask_ticket(): if priority_id: payload["priority"] = int(priority_id) - client = None try: client = _build_autotask_client_from_settings() + created = client.create_ticket(payload) except Exception as exc: - return jsonify({"status": "error", "message": f"Autotask client setup failed: {exc}"}), 400 + return jsonify({"status": "error", "message": f"Autotask ticket creation failed: {exc}"}), 400 - ticket_id = getattr(run, "autotask_ticket_id", None) - ticket_number = getattr(run, "autotask_ticket_number", None) + ticket_id = created.get("id") if isinstance(created, dict) else None + ticket_number = None + if isinstance(created, dict): + ticket_number = created.get("ticketNumber") or created.get("number") or created.get("ticket_number") - # Create ticket only when missing. if not ticket_id: - try: - created = client.create_ticket(payload) - except Exception as exc: - return jsonify({"status": "error", "message": f"Autotask ticket creation failed: {exc}"}), 400 + return jsonify({"status": "error", "message": "Autotask did not return a ticket id."}), 400 - ticket_id = created.get("id") if isinstance(created, dict) else None - if isinstance(created, dict): - ticket_number = created.get("ticketNumber") or created.get("number") or created.get("ticket_number") - - if not ticket_id: - return jsonify({"status": "error", "message": "Autotask did not return a ticket id."}), 400 - - try: - run.autotask_ticket_id = int(ticket_id) - except Exception: - run.autotask_ticket_id = None - - run.autotask_ticket_number = (str(ticket_number).strip() if ticket_number is not None else "") or None - run.autotask_ticket_created_at = datetime.utcnow() - run.autotask_ticket_created_by_user_id = current_user.id - - try: - db.session.add(run) - db.session.commit() - except Exception as exc: - db.session.rollback() - return jsonify({"status": "error", "message": f"Failed to store ticket reference: {exc}"}), 500 - - # Mandatory post-create (or repair) retrieval for Ticket Number. - if ticket_id and not (ticket_number or "").strip(): - try: - fetched = client.get_ticket(int(ticket_id)) - ticket_number = None - if isinstance(fetched, dict): - ticket_number = fetched.get("ticketNumber") or fetched.get("number") or fetched.get("ticket_number") - ticket_number = (str(ticket_number).strip() if ticket_number is not None else "") or None - except Exception as exc: - # Ticket ID is persisted, but internal propagation must not proceed without the ticket number. - return jsonify({"status": "error", "message": f"Autotask ticket created but ticket number retrieval failed: {exc}"}), 400 - - if not ticket_number: - return jsonify({"status": "error", "message": "Autotask ticket created but ticket number is not available."}), 400 - - try: - run = JobRun.query.get(run_id) - if not run: - return jsonify({"status": "error", "message": "Run not found."}), 404 - run.autotask_ticket_number = ticket_number - db.session.add(run) - db.session.commit() - except Exception as exc: - db.session.rollback() - return jsonify({"status": "error", "message": f"Failed to store ticket number: {exc}"}), 500 - - # Internal ticket + linking propagation (required for UI parity) try: - run = JobRun.query.get(run_id) - if not run: - return jsonify({"status": "error", "message": "Run not found."}), 404 + run.autotask_ticket_id = int(ticket_id) + except Exception: + run.autotask_ticket_id = None - ticket_id_int = int(getattr(run, "autotask_ticket_id", None) or 0) - ticket_number_str = (getattr(run, "autotask_ticket_number", None) or "").strip() - - if ticket_id_int <= 0 or not ticket_number_str: - return jsonify({"status": "error", "message": "Autotask ticket reference is incomplete."}), 400 - - # Create/reuse internal ticket (code == Autotask Ticket Number) - internal_ticket = ensure_internal_ticket_for_job( - ticket_code=ticket_number_str, - title=subject, - description=description, - job=job, - active_from_dt=getattr(run, "run_at", None) or datetime.utcnow(), - start_dt=getattr(run, "autotask_ticket_created_at", None) or datetime.utcnow(), - ) - - # Link ticket to all open runs for this job (reviewed_at IS NULL) and propagate PSA reference. - open_runs = JobRun.query.filter(JobRun.job_id == job.id, JobRun.reviewed_at.is_(None)).all() - run_ids_to_link: list[int] = [] - - for r in open_runs: - # Never overwrite an existing different Autotask ticket for a run. - existing_id = getattr(r, "autotask_ticket_id", None) - if existing_id and int(existing_id) != ticket_id_int: - continue - - # Ensure all open runs get BOTH the Autotask ticket id and number. - # Some runs may already have the id (indicator) but still miss the number. - if not existing_id: - r.autotask_ticket_id = ticket_id_int - r.autotask_ticket_number = ticket_number_str - r.autotask_ticket_created_at = getattr(run, "autotask_ticket_created_at", None) - r.autotask_ticket_created_by_user_id = getattr(run, "autotask_ticket_created_by_user_id", None) - db.session.add(r) - else: - updated = False - if not (getattr(r, "autotask_ticket_number", None) or "").strip(): - r.autotask_ticket_number = ticket_number_str - updated = True - if getattr(r, "autotask_ticket_created_at", None) is None: - r.autotask_ticket_created_at = getattr(run, "autotask_ticket_created_at", None) - updated = True - if getattr(r, "autotask_ticket_created_by_user_id", None) is None: - r.autotask_ticket_created_by_user_id = getattr(run, "autotask_ticket_created_by_user_id", None) - updated = True - if updated: - db.session.add(r) - - run_ids_to_link.append(int(r.id)) - - ensure_ticket_jobrun_links(ticket_id=int(internal_ticket.id), run_ids=run_ids_to_link, link_source="autotask") + run.autotask_ticket_number = (str(ticket_number).strip() if ticket_number is not None else "") or None + run.autotask_ticket_created_at = datetime.utcnow() + run.autotask_ticket_created_by_user_id = current_user.id + try: + db.session.add(run) db.session.commit() except Exception as exc: db.session.rollback() - return jsonify({"status": "error", "message": f"Failed to propagate internal ticket linkage: {exc}"}), 500 + return jsonify({"status": "error", "message": f"Failed to store ticket reference: {exc}"}), 500 return jsonify( { "status": "ok", - "ticket_id": int(getattr(run, "autotask_ticket_id", None) or 0) or None, - "ticket_number": getattr(run, "autotask_ticket_number", None) or "", - "already_exists": already_exists, + "ticket_id": int(run.autotask_ticket_id) if run.autotask_ticket_id else None, + "ticket_number": run.autotask_ticket_number or "", + "already_exists": False, } ) diff --git a/containers/backupchecks/src/templates/main/run_checks.html b/containers/backupchecks/src/templates/main/run_checks.html index dcf56ca..ef5f95d 100644 --- a/containers/backupchecks/src/templates/main/run_checks.html +++ b/containers/backupchecks/src/templates/main/run_checks.html @@ -216,12 +216,21 @@