Frisk/RcGcDw
1
0
Fork 0
mirror of https://gitlab.com/chicken-riders/RcGcDw.git synced 2025-02-23 00:24:09 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Added more safeguards to prevent sending again the same messages

Browse source
This commit is contained in:
Frisk 2018-08-21 16:14:32 +02:00
parent 406ac11e97
commit 51d8987756
No known key found for this signature in database
GPG key ID: 0E9A7D3C0A01586C
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
rcgcdw.py
View file

@ -603,6 +603,7 @@ class recent_changes_class(object):
groups = {} groups = {}
unsent_messages = [] unsent_messages = []
streak = -1 streak = -1
last_datetime = datetime.datetime.fromisoformat("1999-01-01T00:00:00")
if settings["limitrefetch"] != -1: if settings["limitrefetch"] != -1:
with open("lastchange.txt", "r") as record: with open("lastchange.txt", "r") as record:
file_content = record.read().strip() file_content = record.read().strip()
@ -673,13 +674,17 @@ class recent_changes_class(object):
self.streak = -1 self.streak = -1
send(_("Connection to {wiki} seems to be stable now.").format(wiki=settings["wikiname"]), _("Connection status"), settings["avatars"]["connection_restored"]) send(_("Connection to {wiki} seems to be stable now.").format(wiki=settings["wikiname"]), _("Connection status"), settings["avatars"]["connection_restored"])
for change in changes: for change in changes:
if change["rcid"] in self.ids: if change["rcid"] in self.ids or change["rcid"] < self.recent_id or datetime.datetime.fromisoformat(change["timestamp"][0:19]) < self.last_datetime:
logging.debug("Change ({}) is in ids or is lower than recent_id {}".format(change["rcid"]), self.recent_id)
continue continue
logging.debug(self.ids)
logging.debug(self.recent_id)
self.add_cache(change) self.add_cache(change)
if clean and not (self.recent_id == 0 and change["rcid"] > self.file_id): if clean and not (self.recent_id == 0 and change["rcid"] > self.file_id):
logging.debug("Rejected {val}".format(val=change["rcid"])) logging.debug("Rejected {val}".format(val=change["rcid"]))
continue continue
first_pass(change) first_pass(change)
self.last_datetime = change["timestamp"]
return change["rcid"] return change["rcid"]
def safe_request(self, url): def safe_request(self, url):