path: root/src/conf_mode/container.py

#!/usr/bin/env python3
#
# Copyright VyOS maintainers and contributors <maintainers@vyos.io>
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License version 2 or later as
# published by the Free Software Foundation.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program.  If not, see <http://www.gnu.org/licenses/>.

import os

from decimal import Decimal
from hashlib import sha256
from ipaddress import ip_address
from ipaddress import ip_network
from json import dumps as json_write

import psutil
from vyos.base import Warning
from vyos.config import Config
from vyos.configdict import dict_merge
from vyos.configdict import node_changed
from vyos.configdict import is_node_changed
from vyos.configverify import verify_vrf
from vyos.container import restart_network
from vyos.utils.configfs import delete_cli_node
from vyos.utils.configfs import add_cli_node
from vyos.utils.cpu import get_core_count
from vyos.utils.file import write_file
from vyos.utils.dict import dict_search
from vyos.utils.process import call
from vyos.utils.process import cmd
from vyos.utils.process import run
from vyos.utils.network import gen_mac
from vyos.utils.network import get_host_identity
from vyos.utils.network import interface_exists
from vyos.template import bracketize_ipv6
from vyos.template import inc_ip
from vyos.template import is_ipv4
from vyos.template import is_ipv6
from vyos.template import render
from vyos.xml_ref import default_value
from vyos import ConfigError
from vyos import airbag

airbag.enable()

config_containers = '/etc/containers/containers.conf'
config_registry = '/etc/containers/registries.conf'
config_storage = '/etc/containers/storage.conf'
systemd_unit_path = '/run/systemd/system'


def _cmd(command):
    if os.path.exists('/tmp/vyos.container.debug'):
        print(command)
    return cmd(command)


def network_exists(name):
    # Check explicit name for network, returns True if network exists
    c = _cmd(f'podman network ls --quiet --filter name=^{name}$')
    return bool(c)


# Common functions
def get_config(config=None):
    if config:
        conf = config
    else:
        conf = Config()

    base = ['container']
    container = conf.get_config_dict(base, key_mangling=('-', '_'),
                                     no_tag_node_value_mangle=True,
                                     get_first_key=True,
                                     with_recursive_defaults=True)

    for name in container.get('name', []):
        # T5047: Any container related configuration changed? We only
        # wan't to restart the required containers and not all of them ...
        tmp = is_node_changed(conf, base + ['name', name])
        if tmp:
            if 'container_restart' not in container:
                container['container_restart'] = [name]
            else:
                container['container_restart'].append(name)

    # registry is a tagNode with default values - merge the list from
    # default_values['registry'] into the tagNode variables
    if 'registry' not in container:
        container.update({'registry': {}})
        default_values = default_value(base + ['registry'])
        for registry in default_values:
            tmp = {registry: {}}
            container['registry'] = dict_merge(tmp, container['registry'])

    # Delete container network, delete containers
    tmp = node_changed(conf, base + ['network'])
    if tmp: container.update({'network_remove': tmp})

    tmp = node_changed(conf, base + ['name'])
    if tmp: container.update({'container_remove': tmp})

    return container


