chore: new endpoints

Author: CarlosAndreo

app/core/config.py

@@ -10,6 +10,9 @@ class Settings(BaseSettings):
     SECRET_KEY: str = "your_secret_key"
     JWT_ALGORITHM: str = "HS256"
     ACCESS_TOKEN_EXPIRE_MINUTES: int = 10080  # 7 days
+    REFRESH_TOKEN_EXPIRE_DAYS: int = 7
+    LOG_LEVEL: str = "INFO"
+    LOG_JSON_FORMAT: bool = True
 
     # MongoDB Configuration
     MONGO_INITDB_DATABASE: str
@@ -22,4 +25,4 @@ class Settings(BaseSettings):
     )
 
 
-settings = Settings()
+settings = Settings()  # type: ignore[call-arg]

app/core/constants.py

@@ -0,0 +1 @@
+API_PREFIX = "/api/v1"

app/core/jwt.py

@@ -1,5 +1,5 @@
 from datetime import datetime, timedelta, timezone
-from typing import Dict
+from typing import Any, Dict
 
 import jwt
 
@@ -11,7 +11,21 @@ def create_access_token(data: Dict):
     expire = datetime.now(timezone.utc) + timedelta(
         minutes=settings.ACCESS_TOKEN_EXPIRE_MINUTES
     )
