Add: /camera/new

Author: Gogobobo11

src/api/api.py

@@ -1,4 +1,4 @@
-from fastapi import FastAPI
+from fastapi import FastAPI, HTTPException, status
 from pydantic import BaseModel
 from fastapi.middleware.cors import CORSMiddleware
 
@@ -48,4 +48,28 @@ def get_version():
 
         @self.app.post("/cameras/new")
         def create_new_camera(new_camera: CreateCamera):
-            return {"Test"}
+            try:
+                if self.db_manager.camera_already_exists(new_camera.title):
+                    raise HTTPException(
+                        status_code=status.HTTP_409_CONFLICT,
+                        detail=f"Camera with title '{new_camera.title}' already exists"
+                    )
+                
+                camera_id = self.db_manager.create_camera({
+                    "title": new_camera.title,
+                    "latitude": new_camera.latitude,
+                    "longitude": new_camera.longitude
+                })
+                
+                return {
+                    "status": "success",
+                    "message": "Camera created successfully",
+                    "camera_id": camera_id
+                }
+            except HTTPException:
+                raise
+            except Exception as e:
+                raise HTTPException(
+                    status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+                    detail=f"Internal server error: {str(e)}"
+                )

src/api/models.py

@@ -21,7 +21,7 @@ def validate_latitude(cls, latitude):
 
     @field_validator('longitude')
     @classmethod
-    def validate_latitude(cls, longitude):
+    def validate_longitude(cls, longitude):
         if longitude > 90 or longitude < -90:
             raise ValueError("Invalid longitude value")
         return longitude

src/db_manager/db_manager.py

@@ -5,7 +5,7 @@
 from typing import Generator, Optional
 import os
 
-from .models import Base
+from .models import Base, Camera
 
 class DBManager:
     def __init__(self, database_url: Optional[str] = None):
@@ -115,4 +115,22 @@ def execute_raw_sql(self, query: str, params: dict = None):
         """Выполнить сырой SQL запрос"""
         with self.get_session() as session:
             result = session.execute(query, params or {})
-            return result
+            return result
+        
+    def camera_already_exists(self, title) -> bool:
+        with self.get_session() as session:
+            return session.query(Camera).filter(Camera.title.ilike(title)).first is not None
+        
+    def create_camera(self, camera):
+        with self.get_session() as session:
+            new_camera = Camera(
+                title=camera['title'],
+                latitude=camera['latitude'],
+                longitude=camera['longitude']
+            )
+
+            session.add(new_camera)
+
+            session.flush()
+
+            return new_camera.id