api_keys.py 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137
  1. import logging
  2. from fastapi import APIRouter, Depends, HTTPException
  3. from sqlalchemy import select
  4. from sqlalchemy.ext.asyncio import AsyncSession
  5. from backend.app.core.auth import generate_api_key
  6. from backend.app.core.database import get_db
  7. from backend.app.models.api_key import APIKey
  8. from backend.app.schemas.api_key import (
  9. APIKeyCreate,
  10. APIKeyCreateResponse,
  11. APIKeyResponse,
  12. APIKeyUpdate,
  13. )
  14. logger = logging.getLogger(__name__)
  15. router = APIRouter(prefix="/api-keys", tags=["api-keys"])
  16. @router.get("/", response_model=list[APIKeyResponse])
  17. async def list_api_keys(db: AsyncSession = Depends(get_db)):
  18. """List all API keys (without full key values)."""
  19. result = await db.execute(select(APIKey).order_by(APIKey.created_at.desc()))
  20. return list(result.scalars().all())
  21. @router.post("/", response_model=APIKeyCreateResponse)
  22. async def create_api_key(
  23. data: APIKeyCreate,
  24. db: AsyncSession = Depends(get_db),
  25. ):
  26. """Create a new API key.
  27. IMPORTANT: The full API key is only returned in this response.
  28. Store it securely - it cannot be retrieved again.
  29. """
  30. # Generate the key
  31. full_key, key_hash, key_prefix = generate_api_key()
  32. api_key = APIKey(
  33. name=data.name,
  34. key_hash=key_hash,
  35. key_prefix=key_prefix,
  36. can_queue=data.can_queue,
  37. can_control_printer=data.can_control_printer,
  38. can_read_status=data.can_read_status,
  39. printer_ids=data.printer_ids,
  40. expires_at=data.expires_at,
  41. )
  42. db.add(api_key)
  43. await db.flush()
  44. await db.refresh(api_key)
  45. # Return with full key (only time it's shown)
  46. return APIKeyCreateResponse(
  47. id=api_key.id,
  48. name=api_key.name,
  49. key_prefix=api_key.key_prefix,
  50. key=full_key, # Only returned on creation
  51. can_queue=api_key.can_queue,
  52. can_control_printer=api_key.can_control_printer,
  53. can_read_status=api_key.can_read_status,
  54. printer_ids=api_key.printer_ids,
  55. enabled=api_key.enabled,
  56. last_used=api_key.last_used,
  57. created_at=api_key.created_at,
  58. expires_at=api_key.expires_at,
  59. )
  60. @router.get("/{key_id}", response_model=APIKeyResponse)
  61. async def get_api_key(
  62. key_id: int,
  63. db: AsyncSession = Depends(get_db),
  64. ):
  65. """Get an API key by ID."""
  66. result = await db.execute(select(APIKey).where(APIKey.id == key_id))
  67. api_key = result.scalar_one_or_none()
  68. if not api_key:
  69. raise HTTPException(status_code=404, detail="API key not found")
  70. return api_key
  71. @router.patch("/{key_id}", response_model=APIKeyResponse)
  72. async def update_api_key(
  73. key_id: int,
  74. data: APIKeyUpdate,
  75. db: AsyncSession = Depends(get_db),
  76. ):
  77. """Update an API key."""
  78. result = await db.execute(select(APIKey).where(APIKey.id == key_id))
  79. api_key = result.scalar_one_or_none()
  80. if not api_key:
  81. raise HTTPException(status_code=404, detail="API key not found")
  82. # Update fields if provided
  83. if data.name is not None:
  84. api_key.name = data.name
  85. if data.can_queue is not None:
  86. api_key.can_queue = data.can_queue
  87. if data.can_control_printer is not None:
  88. api_key.can_control_printer = data.can_control_printer
  89. if data.can_read_status is not None:
  90. api_key.can_read_status = data.can_read_status
  91. if data.printer_ids is not None:
  92. api_key.printer_ids = data.printer_ids
  93. if data.enabled is not None:
  94. api_key.enabled = data.enabled
  95. if data.expires_at is not None:
  96. api_key.expires_at = data.expires_at
  97. await db.flush()
  98. await db.refresh(api_key)
  99. return api_key
  100. @router.delete("/{key_id}")
  101. async def delete_api_key(
  102. key_id: int,
  103. db: AsyncSession = Depends(get_db),
  104. ):
  105. """Delete (revoke) an API key."""
  106. result = await db.execute(select(APIKey).where(APIKey.id == key_id))
  107. api_key = result.scalar_one_or_none()
  108. if not api_key:
  109. raise HTTPException(status_code=404, detail="API key not found")
  110. await db.delete(api_key)
  111. return {"message": "API key deleted"}