|
|
@ -151,7 +151,12 @@ class FederationActions(AbstractAction):
|
|
|
|
)
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
async def get_users(
|
|
|
|
async def get_users(
|
|
|
|
self, host: str, since_id: str | None = None, until_id: str | None = None, limit: int = 10, get_all: bool = False
|
|
|
|
self,
|
|
|
|
|
|
|
|
host: str,
|
|
|
|
|
|
|
|
since_id: str | None = None,
|
|
|
|
|
|
|
|
until_id: str | None = None,
|
|
|
|
|
|
|
|
limit: int = 10,
|
|
|
|
|
|
|
|
get_all: bool = False,
|
|
|
|
) -> AsyncGenerator[UserDetailed, None]:
|
|
|
|
) -> AsyncGenerator[UserDetailed, None]:
|
|
|
|
if limit > 100:
|
|
|
|
if limit > 100:
|
|
|
|
raise ParameterError('limitは100以下である必要があります')
|
|
|
|
raise ParameterError('limitは100以下である必要があります')
|
|
|
@ -161,7 +166,9 @@ class FederationActions(AbstractAction):
|
|
|
|
|
|
|
|
|
|
|
|
body = {'host': host, 'sinceId': since_id, 'untilId': until_id, 'limit': limit}
|
|
|
|
body = {'host': host, 'sinceId': since_id, 'untilId': until_id, 'limit': limit}
|
|
|
|
|
|
|
|
|
|
|
|
pagination = Pagination[IUserDetailed](self.__session, Route('POST', '/api/federation/users'), json=body)
|
|
|
|
pagination = Pagination[IUserDetailed](
|
|
|
|
|
|
|
|
self.__session, Route('POST', '/api/federation/users'), json=body
|
|
|
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
while True:
|
|
|
|
while True:
|
|
|
|
res_users: list[IUserDetailed] = await pagination.next()
|
|
|
|
res_users: list[IUserDetailed] = await pagination.next()
|
|
|
@ -171,7 +178,6 @@ class FederationActions(AbstractAction):
|
|
|
|
if get_all is False or pagination.is_final:
|
|
|
|
if get_all is False or pagination.is_final:
|
|
|
|
break
|
|
|
|
break
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
async def get_stats(self, limit: int = 10) -> IFederationInstanceStat:
|
|
|
|
async def get_stats(self, limit: int = 10) -> IFederationInstanceStat:
|
|
|
|
if limit > 100:
|
|
|
|
if limit > 100:
|
|
|
|
raise ParameterError('limitは100以下である必要があります')
|
|
|
|
raise ParameterError('limitは100以下である必要があります')
|
|
|
|