Method run

intercept_agent.py:3757–3779

Main push loop.

(self)

        self.stop_event = threading.Event()

    def run(self):
        """Main push loop."""
        logger.info(f"Data push loop started (interval: {self.interval}s)")

        while not self.stop_event.is_set():
            if push_client and push_client.running:
                # Push data for all running modes
                for mode in list(mode_manager.running_modes.keys()):
                    try:
                        data = mode_manager.get_mode_data(mode)
                        if data.get('data'):  # Only push if there's data
                            push_client.enqueue(
                                scan_type=mode,
                                payload=data,
                                interface=None
                            )
                    except Exception as e:
                        logger.warning(f"Failed to push {mode} data: {e}")

            # Wait for next interval
            self.stop_event.wait(self.interval)

        logger.info("Data push loop stopped")

    def stop(self):
        """Stop the push loop."""