main.py

import os, sys, time
import serial
import configparser
from threading import Thread

from PyQt5.QtGui import QTextCursor
from PyQt5.QtCore import QObject, Qt, QEvent, pyqtSignal, pyqtSlot
from PyQt5.QtWidgets import (
    QApplication, QMainWindow, QTextEdit, QWidget
)
from PyQt5 import uic

from frames import RivrLineHandler

# ── Colour helpers (mirrors frames.py) ───────────────────────────────────────
serverFormat = '<span style="color:#29F500;">{}</span>'
allFormat    = '<span style="color:gray;">{}</span>'
uiFormat     = '<span style="color:yellow;">{}</span>'
discFormat   = '<span style="color:red;">{}</span>'

config = configparser.ConfigParser()
config.read('./config.ini')

ui = None  # set in GppyGUI.__init__


# ── Rivr serial line reader thread ───────────────────────────────────────────
class RivrSerialThread(Thread):
    def __init__(self, signal, chat_signal):
        super().__init__(daemon=True)
        self._signal      = signal       # all lines
        self._chat_signal = chat_signal  # chat lines only
        self._lh   = RivrLineHandler()
        self._ser  = None

    def open_port(self):
        config.read('./config.ini')
        port = config['rivr']['serial_port']
        baud = int(config['rivr']['baud_rate'])
        self._ser = serial.Serial(port, baud, timeout=1)
        self._signal.emit(
            serverFormat.format(f"Verbonden met {port} @ {baud} baud")
        )

    def run(self):
        try:
            self.open_port()
        except serial.SerialException as exc:
            self._signal.emit(discFormat.format(f"Seriële poort fout: {exc}"))
            return

        while True:
            try:
                raw = self._ser.readline()   # blocks until \n or timeout
            except serial.SerialException as exc:
                self._signal.emit(discFormat.format(f"Leesfout: {exc}"))
                break

            if not raw:
                continue

            try:
                line = raw.decode('utf-8', errors='replace')
            except Exception:
                continue

            proxy = _MonitorProxy(self._signal, self._chat_signal)
            self._lh.received_line(line, proxy)


class _MonitorProxy:
    """Thin wrapper that forwards tEMonitor/tEChat calls as Qt signals."""
    def __init__(self, signal, chat_signal):
        self.tEMonitor = _AppendProxy(signal)
        self.tEChat    = _AppendProxy(chat_signal)


class _AppendProxy:
    def __init__(self, signal):
        self._signal = signal

    def append(self, html: str):
        self._signal.emit(html)

    def moveCursor(self, *_):
        pass   # scroll is handled in the Qt slot


