s7_worker.py

from PyQt5.QtCore import QObject, pyqtSignal
import asyncio
from concurrent.futures import ThreadPoolExecutor
from s7_client import run

class S7Worker(QObject):
    finished = pyqtSignal(dict)
    error = pyqtSignal(str)

    def __init__(self, connection_params):
        super().__init__()
        self.connection_params = connection_params
        self.executor = ThreadPoolExecutor(max_workers=1)

    async def run_async(self):
        """
        Asynchronously connect to the S7 server and scrape nodes.
        """
        try:
            memory_map = await asyncio.get_event_loop().run_in_executor(
                self.executor,
                run,
                self.connection_params['ip']
            )

            self.finished.emit(memory_map)

        except Exception as e:
            self.error.emit(f"Failed to connect or scrape nodes: {e}")

    def run_worker(self):
        """
        Wrapper to execute the asynchronous run in the asyncio event loop.
        Initializes and runs the event loop within this thread.
        """
        try:
            loop = asyncio.new_event_loop()
            asyncio.set_event_loop(loop)

            loop.run_until_complete(self.run_async())
        except Exception as e:
            self.error.emit(f"Runtime error in worker: {e}")
        finally:
            loop.close()

    def run(self):
        """
        Public method to start the worker.
        """
        self.run_worker()