BRIX5

#!/usr/bin/env python3

#vim:ts=2:sw=2:expandtab:autoindent

#v 0.1

#dumb router

#echos serial from serial port to a udp socket

#

#TODO: OSC client as well

#TODO: OSCQuery everything

from IPython import embed

# local packages

import os, sys

path = os.path.realpath(__file__).split('/')

package_path = path[:-1]

#package_path.append('python-packages')

package_path.append('SlipLib/src')

sys.path.append('/'.join(package_path))

import serial

import sliplib

import socket

import socketserver

from time import sleep

#import threading

DEBUG = False

if(len(sys.argv) > 1 and sys.argv[1] == '-v'):

    DEBUG = True

TARGET_HOST="127.0.0.1"

TARGET_PORTS=[1234, 57120, 57121, 57122];

TARGET_PORT=1234

#RECV_PORT=9999

sock = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)

#sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # default socket

#slipsocket = sliplib.SlipSocket(sock)

#slipsocket.create_connection((TARGET_HOST, TARGET_PORT))

#TODO:autodetect serialport

ser = serial.Serial('/dev/ttyACM0',9600)

drv = sliplib.Driver()

messages = []

#embed()

while True:

#  slipsocket.driver

  #TODO: handle drv errors on improper packet

  messages = drv.receive(ser.read(ser.inWaiting()))

  if DEBUG:

    print(len(messages), " messages in read")

#  embed()

  for msg in messages:

    if DEBUG:

      print(len, msg)

    try:

      if not sliplib.is_valid(msg):

        for port in TARGET_PORTS:

          sock.sendto(msg, (TARGET_HOST, port))

    except sliplib.ProtocolError:

      if DEBUG:

        print ("Invalid Packet received")

  print("---");

  sleep(0.1)

slipsocket.close()

sock.close()

#import subprocess, shlex

#sc_port_cmd = "lsof -p `pidof sclang`|grep UDP|awk '{ print $9}'|cut -d: -f2"

#sp = subprocess.Popen(sc_port_cmd, stdout=subprocess.PIPE, shell=True)

#print(sp.returncode)