JOJ/Joint-Teapot
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: List[Tuple] -> Dict[str, Tuple]

Browse Source
This commit is contained in:
张泊明518370910136 2022-05-27 09:54:28 +08:00
parent 89172137fe
commit 5f8f9d2f08
No known key found for this signature in database
GPG Key ID: FBEF5DE8B9F4C629
2 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
joint_teapot/teapot.py
View File

@ -144,7 +144,10 @@ class Teapot:
return True return True
def get_repos_status(self, commit_lt: int, issue_lt: int) -> None: def get_repos_status(self, commit_lt: int, issue_lt: int) -> None:
for repo_name, commit_count, issue_count in self.gitea.get_repos_status(): for repo_name, (
commit_count,
issue_count,
) in self.gitea.get_repos_status().items():
if commit_count < commit_lt or issue_count < issue_lt: if commit_count < commit_lt or issue_count < issue_lt:
logger.info( logger.info(
f"{self.gitea.org_name}/{repo_name} has " f"{self.gitea.org_name}/{repo_name} has "

10
joint_teapot/workers/gitea.py
View File

@ -290,9 +290,11 @@ class Gitea:
res.append(data.name) res.append(data.name)
return res return res
def get_repos_status(self) -> List[Tuple[str, int, int]]: def get_repos_status(self) -> Dict[str, Tuple[int, int]]:
res = [] res = {}
for repo in list_all(self.organization_api.org_list_repos, self.org_name): for repo in list_all(self.organization_api.org_list_repos, self.org_name):
commits = []
issues = []
try: try:
commits = self.repository_api.repo_get_all_commits( commits = self.repository_api.repo_get_all_commits(
self.org_name, repo.name self.org_name, repo.name
@ -300,14 +302,12 @@ class Gitea:
except ApiException as e: except ApiException as e:
if e.status != 409: if e.status != 409:
raise raise
commits = []
issues = self.issue_api.issue_list_issues( issues = self.issue_api.issue_list_issues(
self.org_name, repo.name, state="all" self.org_name, repo.name, state="all"
) )
# if not commits: # if not commits:
# logger.info(f"{self.org_name}/{repo.name} has no commits") # logger.info(f"{self.org_name}/{repo.name} has no commits")
# res.append(repo.name) res[repo.name] = (len(commits), len(issues))
res.append((repo.name, len(commits), len(issues)))
return res return res
def create_issue( def create_issue(