socketclient2.py

# echo-client.py

import socket
import json
import sys
import asyncio
from select import select

HOST = "192.168.103.215"  # The server's hostname or IP address
PORT = 6100  # The port used by the server

async def user_input():
    while True:
        loop = asyncio.get_event_loop()
        receiver = await loop.run_in_executor(None, input, "To: ")
        message = input("Message: ")
        s.sendall(bytes(str(Message(username,receiver,message)).encode()))

async def print_something():
    await asyncio.sleep(180)
    data = s.recv(1024).decode()
    if data != "received": print("Received:", data)
    else: print("Message sent successfully.") # tick.

async def main():
    tasks = [user_input(), print_something()]
    await asyncio.gather(*tasks)


class Message:
    def __init__(self, sender, rec, msg) -> None:
        self.sender =  sender
        self.recipient = rec
        self.message = msg
    
    def __repr__(self) -> str:
        return json.dumps({"Sender": self.sender, "Recipient": self.recipient, "Message": self.message})

with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
    s.connect((HOST, PORT))

    a=""
    # user login
    while(True):
        username = input("Username (-1 to create an account): ")
        newuser = (username == '-1')
        if newuser:
            username = input("Choose username: ")
        password = input(("Choose " if newuser else "") + "Password: ")
        login_data = {"Username" : username, "Password" : password, "Newuser" : newuser}
        s.sendall(json.dumps(login_data).encode())
        data = s.recv(1024).decode()
        if (data == "invalid"):
            print("This username already exists. Please try again." if newuser else "Invalid username, please try again.")
        else: break
    
    print(data)

    # messaging loop
    while(a!="exit"):
        loop = asyncio.get_event_loop()
        loop.run_until_complete(main())
        loop.close()