-    to_encode.update({"exp": expire})
+    to_encode.update({"exp": expire, "type": "access"})
+    encoded_jwt = jwt.encode(
+        to_encode,
+        settings.SECRET_KEY,
+        algorithm=settings.JWT_ALGORITHM,
+    )
+    return encoded_jwt
+
+
+def create_refresh_token(data: Dict[str, str]) -> str:
+    to_encode: Dict[str, Any] = data.copy()
+    expire = datetime.now(timezone.utc) + timedelta(
+        days=settings.REFRESH_TOKEN_EXPIRE_DAYS
+    )
+    to_encode.update({"exp": expire, "type": "refresh"})
     encoded_jwt = jwt.encode(
         to_encode,
         settings.SECRET_KEY,
@@ -22,3 +36,12 @@ def create_access_token(data: Dict):
 
 def decode_access_token(token: str):
     return jwt.decode(token, settings.SECRET_KEY, algorithms=[settings.JWT_ALGORITHM])
+
+
+def verify_refresh_token(token: str) -> Dict | None:
+    payload = jwt.decode(
+        token, settings.SECRET_KEY, algorithms=[settings.JWT_ALGORITHM]
+    )
+    if payload.get("type") != "refresh":
+        return None
+    return payload

app/core/logger.py

@@ -0,0 +1,177 @@
+import json
+import logging
+import logging.config
+import sys
+from datetime import datetime, timezone
+from pathlib import Path
+from typing import Any, Dict
+
+
+class JsonFormatter(logging.Formatter):
+    """Custom JSON formatter for structured logging.
+
+    Formats log records as JSON objects with consistent structure including
+    timestamp, level, logger name, module, line number, message and exceptions.
+    """
+
+    def format(self, record: logging.LogRecord) -> str:
+        """Format the log record as a JSON string.
+
+        Args:
+            record: The log record to format.
+
+        Returns:
+            JSON-formatted string with log information.
+        """
+        log_data: Dict[str, Any] = {
+            "timestamp": datetime.now(timezone.utc).isoformat(),
+            "level": record.levelname,
+            "logger": record.name,
+            "module": record.module,
+            "function": record.funcName,
+            "line": record.lineno,
+            "message": record.getMessage(),
+        }
+        if record.exc_info:
+            log_data["exception"] = self.formatException(record.exc_info)
+        # core/logging.py
+        if hasattr(record, "request_id"):
+            log_data["request_id"] = getattr(record, "request_id")
+        if hasattr(record, "method"):
+            log_data["method"] = getattr(record, "method")
+        if hasattr(record, "path"):
+            log_data["path"] = getattr(record, "path")
+        if hasattr(record, "client_host"):
+            log_data["client_host"] = getattr(record, "client_host")
+        if hasattr(record, "query_params"):
+            log_data["query_params"] = getattr(record, "query_params")
+        if hasattr(record, "status_code"):
+            log_data["status_code"] = getattr(record, "status_code")
+        if hasattr(record, "duration_ms"):
+            log_data["duration_ms"] = getattr(record, "duration_ms")
+        # all routers
+        return json.dumps(log_data, default=str)
+
+
+LOG_DIR = Path("/var/log/backend")
+if "pytest" in sys.modules:
+    LOG_DIR = Path("/tmp/logs")
+LOG_DIR.mkdir(exist_ok=True)
+
+LOGGING_CONFIG = {
+    "version": 1,
+    "disable_existing_loggers": False,
+    "formatters": {
+        "default": {
+            "format": "%(asctime)s - %(name)s - %(levelname)s - %(message)s",
+            "datefmt": "%Y-%m-%d %H:%M:%S",
+        },
+        "json": {
+            "()": JsonFormatter,
+        },
+    },
+    "handlers": {
+        "console": {
+            "class": "logging.StreamHandler",
+            "level": "INFO",
+            "formatter": "default",
+            "stream": sys.stdout,
+        },
+        "console_json": {
+            "class": "logging.StreamHandler",
+            "level": "DEBUG",
+            "formatter": "json",
+            "stream": sys.stdout,
+        },
+        "file": {
+            "class": "logging.handlers.RotatingFileHandler",
+            "level": "INFO",
+            "formatter": "json",
+            "filename": str(LOG_DIR / "app.log"),
+            "maxBytes": 10485760,  # 10MB
+            "backupCount": 5,
+            "encoding": "utf-8",
+        },
+        "error_file": {
+            "class": "logging.handlers.RotatingFileHandler",
+            "level": "ERROR",
+            "formatter": "json",
+            "filename": str(LOG_DIR / "error.log"),
+            "maxBytes": 10485760,  # 10MB
+            "backupCount": 5,
+            "encoding": "utf-8",
+        },
+    },
+    "loggers": {
+        # Root logger
+        "": {
+            "level": "INFO",
+            "handlers": ["console", "file", "error_file"],
+        },
+        # App logger
+        "app": {
+            "level": "DEBUG",
+            "handlers": ["console_json", "file", "error_file"],
+            "propagate": False,
+        },
+        # Uvicorn loggers
+        "uvicorn": {
+            "level": "INFO",
+            "handlers": ["console"],
+            "propagate": False,
+        },
+        "uvicorn.access": {
+            "level": "INFO",
+            "handlers": ["file"],
+            "propagate": False,
+        },
+        "uvicorn.error": {
+            "level": "INFO",
+            "handlers": ["console", "error_file"],
+            "propagate": False,
+        },
+        # Silence watchfiles (used by uvicorn --reload)
+        "watchfiles": {
+            "level": "WARNING",
+            "handlers": ["console"],
+            "propagate": False,
+        },
+        "watchfiles.main": {
+            "level": "WARNING",
+            "handlers": ["console"],
+            "propagate": False,
+        },
+    },
+}
+
+
+def setup_logging(log_level: str = "INFO", use_json: bool = False) -> None:
+    """Configure logging for the application.
+
+    Args:
+        log_level: The minimum log level to capture (DEBUG, INFO, WARNING, ERROR, CRITICAL).
+        use_json: Whether to use JSON formatting for console output.
+    """
+    LOGGING_CONFIG["loggers"][""]["level"] = log_level
+    LOGGING_CONFIG["loggers"]["app"]["level"] = log_level
+    if use_json:
+        LOGGING_CONFIG["loggers"][""]["handlers"] = [
+            "console_json",
+            "file",
+            "error_file",
+        ]
+    else:
+        LOGGING_CONFIG["loggers"][""]["handlers"] = ["console", "file", "error_file"]
+    logging.config.dictConfig(config=LOGGING_CONFIG)
+
+
+def get_logger(name: str) -> logging.Logger:
+    """Get a logger instance with the specified name.
+
+    Args:
+        name: The name of the logger (typically __name__ of the module).
+
+    Returns:
+        A configured logger instance.
+    """
+    return logging.getLogger(name=name)

app/repositories/user.py

@@ -6,7 +6,7 @@ def get_collection():
     """
     Collection for user
     """
-    return mongodb.db["users"]
+    return mongodb.db["users"]  # type: ignore
 
 
 async def find_user_by_username(username: str) -> UserInDB | None:

app/routers/__init__.py

@@ -1,6 +1,8 @@
 from fastapi import APIRouter
 
-from routers.user import user_router
+from routers.auth import auth_router
+from routers.me import me_router
 
 router = APIRouter(prefix="/api/v1")
-router.include_router(router=user_router)
+router.include_router(router=auth_router)
+router.include_router(router=me_router)