server.py

import socket
from threading import Thread
import threading
import mysql.connector
from deep_translator import GoogleTranslator

HOST = '0.0.0.0'
PORT =  5500
CHAR_LIMIT = 2048
LISTENER_LIMIT = 10

active_clients = [] # List of all connected users

mydb = mysql.connector.connect(
    host = '127.0.0.1',
    user = 'Findlay',
    password = 'helloworld',
    database = 'COMMUNIFY')

mycursor = mydb.cursor()

# Function to listen for upcoming messages from a client
def listen_for_messages(client,username):
    while True:
        message = ''
        message = client.recv(CHAR_LIMIT).decode('utf-8')
        if GoogleTranslator(source='auto',target='en').translate(message) == 'quit': 
            print(f"{username} has quit :(")
            active_clients.remove((username, client,))
            client.shutdown(socket.SHUT_RD)
            #client.close()
            break
        elif message != '':
            final_msg = username + '-' + message
            send_messages_to_all(final_msg)
        else:
            print(f'The message sent from client {username} is empty')


def send_messages_to_all(message):
    for user in active_clients:
        try:
            send_message_to_client(user[1],message)
        except Exception as e:
            
            print("[EXCPETION]",e)

# Function to send message to a single client
def send_message_to_client(client, message):
    client.sendall(message.encode())

# Function to handle client
def client_handler(client):
# Server will listen for client message that will
# Contain the username
    while True:
        try:
            username = client.recv(CHAR_LIMIT).decode('utf-8')
            
            print(f"{username} has joined server!")
            active_clients.append((username, client))
            break
        except Exception as e:
            print("[EXCEPTION]",e)
            break
    try:
        Thread(target = listen_for_messages, args = (client, username, )).start()
    except Exception as e:
        print("[EXCEPTION]",e)

# Main function
def main():
# Creating the server socket class object
    server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
    try:
    # Provide the server with an address in the form of 
    # host IP and port
        server.bind((HOST, PORT))
        print(f"Server is running on {HOST} {PORT}")
    except:
        print(f'Unable to bind to host: {HOST} and port: {PORT}')

    server.listen(LISTENER_LIMIT)

    while True:
        (client, address) = server.accept()
        print(f"Successfully connected to client {address[0]} {address[1]}")

        Thread(target=client_handler,args=(client, )).start()

    server.close()


if __name__ == '__main__':
    main()