Dome/GTS-Federator
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update gts-federator.py

Browse Source
This commit is contained in:
Dome
2026-04-19 20:46:12 +02:00
parent 001ba6adb6
commit df7e15dff7
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
gts-federator.py
+5 -4
View File
@@ -68,7 +68,7 @@ class GTSFederator:
if not os.path.exists(self.config["rss_urls_file"]): if not os.path.exists(self.config["rss_urls_file"]):
self.logger.error("RSS_URLS_FILE missing!") self.logger.error("RSS_URLS_FILE missing!")
return 0, 0, 0 return 0, 0, 0, 0
with open(self.config["rss_urls_file"], 'r', encoding='utf-8') as f: with open(self.config["rss_urls_file"], 'r', encoding='utf-8') as f:
rss_urls = [l.split('#')[0].strip() for l in f if l.strip() and not l.strip().startswith('#')] rss_urls = [l.split('#')[0].strip() for l in f if l.strip() and not l.strip().startswith('#')]
@@ -122,17 +122,18 @@ class GTSFederator:
runtime = str(timedelta(seconds=int(time.time() - start_time))) runtime = str(timedelta(seconds=int(time.time() - start_time)))
print(f"\n✅ Run Completed | Time: {runtime} | New Posts: {total_new} | Instances: {curr} (+{diff})") print(f"\n✅ Run Completed | Time: {runtime} | New Posts: {total_new} | Instances: {curr} (+{diff})")
self.save_state(curr) self.save_state(curr)
self.previous_instances = curr
return total_new, num_feeds, curr return total_new, num_feeds, curr, diff
def run_forever(self): def run_forever(self):
wait_seconds = self.parse_interval(self.config["fetch_interval"]) wait_seconds = self.parse_interval(self.config["fetch_interval"])
self.logger.info(f"GTS-Federator Active. Interval: {self.config['fetch_interval']}") self.logger.info(f"GTS-Federator Active. Interval: {self.config['fetch_interval']}")
while True: while True:
posts, feeds, instances = self.process_feeds() posts, feeds, instances, growth = self.process_feeds()
self.logger.info(f"💤 Run completed. Pausing for {self.config['fetch_interval']}.") self.logger.info(f"💤 Run completed. Pausing for {self.config['fetch_interval']}.")
self.logger.info(f"📊 Fetched {posts} Posts from {feeds} RSS-Feeds. Known Instances: {instances}") self.logger.info(f"📊 Fetched {posts} Posts from {feeds} RSS-Feeds. Known Instances: {instances} (+{growth})")
next_run = datetime.now() + timedelta(seconds=wait_seconds) next_run = datetime.now() + timedelta(seconds=wait_seconds)
self.logger.info(f"⏰ Next scheduled run: {next_run.strftime('%H:%M:%S')}") self.logger.info(f"⏰ Next scheduled run: {next_run.strftime('%H:%M:%S')}")