Welcome to mirror list, hosted at ThFree Co, Russian Federation.

network_watcher.py « src - dev.gajim.org/gajim/gajim.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
blob: 0bc4edddf83ba8dca339bb97c2d53d3059128eb9 (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
# -*- coding: utf-8 -*-
## src/network_watcher.py
##
## Copyright (C) 2006 Jeffrey C. Ollie <jeff AT ocjtech.us>
##                    Nikos Kouremenos <kourem AT gmail.com>
##                    Stefan Bethge <stefan AT lanpartei.de>
## Copyright (C) 2006-2017 Yann Leboulanger <asterix AT lagaule.org>
## Copyright (C) 2017 Jörg Sommer <joerg@alea.gnuu.de>
##
## This file is part of Gajim.
##
## Gajim is free software; you can redistribute it and/or modify
## it under the terms of the GNU General Public License as published
## by the Free Software Foundation; version 3 only.
##
## Gajim 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 Gajim. If not, see <http://www.gnu.org/licenses/>.
##

from common import gajim

def update_accounts(connection_is_up):
    if connection_is_up:
        for connection in gajim.connections.itervalues():
            if gajim.config.get_per('accounts', connection.name,
            'listen_to_network_manager') and connection.time_to_reconnect:
                connection._reconnect()
    else:
        for connection in gajim.connections.itervalues():
            if gajim.config.get_per('accounts', connection.name,
            'listen_to_network_manager') and connection.connected > 1:
                connection._disconnectedReconnCB()

supported = False

from common import dbus_support

if dbus_support.supported:
    import dbus

    from common.dbus_support import system_bus

    bus = system_bus.bus()

    if 'org.freedesktop.NetworkManager' in bus.list_names():
        try:
            """
            For Network Manager 0.7 - 0.9
            """
            nm_object = bus.get_object('org.freedesktop.NetworkManager',
                                       '/org/freedesktop/NetworkManager')
            props = dbus.Interface(nm_object, "org.freedesktop.DBus.Properties")

            bus.add_signal_receiver(lambda state: update_accounts(connection_is_up = state == 70),
                    'StateChanged',
                    'org.freedesktop.NetworkManager',
                    'org.freedesktop.NetworkManager',
                    '/org/freedesktop/NetworkManager')
            supported = True

        except dbus.DBusException:
            try:
                """
                For Network Manager 0.6
                """
                supported = True

                bus.add_signal_receiver(lambda *args: update_accounts(connection_is_up = False),
                        'DeviceNoLongerActive',
                        'org.freedesktop.NetworkManager',
                        'org.freedesktop.NetworkManager',
                        '/org/freedesktop/NetworkManager')

                bus.add_signal_receiver(lambda *args: update_accounts(connection_is_up = True),
                        'DeviceNowActive',
                        'org.freedesktop.NetworkManager',
                        'org.freedesktop.NetworkManager',
                        '/org/freedesktop/NetworkManager')
            except Exception:
                pass
    elif 'org.freedesktop.network1' in bus.list_names():
        """
        For systemd-networkd
        """
        def state_changed(sender, data, junk):
            if 'OperationalState' in data:
                update_accounts(connection_is_up = data['OperationalState'] == 'routable')

        bus.add_signal_receiver(state_changed, 'PropertiesChanged',
                path = '/org/freedesktop/network1')
        supported = True