From 05c04c2cf37cdddcecc33c0123f44fe1f230da25 Mon Sep 17 00:00:00 2001 From: spoonLead Date: Sat, 25 Aug 2018 17:27:23 +0400 Subject: [PATCH] Add the test prototype of programm on python --- README.txt | 0 Test/client.py | 52 ++++++++++++++++++++++++++++++++++++++++++++++++++ Test/main.py | 1 - Test/server.py | 35 +++++++++++++++++++++++++++++++++ 4 files changed, 87 insertions(+), 1 deletion(-) create mode 100644 README.txt create mode 100644 Test/client.py delete mode 100644 Test/main.py create mode 100644 Test/server.py diff --git a/README.txt b/README.txt new file mode 100644 index 0000000..e69de29 diff --git a/Test/client.py b/Test/client.py new file mode 100644 index 0000000..afce65c --- /dev/null +++ b/Test/client.py @@ -0,0 +1,52 @@ +import os +import socket +import threading +import time + +os.system("cls") +print(" ...Welcome to the CryptoMessanger... ") + +shutdown = False +join = False + +def receving(name, sock): + while not shutdown: + try: + while True: + data, addr = sock.recvfrom(1024) + print(data.decode("utf-8")) + time.sleep(0.2) + except: + pass + +host = socket.gethostbyname(socket.gethostname()) +port = 0 + +server = ("192.168.0.103", 9090) + +sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) #socket difinition; protocol TCP/IP +sock.bind((host, port)) +sock.setblocking(0) + +alias = input("Name: ") + +rT = threading.Thread(target = receving, args = ("RecvThread", sock)) +rT.start() + +while not shutdown: + if not join: + sock.sendto(("[" + alias + "] >> join chat ").encode("utf-8"), server) + join = True + else: + try: + message = input() + if message != "": + sock.sendto(("[" + alias + "] :: " + message).encode("utf-8"), server) + time.sleep(0.2) + except: + sock.sendto(("[" + alias + "] << left chat ").encode("utf-8"), server) + shutdown = True + + +rT.join() +sock.close() diff --git a/Test/main.py b/Test/main.py deleted file mode 100644 index 9c558e3..0000000 --- a/Test/main.py +++ /dev/null @@ -1 +0,0 @@ -. diff --git a/Test/server.py b/Test/server.py new file mode 100644 index 0000000..c69361e --- /dev/null +++ b/Test/server.py @@ -0,0 +1,35 @@ +import os +import socket +import sys + +os.system("cls") +host = socket.gethostbyname(socket.gethostname()) #ip of the server host machine +port = 9090 + +users = [] + +sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) #socket difinition; protocol TCP/IP +sock.bind((host, port)) + +quit = False +print(" ...Server started... ") + +while not quit: + try: + data, addr = sock.recvfrom(1024) + if addr not in users: #add new user + users.append(addr) + + print(data.decode("utf-8")) + + #send the message for all users in chat except the sender + for user in users: + if addr != user: + sock.sendto(data, user) + + except: + print(sys.exc_info()) + print("[ Server stopped ]") + quit = True; + +sock.close()