Feedback

.gitignore

@@ -0,0 +1,2 @@
+# Byte-compiled / optimized / DLL files
+__pycache__/

README.md

@@ -0,0 +1,20 @@
+[![Review Assignment Due Date](https://classroom.github.com/assets/deadline-readme-button-24ddc0f5d75046c5622901739e7c5dd533143b0c8e959d652212380cedb1ea36.svg)](https://classroom.github.com/a/RvxJKA0f)
+[![Open in Codespaces](https://classroom.github.com/assets/launch-codespace-7f7980b617ed060a017424585567c406b6ee15c891e84e1186181d67ecf80aa0.svg)](https://classroom.github.com/open-in-codespaces?assignment_repo_id=13264709)
+
+Para ejecutar el programa de chat, sigue estos pasos:
+
+1. Abre dos terminales (ventanas de línea de comandos) en tu sistema operativo.
+2. En la primera terminal, ejecuta el servidor de chat:
+
+   python chat_server.py
+
+   El servidor estará en espera de conexiones de clientes.
+3. En la segunda terminal, ejecuta el cliente:
+
+   python chat_client.py
+
+   Ingresa un nombre de usuario cuando se te solicite.
+
+Repite el paso 3 para abrir más clientes y únete al chat con diferentes nombres de usuario.
+
+Ahora deberías tener varios clientes conectados al servidor, y pueden comenzar a enviar mensajes entre ellos. Ten en cuenta que en este ejemplo, tanto el servidor como los clientes se están ejecutando localmente en el mismo dispositivo, pero puedes modificar las direcciones IP para conectarte en una red local.

chat_canales.py

@@ -0,0 +1,44 @@
+class Canal:
+    def __init__(self, nombre):
+        self.nombre = nombre # Nombre del canal
+        self.clientes = []  # Clientes del canal
+        self.mensajes = []  # lista de mensajes del canal
+
+    # Para agregar un nuevo cliente al canal
+    def agregar_cliente(self, cliente):
+        self.clientes.append(cliente)
+
+    # Para eliminar un cliente del canal
+    def eliminar_cliente(self, cliente):
+        self.clientes.remove(cliente)
+
+    # Para enviar mensaje a TODOS los clientes del canal
+    def enviar_mensaje(self, mensaje):
+        self.mensajes.append(mensaje)
+
+    # Obtienes los últimos 10 mensajes cuando te conectas POR PRIMERA VEZ
+    # También se puede usar para borrar los mensajes que tienes en la pantalla con /clear 
+    # Y volver a cargar los últimos 10 mensajes
+    def obtener_ultimos_mensajes(self):
+        return self.mensajes[-10:]
+
+    # eliminar canal de forma segura
+    def vaciar_canal(self):
+        clientesCanal = self.clientes
+        self.clientes = []
+        self.mensajes = []
+        return clientesCanal
+
+    #Encontrar un cliente
+    def encontrar_cliente(self, cliente):
+        for client in self.clientes:
+            if client == cliente:
+                return client
+        return None
+
+
+
+
+    # Como no funciona se puede borrar
+    # def __str__(self):
+    #     return self.nombre + 'se ha empleado este metodo'

chat_client.py

@@ -0,0 +1,171 @@
+import socket
+import threading
+import time
+import sys
+from chat_canales import Canal
+
+# Configuración del cliente
+host = input("Ingresa la dirección IP del servidor: \nEn caso de dejarlo en blanco se asignará localhost\n")
+if host == '':
+    host = '127.0.0.1'
+port = 65000
+
+
+# Crear un socket del cliente
+server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+server.connect((host, port))
+
+
+# Nombre de usuario
+username = 'null'
+
+quit = False
+
+
+#Variable para almacenar el tiempo del último mensaje
+last_message_time = time.time()
+
+#Función para cerrar la conexión con el server
+def close_connection():
+    global quit
+    print("Cerrando conexión...")
+    try:
+        server.close()
+    except Exception as e:
+        pass
+    quit = True
+    print("Conexión cerrada.\nPresiona ctrl+c para salir.")
+
+
+#Función para verificar la inactividad del usuario
+def check_inactivity():
+    global last_message_time
+    global quit
+    while not quit:   
+        if time.time() - last_message_time > 5 * 60:  # 5 minutos
+            print("Llevas demasiado tiempo inactivo")
+            close_connection()
+            break
+        if time.time() - last_message_time > 4 * 60:  # 4 minutos
+            print("Si no escribes un mensaje dentro de un minuto, se cerrará la conexión.")
+
+        time.sleep(60)  # Comprobar cada minuto
+
+
+
+# Función para recibir mensajes del servidor
+def receive():
+    global quit
+    global username
+    global duplicateUsername
+    while not quit:
+        try:
+            # Recibir y mostrar mensajes del servidor
+            message = server.recv(1024).decode('utf-8')
+            if message == 'Nombre de usuario ya está en uso. Por favor, elige otro.':
+                duplicateUsername = username
+                username = 'null'
+                time.sleep(1)  # Clear the username
+            elif message == 'Has sido expulsado por un administrador.':
+                print("Has sido expulsado del servidor.")
+                close_connection()
+                break
+            print(message)
+        except Exception as e:
+            # Cerrar la conexión si hay un problema al recibir el mensaje
+            #print(f"Error en receive: {e}")
+            #print("Cerrando conexión...")
+            #close_connection()
+            #print("Conexión cerrada.\nPresiona ctrl+c para salir.")
+            break       
+
+#Constantes secuencias de escape
+MOVES_CURSOR_1_LINE_UP = "\x1b[1A" 
+CLEAR_ENTIRE_LINE = "\x1b[2K"
+MOVES_CURSOR_1_LINE_DOWN = "\x1b[1B"
+
+#Diccionario de palabras malsonantes
+BAD_WORDS = {
+    'joder' : 'practicar deporte en horizontal',
+    'follar' : 'hacer bebes',
+    'puta': 'persona con un trabajo complicado',
+    'coño': 'la parte entre el ombligo y las rodillas (en femenino)',
+    'chúpamela': 'no estoy de acuerdo contigo',
+    'mierda': 'excremento',
+    'cabrón': 'persona con mucho carácter',
+    'gilipollas': 'persona con mucho carácter',
+    'polla': 'ave',
+    'pene': 'miembro viril',
+    'verga': 'palo',
+    'coger': 'agarrar',
+    'culo': 'parte trasera',
+    'zorra': 'animal',
+    'maricón': 'persona con mucha sensibilidad',
+    'puto': 'persona con un trabajo complicado',
+    'Gorka': 'Dios',
+    'Agustín': 'Un poco menos que Dios',
+    'agustín': 'Un poco menos que Dios',
+    'salesianos': 'la mejor escuela del mundo',
+    'salesiano': 'persona con mucha suerte',
+    'salesiana': 'persona con mucha suerte',
+    'comunista': ' ☭ ',
+    'Nacho': ' ☭ ',
+    'nacho': ' ☭ ',
+    'Fuck': 'F***',
+}
+
+# Función para enviar mensajes al servidor
+def send():
+    global end
+    global last_message_time
+    global username
+    global quit
+    usernameSet = False
+    while not quit:
+        if username == 'null':
+            while not usernameSet:  # Keep asking for a username until a valid one is entered
+                username = input("username: ")
+                if ' ' in username:
+                    print("Nombre de usuario no puede tener espacios. Utiliza solo una palabra.")
+                    username == 'null'
+                elif username == '':
+                    print("Nombre de usuario no puede estar vacío.")
+                    username == 'null'
+                elif any(bad_word in username.lower() for bad_word in BAD_WORDS):
+                    print("Nombre de usuario no puede contener la palabra prohibida.")
+                    username == 'null'
+                elif len(username.split(' ')) > 1:
+                    print("El nombre de usuario no puede tener más de una palabra")
+                    username == 'null'
+                else:
+                    message = username
+                    server.send(message.encode('utf-8'))  # Send the username to the server
+                    time.sleep(1)  # Wait for a response from the server
+                    if username != 'null':  # If the server accepted the username, break the loop
+                        usernameSet = True
+                        continue
+            data = ''
+        else:
+            data = input("")    
+            message = f'{username}: {data}'
+        if data is not None and data != '':
+            try:
+                server.send(message.encode('utf-8'))
+                print(MOVES_CURSOR_1_LINE_UP+CLEAR_ENTIRE_LINE+MOVES_CURSOR_1_LINE_UP)
+                if data == '/exit':
+                    close_connection()
+                    break
+                last_message_time = time.time()  # Update the last message time
+            except Exception as e:
+                close_connection()
+                break  
+
+# Instanciar un hilo para verificar la inactividad del usuario
+inactivity_thread = threading.Thread(target=check_inactivity)
+inactivity_thread.start()
+# Iniciar hilos para recibir y enviar mensajes simultáneamente
+receive_thread = threading.Thread(target=receive)
+receive_thread.start()
+
+send_thread = threading.Thread(target=send)
+send_thread.start()