Mass dm bot (Instagram)

from instagrapi import Client
from instagrapi.exceptions import LoginRequired, UnknownError, FeedbackRequired, UserNotFound, ClientError, ClientConnectionError, ClientNotFoundError
import time
import random, os, sys
from datetime import date
import tkinter as tk
from tkinter import *
from PIL import Image, ImageTk
from tkinter import filedialog
import emoji, threading, sqlite3

class SampleApp(tk.Tk):
    def __init__(self):
        tk.Tk.__init__(self)
        self._frame = None
        self.title('Instagram Bot')
        self.geometry("500x600")
        self.image = None
        # Set background image
        self.canvas = Canvas(self._frame,width=200,height=200)
        self.image = ImageTk.PhotoImage(Image.open('ngineX.png'))
        self.canvas.create_image(0,0,anchor=NW,image=self.image)
        self.canvas.pack()
        self.image1 = None
        self.canvas1 = Canvas(self._frame,width=200,height=200)
        self.image1 = ImageTk.PhotoImage(Image.open('41KSu1weSuL.jpg'))
        self.canvas1.create_image(0,0,anchor=NW,image=self.image1)
        self.canvas1.pack()
        self.switch_frame(StartPage)
        self.amount = None
        self.name = None
        self.url = None
        self.time = None
        self.user = None
        self.amout_dm = None
        self.proxy_count = None
        self.requsets_time = None
        self.amount_dm_total = None
        
    def switch_frame(self, frame_class):
        """Destroys current frame and replaces it with a new one."""
        new_frame = frame_class(self)
        if self._frame is not None:
            self.canvas1.destroy()
            self._frame.destroy()
        self._frame = new_frame
        self._frame.pack()




class StartPage(tk.Frame):
    def __init__(self, master):
        tk.Frame.__init__(self, master)
    
        tk.Label(self, text="code by Mike Hadzhiev").pack(side="top", fill="x", pady=10)

        tk.Button(self, text="Login", command=lambda: master.switch_frame(PageOne)).pack()





class PageOne(tk.Frame):
	def __init__(self, master):
		tk.Frame.__init__(self, master)
		tk.Label(self, text="Welcome to Instagram Bot \n Plese choice a option").pack(side="top", fill="x", pady=10)
		tk.Button(self, text='Send dm from user list', command=lambda: master.switch_frame(Dm_likers)).pack()
		tk.Button(self, text='Export list of users followers', command=lambda: master.switch_frame(Export_users)).pack()
		tk.Button(self, text='Export settings', command=lambda: master.switch_frame(Export_setting)).pack()

