added status server

Author: JabelResendiz

src/client/__pycache__/http_parser.cpython-312.pyc

@@ -110,9 +110,9 @@ def final_request (method="GET",url="/",headers = None,body =""):
     endpoint = "/api/Authentication/register"
 
     body = json.dumps({
-        "id":33590,
+        "id":3591,
         "name": "User_335",
-        "userName": "username_33590",
+        "userName": "username_3591",
         "email": "example3@gmail.com",
         "password": "Password_333!",
         "userRole": "Technician",
@@ -141,9 +141,11 @@ def final_request (method="GET",url="/",headers = None,body =""):
     print("Encabezados:", response.headers)
     print("Cuerpo:", response.body[:500])
 
-    # Case 3: HTTPS
-    response = final_request("GET","https://jsonplaceholder.typicode.com", headers={}, body="")
+    # Case 3: GET DownTrack
 
+    endpoint = "/api/Employee/GET_ALL"
+    response = final_request("GET", f"{host}{endpoint}", headers={}, body="")
+
     print("Código de estado:", response.code)
     print("Encabezados:", response.headers)
     print("Cuerpo:", response.body[:500])

src/client/http_client.py

@@ -4,6 +4,7 @@
 import datetime
 import zlib
 from logger import logger
+from status import HTTP_STATUS_CODES
 
 # Configuración del servidor
 HOST = '0.0.0.0'  # Escucha en todas las interfaces
@@ -22,7 +23,7 @@ def start(self):
         server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)  # Permite reutilizar el puerto
         server_socket.bind((self.host, self.port))
         server_socket.listen(5)
-
+        
         logger.info(f"Servidor HTTP en {self.host}:{self.port}")
 
         while True:
@@ -44,6 +45,7 @@ def handle_client(self, client_socket):
 
         except Exception as e:
             logger.error(f"Error al procesar la solicitud: {e}")
+            client_socket.sendall(self.http_response(500, "Internal Server Error", "An unexpected error occurred.").encode())
 
         finally:
             client_socket.close()
@@ -79,41 +81,94 @@ def parse_headers(self, header_lines):
     def build_response(self, method, path, headers, body):
         """Genera respuestas HTTP según el método y la ruta solicitada."""
 
-        logger.info(f"Method : {method}")
+        logger.info(f"Method : {method} - Path: {path}")
+        
+        # 414 - URI Too Long
+        if len(path) > 2048:
+            return self.http_response(414)
+
+        # Verificar si el cliente tiene una versión válida del recurso (usando If-Modified-Since o If-None-Match)
+        last_modified = self.get_last_modified(path)  # Esta función puede devolver la última fecha de modificación del recurso
+        if last_modified:
+            if "If-Modified-Since" in headers:
+                if_modified_since = headers["If-Modified-Since"]
+                if if_modified_since >= last_modified:
+                    return self.http_response(304, headers=headers)  # No se ha modificado, devolver 304
+
+            if "If-None-Match" in headers:
+                if_none_match = headers["If-None-Match"]
+                if if_none_match == self.get_etag(path):  # Comparar con el ETag
+                    return self.http_response(304, headers=headers)  # ETag coincide, devolver 304
+
+        # Redirecciones
+        if path == "/old-page":
+            return self.http_response(301, location="/new-page")
+        
+        if path == "/temp-move":
+            return self.http_response(302, location="/temporary-page")  # 302 Found
+
+        
+         # Si la ruta no existe
+        if path != "/":
+            return self.http_response(404)
+        
+        # 411 - Length Required
+        if method in ["POST", "PUT"] and "Content-Length" not in headers:
+            return self.http_response(411)
+
+        # 415 - Unsupported Media Type
+        if method in ["POST", "PUT"]:
+            supported_types = ["application/json", "application/x-www-form-urlencoded", "text/plain"]
+            if "Content-Type" in headers and headers["Content-Type"] not in supported_types:
+                return self.http_response(415)
+
         if method == "GET":
-            return self.http_response(200, "OK", "Hello, GET!")
+            return self.http_response(200, "Hello, GET!")
 
         elif method == "POST":
-            return self.http_response(200, "OK", f"Received POST: {body}")
+            return self.http_response(200, f"Received POST: {body}")
 
         elif method == "HEAD":
-            return self.http_response(200, "OK", "", include_body=False)
+            return self.http_response(200, "", include_body=False)
 
         elif method == "PUT":
-            return self.http_response(200, "OK", "PUT request successful!")
+            return self.http_response(200, "PUT request successful!")
 
         elif method == "DELETE":
-            return self.http_response(200, "OK", "DELETE request successful!")
+            return self.http_response(200, "DELETE request successful!")
 
         elif method == "OPTIONS":
-            return self.http_response(200, "OK", "", headers={"Allow": "OPTIONS, GET, POST, HEAD, PUT, DELETE, TRACE, CONNECT"})
+            return self.http_response(200, "", headers={"Allow": "OPTIONS, GET, POST, HEAD, PUT, DELETE, TRACE, CONNECT"})
 
         elif method == "TRACE":
-            return self.http_response(200, "OK", f"TRACE received:\n{headers}")
+            return self.http_response(200, f"TRACE received:\n{headers}")
 
         else:
-            return self.http_response(405, "Method Not Allowed", "This method is not supported.")
+            return self.http_response(405)
 
-    def http_response(self, status_code, reason, body, headers=None, include_body=True):
+    def http_response(self, status_code, reason, body, headers=None,location=None, include_body=True):
         """Construye una respuesta HTTP válida con headers y cuerpo."""
         headers = headers or {}
         headers["Server"] = "CustomHTTPServer/1.0"
         headers["Date"] = datetime.datetime.now(datetime.timezone.utc).strftime("%a, %d %b %Y %H:%M:%S GMT")
 
+        
+         # Obtener el mensaje de estado y la descripción
+        reason, default_body = HTTP_STATUS_CODES.get(status_code, ("Unknown", "Unknown error"))
+
+        # Manejo de redirecciones (301, 302, etc.)
+        if status_code in [301, 302, 304] and location:
+            headers["Location"] = location
+            body = f"Redirecting to {location}"
+
+        # Si no se especifica un body, usar el mensaje por defecto
+        if not body and include_body:
+            body = default_body
+            
         # Verificar si el cliente acepta gzip
-        acceptes_encoding = headers.get("accept-encoding","")
-        accepts_gzip = "gzip" in acceptes_encoding
-        accepts_deflate = "deflate" in acceptes_encoding
+        accept_encoding = headers.get("Accept-Encoding","").lower()
+        accepts_gzip = "gzip" in accept_encoding
+        accepts_deflate = "deflate" in accept_encoding
 
         if include_body:
             body_bytes = body.encode()
@@ -135,7 +190,7 @@ def http_response(self, status_code, reason, body, headers=None, include_body=Tr
             response += f"{key}: {value}\r\n"
         response += "\r\n"
 
-        logger.debug(f"Respuesta generada: {status_code} {reason}")
+        logger.debug(f"Respuesta generada: {status_code} {reason} {'-> ' + location if location else ''}")
         return response + body_bytes.decode()
 
 

src/server/server.py

@@ -0,0 +1,30 @@
+HTTP_STATUS_CODES = {
+    # Informativos
+    100: ("Continue", "The server has received the request headers and the client should proceed to send the body."),
+    101: ("Switching Protocols", "The server is switching protocols as requested."),
+    
+    # Éxito
+    200: ("OK", "Request processed successfully."),
+    201: ("Created", "The resource was successfully created."),
+    204: ("No Content", "The server successfully processed the request, but is not returning any content."),
+    
+    # Redirección
+    301: ("Moved Permanently", "The requested resource has been permanently moved."),
+    302: ("Found", "The requested resource is temporarily at a different location."),
+    304: ("Not Modified", "The resource has not changed since the last request."),
+    
+    # Errores del cliente
+    400: ("Bad Request", "Invalid request format."),
+    401: ("Unauthorized", "Authentication is required to access this resource."),
+    403: ("Forbidden", "You do not have permission to access this resource."),
+    404: ("Not Found", "The requested resource was not found."),
+    405: ("Method Not Allowed", "This method is not supported."),
+    411: ("Length Required", "Content-Length header is required for POST and PUT."),
+    414: ("URI Too Long", "Requested URL is too long."),
+    415: ("Unsupported Media Type", "This content type is not supported."),
+    
+    # Errores del servidor
+    500: ("Internal Server Error", "An unexpected error occurred."),
+    501: ("Not Implemented", "This method is not supported by the server."),
+    503: ("Service Unavailable", "The server is currently unable to handle the request."),
+}