Spaces:
Sleeping
Sleeping
Upload 141 files
Browse files
src/.DS_Store
CHANGED
|
Binary files a/src/.DS_Store and b/src/.DS_Store differ
|
|
|
src/apis/.DS_Store
CHANGED
|
Binary files a/src/apis/.DS_Store and b/src/apis/.DS_Store differ
|
|
|
src/apis/models/BaseModel.py
CHANGED
|
@@ -1,13 +1,15 @@
|
|
| 1 |
from pydantic import BaseModel, Field
|
| 2 |
from typing import Optional
|
| 3 |
from datetime import datetime
|
|
|
|
|
|
|
| 4 |
|
| 5 |
class BaseDocument(BaseModel):
|
| 6 |
created_at: Optional[datetime] = Field(
|
| 7 |
-
default_factory=lambda:
|
| 8 |
)
|
| 9 |
updated_at: Optional[datetime] = Field(
|
| 10 |
-
default_factory=lambda:
|
| 11 |
)
|
| 12 |
expire_at: Optional[datetime] = None
|
| 13 |
|
|
|
|
| 1 |
from pydantic import BaseModel, Field
|
| 2 |
from typing import Optional
|
| 3 |
from datetime import datetime
|
| 4 |
+
from src.utils.logger import get_date_time
|
| 5 |
+
|
| 6 |
|
| 7 |
class BaseDocument(BaseModel):
|
| 8 |
created_at: Optional[datetime] = Field(
|
| 9 |
+
default_factory=lambda: get_date_time().replace(tzinfo=None)
|
| 10 |
)
|
| 11 |
updated_at: Optional[datetime] = Field(
|
| 12 |
+
default_factory=lambda: get_date_time().replace(tzinfo=None)
|
| 13 |
)
|
| 14 |
expire_at: Optional[datetime] = None
|
| 15 |
|
src/apis/models/__pycache__/BaseModel.cpython-311.pyc
CHANGED
|
Binary files a/src/apis/models/__pycache__/BaseModel.cpython-311.pyc and b/src/apis/models/__pycache__/BaseModel.cpython-311.pyc differ
|
|
|
src/utils/__pycache__/mongo.cpython-311.pyc
CHANGED
|
Binary files a/src/utils/__pycache__/mongo.cpython-311.pyc and b/src/utils/__pycache__/mongo.cpython-311.pyc differ
|
|
|
src/utils/mongo.py
CHANGED
|
@@ -14,7 +14,7 @@ from src.apis.models.schedule_models import Schedule
|
|
| 14 |
from src.apis.models.hotel_models import BookHotel
|
| 15 |
from src.apis.interfaces.api_interface import ChatHistoryManagement
|
| 16 |
from src.apis.models.user_models import User
|
| 17 |
-
|
| 18 |
|
| 19 |
client: AsyncIOMotorClient = AsyncIOMotorClient(MongoCfg.MONGODB_URL)
|
| 20 |
database = client[MongoCfg.MONGO_INDEX]
|
|
@@ -56,7 +56,7 @@ class MongoCRUD:
|
|
| 56 |
async def create(self, data: Dict) -> str:
|
| 57 |
"""Create a new document in the collection asynchronously, optionally using a user-specified ID."""
|
| 58 |
await self._ensure_ttl_index()
|
| 59 |
-
now =
|
| 60 |
data["created_at"] = now
|
| 61 |
data["updated_at"] = now
|
| 62 |
if self.ttl_seconds is not None:
|
|
|
|
| 14 |
from src.apis.models.hotel_models import BookHotel
|
| 15 |
from src.apis.interfaces.api_interface import ChatHistoryManagement
|
| 16 |
from src.apis.models.user_models import User
|
| 17 |
+
from src.utils.logger import get_date_time
|
| 18 |
|
| 19 |
client: AsyncIOMotorClient = AsyncIOMotorClient(MongoCfg.MONGODB_URL)
|
| 20 |
database = client[MongoCfg.MONGO_INDEX]
|
|
|
|
| 56 |
async def create(self, data: Dict) -> str:
|
| 57 |
"""Create a new document in the collection asynchronously, optionally using a user-specified ID."""
|
| 58 |
await self._ensure_ttl_index()
|
| 59 |
+
now = get_date_time().replace(tzinfo=None)
|
| 60 |
data["created_at"] = now
|
| 61 |
data["updated_at"] = now
|
| 62 |
if self.ttl_seconds is not None:
|