import serial
import sys
import threading

PORT = "/dev/ttyAMA0"   # spremeni po potrebi
BAUD = 115200

ser = serial.Serial(PORT, BAUD, timeout=0)

def read_serial():
    while True:
        try:
            data = ser.read(1024)
            if data:
                try:
                    print(data.decode(errors='ignore'), end='', flush=True)
                except:
                    pass
        except:
            break

def write_serial():
    while True:
        try:
            line = sys.stdin.readline()
            if not line:
                break
            ser.write(line.encode())
        except:
            break

print(f"Connected to {PORT} @ {BAUD}")
print("CTRL+C za izhod\n")

t1 = threading.Thread(target=read_serial, daemon=True)
t2 = threading.Thread(target=write_serial, daemon=True)

t1.start()
t2.start()

try:
    t1.join()
    t2.join()
except KeyboardInterrupt:
    print("\nClosing...")
    ser.close()