add files

Author: Sajjad

Pipfile

@@ -0,0 +1,11 @@
+[[source]]
+name = "pypi"
+url = "https://pypi.org/simple"
+verify_ssl = true
+
+[dev-packages]
+
+[packages]
+
+[requires]
+python_version = "3.7"

Pipfile.lock

@@ -0,0 +1,126 @@
+
+"""
+activenodes/activeNodes.py
+Python3 package for find active nodes for IPv4 in range of IP address
+"""
+
+import sys
+import time
+import subprocess
+import ipaddress
+from threading import Thread
+from queue import Queue
+
+import error
+
+class ActiveNodes:
+    def __init__(self, start, end, threads=512, log=False):
+
+        self.start = start
+        self.end = end
+        self.threads = threads
+        self.log = log
+        self.logs = []
+        self.addresses = []
+        self.activeNodes = []
+        self.deactiveNodes = []
+
+        try:
+            ipaddress.IPv4Address(start)
+            ipaddress.IPv4Address(end)
+        except ValueError as e:
+            raise e
+
+        if ipaddress.ip_address(self.start) > ipaddress.ip_address(self.end):
+            raise error.AddressRangeError("Start and end address are not same range")
+
+    def __repr__(self):
+        return "ActiveNodes('{0}', '{1}', {2})".format(self.start, self.end, self.threads)
+
+    def genAddresses(self):
+
+        """
+        collect IPv4 addresses
+        """
+        
+        self.addresses.clear()
+
+        #start from first address 
+        address = self.start
+        while address != self.end:
+            #print(address)
+            address = str(ipaddress.ip_address(address) + 1)
+            self.addresses.append(address)
+
+        return self.addresses
+    
+    def pinger(self, thread, queue):
+        
+        """
+        Pings subnet
+        """
+
+        self.logs.clear()
+        
+        while True:
+            address = queue.get()
+
+            if self.log:
+                log = "{0} Thread <{1}> Pinging : {2}".format(time.ctime(), thread, address)
+                self.logs.append(log)
+                print(log)
+
+            ret = subprocess.call("ping -c 1 {0}".format(address),
+            shell=True,
+            stdout=open('/dev/null', 'w'),
+            stderr=subprocess.STDOUT)
+            if ret == 0:
+                if self.log:
+                    log = "{0} Active Node at : {1}".format(time.ctime(), address)
+                    self.logs.append(log)
+                    print(log)
+                self.activeNodes.append(address)
+            else:
+                if self.log:
+                    log = "{0} Node Not Active at : {1}".format(time.ctime(), address)
+                    self.logs.append(log)
+                    print(log)
+                self.deactiveNodes.append(address)
+            queue.task_done()
+
+    def active(self):
+
+        """
+        return self.activeNodes, self.deactiveNodes
+        """
+
+        self.genAddresses()
+        queue = Queue()
+
+        for thread in range(self.threads):
+            worker = Thread(target=self.pinger, args=(thread, queue))
+            worker.setDaemon(True)
+            worker.start()
+
+        for address in self.addresses:
+            queue.put(address)
+        queue.join()
+
+        #remove duplicates addresses and sort them
+        self.activeNodes = list(dict.fromkeys(sorted(self.activeNodes)))
+        self.deactiveNodes = list(dict.fromkeys(sorted(self.deactiveNodes)))
+
+        #ratio add after this function run
+        self.ratio = {
+            "addresses": len(self.addresses),
+            "active": len(self.activeNodes),
+            "deactive": len(self.deactiveNodes)
+        }
+        
+        return self.activeNodes
+
+    def deactive(self):
+        self.active()
+        return self.deactiveNodes
+
+x = ActiveNodes("192.168.0.1", "192.168.0.225", log=True)

activenodes/__init__.py

@@ -0,0 +1,22 @@
+
+"""
+activenodes/activeNodesTool.py
+executable python file of activeNodes.py as Terminal Tool
+"""
+
+import sys
+import re
+
+from activeNodes import ActiveNodes
+
+start = sys.argv[1]
+end = sys.argv[2]
+
+if 'log' in sys.argv:
+    log = True
+
+for arg in sys.argv:
+    if re.search(r'threads:([0-9])\d+', arg):
+        threads = arg.split(':')[1]
+
+ant = ActiveNodes(start, end, threads=512, log=log).active()

activenodes/activeNodes.py

@@ -0,0 +1,11 @@
+
+
+class MessageError(Exception):
+    """Base class for errors in the email package."""
+
+
+class NotVaildIPAddressError(MessageError):
+    """Base class for Not a vaild IPv4 address"""
+
+class AddressRangeError(MessageError):
+    """Raise when end address bigger than start address"""

activenodes/activeNodesTool.py

@@ -0,0 +1,91 @@
+
+"""
+activenodes/activeNodesExec.py
+executable python file of activeNodes.py
+"""
+
+import sys
+import subprocess
+import ipaddress
+from threading import Thread
+from queue import Queue
+
+def next(oldip):
+
+    def gen_next_ip(ip):
+        octets = ip.split(".")
+        last_octet = octets[-1]
+        if last_octet == '254':
+            octets[2] = str(int(octets[2]) + 1)
+            nextip = '{0}.{1}.{2}.{3}'.format(octets[0],octets[1],octets[2],"0")
+
+        else:
+            octets[3] = str(int(octets[3]) + 1)
+            nextip = '{0}.{1}.{2}.{3}'.format(octets[0],octets[1],octets[2],octets[3])
+        return str(nextip)
+
+    try :
+        oldip == str(ipaddress.IPv4Address(oldip))
+
+        out = gen_next_ip(oldip)
+        return out
+    except:
+        print("Your address is not vaild")
+
+
+if len(sys.argv) == 3:
+	start_range = sys.argv[1]
+	end_range = sys.argv[2]
+	
+	print("Please Wait ...")
+else:
+	print("""Use it like that
+~$ python3 livenodes.py 192.168.0.1 192.168.3.254""")
+	exit()
+
+address = start_range
+iprange = []
+
+while address != end_range:
+    address = next(address)
+    iprange.append(address)
+#iprange = iprange[--:--]
+#print(iprange)
+
+
+LiveNodes = []
+#the number of threads set to 512 if you have powerfull computer you can increases
+num_threads = 512
+queue = Queue()
+
+#wraps system ping command
+def pinger(i, q):
+	"""Pings subnet"""
+	while True:
+		ip = q.get()
+		#print("Thread {0}: Pinging {1}".format(i, ip))
+		ret = subprocess.call("ping -c 1 {0}".format(ip),
+		shell=True,
+		stdout=open('/dev/null', 'w'),
+		stderr=subprocess.STDOUT)
+		if ret == 0:
+			#print( "There is a Live Node at : {0}".format(ip))
+			LiveNodes.append(ip)
+		else:
+			pass
+			#print( "There is no Node Available at {0}".format(ip))
+		q.task_done()
+#Spawn thread pool
+for i in range(num_threads):
+
+    worker = Thread(target=pinger, args=(i, queue))
+    worker.setDaemon(True)
+    worker.start()
+#Place work in queue
+for ip in iprange:
+    queue.put(ip)
+#Wait until worker threads are done to exit
+queue.join()
+print("\nAll live nodes in Range ({0} -- {1})".format(start_range, end_range))
+for node in LiveNodes:
+	print(node)