import asyncio
from proxmoxer import ProxmoxAPI

async def main():
    async with await ProxmoxAPI.create(
        host="10.0.0.1",
        user="root@pam",
        password="secret",
        verify_ssl=False,
    ) as proxmox:
        # Get nodes
        nodes = await proxmox.nodes.get()
        print(f"Found {len(nodes)} nodes")

        # Get VMs on a node
        vms = await proxmox.nodes("pve").qemu.get()
        for vm in vms:
            print(f"VM {vm['vmid']}: {vm['name']}")

asyncio.run(main())

from proxmoxer import ProxmoxAPI, FirewallManager

async with await ProxmoxAPI.create(...) as proxmox:
    # For QEMU VMs (default)
    fw = FirewallManager(proxmox, "pve", 100)

    # For LXC Containers
    fw = FirewallManager(proxmox, "pve", 100, vm_type="lxc")

    # Enable firewall
    await fw.enable()

    # Allow SSH from specific network
    await fw.allow_ssh(source="192.168.1.0/24")

    # Allow HTTP/HTTPS
    await fw.allow_http()
    await fw.allow_https()

    # Block malicious IP
    await fw.block_ip("1.2.3.4", comment="Attacker")

    # Get options - returns FirewallOptions model
    options = await fw.get_options()
    print(f"Firewall enabled: {options.enable}")
    print(f"Policy IN: {options.policy_in}")
    print(f"DHCP: {options.dhcp}")

    # Get all aliases - returns list[FirewallAlias]
    aliases = await fw.get_aliases()
    for alias in aliases:
        print(f"{alias.name}: {alias.cidr}")

    # Get specific alias by name
    alias = await fw.get_alias("admin_workstation")
    print(f"{alias.name}: {alias.cidr} - {alias.comment}")

    # Get IP sets - returns list[FirewallIPSet]
    ipsets = await fw.get_ipsets()
    for ipset in ipsets:
        entries = await fw.get_ipset_entries(ipset.name)
        for entry in entries:
            print(f"{ipset.name}: {entry.cidr}")

# Fetch multiple resources in parallel (FAST!)
nodes, storages, vms = await asyncio.gather(
    proxmox.nodes.get(),
    proxmox.storage.get(),
    proxmox.nodes("pve").qemu.get(),
)

from proxmoxer.tools import Files

files = Files(proxmox, "pve", "local")

# Upload ISO with checksum validation
await files.upload_local_file_to_storage(
    "/path/to/ubuntu.iso",
    do_checksum_check=True,
    wait_for_task=True,
)

from proxmoxer.tools import Tasks

# Start VM
upid = await proxmox.nodes("pve").qemu(100).status.start.post()

# Wait for completion with auto-retry
result = await Tasks.wait_for_task(proxmox, upid, timeout=300)

print(f"Task completed: {result['exitstatus']}")

proxmox = await ProxmoxAPI.create(
    host="proxmox.example.com",
    user="root@pam",
    password="secret",
    backend="https",  # Default
)

proxmox = await ProxmoxAPI.create(
    host="proxmox.example.com",
    user="root",
    private_key="/path/to/key",
    backend="ssh",
)

proxmox = await ProxmoxAPI.create(
    backend="local",
    service="PVE",
)

proxmox = await ProxmoxAPI.create(
    host="proxmox.example.com",
    user="root@pam",
    password="secret",
)

proxmox = await ProxmoxAPI.create(
    host="proxmox.example.com",
    user="root@pam",
    token_name="my-token",
    token_value="xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx",
)

proxmox = await ProxmoxAPI.create(
    host="proxmox.example.com",
    full_token_id="root@pam!my-token",
    token_value="xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx",
)

async with await ProxmoxAPI.create(...) as proxmox:
    # Create VM
    await proxmox.nodes("pve").qemu.create(
        vmid=100,
        name="test-vm",
        memory=2048,
        cores=2,
    )

    # Start VM
    upid = await proxmox.nodes("pve").qemu(100).status.start.post()

    # Wait for start
    await Tasks.wait_for_task(proxmox, upid)

    # Get status
    status = await proxmox.nodes("pve").qemu(100).status.current.get()
    print(f"VM status: {status['status']}")

# Start multiple VMs concurrently
upids = await asyncio.gather(
    proxmox.nodes("pve").qemu(100).status.start.post(),
    proxmox.nodes("pve").qemu(101).status.start.post(),
    proxmox.nodes("pve").qemu(102).status.start.post(),
)

# Wait for all
results = await Tasks.wait_for_multiple_tasks(proxmox, upids)

fw = FirewallManager(proxmox, "pve", 100)

# Configure options
await fw.set_options(
    enable=True,
    policy_in="DROP",  # Drop all by default
    policy_out="ACCEPT",
    log_level_in=FirewallLogLevel.INFO,
)

# Create IP set for trusted IPs
await fw.create_ipset("trusted_ips")
await fw.add_ipset_entry("trusted_ips", "192.168.1.100")
await fw.add_ipset_entry("trusted_ips", "10.0.10.0/24")

# Allow from trusted IPs
from proxmoxer import FirewallRule, FirewallRuleAction, FirewallRuleType

rule = FirewallRule(
    action=FirewallRuleAction.ACCEPT,
    type=FirewallRuleType.IN,
    source="+trusted_ips",  # Reference IP set
    comment="Allow trusted IPs",
)
await fw.add_rule(rule)

# Allow web traffic
await fw.allow_http()
await fw.allow_https()