mirror of
https://github.com/MacRimi/ProxMenux.git
synced 2026-10-09 06:56:37 +00:00
MacRimi
1f9d2acef5
The installation record of an OCI application travels with its container: a copy inside the container and another in /etc/pve, written together with the one kept on the host. A container restored on a newly installed Proxmox, restored with another ID or moved to another node of a cluster is recognised and registered again, with its private network, hookscript, Rclone mount, host firewall rule and NVIDIA runtime. The Monitor offers the same recovery from the Updates tab. AMD GPUs are offered by generation. A GPU the ROCm image supports takes the profile as it is; one of a supported family (Radeon 680M, 780M) is an experimental option that asks for confirmation and is never proposed; an older one is not offered. The GPU is checked with a real inference before the installation accepts it. Recreate changes what runs recognition in an installed Immich, between the CPU and a GPU of the host. Updates: - A failed update that is restored and checked removes its temporary container and the disks of the failed attempt. - Every container volume is part of the backups, so Jellyfin, Plex and Hugo update with their default installation. - An image published with a Docker-format manifest is recognised by its layers and build time and updates. - The Proxmox notes of a multi-container application link to its LAN address.
96 lines
3.6 KiB
Python
96 lines
3.6 KiB
Python
"""What the VM & LXC modal needs to know about an OCI instance.
|
|
|
|
Read-only view of the installation record OCI manager Apps keeps for every
|
|
container it created: whether the container is one, whether it belongs to a
|
|
multi-container application, whether it uses host directories (which its
|
|
backup does not revert), whether an operation is pending and whether it was
|
|
restored from a backup and is not registered on this host yet. Nothing here
|
|
changes the record or runs inside the container.
|
|
"""
|
|
from __future__ import annotations
|
|
|
|
import json
|
|
import os
|
|
import re
|
|
import socket
|
|
|
|
import oci_console_logs
|
|
|
|
ROOT = "/usr/local/share/proxmenux/oci/instances"
|
|
|
|
|
|
def _record(vmid: int) -> dict | None:
|
|
path = os.path.join(ROOT, str(int(vmid)), "oci-compose.json")
|
|
try:
|
|
with open(path, encoding="utf-8") as handle:
|
|
record = json.load(handle)
|
|
except (OSError, ValueError):
|
|
return None
|
|
return record if isinstance(record, dict) else None
|
|
|
|
|
|
def _installation(vmid: int) -> str | None:
|
|
"""The installation the container says it belongs to: the mark OCI manager
|
|
Apps leaves in its notes, which a backup keeps."""
|
|
path = f"/etc/pve/nodes/{socket.gethostname().split('.', 1)[0]}/lxc/{int(vmid)}.conf"
|
|
try:
|
|
with open(path, encoding="utf-8", errors="ignore") as handle:
|
|
text = handle.read().split("\n[", 1)[0]
|
|
except OSError:
|
|
return None
|
|
match = re.search(r"^#.*proxmenux-instance=([0-9a-f-]{36})(?![0-9a-f-])", text, re.MULTILINE)
|
|
return match.group(1) if match else None
|
|
|
|
|
|
def _unrecoverable(vmid: int, installation: str) -> bool:
|
|
"""A restored container that carries no copy of its record: the menu
|
|
found nothing to recover it from and left it as an ordinary container."""
|
|
try:
|
|
with open(os.path.join(ROOT, ".unrecoverable.json"), encoding="utf-8") as handle:
|
|
value = json.load(handle)
|
|
except (OSError, ValueError):
|
|
return False
|
|
return isinstance(value, dict) and value.get(str(int(vmid))) == installation
|
|
|
|
|
|
def _host_dirs(record: dict) -> bool:
|
|
mounts = (record.get("deployment") or {}).get("mounts") or []
|
|
return any(isinstance(m, dict) and m.get("type") == "host-bind" for m in mounts)
|
|
|
|
|
|
def info(vmid: int) -> dict:
|
|
vmid = int(vmid)
|
|
result = {
|
|
"vmid": vmid,
|
|
"oci_instance": False,
|
|
"console_log": oci_console_logs.configured_log(vmid) is not None,
|
|
"stack": False,
|
|
"primary_vmid": vmid,
|
|
"members": [],
|
|
"host_directories": False,
|
|
"pending": False,
|
|
"restored": False,
|
|
}
|
|
record = _record(vmid)
|
|
installation = _installation(vmid)
|
|
if installation and (record is None or record.get("installation_id") != installation):
|
|
# Restored from a backup: the record stayed on the host it came from.
|
|
result["restored"] = not _unrecoverable(vmid, installation)
|
|
return result
|
|
if record is None:
|
|
return result
|
|
primary_id = int((record.get("stack_member") or {}).get("primary_vmid") or vmid)
|
|
primary = record if primary_id == vmid else (_record(primary_id) or {})
|
|
members = [int(m["vmid"]) for m in (primary.get("stack") or {}).get("members") or []
|
|
if isinstance(m, dict) and str(m.get("vmid", "")).isdigit()]
|
|
records = [record] if not members else [r for r in (_record(m) for m in members) if r]
|
|
result.update(
|
|
oci_instance=True,
|
|
stack=bool(members) or bool(record.get("stack_member")),
|
|
primary_vmid=primary_id,
|
|
members=members,
|
|
host_directories=any(_host_dirs(r) for r in records),
|
|
pending=bool(record.get("pending_transaction") or primary.get("pending_stack_transaction")),
|
|
)
|
|
return result
|