forked from rDrama/rDrama
sfd
parent
f2e66fc280
commit
4cc4f8f14f
|
@ -54,7 +54,19 @@ def notif_comment(text, autojanny=False):
|
||||||
|
|
||||||
text_html = sanitize(text, alert=alert)
|
text_html = sanitize(text, alert=alert)
|
||||||
|
|
||||||
existing = g.db.query(Comment.id).filter_by(author_id=author_id, parent_submission=None, body_html=text_html).one_or_none()
|
try: existing = g.db.query(Comment.id).filter_by(author_id=author_id, parent_submission=None, body_html=text_html).one_or_none()
|
||||||
|
except:
|
||||||
|
existing = g.db.query(Comment).filter_by(author_id=author_id, parent_submission=None, body_html=text_html).all()
|
||||||
|
|
||||||
|
|
||||||
|
notifs = g.db.query(Notification).filter(Notification.comment_id.in_([x.id for x in existing])).all()
|
||||||
|
for c in notifs: g.db.delete(c)
|
||||||
|
g.db.flush()
|
||||||
|
|
||||||
|
|
||||||
|
for c in existing: g.db.delete(c)
|
||||||
|
g.db.flush()
|
||||||
|
existing = g.db.query(Comment.id).filter_by(author_id=author_id, parent_submission=None, body_html=text_html).one_or_none()
|
||||||
|
|
||||||
if existing: return existing[0]
|
if existing: return existing[0]
|
||||||
else: return create_comment(text_html, autojanny)
|
else: return create_comment(text_html, autojanny)
|
||||||
|
|
Loading…
Reference in New Issue