diff options
Diffstat (limited to 'src/leap/bitmask/vpn')
| -rw-r--r-- | src/leap/bitmask/vpn/_control.py | 4 | ||||
| -rw-r--r-- | src/leap/bitmask/vpn/_human.py | 24 | ||||
| -rw-r--r-- | src/leap/bitmask/vpn/_management.py | 6 | ||||
| -rw-r--r-- | src/leap/bitmask/vpn/_status.py | 10 | ||||
| -rw-r--r-- | src/leap/bitmask/vpn/eip.py | 6 | ||||
| -rw-r--r-- | src/leap/bitmask/vpn/manager.py | 4 | ||||
| -rw-r--r-- | src/leap/bitmask/vpn/process.py | 4 |
7 files changed, 38 insertions, 20 deletions
diff --git a/src/leap/bitmask/vpn/_control.py b/src/leap/bitmask/vpn/_control.py index e05aeed1..31a12160 100644 --- a/src/leap/bitmask/vpn/_control.py +++ b/src/leap/bitmask/vpn/_control.py @@ -98,6 +98,10 @@ class VPNControl(object): return 'OFFLINE' return self._vpnproc.status + @property + def traffic_status(self): + return self._vpnproc.traffic_status + def stop(self, shutdown=False, restart=False): """ diff --git a/src/leap/bitmask/vpn/_human.py b/src/leap/bitmask/vpn/_human.py index 1b2ba64c..803d3656 100644 --- a/src/leap/bitmask/vpn/_human.py +++ b/src/leap/bitmask/vpn/_human.py @@ -1,6 +1,3 @@ -## {{{ http://code.activestate.com/recipes/578019/ (r15) -#!/usr/bin/env python - """ Bytes-to-human / human-to-bytes converter. Based on: http://goo.gl/kTQMs @@ -12,14 +9,15 @@ License: MIT # see: http://goo.gl/kTQMs SYMBOLS = { - 'customary' : ('B', 'K', 'M', 'G', 'T', 'P', 'E', 'Z', 'Y'), - 'customary_ext' : ('byte', 'kilo', 'mega', 'giga', 'tera', 'peta', 'exa', - 'zetta', 'iotta'), - 'iec' : ('Bi', 'Ki', 'Mi', 'Gi', 'Ti', 'Pi', 'Ei', 'Zi', 'Yi'), - 'iec_ext' : ('byte', 'kibi', 'mebi', 'gibi', 'tebi', 'pebi', 'exbi', - 'zebi', 'yobi'), + 'customary': ('B', 'K', 'M', 'G', 'T', 'P', 'E', 'Z', 'Y'), + 'customary_ext': ('byte', 'kilo', 'mega', 'giga', 'tera', 'peta', 'exa', + 'zetta', 'iotta'), + 'iec': ('Bi', 'Ki', 'Mi', 'Gi', 'Ti', 'Pi', 'Ei', 'Zi', 'Yi'), + 'iec_ext': ('byte', 'kibi', 'mebi', 'gibi', 'tebi', 'pebi', 'exbi', + 'zebi', 'yobi'), } + def bytes2human(n, format='%(value).1f %(symbol)s', symbols='customary'): """ Convert n bytes into a human readable string based on format. @@ -63,13 +61,14 @@ def bytes2human(n, format='%(value).1f %(symbol)s', symbols='customary'): symbols = SYMBOLS[symbols] prefix = {} for i, s in enumerate(symbols[1:]): - prefix[s] = 1 << (i+1)*10 + prefix[s] = 1 << (i + 1) * 10 for symbol in reversed(symbols[1:]): if n >= prefix[symbol]: value = float(n) / prefix[symbol] return format % locals() return format % dict(symbol=symbols[0], value=n) + def human2bytes(s): """ Attempts to guess the string format based on default symbols @@ -115,8 +114,7 @@ def human2bytes(s): letter = letter.upper() else: raise ValueError("can't interpret %r" % init) - prefix = {sset[0]:1} + prefix = {sset[0]: 1} for i, s in enumerate(sset[1:]): - prefix[s] = 1 << (i+1)*10 + prefix[s] = 1 << (i + 1) * 10 return int(num * prefix[letter]) - diff --git a/src/leap/bitmask/vpn/_management.py b/src/leap/bitmask/vpn/_management.py index 905372b1..8bf3cc78 100644 --- a/src/leap/bitmask/vpn/_management.py +++ b/src/leap/bitmask/vpn/_management.py @@ -265,7 +265,11 @@ class VPNManagement(object): if len(parts) < 2: continue - text, value = parts + try: + text, value = parts + except ValueError: + logger.debug("Could not parse %s" % parts) + return # text can be: # "TUN/TAP read bytes" # "TUN/TAP write bytes" diff --git a/src/leap/bitmask/vpn/_status.py b/src/leap/bitmask/vpn/_status.py index 11d564fa..da8992ed 100644 --- a/src/leap/bitmask/vpn/_status.py +++ b/src/leap/bitmask/vpn/_status.py @@ -1,9 +1,11 @@ from itertools import chain, repeat from twisted.logger import Logger +from ._human import bytes2human logger = Logger() + # TODO implement a state machine in this class @@ -49,20 +51,18 @@ class VPNStatus(object): status, errcode = self._status_codes(event) self.set_status(status, errcode) - def set_status(self, status, errcode): self.status = status self.errcode = errcode def set_traffic_status(self, status): - down, up = status + up, down = status self._traffic_up = up self._traffic_down = down def get_traffic_status(self): - # XXX return Human readable too - return {'down': self._traffic_down, - 'up': self._traffic_up} + return {'down': bytes2human(self._traffic_down), + 'up': bytes2human(self._traffic_up)} def _status_codes(self, event): # TODO check good transitions diff --git a/src/leap/bitmask/vpn/eip.py b/src/leap/bitmask/vpn/eip.py index c2aa4fb3..0c47cc32 100644 --- a/src/leap/bitmask/vpn/eip.py +++ b/src/leap/bitmask/vpn/eip.py @@ -75,7 +75,11 @@ class EIPManager(object): def get_status(self): vpn_status = self._vpn.status fw_status = self._firewall.status + result = {'EIP': vpn_status, 'firewall': fw_status} + if vpn_status == 'CONNECTED': + traffic = self._vpn.traffic_status + result['↑↑↑'] = traffic['up'] + result['↓↓↓'] = traffic['down'] return result - diff --git a/src/leap/bitmask/vpn/manager.py b/src/leap/bitmask/vpn/manager.py index 04e88097..8781603d 100644 --- a/src/leap/bitmask/vpn/manager.py +++ b/src/leap/bitmask/vpn/manager.py @@ -89,6 +89,10 @@ class VPNManager(object): def status(self): return self._vpn.status + @property + def traffic_status(self): + return self._vpn.traffic_status + def _get_management_location(self): """ diff --git a/src/leap/bitmask/vpn/process.py b/src/leap/bitmask/vpn/process.py index 185ba624..82b4e7c3 100644 --- a/src/leap/bitmask/vpn/process.py +++ b/src/leap/bitmask/vpn/process.py @@ -103,6 +103,10 @@ class VPNProcess(protocol.ProcessProtocol, _management.VPNManagement): def status(self): return self._status.status + @property + def traffic_status(self): + return self._status.get_traffic_status() + # processProtocol methods def connectionMade(self): |