implemented abstracted layer with matching and passed callback.

tests as well.

1 files changed, 21 insertions, 0 deletions

diff --git a/src/leap/base/checks.py b/src/leap/base/checks.py
index 4d4a5d8b..587012fb 100644
--- a/src/leap/base/checks.py
+++ b/src/leap/base/checks.py
@@ -12,6 +12,9 @@ from leap.base import exceptions
 
 logger = logging.getLogger(name=__name__)
 
+#EVENTS OF NOTE
+EVENT_CONNECT_REFUSED = "[ECONNREFUSED]: Connection refused (code=111)"
+
 
 class LeapNetworkChecker(object):
     """
@@ -34,6 +37,8 @@ class LeapNetworkChecker(object):
         if self.provider_gateway:
             checker.ping_gateway(self.provider_gateway)
 
+        checker.parse_log_and_react([], ())
+
     def check_internet_connection(self):
         try:
             # XXX remove this hardcoded random ip
@@ -136,3 +141,19 @@ class LeapNetworkChecker(object):
             return True
         except socket.gaierror:
             raise exceptions.CannotResolveDomainError
+
+    def parse_log_and_react(self, log, error_matrix=None):
+        """
+        compares the recent openvpn status log to
+        strings passed in and executes the callbacks passed in.
+        @param log: openvpn log
+        @type log: list of strings
+        @param error_matrix: tuples of strings and tuples of callbacks
+        @type error_matrix: tuples strings and call backs
+        """
+        for line in log:
+            for each in error_matrix:
+                error, callbacks = each
+                if error in line:
+                    for cb in callbacks:
+                        cb()