serialPort.py

import threading

import schedule

from Connection.serialPortThread import SerialPortThread
from DataStructures.makesmithInitFuncs import MakesmithInitFuncs


class SerialPort(MakesmithInitFuncs):
    """

    The SerialPort is an object which manages communication with the device over the serial port.

    The actual connection is run in a separate thread by an instance of a SerialPortThread object.

    """

    serialPortRequest = ""

    # COMports = ListProperty(("Available Ports:", "None"))

    def __init__(self):
        """
        Runs on creation, schedules the software to attempt to connect to the machine

        """
        schedule.every(5).seconds.do(self.openConnection)

    def setPort(self, port):
        """

        Defines which port the machine is attached to

        """
        self.data.console_queue.put(port)
        self.data.comport = port

    def connect(self, *args):
        """

        Forces the software to begin trying to connect on the new port.

        This function may not be necessary, but it should stay in because it simplifies the user experience.

        """
        self.data.config.setValue(
            "Makesmith Settings", "COMport", str(self.data.comport)
        )

    """

    Serial Connection Functions

    """

    def openConnection(self, *args):
        # This function opens the thread which handles the input from the serial port

        if not self.data.connectionStatus:
            # self.data.ui_queue.put(
            #    "Action: connectionStatus:_" + json.dumps({'status': 'disconnected', 'port': 'none'})
            # )  # the "_" facilitates the parse
            self.data.ui_queue1.put(
                "Action",
                "connectionStatus",
                {
                    "status": "disconnected",
                    "port": "none",
                    "fakeServoStatus": self.data.fakeServoStatus,
                },
            )
            x = SerialPortThread()
            x.data = self.data
            self.th = threading.Thread(target=x.getmessage)
            self.th.daemon = True
            self.th.start()
        else:
            self.data.ui_queue1.put(
                "Action",
                "connectionStatus",
                {
                    "status": "connected",
                    "port": self.data.comport,
                    "fakeServoStatus": self.data.fakeServoStatus,
                },
            )
            # self.data.ui_queue.put(
            #    "Action: connectionStatus:_" + json.dumps({'status': 'connected', 'port': self.data.comport})
            # )  # the "_" facilitates the parse

    def closeConnection(self):
        self.serialPortRequest = "requestToClose"

    def getConnectionStatus(self):
        return self.serialPortRequest