65 lines
1.7 KiB
Python
65 lines
1.7 KiB
Python
import socket
|
|
import json
|
|
import time
|
|
import datetime
|
|
import threading
|
|
import select
|
|
|
|
run = True
|
|
|
|
def make_payload(name, msg):
|
|
payload = {
|
|
"name": name,
|
|
"msg": msg,
|
|
"time": time.time()
|
|
}
|
|
return json.dumps(payload).encode("utf-8")
|
|
|
|
def read_msg(s):
|
|
while run:
|
|
ready_to_read, _, _ = select.select([s], [], [], 1.0)
|
|
if ready_to_read:
|
|
data = s.recv(1024)
|
|
msg = json.loads(data.decode("utf-8"))
|
|
print(f"{msg["name"]} {datetime.datetime.fromtimestamp(float(msg["time"])).strftime("%d-%m-%Y %H:%M")}")
|
|
print(msg["msg"])
|
|
# print(f"Received {data!r}")
|
|
|
|
def event_handel(name, s):
|
|
global run
|
|
while run:
|
|
msg = input("> ")
|
|
if msg in ["", " "]:
|
|
run = False
|
|
print("Closing socket and exit")
|
|
|
|
else:
|
|
payload = make_payload(name, msg)
|
|
s.sendall(payload)
|
|
|
|
if __name__ == "__main__":
|
|
try:
|
|
Host = input("Enter ip: (default 127.0.0.1) ")
|
|
if Host == "":
|
|
HOST = "127.0.0.1"
|
|
PORT_str = input("Enter port: (default 65432) ")
|
|
if PORT_str == "":
|
|
PORT = 65432
|
|
else:
|
|
PORT = int(PORT_str)
|
|
|
|
try:
|
|
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
|
|
s.connect((HOST, PORT))
|
|
name = input("Enter name: ")
|
|
threading.Thread(target=event_handel, args=(name, s,)).start()
|
|
read_msg(s)
|
|
except ConnectionRefusedError:
|
|
print("Could not connect to the server!")
|
|
|
|
|
|
except KeyboardInterrupt:
|
|
print("Exit with CTRL+C")
|
|
finally:
|
|
pass
|