86 lines
3.4 KiB
Python
86 lines
3.4 KiB
Python
import logging
|
|
|
|
from github import PullRequest
|
|
|
|
from actioner.clients import get_todoist_client, github
|
|
from actioner.utils import get_todoist_project_from_repo
|
|
from actioner.utils.github import get_existing_task, get_issue_link
|
|
from actioner.utils.todoist import is_task_completed
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
REPOS = ["srobo/core-team-minutes"]
|
|
|
|
|
|
def pr_to_task_name(pr: PullRequest) -> str:
|
|
return "Review " + get_issue_link(pr) + ": " + pr.title
|
|
|
|
|
|
def get_my_review(me, pr: PullRequest):
|
|
for review in pr.get_reviews().reversed:
|
|
if review.user.login == me.login:
|
|
return review
|
|
|
|
|
|
def todoist_repo_prs():
|
|
todoist = get_todoist_client()
|
|
me = github.get_user()
|
|
todoist.projects.sync()
|
|
todoist.items.sync()
|
|
for repo_name in REPOS:
|
|
project_id = get_todoist_project_from_repo(repo_name)
|
|
existing_tasks = {
|
|
item["id"]: item["content"]
|
|
for item in todoist.state["items"]
|
|
if item["project_id"] == project_id
|
|
}
|
|
repo = github.get_repo(repo_name)
|
|
for pr in repo.get_pulls(state="all"):
|
|
existing_task_id = get_existing_task(existing_tasks, pr)
|
|
|
|
if pr.state == "closed" and existing_task_id:
|
|
my_review = get_my_review(me, pr)
|
|
if pr.merged and my_review and my_review.state == "APPROVED":
|
|
if not is_task_completed(todoist.items.get_by_id(existing_task_id)):
|
|
logger.info("Completing task to review '{}'".format(pr.title))
|
|
todoist.items.complete([existing_task_id])
|
|
else:
|
|
logger.info("Deleting task to review '{}'".format(pr.title))
|
|
todoist.items.delete([existing_task_id])
|
|
|
|
elif pr.state == "open":
|
|
my_review = get_my_review(me, pr)
|
|
|
|
if existing_task_id:
|
|
existing_task = todoist.items.get_by_id(existing_task_id)
|
|
task_completed = is_task_completed(existing_task)
|
|
if my_review:
|
|
if my_review.commit_id == pr.head.sha and not task_completed:
|
|
logger.info(
|
|
"Completing task to review '{}', because I already did it".format(
|
|
pr.title
|
|
)
|
|
)
|
|
todoist.items.complete([existing_task_id])
|
|
elif task_completed:
|
|
logger.info(
|
|
"Re-opening task to review '{}'".format(pr.title)
|
|
)
|
|
todoist.items.uncomplete([existing_task_id])
|
|
continue
|
|
elif my_review and my_review.commit_id != pr.head.sha:
|
|
logger.info("Creating task to review '{}'".format(pr.title))
|
|
existing_task_id = todoist.items.add(
|
|
pr_to_task_name(pr), project_id
|
|
)["id"]
|
|
if existing_task_id is not None:
|
|
existing_task = todoist.items.get_by_id(existing_task_id)
|
|
existing_task.update(content=pr_to_task_name(pr))
|
|
if pr.milestone and pr.milestone.due_on:
|
|
existing_task.update(
|
|
date_string=pr.milestone.due_on.strftime("%d/%m/%Y")
|
|
)
|
|
|
|
todoist.commit()
|