def verify(container):
    # bail out early - looks like removal from running config
    if not container:
        return None

    # Add new container
    if 'name' in container:
        net_dict = {}
        net_dict['mac'] = {}
        net_dict['address'] = {}

        for name, container_config in container['name'].items():
            # Container image is a mandatory option
            if 'image' not in container_config:
                raise ConfigError(f'Container image for "{name}" is mandatory!')

            # Check if requested container image exists locally. If it does not
            # exist locally - inform the user. This is required as there is a
            # shared container image storage across all VyOS images. A user can
            # delete a container image from the system, boot into another version
            # of VyOS and then it would fail to boot. This is to prevent any
            # configuration error when container images are deleted from the
            # global storage. A per image local storage would be a super waste
            # of diskspace as there will be a full copy (up tu several GB/image)
            # on upgrade. This is the "cheapest" and fastest solution in terms
            # of image upgrade and deletion.
            image = container_config['image']
            if run(f'podman image exists {image}') != 0:
                Warning(f'Image "{image}" used in container "{name}" does not exist ' \
                        f'locally. Please use "add container image {image}" to add it ' \
                        f'to the system! Container "{name}" will not be started!')

            if 'cpu_quota' in container_config:
                cores = get_core_count()
                if Decimal(container_config['cpu_quota']) > cores:
                    raise ConfigError(f'Cannot set limit to more cores than available "{name}"!')

            if 'network' in container_config:
                if len(container_config['network']) > 1:
                    raise ConfigError(f'Only one network can be specified for container "{name}"!')

                # Check if the specified container network exists
                network_name = list(container_config['network'])[0]
                if network_name not in container.get('network', {}):
                    raise ConfigError(f'Container network "{network_name}" does not exist!')

                if 'name_server' in container_config and 'no_name_server' not in container['network'][network_name]:
                    raise ConfigError(f'Setting name server has no effect when attached container network has DNS enabled!')

                mac = dict_search(f'network.{network_name}.mac', container_config)
                if mac:
                    if mac in net_dict['mac'].keys():
                        raise ConfigError(f'MAC address "{mac}" is already used by container "{net_dict["mac"][mac]}"!')
                    if mac != 'auto':
                        net_dict['mac'][mac] = name

                if 'address' in container_config['network'][network_name]:
                    cnt_ipv4 = 0
                    cnt_ipv6 = 0
                    for address in container_config['network'][network_name]['address']:
                        network = None
                        if is_ipv4(address):
                            try:
                                network = [x for x in container['network'][network_name]['prefix'] if is_ipv4(x)][0]
                                cnt_ipv4 += 1
                            except Exception:
                                raise ConfigError(f'Network "{network_name}" does not contain an IPv4 prefix!')
                        elif is_ipv6(address):
                            try:
                                network = [x for x in container['network'][network_name]['prefix'] if is_ipv6(x)][0]
                                cnt_ipv6 += 1
                            except Exception:
                                raise ConfigError(f'Network "{network_name}" does not contain an IPv6 prefix!')

                        # Specified container IP address must belong to network prefix
                        if ip_address(address) not in ip_network(network):
                            raise ConfigError(f'Used container address "{address}" not in network "{network}"!')

                        # We cannot use the first IP address of a network prefix as this is used by podman
                        if ip_address(address) == ip_network(network)[1]:
                            raise ConfigError(f'IP address "{address}" cannot be used for a container, ' \
                                              'reserved for the container engine!')

                        if address in net_dict['address'].keys():
                            raise ConfigError(f'IP address "{address}" is already used by container "{net_dict["address"][address]}"!')
                        net_dict['address'][address] = name

                    if cnt_ipv4 > 1 or cnt_ipv6 > 1:
                        raise ConfigError(f'Only one IP address per address family can be used for ' \
                                          f'container "{name}". {cnt_ipv4} IPv4 and {cnt_ipv6} IPv6 address(es)!')

            if 'device' in container_config:
                for dev, dev_config in container_config['device'].items():
                    if 'source' not in dev_config:
                        raise ConfigError(f'Device "{dev}" has no source path configured!')

                    if 'destination' not in dev_config:
                        raise ConfigError(f'Device "{dev}" has no destination path configured!')

                    source = dev_config['source']
                    if not os.path.exists(source):
                        raise ConfigError(f'Device "{dev}" source path "{source}" does not exist!')

            if 'sysctl' in container_config and 'parameter' in container_config['sysctl']:
                for var, cfg in container_config['sysctl']['parameter'].items():
                    if 'value' not in cfg:
                        raise ConfigError(f'sysctl parameter {var} has no value assigned!')
                    if var.startswith('net.') and 'allow_host_networks' in container_config:
                        raise ConfigError(f'sysctl parameter {var} cannot be set when using host networking!')

            if 'environment' in container_config:
                for var, cfg in container_config['environment'].items():
                    if 'value' not in cfg:
                        raise ConfigError(f'Environment variable {var} has no value assigned!')

            if 'label' in container_config:
                for var, cfg in container_config['label'].items():
                    if 'value' not in cfg:
                        raise ConfigError(f'Label variable {var} has no value assigned!')

            if 'volume' in container_config:
                for volume, volume_config in container_config['volume'].items():
                    if 'source' not in volume_config:
                        raise ConfigError(f'Volume "{volume}" has no source path configured!')

                    if 'destination' not in volume_config:
                        raise ConfigError(f'Volume "{volume}" has no destination path configured!')

                    source = volume_config['source']
                    if not os.path.exists(source):
                        raise ConfigError(f'Volume "{volume}" source path "{source}" does not exist!')

            if 'tmpfs' in container_config:
                for tmpfs, tmpfs_config in container_config['tmpfs'].items():
                    if 'destination' not in tmpfs_config:
                        raise ConfigError(f'tmpfs "{tmpfs}" has no destination path configured!')
                    if 'size' in tmpfs_config:
                        free_mem_mb: int = psutil.virtual_memory().available / 1024 /  1024
                        if int(tmpfs_config['size']) > free_mem_mb:
                            Warning(f'tmpfs "{tmpfs}" size is greater than the current free memory!')

                        total_mem_mb: int = (psutil.virtual_memory().total / 1024 /  1024) / 2
                        if int(tmpfs_config['size']) > total_mem_mb:
                            raise ConfigError(f'tmpfs "{tmpfs}" size should not be more than 50% of total system memory!')
                    else:
                        raise ConfigError(f'tmpfs "{tmpfs}" has no size configured!')

            if 'port' in container_config:
                for tmp in container_config['port']:
                    if not {'source', 'destination'} <= set(container_config['port'][tmp]):
                        raise ConfigError(f'Both "source" and "destination" must be specified for a port mapping!')

            # If 'allow-host-networks' or 'network' not set.
            if 'allow_host_networks' not in container_config and 'network' not in container_config:
                raise ConfigError(f'Must either set "network" or "allow-host-networks" for container "{name}"!')

            # Cannot set both allow-host-networks and network at the same time
            if {'allow_host_networks', 'network'} <= set(container_config):
                raise ConfigError(
                    f'"allow-host-networks" and "network" for "{name}" cannot be both configured at the same time!')

            # gid cannot be set without uid
            if 'gid' in container_config and 'uid' not in container_config:
                raise ConfigError(f'Cannot set "gid" without "uid" for container')

    # Add new network
    if 'network' in container:
        for network, network_config in container['network'].items():
            net_dict = {'ipv4_pfx_len': 0, 'ipv6_pfx_len': 0, 'ipv4_gateway_len': 0, 'ipv6_gateway_len': 0}

            # If ipv4-prefix not defined for user-defined network
            if 'prefix' not in network_config:
                raise ConfigError(f'prefix for network "{network}" must be defined!')

            for prefix in network_config['prefix']:
                if is_ipv4(prefix):
                    net_dict['ipv4_pfx_len'] += 1
                    net_dict['ipv4_prefix'] = prefix
                elif is_ipv6(prefix):
                    net_dict['ipv6_pfx_len'] += 1
                    net_dict['ipv6_prefix'] = prefix

            for gateway in network_config.get('gateway', []):
                if is_ipv4(gateway):
                    net_dict['ipv4_gateway_len'] += 1
                    net_dict['ipv4_gateway'] = gateway
                elif is_ipv6(gateway):
                    net_dict['ipv6_gateway_len'] += 1
                    net_dict['ipv6_gateway'] = gateway

            if net_dict['ipv4_pfx_len'] > 1:
                raise ConfigError(f'Only one IPv4 prefix can be defined for network "{network}"!')
            if net_dict['ipv6_pfx_len'] > 1:
                raise ConfigError(f'Only one IPv6 prefix can be defined for network "{network}"!')
            if net_dict['ipv4_gateway_len'] > 1:
                raise ConfigError(f'Only one IPv4 gateway can be defined for network "{network}"!')
            if net_dict['ipv6_gateway_len'] > 1:
                raise ConfigError(f'Only one IPv6 gateway can be defined for network "{network}"!')

            if net_dict.get('ipv4_prefix') and net_dict.get('ipv4_gateway'):
                if ip_address(net_dict['ipv4_gateway']) not in ip_network(net_dict['ipv4_prefix']):
                    raise ConfigError(f'IPv4 gateway "{net_dict["ipv4_gateway"]}" is not in the IPv4 prefix "{net_dict["ipv4_prefix"]}"!')
            if net_dict.get('ipv6_prefix') and net_dict.get('ipv6_gateway'):
                if ip_address(net_dict['ipv6_gateway']) not in ip_network(net_dict['ipv6_prefix']):
                    raise ConfigError(f'IPv6 gateway "{net_dict["ipv6_gateway"]}" is not in the IPv6 prefix "{net_dict["ipv6_prefix"]}"!')
            if net_dict.get('ipv4_gateway') and not net_dict.get('ipv4_prefix'):
                raise ConfigError(f'IPv4 gateway configured but no IPv4 prefix defined for network "{network}"!')
            if net_dict.get('ipv6_gateway') and not net_dict.get('ipv6_prefix'):
                raise ConfigError(f'IPv6 gateway configured but no IPv6 prefix defined for network "{network}"!')

            type_config = dict_search('type', network_config)
            if dict_search('macvlan', type_config):
                parent = dict_search('macvlan.parent', type_config)
                if not parent:
                    raise ConfigError(f'MACVLAN networks must have a parent interface!')
                if not interface_exists(parent):
                    raise ConfigError(f'MACVLAN parent interface "{parent}" does not exist!')
                if not dict_search('macvlan.mode', type_config):
                    raise ConfigError(f'MACVLAN networks must have a mode configured!')
                if dict_search('vrf', network_config):
                    raise ConfigError(f'MACVLAN networks do not support direct VRF assignment!')

            # Verify VRF exists
            verify_vrf(network_config)

    # A network attached to a container cannot be deleted
    if {'network_remove', 'name'} <= set(container):
        for network in container['network_remove']:
            for c, c_config in container['name'].items():
                if 'network' in c_config and network in c_config['network']:
                    raise ConfigError(f'Cannot remove network "{network}", used by container "{c}"!')

    if 'registry' in container:
        for registry, registry_config in container['registry'].items():
            if 'mirror' in registry_config:
                if 'host_name' in registry_config['mirror'] and 'address' in registry_config['mirror']:
                    raise ConfigError(f'Container registry mirror address/host-name are mutually exclusive!')

                if 'path' in registry_config['mirror'] and not registry_config['mirror']['path'].startswith('/'):
                    raise ConfigError('Container registry mirror path must start with "/"!')

            if 'authentication' not in registry_config:
                continue
            if not {'username', 'password'} <= set(registry_config['authentication']):
                raise ConfigError('Container registry requires both username and password to be set!')

    return None


def generate_run_arguments(name, container_config, host_ident):
    image = container_config['image']
    cpu_quota = container_config['cpu_quota']
    memory = container_config['memory']
    shared_memory = container_config['shared_memory']
    restart = container_config['restart']
    log_driver = container_config['log_driver']

    # Add sysctl options
    sysctl_opt = ''
    if 'sysctl' in container_config and 'parameter' in container_config['sysctl']:
        for k, v in container_config['sysctl']['parameter'].items():
            sysctl_opt += f" --sysctl \"{k}={v['value']}\""

    # Add capability options. Should be in uppercase
    capabilities = ''
    if 'capability' in container_config:
        for cap in container_config['capability']:
            cap = cap.upper().replace('-', '_')
            capabilities += f' --cap-add={cap}'

    # Grant root capabilities to the container
    privileged = ''
    if 'privileged' in container_config:
        privileged = '--privileged'

    # Add a host device to the container /dev/x:/dev/x
    device = ''
    if 'device' in container_config:
        for dev, dev_config in container_config['device'].items():
            source_dev = dev_config['source']
            dest_dev = dev_config['destination']
            device += f' --device={source_dev}:{dest_dev}'

    # Check/set environment options "-e foo=bar"
    env_opt = ''
    if 'environment' in container_config:
        for k, v in container_config['environment'].items():
            env_opt += f" --env \"{k}={v['value']}\""

    # Check/set label options "--label foo=bar"
    label = ''
    if 'label' in container_config:
        for k, v in container_config['label'].items():
            label += f" --label \"{k}={v['value']}\""

    hostname = ''
    if 'host_name' in container_config:
        hostname = container_config['host_name']
        hostname = f'--hostname {hostname}'

    # Publish ports
    port = ''
    if 'port' in container_config:
        protocol = ''
        for portmap in container_config['port']:
            protocol = container_config['port'][portmap]['protocol']
            sport = container_config['port'][portmap]['source']
            dport = container_config['port'][portmap]['destination']
            listen_addresses = container_config['port'][portmap].get('listen_address', [])

            # If listen_addresses is not empty, include them in the publish command
            if listen_addresses:
                for listen_address in listen_addresses:
                    port += f' --publish {bracketize_ipv6(listen_address)}:{sport}:{dport}/{protocol}'
            else:
                # If listen_addresses is empty, just include the standard publish command
                port += f' --publish {sport}:{dport}/{protocol}'

    # Set uid and gid
    uid = ''
    if 'uid' in container_config:
        uid = container_config['uid']
        if 'gid' in container_config:
            uid += ':' + container_config['gid']
        uid = f'--user {uid}'

    # Bind volume
    volume = ''
    if 'volume' in container_config:
        for vol, vol_config in container_config['volume'].items():
            svol = vol_config['source']
            dvol = vol_config['destination']
            mode = vol_config['mode']
            prop = vol_config['propagation']
            volume += f' --volume {svol}:{dvol}:{mode},{prop}'

    # Mount tmpfs
    tmpfs = ''
    if 'tmpfs' in container_config:
        for tmpfs_config in container_config['tmpfs'].values():
            dest = tmpfs_config['destination']
            size = tmpfs_config['size']
            tmpfs += f' --mount=type=tmpfs,tmpfs-size={size}M,destination={dest}'

    host_pid = ''
    if 'allow_host_pid' in container_config:
      host_pid = '--pid host'

    name_server = []
    if 'name_server' in container_config:
        for ns in container_config['name_server']:
            name_server.append(f'--dns {ns}')
    if name_server:
        name_server = ' '.join(name_server)
    else:
        name_server = ''

    container_base_cmd = f'--detach --interactive --tty --replace {capabilities} {privileged} --cpus {cpu_quota} {sysctl_opt} ' \
                         f'--memory {memory}m --shm-size {shared_memory}m --memory-swap 0 --restart {restart} --log-driver={log_driver} ' \
                         f'--name {name} {hostname} {device} {port} {name_server} {volume} {tmpfs} {env_opt} {label} {uid} {host_pid}'

    entrypoint = ''
    if 'entrypoint' in container_config:
        # it needs to be json-formatted with single quote on the outside
        entrypoint = json_write(container_config['entrypoint'].split()).replace('"', "&quot;")
        entrypoint = f'--entrypoint &apos;{entrypoint}&apos;'

    healthcheck = ' --no-healthcheck'
    if 'health_check' in container_config:
        healthcheck = ''
        if 'command' in container_config['health_check']:
            health_cmd = container_config['health_check']['command']
            healthcheck += f' --health-cmd="{health_cmd}"'
        if 'interval' in container_config['health_check']:
            health_int = container_config['health_check']['interval']
            if health_int != 'disable':
                health_int = f'{health_int}s'
            healthcheck += f' --health-interval={health_int}'
        if 'timeout' in container_config['health_check']:
            health_to = container_config['health_check']['timeout']
            healthcheck += f' --health-timeout={health_to}s'
        if 'retry' in container_config['health_check']:
            health_rt = container_config['health_check']['retry']
            healthcheck += f' --health-retries={health_rt}'

    command = ''
    if 'command' in container_config:
        command = container_config['command'].strip()

    command_arguments = ''
    if 'arguments' in container_config:
        command_arguments = container_config['arguments'].strip()

    net = ''
    if 'allow_host_networks' in container_config:
        net = '--net host'
    else:
        ip_param = ''
        addr_info = ''
        networks = ",".join(container_config['network'])
        for network in container_config['network']:
            network_name = network
            if 'address' not in container_config['network'][network]:
                continue
            for address in container_config['network'][network]['address']:
                if is_ipv6(address):
                    ip_param += f' --ip6 {address}'
                else:
                    ip_param += f' --ip {address}'

            addr_info = ''.join(container_config['network'][network]['address'])

        get_mac = dict_search(f'network.{network_name}.mac', container_config)
        if get_mac == 'auto' or get_mac is None:
            mac_add = gen_mac(name, addr_info, host_ident)
        else:
            mac_add = get_mac

        mac_address = f'--mac-address {mac_add}'

        # Replace mac-auto with the generated mac address
        if get_mac == 'auto':
            mac_config_path = [
                'container',
                'name',
                name,
                'network',
                network_name,
                'mac',
            ]

            delete_cli_node(mac_config_path)
            add_cli_node(mac_config_path, value=mac_add)

        net = f'--net {networks} {ip_param} {mac_address}'

    return f'{container_base_cmd} {healthcheck} {net} {entrypoint} {image} {command} {command_arguments}'.strip()


