Skip to content

Commit

Permalink
Enable targetting foreign repo
Browse files Browse the repository at this point in the history
  • Loading branch information
Eclipse-Dominator committed Jun 1, 2023
1 parent fd2f867 commit dc67e60
Show file tree
Hide file tree
Showing 2 changed files with 14 additions and 18 deletions.
9 changes: 4 additions & 5 deletions app.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,12 +11,11 @@

savefile = digest_dir + "digest.setting.json"
def create_digest_setting():
owner, repo = curr_repo.split("/")
os.makedirs(digest_dir, exist_ok=True)
with open(savefile, 'w') as f:
json.dump({
"owner": owner,
"repo": repo,
"target_repo": lookup_repo,
"my_repo": curr_repo,
"target_issue": "",
"ignore_list": []
}, f, indent=4)
Expand All @@ -33,8 +32,8 @@ def create_digest_setting():
setting = json.load(f)

ql = DigestManager(
setting["owner"],
setting["repo"],
setting["target_repo"],
setting["my_repo"],
setting["target_issue"],
ignore_numbers=setting["ignore_list"]
)
Expand Down
23 changes: 10 additions & 13 deletions digest_manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,34 +21,30 @@

class DigestManager:
cursor:str = None
owner: str
repo: str
target_repo: str
local_repo: str
timestamp: datetime
target_issue: str
complete: bool
ignore_numbers: list[int]
last_update_time: datetime
query = MainQuery()

def __init__(self, owner:str, repo:str, target_issue:str, ignore_numbers=[]) -> None:
self.owner = owner
self.repo = repo
def __init__(self, target_repo:str, local_repo:str, target_issue:str, ignore_numbers=[]) -> None:
self.target_repo = target_repo
self.local_repo = local_repo
self.target_issue = target_issue
self.complete = False
self.ignore_numbers = ignore_numbers
self.last_update_time = datetime.now() - timedelta(days=1)
self.create_issue()
self.update_last_change_date()

@property
def repo_repr(self) -> str:
return f"{self.owner}/{self.repo}"

def run_query(self, additional_queries: list[str] = []) -> dict:
if not self.complete:
additional_queries.append(
self.query.partial_query(
self.repo_repr,
self.target_repo,
self.last_update_time.strftime("%Y-%m-%dT%H:%M:%SZ"),
self.cursor)
)
Expand Down Expand Up @@ -94,8 +90,9 @@ def send_data(self, issues: list[GitIssue]):
run_mutations([r1, r2])

def find_repo_id(self) -> str:
owner, repo = self.local_repo.split("/")
q = FindRepoId("find_repo_id")
res = q.run(owner=self.owner, repo=self.repo)
res = q.run(owner=owner, repo=repo)

return q.get_repo_id(res)

Expand All @@ -112,5 +109,5 @@ def create_issue(self):
q = CreateIssue("create_issue")
res = q.run(repo_id=repo_id, title="Issues Digest", body=digest_content)
self.target_issue = q.get_issue_id(res)
self.ignore_numbers.append(q.get_issue_number(res))

if self.local_repo != self.target_repo:
self.ignore_numbers.append(q.get_issue_number(res))

0 comments on commit dc67e60

Please sign in to comment.