namespace

chain_service/database/models/namespace.py

@@ -0,0 +1,5 @@
+from .base import BaseMongoModel
+
+
+class Namespace(BaseMongoModel):
+    name: str

chain_service/repositories/namespace.py

@@ -0,0 +1,14 @@
+from chain_service.database.database import Database
+from chain_service.database.models.namespace import Namespace
+
+
+class NamespaceRepository:
+
+    def __init__(self, database: Database):
+        self.collection = database.get_collection("namespaces")
+
+    async def upsert(self, namespace: Namespace) -> Namespace:
+        query = {"_id": namespace.id}
+        payload = namespace.model_dump(by_alias=True)
+        await self.collection.replace_one(query, payload, upsert=True)
+        return namespace