diff --git a/app/application/site/mutation.py b/app/application/site/mutation.py index ef998aee4..5794da621 100644 --- a/app/application/site/mutation.py +++ b/app/application/site/mutation.py @@ -21,7 +21,7 @@ class SiteMutationRepository(Protocol): """读取指定站点。""" ... - async def get_by_domain(self, domain: str) -> Optional[Any]: + async def async_get_by_domain(self, domain: str) -> Optional[Any]: """按域名读取站点。""" ... @@ -90,7 +90,7 @@ class SiteMutationCommand: site_info = await self._indexer_loader(domain) if not site_info: return SiteMutationResult(False, "该站点不支持,请检查站点域名是否正确") - if await self._repository.get_by_domain(domain): + if await self._repository.async_get_by_domain(domain): return SiteMutationResult(False, f"{domain} 站点己存在") values.update({ diff --git a/app/db/oper/site.py b/app/db/oper/site.py index b367b90d5..14a85e5fa 100644 --- a/app/db/oper/site.py +++ b/app/db/oper/site.py @@ -41,10 +41,6 @@ class SiteOper(DbOper): """读取站点写用例需要的目标站点。""" return await self.async_get(site_id) - async def get_by_domain(self, domain: str) -> Optional[Site]: - """按域名读取站点写用例的重复目标。""" - return await Site.async_get_by_domain(self._db, domain) - async def stage_create(self, payload: Mapping[str, Any]) -> None: """暂存新增站点,不由仓储自行提交。""" values = dict(payload) diff --git a/tests/test_site_mutation_command.py b/tests/test_site_mutation_command.py index bad75ec91..0e1a5c370 100644 --- a/tests/test_site_mutation_command.py +++ b/tests/test_site_mutation_command.py @@ -9,7 +9,7 @@ def _command(**overrides): """构造可观察站点写用例及其依赖。""" repository = Mock() repository.get_by_id = AsyncMock(return_value=object()) - repository.get_by_domain = AsyncMock(return_value=None) + repository.async_get_by_domain = AsyncMock(return_value=None) repository.stage_create = AsyncMock() repository.stage_update = AsyncMock(return_value=True) repository.stage_delete = AsyncMock()