def generate(container):
    # bail out early - looks like removal from running config
    if not container:
        for file in [config_containers, config_registry, config_storage]:
            if os.path.exists(file):
                os.unlink(file)
        return None

    if 'network' in container:
        for network, network_config in container['network'].items():
            type_config = dict_search('type', network_config)
            if dict_search('macvlan', type_config):
                net_interface = dict_search('macvlan.parent', type_config)
                driver = 'macvlan'
                mode = dict_search('macvlan.mode', type_config)
            elif dict_search('bridge', type_config) is not None:
                net_interface = f'pod-{network}'
                driver = 'bridge'
            else:
                net_interface = f'pod-{network}'
                driver = 'bridge'
            tmp = {
                'name': network,
                'id': sha256(f'{network}'.encode()).hexdigest(),
                'driver': driver,
                'network_interface': net_interface,
                'subnets': [],
                'ipv6_enabled': False,
                'internal': False,
                'dns_enabled': True,
                'ipam_options': {
                    'driver': 'host-local'
                },
                'options': {
                    **({'mode': mode} if driver == 'macvlan' else {}),
                    'mtu': '1500'
                }
            }

            if 'no_name_server' in network_config:
                tmp['dns_enabled'] = False

            if 'mtu' in network_config:
                tmp['options']['mtu'] = network_config['mtu']

            for prefix in network_config['prefix']:
                gateway4, gateway6 = None, None
                if dict_search('gateway', network_config):
                    for gw in network_config['gateway']:
                        if is_ipv6(gw):
                            gateway6 = gw
                        else:
                            gateway4 = gw

                if is_ipv6(prefix) and not gateway6:
                    gateway6 = inc_ip(prefix, 1)
                elif not gateway4:
                    gateway4 = inc_ip(prefix, 1)

                if is_ipv6(prefix):
                    tmp['ipv6_enabled'] = True
                    net = {'subnet': prefix, 'gateway': gateway6}
                else:
                    net = {'subnet': prefix, 'gateway': gateway4}

                tmp['subnets'].append(net)

            write_file(f'/etc/containers/networks/{network}.json', json_write(tmp, indent=2))

    render(config_containers, 'container/containers.conf.j2', container)
    render(config_registry, 'container/registries.conf.j2', container)
    render(config_storage, 'container/storage.conf.j2', container)

    if 'name' in container:
        host_ident = get_host_identity()
        for name, container_config in container['name'].items():
            if 'disable' in container_config:
                continue

            file_path = os.path.join(systemd_unit_path, f'vyos-container-{name}.service')
            run_args = generate_run_arguments(name, container_config, host_ident)
            render(file_path, 'container/systemd-unit.j2', {'name': name, 'run_args': run_args, },
                   formatter=lambda _: _.replace("&quot;", '"').replace("&apos;", "'"))

    return None


