fz0x1/HPI
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

basic event merging

Browse source
This commit is contained in:
Dima Gerasimov 2019-12-06 22:57:46 +00:00
parent ed25ee91bf
commit 23faedb8c0
1 changed files with 19 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
my/coding/github.py
View file

@ -58,7 +58,7 @@ def _get_summary(e) -> Tuple[str, Optional[str]]:
link = com['html_url'] link = com['html_url']
iss = pl['issue'] iss = pl['issue']
title = iss['title'] title = iss['title']
return f"commented on issue {title}", link return f"commented on issue {title}", link, f'issue_comment_' + link
elif tp == "ReleaseEvent": elif tp == "ReleaseEvent":
action = pl['action'] action = pl['action']
rel = pl['release'] rel = pl['release']
@ -155,13 +155,16 @@ def _parse_commit_comment(d: Dict) -> Event:
def _parse_event(d: Dict) -> Event: def _parse_event(d: Dict) -> Event:
summary, link = _get_summary(d) xx = _get_summary(d)
if len(xx) != 3:
xx += (d['id'], )
summary, link, eid = xx
body = d.get('payload', {}).get('comment', {}).get('body') body = d.get('payload', {}).get('comment', {}).get('body')
return Event( return Event(
dt=_parse_dt(d['created_at']), dt=_parse_dt(d['created_at']),
summary=summary, summary=summary,
link=link, link=link,
eid=d['id'], eid=eid,
body=body, body=body,
) )
@ -206,12 +209,24 @@ def iter_gdpr_events() -> Iterator[Res[Event]]:
yield e yield e
def iter_events(): def iter_backup_events():
model = get_model() model = get_model()
for d in model.events(): for d in model.events():
yield _parse_event(d) yield _parse_event(d)
def iter_events():
logger = get_logger()
from itertools import chain
emitted = set()
for e in chain(iter_gdpr_events(), iter_backup_events()):
key = (e.dt, e.eid) # use both just in case
if key in emitted:
logger.debug('ignoring %s: %s', key, e)
continue
yield e
emitted.add(key)
# TODO load events from GDPR export? # TODO load events from GDPR export?
def get_events(): def get_events():
return sorted(iter_events(), key=lambda e: e.dt) return sorted(iter_events(), key=lambda e: e.dt)