version="0.0.3" # Plugins/NetworkWatcher/__init__.py # # Copyright (C) 2013 Pako (lubos.ruckl@quick.cz) # # This file is a plugin for EventGhost. # Copyright (C) 2005-2009 Lars-Peter Voss # # EventGhost is free software; you can redistribute it and/or modify it under # the terms of the GNU General Public License version 2 as published by the # Free Software Foundation; # # EventGhost 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 . # # Changelog (in reverse chronological order): # ------------------------------------------- # 0.0.3 by Pako 2014-03-13 11:00 UTC+1 # - added internet accessibility test # 0.0.2 by Pako 2013-12-09 11:01 UTC+1 # - added option to ignore certain IP addresses (for ex. VirtualBox Host) # 0.0.1 by Pako 2013-10-03 08:51 UTC+1 # - support url updated # 0.0.0 by Pako 2013-10-02 18:23 UTC+1 # - initial version eg.RegisterPlugin( name = "Network watcher", author = "Pako", version = version, guid = "{344DE9EF-B649-405D-BC58-C87B248EBD3B}", canMultiLoad = False, createMacrosOnAdd = True, description = u'''Generates events if an IP address is changed ... ... and whether or not the internet is available.''', url = "http://www.eventghost.net/forum/viewtopic.php?f=9&t=5707", icon = ( "iVBORw0KGgoAAAANSUhEUgAAABAAAAAQCAYAAAAf8/9hAAACRUlEQVQ4y42TwU4TURiF" "vzszdICWihUakZYmLOiCBSgmLkxIKvEFcOHCFSb4FD6HLHDlTh9AMcG9XTQmpSEWFyKU" "ZArNFGqnmU5n5ndRmLSgiWd577nfPffPuYr/lIg0gVvXlkMDIAxDabVaNBoNRGTIoZRi" "enoaEUEpdYNrANRqNba3tzk6PeqbBnwSCrl0js1Xm2QymeuAwADY29vDHrVpvm5ybB4P" "OXJujsbbBuVymdnZ2RspDADHcXBnXXbv7dLROpds4AgO24esssr+/j5zc3MoFCOxEXK5" "HKZp9gEIKE2hrrILGB8Nkp+STLVHcWoWRfMLh5UKCPhmjPsPVth4udEHKE3hdb3osHIV" "E5UJnvdGePHD4a51gqk3iJ+cILpObWmJdwdVzs7O+oCZmRnCUsjih0Vi8RhhN6Rz4PCo" "Wufx1wvgYujd2tgY2spDfN/vA5aXl1k7WCNbzuJ5HkEQUDmucLvZBawbnVBhODzEUqnE" "zucdbNuONizLou04BAN9uJq/P9AJA+C0fkr1e5VerxeZRYT3bpdviQSappHJZEin04gI" "NRHM5ATxeLwPWMgvsP5sHcdxogS+72NZFj9dF03T+D01xa/xcQCSySRPCwUmJycxRMQL" "goD5+fmoxp7nsfVmi2KxSBAEKBT1ej2KHR+P07pokc/nMQBD13USiUR0e6fTwbZtzpvn" "f/1YbbONruu4rntZpGuKxWIUnhRI3UkRDkx8UNlsllQqhRIRF9Avyxup1+sRBME/v7em" "aRiG4f0BGA744LHgjnkAAAAASUVORK5CYII=" ), ) from socket import gethostbyname,gethostbyname_ex,gethostname,create_connection #=============================================================================== class Text: label_1 = "Event prefix:" label_2 = "Polling period (s):" prefix = "Network" removed = "Removed" added = "Added" disconnected = "Disconnected" connected = "Connected" unavailable = "Unavailable" available = "Available" ignored = "The IP addresses to be ignored:" server = "Connectivity test server:" toolTip = """Enter the IP addresses that should be ignored. Useful (for example) for VirtualBox Host IP address. Use a comma as the separator. Example: 192.168.56.1, 172.16.56.1""" #=============================================================================== class NetworkWatcher(eg.PluginBase): text = Text task = None oldAddrs = None connected = False internet = None host = None def __init__(self): self.AddAction(GetConnected) self.AddAction(GetAddresses) self.AddAction(GetInternet) def __start__( self, prefix = "", period = 0.5, ignored = "", server = "www.google.com" ): self.info.eventPrefix = prefix if prefix != "" else self.text.prefix self.period = period self.task = eg.scheduler.AddTask(0.01, self.NetWatcher) self.ignrd = ignored.replace(" ","").split(",") self.server = server def __stop__(self): if self.task: eg.scheduler.CancelTask(self.task) self.task = None self.oldAddrs = None self.internet = None self.host = None def GetAdresses(self): tmp = [a for a in gethostbyname_ex(gethostname())[2]] addresses = [] for a in tmp: if a.startswith("127.") or a.startswith("169.") or a in self.ignrd: continue addresses.append(a) return addresses def NetWatcher(self): self.task = 0 newAddrs = self.GetAdresses() newA = set(newAddrs) oldA = set(self.oldAddrs) if self.oldAddrs is not None else set([]) for ip in oldA.difference(newA): self.TriggerEvent(self.text.removed, payload = ip) for ip in newA.difference(oldA): self.TriggerEvent(self.text.added, payload = ip) if not newAddrs and (self.oldAddrs is None or self.oldAddrs): self.TriggerEvent(self.text.disconnected) self.connected = False elif not self.oldAddrs and newAddrs: self.TriggerEvent(self.text.connected) self.connected = True self.oldAddrs = newAddrs if self.connected: try: if not self.host: self.host = gethostbyname(self.server) s = create_connection((self.host, 80), 1) s.close() if not self.internet: eg.TriggerEvent(self.text.available, prefix = "Internet") self.internet = True except: if self.internet or self.internet is None: eg.TriggerEvent(self.text.unavailable, prefix = "Internet") self.internet = False if self.task is not None: self.task = eg.scheduler.AddTask(self.period, self.NetWatcher) def Configure( self, prefix = "", period = 0.5, ignored = "", server = "www.google.com" ): prefix = prefix if prefix != "" else self.text.prefix panel = eg.ConfigPanel() label_1 = wx.StaticText(panel, -1, self.text.label_1) label_2 = wx.StaticText(panel, -1, self.text.label_2) label_3 = wx.StaticText(panel, -1, self.text.ignored) label_4 = wx.StaticText(panel, -1, self.text.server) prefixCtrl = wx.TextCtrl(panel, -1, prefix) periodCtrl = eg.SpinNumCtrl( panel, -1, period, integerWidth = 5, fractionWidth = 1, allowNegative = False, min = 0.1, increment = 0.1, ) ignoredCtrl = wx.TextCtrl(panel, -1, ignored) label_3.SetToolTipString(self.text.toolTip) ignoredCtrl.SetToolTipString(self.text.toolTip) serverCtrl = wx.TextCtrl(panel, -1, server) Sizer = wx.GridBagSizer(10, 10) Sizer.AddGrowableCol(1) Sizer.Add(label_1, (0, 0), flag = wx.TOP, border = 3) Sizer.Add(prefixCtrl, (0, 1)) Sizer.Add(label_2, (1, 0), flag = wx.TOP, border = 3) Sizer.Add(periodCtrl, (1, 1)) Sizer.Add(label_3, (2, 0), flag = wx.TOP, border = 3) Sizer.Add(ignoredCtrl, (2, 1), flag = wx.EXPAND) Sizer.Add(label_4, (3, 0), flag = wx.TOP, border = 3) Sizer.Add(serverCtrl, (3, 1), flag = wx.EXPAND) panel.sizer.Add(Sizer, 1, wx.EXPAND | wx.ALL,10) while panel.Affirmed(): panel.SetResult( prefixCtrl.GetValue(), periodCtrl.GetValue(), ignoredCtrl.GetValue(), serverCtrl.GetValue() ) #=============================================================================== class GetInternet(eg.ActionBase): name = "Get internet accessibility" description = "Returns internet accessibility." def __call__(self): return self.plugin.internet #=============================================================================== class GetConnected(eg.ActionBase): name = "Get connected status" description = "Returns connected status." def __call__(self): return self.plugin.oldAddrs != [] #=============================================================================== class GetAddresses(eg.ActionBase): name = "Get addresses" description = "Returns list of all valid IP addresses." def __call__(self): return self.plugin.oldAddrs #===============================================================================