Method _adsb_sbs_reader

intercept_agent.py:1426–1468

Read and parse SBS data from dump1090.

(self, host: str, port: int)

        }

    def _adsb_sbs_reader(self, host: str, port: int):
        """Read and parse SBS data from dump1090."""
        mode = 'adsb'
        stop_event = self.stop_events.get(mode)
        retry_count = 0
        max_retries = 5

        while not (stop_event and stop_event.is_set()):
            try:
                sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                sock.settimeout(5.0)
                sock.connect((host, port))
                logger.info(f"Connected to SBS at {host}:{port}")
                retry_count = 0

                buffer = ""
                sock.settimeout(1.0)

                while not (stop_event and stop_event.is_set()):
                    try:
                        data = sock.recv(4096).decode('utf-8', errors='ignore')
                        if not data:
                            break
                        buffer += data

                        while '\n' in buffer:
                            line, buffer = buffer.split('\n', 1)
                            self._parse_sbs_line(line.strip())

                    except socket.timeout:
                        continue

                sock.close()

            except Exception as e:
                logger.warning(f"SBS connection error: {e}")
                retry_count += 1
                if retry_count >= max_retries:
                    logger.error("Max SBS retries reached, stopping")
                    break
                time.sleep(2)

        logger.info("ADS-B SBS reader stopped")

    def _parse_sbs_line(self, line: str):
        """Parse SBS format line and update aircraft dict."""