connection.py

# Connection handles serial connection with the printer mainboard

import serial
import time
import threading

serial_path = 'COM4'
serial_list = ["COM1", "COM2", "COM3", "COM4", "COM5"]
baud_rate = 115200

global globalresponse
globalresponse = ""

global ready_for_row
ready_for_row = False


def connection_delay(seconds):
    start_time = time.monotonic()
    while time.monotonic() - start_time < seconds:
        pass

class Connection:
    def __init__(self):
        try:
            self.ser = serial.Serial(serial_path, baud_rate, timeout=1)
            print("Connected")
        except Exception as e:

            print(f"Error encountered during connection: {e}")
            
    def send(self, data):
        formatted = data + "\n"

        # Homing specific
        if(data=="G28 X Y"):
            homing_complete = False
            time.sleep(1)
            self.ser.write(formatted.encode())
            print(f"Sent command {data}")
            connection_delay(1)
            while(homing_complete == False):
                response = self.ser.readline()
                # print(f"Response: {response.decode()}")
                connection_delay(1)
                if("busy" not in response.decode() and "processing" not in response.decode()):
                    homing_complete = True
                    print("Homing complete")
                else:
                    print("Homing ongoing")

        # Process all other moves
        else:
            try:
                move_complete = False

                self.ser.write(formatted.encode())
                print(f"Sent command {data}")
                connection_delay(1)
                while move_complete==False:

                    response = self.ser.readline()
                    # print(f"Response: {response.decode()}")
                    time.sleep(0.6)
                    global globalresponse
                    global ready_for_row

                    globalresponse = response.decode()
                    if('Row Complete' in globalresponse):
                        ready_for_row = True

                    if ("ok" in response.decode() and "processing" not in response.decode()):
                        move_complete = True

                        print(f"move complete {data}, response: {response.decode()}")

                        if('Row Complete' in data):
                            self.override_ready()
                            print("Row Ready initiated from line 83")

                    else:
                        pass
                        print(f"move ongoing | response: {response.decode()}")

            except Exception as e:
                print(f"Error : {e}")
                print(f"Error encountered during GCode send: {data}")

    def get_state(self):
        return globalresponse

    def read_next(self):
        global globalresponse
        response = self.ser.readline()
        globalresponse = response.decode()

        global ready_for_row
        if('Row Complete' in globalresponse):
            ready_for_row = True

    def is_ready_for_row(self):
        global ready_for_row
        print(f'Row Ready: {ready_for_row}')
        return ready_for_row

    def reset_row(self):
        global ready_for_row
        ready_for_row = False
        print("row state reset")

    def override_ready(self):
        global ready_for_row
        ready_for_row = True
        print("Ready override triggered")