Hexor/gaspar
1
0
Fork 0
mirror of https://github.com/house-of-vanity/gaspar.git synced 2025-08-21 15:37:16 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix timings

Browse Source
This commit is contained in:
AB
2020-06-07 17:18:17 +00:00
parent e41f7348d4
commit ec5f28a45a
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
gaspar/gaspar.py
View File

@@ -10,7 +10,7 @@ from .database import DataBase
from .tools import format_topic from .tools import format_topic
logging.basicConfig( logging.basicConfig(
level=logging.INFO, level=logging.DEBUG,
format='%(asctime)s - %(name)s - %(levelname)s - %(message)s') format='%(asctime)s - %(name)s - %(levelname)s - %(message)s')
log = logging.getLogger(__name__) log = logging.getLogger(__name__)

5
gaspar/notify.py
View File

@@ -36,6 +36,7 @@ def update_watcher(bot):
for alert in raw: for alert in raw:
alerts.append(alert['id']) alerts.append(alert['id'])
log.info("Checking for updates. Configured interval: %sh , [%s secs]", UPDATE_INTERVAL/60/60, UPDATE_INTERVAL) log.info("Checking for updates. Configured interval: %sh , [%s secs]", UPDATE_INTERVAL/60/60, UPDATE_INTERVAL)
log.info("Checking alert %s", alert['topic_title'])
if update(alert['id']): if update(alert['id']):
log.info("Found update for [%s] %s", torrent.meta['id'], torrent.meta['topic_title']) log.info("Found update for [%s] %s", torrent.meta['id'], torrent.meta['topic_title'])
reg_time = datetime.utcfromtimestamp(int(torrent.meta['reg_time']) reg_time = datetime.utcfromtimestamp(int(torrent.meta['reg_time'])
@@ -50,7 +51,7 @@ def update_watcher(bot):
subs = torrent.db.get_subscribers(alert['id']) subs = torrent.db.get_subscribers(alert['id'])
for sub in subs: for sub in subs:
bot.sendMessage(sub, msg, parse_mode='HTML', disable_web_page_preview=True) bot.sendMessage(sub, msg, parse_mode='HTML', disable_web_page_preview=True)
time.sleep(60) time.sleep(10)
time.sleep(UPDATE_INTERVAL) time.sleep(UPDATE_INTERVAL)
update_thread = threading.Thread(target=__thread) update_thread = threading.Thread(target=__thread)
update_thread.start() update_thread.start()