class Dm_likers(tk.Frame):
	def __init__(self, master):
		tk.Frame.__init__(self, master)
		self.file_lbl1 = tk.Label(self, text='Load file with users')
		self.file_lbl1.pack(side='top',fill='x',pady=10)
		tk.Button(self, text='Browse files', command=self.browseFiles_hstg1).pack()
		
		self.file_lbl2 = tk.Label(self, text='Enter number of dm per account')
		self.file_lbl2.pack(side='top',fill='x',pady=10)
		self.amout_dm = tk.Entry(self)
		self.amout_dm.pack()

		self.file_lbl3 = tk.Label(self, text='Enter number of accounts per proxy')
		self.file_lbl3.pack(side='top',fill='x',pady=10)
		self.proxy_count = tk.Entry(self)
		self.proxy_count.pack()

		self.file_lbl4 = tk.Label(self, text='Enter seconds for each meesage request')
		self.file_lbl4.pack(side='top',fill='x',pady=10)
		self.requsets_time = tk.Entry(self)
		self.requsets_time.pack()

		self.file_lbl5 = tk.Label(self, text='Enter total amount of messages you want to send')
		self.file_lbl5.pack(side='top',fill='x',pady=10)
		self.amount_dm_total = tk.Entry(self)
		self.amount_dm_total.pack()

		tk.Button(self,text='Start Bot', command=self.go).pack()
		tk.Button(self, text='Back', command=lambda: master.switch_frame(PageOne)).pack()
	

	def browseFiles_hstg1(self): 
	    filename = filedialog.askopenfilename(initialdir = "/", 
	                                      title = "Select a File", 
	                                      filetypes = (("Text files", 
	                                                    "*.txt*"), 
	                                                   ("all files", 
	                                                    "*.*"))) 
	    # Change label contents 
	    self.file_lbl1.configure(text = filename)
    
   

	def go(self):
		self.save_credentials()
		self.start_location()


	def save_credentials(self):
		self.master.amout_dm = self.amout_dm.get()
		self.amout_dm1 = int(self.master.amout_dm) 
		self.master.proxy_count = self.proxy_count.get()
		self.proxy_count1 = int(self.master.proxy_count)
		self.master.requsets_time = self.requsets_time.get()
		self.requsets_time1 = int(self.master.requsets_time)
		self.master.amount_dm_total = self.amount_dm_total.get()
		self.amount_dm_total1 = int(self.master.amount_dm_total)

	def start_location(self):
		username_lst = list()
		media_id_hash = list()
		user_id_lst = list()
		sys.tracebacklimit=0

		try:
			conn = sqlite3.connect('users_limit_database.db', check_same_thread=False)
			cursor = conn.cursor()
			print("Opened database successfully")
		except:
			print('Can`t open database')

		try:
			cursor.execute('''CREATE TABLE  USER_COUNT (USERNAME TEXT UNIQUE , AMOUNT_MESSAGES INT );''')
			print ("Table created successfully")
		except:
			pass


		with open('accounts.txt','r') as file:
			data_accounts = [line.strip() for line in file]

		with open('proxyipv4.txt','r') as file:
			data_proxy = [line.strip() for line in file]

		with open(self.file_lbl1.cget('text'), 'r') as file:
			data_users = [line.strip() for line in file]

		with open('messages.txt', 'r') as file:
			data_message = [line.strip() for line in file]
		
		# with open('old_users.txt', 'r') as file:
		# 	old_users = [line.strip() for line in file]

		newcl = 'cl'
		cl_list = list()
		cl_list_final = list()
		account_name = list()

		for each in range(int(len(data_accounts) / 2)):
			newcl = newcl + str(each)
			cl_list.append(newcl)
			newcl = 'cl'
		
		count = 0
		n = 1
		x = 0
		global count_account
		count_account = 0
		proxy = 'https://' + data_proxy[0]

		users_limit = cursor.execute("SELECT USERNAME FROM USER_COUNT WHERE AMOUNT_MESSAGES >= 30")
		#print(type(users_limit), users_limit)
		data_accounts_limit = list()
		
		dadta = cursor.fetchall()
		#print(dadta)

		for each_t in dadta:
			print(each, type(each))
			for each in each_t:
				print(each, type(each))
				data_accounts_limit.append(each)

		for each_ac, each_p in zip(data_accounts[0::2], data_accounts[1::2]):
			for each_a in data_accounts_limit:
				if each_ac == each_a:
					data_accounts_limit.append(each_p)

		#print(data_accounts_limit)
		data_accounts = [x for x in data_accounts if x not in data_accounts_limit]

		for each_usr, each_pass, cl_name in zip(data_accounts[0::2], data_accounts[1::2], cl_list):
			if count == self.proxy_count1:
					proxy = 'https://' + data_proxy[n]
					count = 0
					n += 1
			else:
				pass
		
			ACCOUNT_USERNAME = each_usr
			ACCOUNT_PASSWORD = each_pass
			try:
				cl_name = Client()
				cl_name.request_timeout = self.requsets_time1
				print(proxy)
				cl_name.set_proxy(proxy)	
				cl_name.login(ACCOUNT_USERNAME, ACCOUNT_PASSWORD)
				cl_list_final.append(cl_name)
				account_name.append(ACCOUNT_USERNAME)
				print('Login with ', ACCOUNT_USERNAME)
				count += 1
				with open('good_accounts.txt', 'a+') as file:
					file.write(ACCOUNT_USERNAME + '\n')
				count_account += 1
				try:	
					cursor.execute("INSERT INTO USER_COUNT VALUES (?, ?);", (ACCOUNT_USERNAME, 0))
					conn.commit()
				except:
					pass

				if count_account == self.amount_dm_total1 / self.amout_dm1:
					break
			except Exception as e:
				print(str(e))
				proxy = 'https://' + data_proxy[n]
				n += 1
				print('Can`t login with', ACCOUNT_USERNAME)
				with open('report_bad_accounts.txt', 'a+') as file:
					file.write(each_usr + '\n')

	

		msg = random.choice(data_message)
			
		with open('old_users.txt', 'r') as file:
			old_users = [line.strip() for line in file]
				
		data_users = [x for x in data_users if x not in old_users]
		# global count_messages_send
		# count_messages_send = 0


		def firstOne(data_users, cl_list, acc_namee):
			global count_messages_send
			count_messages_send = 0
			i = count_account / 3
			j = int(i)
			#print(j)
			msg = random.choice(data_message)
			for each_cl, acc_name in zip(cl_list_final[:j], account_name[:j]):
				count1 = 0
				for each_usr in data_users:
					with open('old_users.txt', 'a+') as file:
						file.write(each_usr + '\n')
					try:
						try:
							user_Ids = each_cl.user_id_from_username(each_usr)
						except:
							continue
						each_cl.direct_send(msg ,[user_Ids])
						print('Direct message send: ', msg, ' to user', each_usr, ' from username ', acc_name)
						count1 += 1
						cursor.execute("UPDATE USER_COUNT SET AMOUNT_MESSAGES =  (?)  WHERE USERNAME = (?);", (count1, acc_name))
						conn.commit()
					#	today = date.today()
						count_messages_send += 1
						# d1 = today.strftime("%d/%m/%Y")
						# with open('report_mid.txt', 'w') as file:
						# 	file.write(str(d1) + ' messages send: ' + str(count_messages_send) + '\n')

						old_users.append(each_usr)
						if count1 == self.amout_dm1:
							break					
									
					except Exception as e:
						if 'We limit how often you can do certain things on Instagram' in str(e):
							break
						else:			
							with open('old_users.txt', 'a+') as file:
								file.write(each_usr + '\n')
						
						print(str(e))
						break
					except Exception as e:
						print(str(e))
						break

		def firstSecond(data_users, cl_list, acc_namee):
			global count_messages_send1
			count_messages_send1 = 0
			i = count_account / 3
			j = int(i)
			msg = random.choice(data_message)
			for each_cl, acc_name in zip(cl_list_final[j:j+j], account_name[j:j+j]):
				count1 = 0

				for each_usr in data_users:
					try:
						with open('old_users.txt', 'a+') as file:
							file.write(each_usr + '\n')
						try:
							user_Ids = each_cl.user_id_from_username(each_usr)
						except:
							continue
						each_cl.direct_send(msg ,[user_Ids])
						print('Direct message send: ', msg, ' to user', each_usr, ' from username ', acc_name)
						count1 += 1
						cursor.execute("UPDATE USER_COUNT SET AMOUNT_MESSAGES =  (?)  WHERE USERNAME = (?);", (count1, acc_name))						#today = date.today()
						conn.commit()
						count_messages_send1 += 1
						# d1 = today.strftime("%d/%m/%Y")
						# count_messages_send2 = count_messages_send1 + count_messages_send
						# with open('report_mid.txt', 'w') as file:
						# 	file.write(str(d1) + ' messages send: ' + str(count_messages_send2) + '\n')

						old_users.append(each_usr)
						if count1 == self.amout_dm1:
							break					
									
					except Exception as e:
						if 'We limit how often you can do certain things on Instagram' in str(e):
							break
						else:			
							with open('old_users.txt', 'a+') as file:
								file.write(each_usr + '\n')
						
						print(str(e))
						break
					except Exception as e:
						print(str(e))
						break

		def firstThird(data_users, cl_list, acc_namee):
			global count_messages_send2
			count_messages_send2 = 0
			i = count_account / 3
			j = int(i)
			msg = random.choice(data_message)
			for each_cl, acc_name in zip(cl_list_final[j+j:], account_name[j+j:]):
				count1 = 0
				for each_usr in data_users:
					try:
						with open('old_users.txt', 'a+') as file:
							file.write(each_usr + '\n')
						try:
							user_Ids = each_cl.user_id_from_username(each_usr)
						except:
							continue
						each_cl.direct_send(msg ,[user_Ids])
						print('Direct message send: ', msg, ' to user', each_usr, ' from username ', acc_name)
						count1 += 1
						
						cursor.execute("UPDATE USER_COUNT SET AMOUNT_MESSAGES =  (?)  WHERE USERNAME = (?);", (count1, acc_name))
						conn.commit()
						count_messages_send2 += 1
						today = date.today()
						d1 = today.strftime("%d/%m/%Y")
						total = count_messages_send + count_messages_send1 + count_messages_send2
						with open('report_mid.txt', 'w') as file:
							file.write(str(d1) + ' messages send: ' + str(total) + '\n')

						# #count_messages_send4 = count_messages_send3 + count_messages_send2
						# d1 = today.strftime("%d/%m/%Y")
						# with open('report_mid.txt', 'w') as file:
						# 	file.write(str(d1) + ' messages send: ' + str(count_messages_send4) + '\n')

						old_users.append(each_usr)
						if count1 == self.amout_dm1:
							break					
									
					except Exception as e:
						if 'We limit how often you can do certain things on Instagram' in str(e):
							break
						else:			
							with open('old_users.txt', 'a+') as file:
								file.write(each_usr + '\n')
						
						print(str(e))
						break
					except Exception as e:
						print(str(e))
						break

		user_to = self.amount_dm_total1 / 3
		q = int(user_to)
		#print(q)
		t1 = threading.Thread(target=firstOne, args=(data_users[:q], cl_list_final, account_name,))
		t2 = threading.Thread(target=firstSecond, args=(data_users[q:q+q], cl_list_final, account_name,))
		t3 = threading.Thread(target=firstThird, args=(data_users[q+q:q+q+q], cl_list_final, account_name,))

		t1.start()
		t2.start()
		t3.start()

		t1.join()
		t2.join()
		t3.join()

		today = date.today()
		d1 = today.strftime("%d/%m/%Y")
		total = count_messages_send + count_messages_send1 + count_messages_send2
		with open('report.txt', 'a+') as file:
			file.write(str(d1) + ' messages send: ' + str(total) + '\n')

		# with open('report.txt', 'a+') as file:
		# 	file.write(str(d1) + ' messages send: ' + str(count_messages_send) + '\n')

