Home-Integration/dmx/dmx.py

#!/opt/local/bin/python2.7

# Append the path to help find our OLA packages
import sys
sys.path.append('/usr/local/lib/python2.7/site-packages')
sys.path.append('/opt/local/lib/python2.7/site-packages')
sys.path.append('/opt/local/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/site-packages')

import os
import time
import array
import select
import socket
import string
import subprocess
from ola.ClientWrapper import ClientWrapper

# ====================================
# Defaults
# ====================================
interval     = 10
universe     = 0
max_value    = 255
max_delay    = 300000
max_channels = 512
min_delta    = interval / (5 * 1000)
allow_dups   = False
max_mesg_len = 1024
DEBUG        = False

# ====================================
# Globals
# ====================================
wrapper   = None
sock      = None
lastTick  = time.time()
state_len = 0
state     = [ 0 ] * max_channels
cmds      = {
  'value' : [ 0 ] * max_channels,
  'ticks' : [ 0 ] * max_channels,
  'delay' : [ 0 ] * max_channels,
  'orig'  : [ "" ] * max_channels
}

# ====================================
# Wrapper callback -- exit on errors
# ====================================
def DmxSent(state):
  if not state.Succeeded():
    print 'Error: %s' % state.message

    global wrapper
    if wrapper:
      wrapper.Stop()

# ====================================
# Main calculation
# ====================================
def SendDMXFrame():
  global lastTick
  global wrapper
  global sock
  global cmds
  global state
  global state_len

  # Re-schedule ourselves in interval ms (do this first to keep the timing consistent)
  wrapper.AddEvent(interval, SendDMXFrame)

  # Avoid repeated calls to time()
  now = time.time()

  # Adjust our tick count to match reality
  ticks = ((now - lastTick) * 1000) / interval
  lastTick = now
  
  # Check for new commands
  while (True):
    try:
      cmd = sock.recvfrom(max_mesg_len)[0]
    except socket.error, msg:
      break
    channel, duration, intensity, delay = string.split(cmd, ':')
    try:
      channel = int(channel)
      duration = int(duration)
      intensity = int(intensity)
    except ValueError:
      print 'Invalid command:', cmd
      channel = -1
    try:
      delay = int(delay)
    except ValueError:
      delay = 0
    
    # Save valid commands
    if (
      channel >= 0 and channel <= max_channels and
      intensity >= 0 and intensity <= max_value and
      duration >= 0 and duration <= max_delay and
      delay >= 0 and delay < max_delay
    ):
      if (channel > 0):
        if (channel > state_len):
          state_len = channel
        if (allow_dups or cmd != cmds['orig'][channel - 1]):
          cmds['orig'][channel - 1] = cmd
          cmds['value'][channel - 1] = intensity
          cmds['ticks'][channel - 1] = duration / interval
          cmds['delay'][channel - 1] = delay / interval
      else:
        for i in range(state_len):
          if (allow_dups or cmd != cmds['orig'][channel - 1]):
            cmds['orig'][i] = cmd
            cmds['value'][i] = intensity
            cmds['ticks'][i] = duration / interval
            cmds['delay'][i] = delay / interval
    else:
      print 'Invalid command parameters:', channel, duration, intensity, delay
  
  # Update values for each channel
  for i in range(state_len):
    delta = 0
    if (cmds['value'][i] != state[i]):
      if (cmds['delay'][i] > 0):
        if (cmds['delay'][i] >= ticks):        
          cmds['delay'][i] -= ticks
        else:
          cmds['delay'][i] = 0
      else:
        diff = cmds['value'][i] - state[i]
        if (cmds['ticks'][i] < 1):
          delta = diff
        else:
          delta = float(diff) / float(cmds['ticks'][i])
        if (abs(delta) < min_delta):
          delta = diff
        state[i] += delta
        cmds['ticks'][i] -= ticks
      if (DEBUG):
        print '(', now, ') Channel:', (i + 1)
        print "\tDelay:", '%.3f' % cmds['delay'][i], "\tValue:", '%.3f' % state[i], \
          "\tDelta:", '%.3f' % delta, "\tTicks:", '%.3f' % cmds['ticks'][i]
    
  # Send all DMX channels
  data = array.array('B')
  for i in range(state_len):
    data.append(int(state[i]))
  wrapper.Client().SendDmx(universe, data, DmxSent)

# ====================================
# Main
# ====================================

# Debug
DEBUG = None
if 'DEBUG' in os.environ:
  DEBUG = os.environ['DEBUG']

# Pick a universe (default from above, or as specified in the environment)
if 'UNIVERSE' in os.environ:
  universe = int(os.environ['UNIVERSE'])

# Pick a tick interval (default from above, or as specified in the environment)
if 'INTERVAL' in os.environ:
  interval = int(os.environ['INTERVAL'])

# Pick a socket file ($TMPDIR/plexMonitor/DMX.socket, or as specified in the environment)
cmd_file = None
data_dir = None
if 'SOCKET' in os.environ:
  cmd_file = os.environ['SOCKET']
  data_dir = os.dirname(cmd_file)
else:
  proc = subprocess.Popen(['getconf', 'DARWIN_USER_TEMP_DIR'], stdout=subprocess.PIPE, shell=False)
  (tmp_dir, err) = proc.communicate()
  tmp_dir = tmp_dir.strip()
  data_dir = tmp_dir + 'plexMonitor/'
  cmd_file = data_dir + 'DMX.socket'

# Sanity checks
if (not os.path.isdir(data_dir)):
  raise Exception('Bad config: ' + data_dir)

# Open the socket
if (os.path.exists(cmd_file)):
  os.unlink(cmd_file)
sock = socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM)
sock.bind(cmd_file)
sock.setblocking(0)
if (DEBUG):
  print 'Opened socket: %s' % cmd_file

# Start the DMX loop
wrapper = ClientWrapper()
wrapper.AddEvent(interval, SendDMXFrame)
wrapper.Run()