# ── Main window ───────────────────────────────────────────────────────────────
class GppyGUI(QMainWindow):
    monitor_signal = pyqtSignal(str)   # all lines → tEMonitor
    chat_signal    = pyqtSignal(str)   # chat only → tECh1

    def __init__(self):
        super().__init__()
        global ui
        config.read('./config.ini')
        ui = uic.loadUi("./gppy.ui")

        ui.widConnect.hide()
        ui.widSettings.raise_()
        ui.widSettings.hide()

        ui.widChan1.installEventFilter(self)
        ui.tEInput.installEventFilter(self)

        ui.pBChan1.clicked.connect(self.chan1)
        ui.lWTitle.setText("Monitor")
        ui.pBConnectCh1.clicked.connect(self.pBConnectCh1_clicked)
        ui.pBMonitorCh1.clicked.connect(self.monitor)
        ui.lEConCallsign.returnPressed.connect(self.connectCh1)

        ui.pBSetSave.clicked.connect(self.pBSetSave)
        ui.pBSetCancel.clicked.connect(self.pBSetCancel)

        ui.pBMheard.clicked.connect(self.mheard)
        ui.pBSettings.clicked.connect(self.settings)
        ui.pBMonitor.setEnabled(False)
        ui.pBMonitor.clicked.connect(self.monitor)
        ui.pBDiscCh1.clicked.connect(self.disconnectCh1)
        ui.tEMonitor.document().setMaximumBlockCount(5000)
        ui.tECh1.document().setMaximumBlockCount(2000)
        ui.show()

        # Connect signals so background thread can update UI safely
        self.monitor_signal.connect(self._on_monitor_line)
        self.chat_signal.connect(self._on_chat_line)

    # ── Qt slot: called in main thread ───────────────────────────────────────
    @pyqtSlot(str)
    def _on_monitor_line(self, html: str):
        ui.tEMonitor.append(html)
        ui.tEMonitor.moveCursor(QTextCursor.End)

    @pyqtSlot(str)
    def _on_chat_line(self, html: str):
        ui.tECh1.append(html)
        ui.tECh1.moveCursor(QTextCursor.End)

    def eventFilter(self, a0: QObject, a1: QEvent) -> bool:
        if a1.type() == a1.Type.MouseButtonPress and a0 is ui.widChan1:
            if a1.button() == Qt.MouseButton.RightButton:
                # toggle between full and split view
                if not getattr(self, '_chat_monitor', False):
                    self._chat_monitor = True
                    ui.widConnect.hide()
                    ui.widChan1.resize(1024, 500)
                    ui.tECh1.resize(1024, 500)
                    ui.widStatusBot.move(0, 649)
                    ui.widMonitor.resize(1024, 51)
                    ui.widMonitor.move(0, 670)
                    ui.widMheard.lower()
                    ui.tEMonitor.resize(1024, 51)
                else:
                    self._chat_monitor = False
                    ui.widConnect.hide()
                    ui.widChan1.resize(1024, 551)
                    ui.tECh1.resize(1024, 551)
                    ui.widStatusBot.move(0, 700)
                    ui.widMonitor.resize(1024, 551)
                    ui.widMonitor.move(0, 150)
                    ui.widMonitor.lower()
                    ui.tEMonitor.resize(1024, 551)
        return super().eventFilter(a0, a1)

    def connectCh1(self):
        """Placeholder – no AX25 connect in LoRa mode."""
        ui.widConnect.hide()

    def chan1(self):
        ui.widMonitor.lower()
        ui.widMheard.lower()
        ui.widButtons.lower()
        ui.widChan1.raise_()
        ui.pBMonitor.setEnabled(True)

    def settings(self):
        ui.widSettings.show()
        ui.lESetMycall.setText(config['rivr']['mycall'])

    def pBSetCancel(self):
        ui.widSettings.hide()

    def pBSetSave(self):
        config['rivr']['mycall'] = ui.lESetMycall.text()
        with open('./config.ini', 'w') as f:
            config.write(f)
        ui.widSettings.hide()

    def pBConnectCh1_clicked(self):
        ui.widConnect.show()
        ui.lEConCallsign.setFocus()
        ui.lEConCallsign.selectAll()

    def disconnectCh1(self):
        ui.pBDiscCh1.lower()

    def mheard(self):
        ui.lWTitle.setText("MHeard")
        ui.pBMonitor.setEnabled(True)
        ui.pBMheard.setEnabled(False)
        ui.widMonitor.lower()
        ui.widChan1.lower()
        ui.widStatusBot.lower()
        ui.widMonitor.setEnabled(False)

    def monitor(self):
        ui.lWTitle.setText("Monitor")
        ui.pBMonitor.setEnabled(False)
        ui.pBMheard.setEnabled(True)
        ui.widMonitor.resize(1024, 551)
        ui.widMonitor.move(0, 150)
        ui.tEMonitor.resize(1024, 551)
        ui.widMheard.lower()
        ui.widChan1.lower()
        ui.widButtonsCh1.lower()


# ── Entry point ───────────────────────────────────────────────────────────────
def main():
    app = QApplication(sys.argv)
    window = GppyGUI()
    serial_thread = RivrSerialThread(window.monitor_signal, window.chat_signal)
    serial_thread.start()
    sys.exit(app.exec_())


if __name__ == '__main__':
    main()