phzhik/chain-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

namespace id for chain list

Browse Source
This commit is contained in:
Robert 2024-03-13 03:14:14 +07:00
parent 5473be3675
commit f97fe42f52
No known key found for this signature in database
GPG Key ID: F631C7FD957D5F22
2 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
chain_service/controllers/chain.py
View File

@ -37,9 +37,12 @@ async def chain_upsert_controller(
@router.get("/list") @router.get("/list")
async def chain_list_controller(chain_repository: ChainRepositoryDependency): async def chain_list_controller(
namespace_id: str, chain_repository: ChainRepositoryDependency
):
try: try:
chains = await chain_repository.get_list() chains = await chain_repository.get_list(namespace_id=namespace_id)
return chains return chains
except Exception: except Exception:

8
chain_service/repositories/chain.py
View File

@ -2,6 +2,7 @@ from loguru import logger
from uuid import UUID from uuid import UUID
from typing import List from typing import List
from bson import ObjectId
from pydantic import TypeAdapter from pydantic import TypeAdapter
from chain_service.database.database import Database from chain_service.database.database import Database
@ -19,9 +20,12 @@ class ChainRepository:
await self.collection.replace_one(query, payload, upsert=True) await self.collection.replace_one(query, payload, upsert=True)
return chain return chain
async def get_list(self) -> List[Chain]: async def get_list(self, namespace_id: str) -> List[Chain]:
# sort_order = ("lastModified", pymongo.DESCENDING) # sort_order = ("lastModified", pymongo.DESCENDING)
chains = [chain async for chain in self.collection.find()] query = {"namespaceId": namespace_id}
chains = [
chain async for chain in self.collection.find({"namespaceId": namespace_id})
]
return TypeAdapter(List[Chain]).validate_python(chains) return TypeAdapter(List[Chain]).validate_python(chains)
async def get_by_id(self, chain_id: str) -> Chain | None: async def get_by_id(self, chain_id: str) -> Chain | None: