Server.py

# -*- coding: utf-8 -*-
"""

..::/RADIN\::..

"""
import select 
import queue 
from collections import namedtuple
from time import sleep
from socket import *
person = namedtuple('person', ['name','id','mode','cnn_ip'])
users_index=0
counter=0
serverPort = 12500
inputs=[]
outputs=[]
exp=[]
users=[]
ss = socket(AF_INET,SOCK_STREAM)
ss.bind(('',serverPort))
ss.listen(5)
inputs.append(ss)
exp.append(ss)
message_queues={}
print ('The server is ready to receive')
while 1:   
    readable, writable, exceptional = select.select(inputs,outputs,exp)
    for sock in readable :
        if sock is ss:
            connectionSocket, addr = ss.accept()
            inputs.append(connectionSocket)
            exp.append(connectionSocket)
            users.append(person(name="",id=users_index,mode='',cnn_ip=connectionSocket)) 
            message_queues[connectionSocket] = queue.Queue()
            users_index+=1
            counter+=1
            print ('%d user(s) connected to server.'%counter)
        else:
            msg = sock.recv(1024)
            msg = msg.decode(encoding='UTF-8',errors='strict')
            if msg.__le__(''): # handling the empty message being sent when a client leave the room               
                z=[x.id for x in users if x.cnn_ip==sock]
                # removing specified person from users list and shifting the list
                for x in range(z[0],users_index):
                    users[x]=users[x]._replace(id=users[x].id-1) 
                print(''.join([users[z[0]].name,' Left']))
                x=person(name=users[z[0]].name,id=users[z[0]].id,mode=users[z[0]].mode,cnn_ip=sock)
                users.remove(x)
                exceptional.append(sock)
                break
            if msg[0]=="$": #joining
                 sock.send(bytes(''.join(['Hi ',msg[1:], ' ! ^_^']),'UTF-8'))
                 print(''.join([msg[1:], ' Joined']))
                 z=[x.id for x in users if x.cnn_ip==sock]
                 users[z[0]]=users[z[0]]._replace(name=msg[1:])
            elif msg[0]=="~": #declaring the mode
                 z=[x.id for x in users if x.cnn_ip==sock]    
                 users[z[0]]=users[z[0]]._replace(mode=msg[1])
            elif msg=="&fetch":
				#flushing each person's queue or showing the unseen messages according to the index
                writable.append(sock) 
            else :
                # adding to the Queue
                z=[x.id for x in users if x.cnn_ip==sock]
                msg=''.join([users[z[0]].name," : ",msg])
                for x in users:
                    message_queues[x.cnn_ip].put(msg)   
        #print(users[:])  #checking the object added to the list according to the people
    for sock in writable:
        l= message_queues[sock].qsize()
        sock.send(bytes(str(l),'UTF-8'))
        for c in range(0,l):
            sock.send(bytes(message_queues[sock].get_nowait(),'UTF-8'))
            #need time to send correctly
            sleep(0.05)			
			
    for sock in exceptional:
        # Stop listening for input on the connection
        inputs.remove(sock)
        exp.remove(sock)
        if sock in outputs:
            outputs.remove(sock)
        sock.close()
        # Remove message queue
        del message_queues[sock]
        users_index-=1
        counter-=1
        print ('%d user(s) connected to server.'%counter)