third-party-mirrors/EDDN
1
0
Fork 0
mirror of https://github.com/EDCD/EDDN.git synced 2025-04-24 20:30:53 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

DuplicateMessages: Very initial flake8 pass

Browse Source
This commit is contained in:
Athanasius 2021-11-04 16:24:10 +00:00
parent e9b4afcdf6
commit 01b5ccf7ac
No known key found for this signature in database
GPG Key ID: 8C392035DD80FD62
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/eddn/core/DuplicateMessages.py
View File

@ -1,15 +1,20 @@
# coding: utf8
"""Detect duplicate messages from senders."""
import hashlib
import re
import simplejson
from datetime import datetime, timedelta
from eddn.conf.Settings import Settings
from threading import Lock, Thread
from time import sleep
import simplejson
from eddn.conf.Settings import Settings
class DuplicateMessages(Thread):
"""Class holding all code for duplicate message detection."""
max_minutes = Settings.RELAY_DUPLICATE_MAX_MINUTES
caches = {}
@ -21,13 +26,14 @@ class DuplicateMessages(Thread):
self.daemon = True
def run(self):
"""Expire duplicate messages."""
while True:
sleep(60)
with self.lock:
maxTime = datetime.utcnow()
max_time = datetime.utcnow()
for key in self.caches.keys():
if self.caches[key] + timedelta(minutes=self.max_minutes) < maxTime:
if self.caches[key] + timedelta(minutes=self.max_minutes) < max_time:
del self.caches[key]
def isDuplicated(self, json):