diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/vyos/firewall.py | 14 | ||||
| -rw-r--r-- | python/vyos/frr.py | 9 | ||||
| -rw-r--r-- | python/vyos/raid.py | 71 | ||||
| -rw-r--r-- | python/vyos/utils/disk.py | 23 | 
4 files changed, 114 insertions, 3 deletions
| diff --git a/python/vyos/firewall.py b/python/vyos/firewall.py index 1ec034937..ab40688cc 100644 --- a/python/vyos/firewall.py +++ b/python/vyos/firewall.py @@ -102,6 +102,20 @@ def parse_rule(rule_conf, hook, fw_name, rule_id, ip_name):          if states:              output.append(f'ct state {{{states}}}') +    if 'conntrack_helper' in rule_conf: +        helper_map = {'h323': ['RAS', 'Q.931'], 'nfs': ['rpc'], 'sqlnet': ['tns']} +        helper_out = [] + +        for helper in rule_conf['conntrack_helper']: +            if helper in helper_map: +                helper_out.extend(helper_map[helper]) +            else: +                helper_out.append(helper) + +        if helper_out: +            helper_str = ','.join(f'"{s}"' for s in helper_out) +            output.append(f'ct helper {{{helper_str}}}') +      if 'connection_status' in rule_conf and rule_conf['connection_status']:          status = rule_conf['connection_status']          if status['nat'] == 'destination': diff --git a/python/vyos/frr.py b/python/vyos/frr.py index 9c9e50ff7..ad5c207f5 100644 --- a/python/vyos/frr.py +++ b/python/vyos/frr.py @@ -86,9 +86,12 @@ ch2 = logging.StreamHandler(stream=sys.stdout)  LOG.addHandler(ch)  LOG.addHandler(ch2) -_frr_daemons = ['zebra', 'bgpd', 'fabricd', 'isisd', 'ospf6d', 'ospfd', 'pbrd', -                'pimd', 'ripd', 'ripngd', 'sharpd', 'staticd', 'vrrpd', 'ldpd', -                'bfdd', 'eigrpd', 'babeld' ,'pim6d'] +# Full list of FRR 9.0/stable daemons for reference +#_frr_daemons = ['zebra', 'staticd', 'bgpd', 'ospfd', 'ospf6d', 'ripd', 'ripngd', +#                'isisd', 'pim6d', 'ldpd', 'eigrpd', 'babeld', 'sharpd', 'bfdd', +#                'fabricd', 'pathd'] +_frr_daemons = ['zebra', 'staticd', 'bgpd', 'ospfd', 'ospf6d', 'ripd', 'ripngd', +                'isisd', 'pim6d', 'ldpd', 'babeld', 'bfdd']  path_vtysh = '/usr/bin/vtysh'  path_frr_reload = '/usr/lib/frr/frr-reload.py' diff --git a/python/vyos/raid.py b/python/vyos/raid.py new file mode 100644 index 000000000..7fb794817 --- /dev/null +++ b/python/vyos/raid.py @@ -0,0 +1,71 @@ +# Copyright 2023 VyOS maintainers and contributors <maintainers@vyos.io> +# +# This library is free software; you can redistribute it and/or +# modify it under the terms of the GNU Lesser General Public +# License as published by the Free Software Foundation; either +# version 2.1 of the License, or (at your option) any later version. +# +# This library 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 +# Lesser General Public License for more details. +# +# You should have received a copy of the GNU Lesser General Public License +# along with this library.  If not, see <http://www.gnu.org/licenses/>. + +from vyos.utils.disk import device_from_id +from vyos.utils.process import cmd + +def raid_sets(): +    """ +    Returns a list of RAID sets +    """ +    with open('/proc/mdstat') as f: +        return [line.split()[0].rstrip(':') for line in f if line.startswith('md')] + +def raid_set_members(raid_set_name: str): +    """ +    Returns a list of members of a RAID set +    """ +    with open('/proc/mdstat') as f: +        for line in f: +            if line.startswith(raid_set_name): +                return [l.split('[')[0] for l in line.split()[4:]] +    return [] + +def partitions(): +    """ +    Returns a list of partitions +    """ +    with open('/proc/partitions') as f: +        p = [l.strip().split()[-1] for l in list(f) if l.strip()] +    p.remove('name') +    return p + +def add_raid_member(raid_set_name: str, member: str, by_id: bool = False): +    """ +    Add a member to an existing RAID set +    """ +    if by_id: +        member = device_from_id(member) +    if raid_set_name not in raid_sets(): +        raise ValueError(f"RAID set {raid_set_name} does not exist") +    if member not in partitions(): +        raise ValueError(f"Partition {member} does not exist") +    if member in raid_set_members(raid_set_name): +        raise ValueError(f"Partition {member} is already a member of RAID set {raid_set_name}") +    cmd(f'mdadm --add /dev/{raid_set_name} /dev/{member}') +    disk = cmd(f'lsblk -ndo PKNAME /dev/{member}') +    cmd(f'grub-install /dev/{disk}') + +def delete_raid_member(raid_set_name: str, member: str, by_id: bool = False): +    """ +    Delete a member from an existing RAID set +    """ +    if by_id: +        member = device_from_id(member) +    if raid_set_name not in raid_sets(): +        raise ValueError(f"RAID set {raid_set_name} does not exist") +    if member not in raid_set_members(raid_set_name): +        raise ValueError(f"Partition {member} is not a member of RAID set {raid_set_name}") +    cmd(f'mdadm --remove /dev/{raid_set_name} /dev/{member}') diff --git a/python/vyos/utils/disk.py b/python/vyos/utils/disk.py new file mode 100644 index 000000000..ee540b107 --- /dev/null +++ b/python/vyos/utils/disk.py @@ -0,0 +1,23 @@ +# Copyright 2023 VyOS maintainers and contributors <maintainers@vyos.io> +# +# This library is free software; you can redistribute it and/or +# modify it under the terms of the GNU Lesser General Public +# License as published by the Free Software Foundation; either +# version 2.1 of the License, or (at your option) any later version. +# +# This library 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 +# Lesser General Public License for more details. +# +# You should have received a copy of the GNU Lesser General Public +# License along with this library.  If not, see <http://www.gnu.org/licenses/>. + +from pathlib import Path + +def device_from_id(id): +    """ Return the device name from (partial) disk id """ +    path = Path('/dev/disk/by-id') +    for device in path.iterdir(): +        if device.name.endswith(id): +            return device.readlink().stem | 