def apply(container):
    # Delete old containers if needed. We can't delete running container
    # Option "--force" allows to delete containers with any status
    if 'container_remove' in container:
        for name in container['container_remove']:
            file_path = os.path.join(systemd_unit_path, f'vyos-container-{name}.service')
            call(f'systemctl stop vyos-container-{name}.service')
            if os.path.exists(file_path):
                os.unlink(file_path)

    call('systemctl daemon-reload')

    # Delete old networks if needed
    if 'network_remove' in container:
        for network in container['network_remove']:
            call(f'podman network rm {network} >/dev/null 2>&1')

    # Add container
    disabled_new = False
    if 'name' in container:
        for name, container_config in container['name'].items():
            image = container_config['image']

            if run(f'podman image exists {image}') != 0:
                # container image does not exist locally - user already got
                # informed by a WARNING in verify() - bail out early
                continue

            if 'disable' in container_config:
                # check if there is a container by that name running
                tmp = _cmd('podman ps -a --format "{{.Names}}"')
                if name in tmp:
                    file_path = os.path.join(systemd_unit_path, f'vyos-container-{name}.service')
                    call(f'systemctl stop vyos-container-{name}.service')
                    if os.path.exists(file_path):
                        disabled_new = True
                        os.unlink(file_path)
                continue

            if 'container_restart' in container and name in container['container_restart']:
                cmd(f'systemctl restart vyos-container-{name}.service')

    if disabled_new:
        call('systemctl daemon-reload')

    # Re-Start network and assign it to given VRF if requested.
    restart_network(container)
    return None


if __name__ == '__main__':
    try:
        c = get_config()
        verify(c)
        generate(c)
        apply(c)
    except ConfigError as e:
        print(e)
        exit(1)