[LABI] added tcp socket chat server

1ano/2semestre/labi/tema03/src/tcp_chat_server.py

@@ -0,0 +1,56 @@
+# encoding=utf-8
+
+import socket
+import select
+
+def main ():
+    tcp_s = socket.socket (socket.AF_INET, socket.SOCK_STREAM)
+    tcp_s.bind (("0.0.0.0", 8080))
+    tcp_s.listen (10)
+    connections = []
+
+    connections.append (tcp_s)
+    print ("Chat server started")
+
+    while 1:
+        # Get the list sockets which are ready to be read through select
+        read_sockets = select.select (connections, [], [])[0]
+
+        for sock in read_sockets:
+            #New connection
+            if sock == tcp_s:
+                # Handle the case in which there is a new connection received through server_socket
+                client_s, addr = tcp_s.accept ()
+                connections.append (client_s)
+                print ("Client connected: %s" % str (addr))
+            else:
+                #Some incoming message from a client, process it
+                try:
+                    # Incoming message
+                    data = sock.recv (4096)
+                    if len (data) != 0:
+                        print ("From client: %s" % str (sock.getpeername()))
+                        print ("Got Data: " + data.decode ('utf-8'))
+
+                    else:
+                        print ("Client disconnected: %s" % str (sock.getpeername()))
+                        sock.close()
+                        connections.remove (sock)
+                        break
+
+                    #Do not send the message to master socket
+                    #Create the message identifying the client
+                    message = ('<' + " Fom client: " + str(sock.getpeername()) + '> \n').encode('utf-8') +  data.upper()
+                    for client in connections:
+                        if client != tcp_s: # Eventually do not send the message to the source client !!!
+                            client.send (message)
+
+                except:
+                    print ("Client socket error: %s" % str (addr))
+                    sock.close()
+                    connections.remove (sock)
+                    continue
+
+    tcp_s.close()
+
+main ()