diff --git a/telegram_scraper_with_forwarding.py b/telegram_scraper_with_forwarding.py index 4704064..dbf7240 100644 --- a/telegram_scraper_with_forwarding.py +++ b/telegram_scraper_with_forwarding.py @@ -829,7 +829,7 @@ class OptimizedTelegramScraper: self.state['channels'][channel] = last_message_id self.save_state() - print(f"\nCompleted scraping channel {channel}") + print(f"Completed scraping channel {channel}") except Exception as e: print(f"Error with channel {channel}: {e}") @@ -843,10 +843,10 @@ class OptimizedTelegramScraper: channel_name = self.state.get('channel_names', {}).get(channel, 'Unknown') if not message_ids: - print(f"No media files to reprocess for {channel_name} (ID: {channel})") + # print(f"No media files to reprocess for {channel_name} (ID: {channel})") return - print(f"šŸ“„ Reprocessing {len(message_ids)} media files for {channel_name} (ID: {channel})") + # print(f"šŸ“„ Reprocessing {len(message_ids)} media files for {channel_name} (ID: {channel})") try: entity = await self._resolve_entity(channel) @@ -881,10 +881,10 @@ class OptimizedTelegramScraper: filled_length = int(bar_length * completed_media // len(message_ids)) bar = 'ā–ˆ' * filled_length + 'ā–‘' * (bar_length - filled_length) - sys.stdout.write(f"\ršŸ”„ Rescrape: [{bar}] {progress:.1f}% ({completed_media}/{len(message_ids)})") - sys.stdout.flush() + # sys.stdout.write(f"\ršŸ”„ Rescrape: [{bar}] {progress:.1f}% ({completed_media}/{len(message_ids)})") + # sys.stdout.flush() - print(f"\nāœ… Media reprocessing complete! ({successful_downloads}/{len(message_ids)} successful)") + # print(f"\nāœ… Media reprocessing complete! ({successful_downloads}/{len(message_ids)} successful)") except Exception as e: print(f"Error reprocessing media: {e}") @@ -1306,7 +1306,8 @@ class OptimizedTelegramScraper: await self.client.disconnect() return False else: - print("āœ… Already authenticated!") + pass + # print("āœ… Already authenticated!") return True diff --git a/webui_server.py b/webui_server.py index 5e951f6..9fa86d2 100644 --- a/webui_server.py +++ b/webui_server.py @@ -589,7 +589,9 @@ class ContinuousScrapeManager: if not channels: self._log("No channels configured for continuous scraping.") else: - self._log(f"Starting iteration for {len(channels)} channel(s).") + self._log("=" * 50) + self._log(f"šŸš€ Starting iteration for {len(channels)} channel(s).") + self._log("-" * 50) buffer = io.StringIO() try: with ( @@ -605,7 +607,8 @@ class ContinuousScrapeManager: self.status["last_iteration_at"] = utc_now_iso() self.status["last_finished_at"] = utc_now_iso() self.status["last_error"] = None - self._log("Iteration finished.") + self._log("-" * 50) + self._log("āœ… Iteration finished.") except Exception as exc: output = buffer.getvalue().strip() if output: @@ -616,7 +619,7 @@ class ContinuousScrapeManager: self.status["last_error"] = str(exc) sleep_seconds = max(5, interval_minutes * 60) - self._log(f"Sleeping for {interval_minutes} minute(s).") + self._log(f"šŸ’¤ Sleeping for {interval_minutes} minute(s).") interrupted = self.stop_event.wait(timeout=sleep_seconds) if interrupted: break