Merge pull request 'fix: change some un-exist insert methods to create' (#5) from haolou_local into dev

Reviewed-on: https://gitea.freeleaps.mathmast.com/products/freeleaps-authentication/pulls/5

.freeleaps/devops/helm-pkg/values.alpha.yaml

@@ -15,7 +15,7 @@ authentication:
     registry: docker.io
     repository: null
     name: 6901bcf4ed3725f39f11343d-authentication
-    tag: snapshot-2346a42
+    tag: snapshot-ddcf8d8
     imagePullPolicy: IfNotPresent
   ports:
   - name: http
@@ -81,7 +81,7 @@ authentication:
     appEnv: alpha
     devsvcWebapiUrlBase: http://devsvc-service.freeleaps-alpha.svc.freeleaps.cluster:8007/api/devsvc/
     notificationWebapiUrlBase: http://notification-service.freeleaps-alpha.svc.freeleaps.cluster:8003/api/notification/
-    authServiceEndpoint: http://freeleaps-auth-service.68c0da88a0a7837e84b580eb-alpha.svc.freeleaps.cluster:9000/api/v1/
+    authServiceEndpoint: http://freeleaps-auth-service.freeleaps-alpha.svc.freeleaps.cluster:9000/api/v1/
     jwtAlgorithm: HS256
     serviceApiAccessHost: 0.0.0.0
     serviceApiAccessPort: 8004

.freeleaps/devops/helm-pkg/values.prod.yaml

@@ -18,7 +18,7 @@ authentication:
     registry: docker.io
     repository: null
     name: 6901bcf4ed3725f39f11343d-authentication
-    tag: snapshot-73d6a46
+    tag: snapshot-8584f90
     imagePullPolicy: IfNotPresent
   ports:
   - name: http
@@ -65,14 +65,31 @@ authentication:
       namespace: freeleaps-monitoring-system
       interval: 30s
       scrapeTimeout: ''
-  ingresses: {}
+  ingresses:
+  - name: authentication-ingress
+    host: authentication.freeleaps.com
+    class: nginx
+    rules:
+    - path: /
+      pathType: Prefix
+      backend:
+        service:
+          name: authentication-service
+          port:
+            number: 8004
+    tls:
+      exists: false
+      issuerRef:
+        name: freeleaps-dot-com
+        kind: ClusterIssuer
+      name: authentication.freeleaps.com-cert
   configs:
     tz: UTC
     appName: authentication
     appEnv: prod
     devsvcWebapiUrlBase: http://devsvc-service.freeleaps-prod.svc.freeleaps.cluster:8007/api/devsvc/
     notificationWebapiUrlBase: http://notification-service.freeleaps-prod.svc.freeleaps.cluster:8003/api/notification/
-    authServiceEndpoint: http://freeleaps-auth-service.68c0da88a0a7837e84b580eb-prod.svc.freeleaps.cluster:9000/api/v1/
+    authServiceEndpoint: http://freeleaps-auth-service.freeleaps-prod.svc.freeleaps.cluster:9000/api/v1/
     jwtAlgorithm: HS256
     serviceApiAccessHost: 0.0.0.0
     serviceApiAccessPort: 8004

backend/infra/permission/role_handler.py

@@ -118,7 +118,7 @@ class RoleHandler:
                     raise RequestValidationError("Role with the provided ID already exists.")
                 new_doc.id = custom_role_id
 
-            await new_doc.insert()
+            await new_doc.create()
             return new_doc
 
     async def query_roles(self, role_key: Optional[str], role_name: Optional[str], skip: int = 0, limit: int = 10) -> \

backend/infra/permission/user_role_handler.py

@@ -36,7 +36,7 @@ class UserRoleHandler:
                 user_id=user_id,
                 role_ids=unique_role_ids
             )
-            await user_role_doc.insert()
+            await user_role_doc.create()
             return user_role_doc
 
     async def get_role_and_permission_by_user_id(self, user_id: str) -> tuple[list[str], list[str]]:

backend/models/base_doc.py

@@ -3,6 +3,7 @@ BaseDoc - A custom document class that provides Beanie-like interface using dire
 """
 import asyncio
 from datetime import datetime, timezone
+from bson import ObjectId
 from typing import Optional, List, Dict, Any, Type, Union
 from motor.motor_asyncio import AsyncIOMotorClient, AsyncIOMotorDatabase
 from pydantic import BaseModel
@@ -282,6 +283,13 @@ class BaseDoc(BaseModel, metaclass=QueryModelMeta):
         # Convert Decimal objects to float for MongoDB compatibility
         doc_dict = self._convert_decimals_to_float(doc_dict)
 
+        # Respect pre-populated id by mapping to MongoDB _id
+        if getattr(self, 'id', None):
+            try:
+                doc_dict['_id'] = ObjectId(self.id)
+            except Exception:
+                doc_dict['_id'] = self.id
+
         result = await collection.insert_one(doc_dict)
 
         # Set the id field from the inserted document
@@ -314,7 +322,17 @@ class BaseDoc(BaseModel, metaclass=QueryModelMeta):
         elif hasattr(self, 'auth_code'):
             query['auth_code'] = self.auth_code
 
-        if query:
+        if getattr(self, 'id', None):
+            # Update by primary key when available
+            try:
+                object_id = ObjectId(self.id)
+            except Exception:
+                object_id = self.id
+
+            result = await collection.update_one({"_id": object_id}, {"$set": doc_dict}, upsert=True)
+            if result.upserted_id:
+                self.id = str(result.upserted_id)
+        elif query:
             # Update existing document
             result = await collection.update_one(query, {"$set": doc_dict}, upsert=True)
             # If it was an insert, set the id field