summaryrefslogtreecommitdiff
path: root/src/conf_mode/service_mdns-repeater.py
blob: d4b8ef8c4a973ff6b715c738ccd652e9c9bc980f (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
#!/usr/bin/env python3
#
# Copyright (C) 2017-2022 VyOS maintainers and contributors
#
# 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 json import loads
from sys import exit
from netifaces import ifaddresses, interfaces, AF_INET, AF_INET6

from vyos.config import Config
from vyos.ifconfig.vrrp import VRRP
from vyos.template import render
from vyos.utils.process import call
from vyos import ConfigError
from vyos import airbag
airbag.enable()

config_file = '/run/avahi-daemon/avahi-daemon.conf'
vrrp_running_file = '/run/mdns_vrrp_active'

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

    base = ['service', 'mdns', 'repeater']
    if not conf.exists(base):
        return None

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

    if mdns:
        mdns['vrrp_exists'] = conf.exists('high-availability vrrp')
    return mdns

def verify(mdns):
    if not mdns or 'disable' in mdns:
        return None

    # We need at least two interfaces to repeat mDNS advertisments
    if 'interface' not in mdns or len(mdns['interface']) < 2:
        raise ConfigError('mDNS repeater requires at least 2 configured interfaces!')

    # For mdns-repeater to work it is essential that the interfaces has
    # an IPv4 address assigned
    for interface in mdns['interface']:
        if interface not in interfaces():
            raise ConfigError(f'Interface "{interface}" does not exist!')

        if mdns['ip_version'] in ['ipv4', 'both'] and AF_INET not in ifaddresses(interface):
            raise ConfigError('mDNS repeater requires an IPv4 address to be '
                                  f'configured on interface "{interface}"')

        if mdns['ip_version'] in ['ipv6', 'both'] and AF_INET6 not in ifaddresses(interface):
            raise ConfigError('mDNS repeater requires an IPv6 address to be '
                                  f'configured on interface "{interface}"')

    return None

# Get VRRP states from interfaces, returns only interfaces where state is MASTER
def get_vrrp_master(interfaces):
    json_data = loads(VRRP.collect('json'))
    for group in json_data:
        if 'data' in group:
            if 'ifp_ifname' in group['data']:
                iface = group['data']['ifp_ifname']
                state = group['data']['state'] # 2 = Master
                if iface in interfaces and state != 2:
                    interfaces.remove(iface)
    return interfaces

def generate(mdns):
    if not mdns:
        return None

    if 'disable' in mdns:
        print('Warning: mDNS repeater will be deactivated because it is disabled')
        return None

    if mdns['vrrp_exists'] and 'vrrp_disable' in mdns:
        mdns['interface'] = get_vrrp_master(mdns['interface'])

        if len(mdns['interface']) < 2:
            return None

    render(config_file, 'mdns-repeater/avahi-daemon.j2', mdns)
    return None

def apply(mdns):
    if not mdns or 'disable' in mdns:
        call('systemctl stop avahi-daemon.service')
        if os.path.exists(config_file):
            os.unlink(config_file)

        if os.path.exists(vrrp_running_file):
            os.unlink(vrrp_running_file)
    else:
        if 'vrrp_disable' not in mdns and os.path.exists(vrrp_running_file):
            os.unlink(vrrp_running_file)

        if mdns['vrrp_exists'] and 'vrrp_disable' in mdns:
            if not os.path.exists(vrrp_running_file):
                os.mknod(vrrp_running_file) # vrrp script looks for this file to update mdns repeater

            if len(mdns['interface']) < 2:
                call('systemctl stop avahi-daemon.service')
                return None

        call('systemctl restart avahi-daemon.service')

    return None

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