class Export_users(tk.Frame):
	def  __init__(self, master):
		tk.Frame.__init__(self, master)
		self.hastag_lbl = tk.Label(self, text='Choice name of the file')
		self.hastag_lbl.pack(side='top',fill='x',pady=10)
		self.name = tk.Entry(self)
		self.name.pack()
		self.hastag_lbl1 = tk.Label(self, text='Choice username to extract followers from')
		self.hastag_lbl1.pack(side='top',fill='x',pady=10)
		self.user = tk.Entry(self)
		self.user.pack()
		self.hastag_lbl2 = tk.Label(self, text='Enter amount of followers or 0 for all')
		self.hastag_lbl2.pack(side='top',fill='x',pady=10)
		self.amount = tk.Entry(self)
		self.amount.pack()
		self.file_lbl = tk.Label(self, text='Load settings file:')
		self.file_lbl.pack(side='top',fill='x',pady=10)
		tk.Button(self, text='Browse files', command=self.browseFiles_interact).pack()

		tk.Button(self, text='Start Bot', command=self.go).pack()
		tk.Button(self, text='Back', command=lambda: master.switch_frame(PageOne)).pack()
	
	def browseFiles_interact(self): 
	    filename = filedialog.askopenfilename(initialdir = "/", 
	                                          title = "Select a File", 
	                                          filetypes = (("Text files", 
	                                                        "*.txt*"), 
	                                                       ("all files", 
	                                                        "*.*"))) 
	    # Change label contents 
	    self.file_lbl.configure(text = filename)


    
	def go(self):
	    self.save_credentials()
	    self.start_hashtag()


	def save_credentials(self):
		self.master.name = self.name.get()
		self.name1 = str(self.master.name)
		self.master.user = self.user.get()
		self.user1 = str(self.master.user)
		self.master.amount = self.amount.get()
		self.amount1 = int(self.master.amount)


	def start_hashtag(self): 
		with open('account.txt', 'r') as file:
			ACCOUNT_USERNAME = file.readline()
			ACCOUNT_PASSWORD = file.readline()

		cl = Client()
		if 'Load settings file:' not in self.file_lbl.cget('text'):
			cl.load_settings(self.file_lbl.cget('text'))
		else:
			pass
		cl.request_timeout = 15
		cl.login(ACCOUNT_USERNAME, ACCOUNT_PASSWORD)
		print('Bot login with username: @' + ACCOUNT_USERNAME)
		user_Id = cl.user_id_from_username(self.user1)
		user_followers = cl.user_followers(user_Id, amount=self.amount1)
		keys = user_followers.keys()
		for each in keys:
			username = user_followers[each].username
			with open(self.name1, 'a+') as file:
				file.write(username + '\n')



class Export_setting(tk.Frame):
	def  __init__(self, master):
		tk.Frame.__init__(self, master)
		self.hastag_lbl = tk.Label(self, text='Choice name of the file')
		self.hastag_lbl.pack(side='top',fill='x',pady=10)
		self.name = tk.Entry(self)
		self.name.pack()

		tk.Button(self, text='Start Bot', command=self.go).pack()
		tk.Button(self, text='Back', command=lambda: master.switch_frame(PageOne)).pack()

    
	def go(self):
	    self.save_credentials()
	    self.start_hashtag()


	def save_credentials(self):
		self.master.name = self.name.get()
		self.name1 = str(self.master.name)

	def start_hashtag(self): 
		with open('account.txt', 'r') as file:
			ACCOUNT_USERNAME = file.readline()
			ACCOUNT_PASSWORD = file.readline()
			file.close()
		location_file = os.getcwd() + '/' + self.name1
		cl = Client()
		cl.request_timeout = random.choice(range(15,25))
		cl.login(ACCOUNT_USERNAME, ACCOUNT_PASSWORD)
		print('Bot login with username: @' + ACCOUNT_USERNAME)
		cl.dump_settings(location_file)





if __name__ == "__main__":
    app = SampleApp()
    app.mainloop()