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

# 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 sliplib

import serial

import socket

import socketserver

#from pythonosc import udcp_client

from time import sleep

import threading

DEBUG = False

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

    DEBUG = True

UDP_HOST="127.0.0.1"

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

#RECV_PORT=9999

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

#client = SimpleUDPClient(UDP_HOST,UDP_PORT)

#TODO:autodetect serialport

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

messages = []

drv = sliplib.Driver()

#class MessageHandler(socketserver.BaseRequestHandler):

#    def handle(self):

#        data=self.request[0]

#        socket=self.request[1]

#        ser.write(drv.send(data))

#        print(drv.send(data))

#

#server= socketserver.UDPServer(('',RECV_PORT),MessageHandler)

#server_thread=threading.Thread(target=server.serve_forever)

#server_thread.daemon=True

#server_thread.start()

#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)

while True:

  #TODO: handle drv errors on improper packet

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

  if DEBUG:

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

  for msg in messages:

    try:

      dec = sliplib.decode(msg)

      if DEBUG:

        print(len(msg), dec)

      if sliplib.is_valid(msg):

        for port in UDP_PORTS:

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

    except sliplib.ProtocolError:

      if DEBUG:

        print ("Invalid Packet received")

  print("---");

  sleep(1)

  #sleep(0.005)

#server.shutdown()

#server.server_close()

sock.close()