glow.py

from twisted.internet import reactor
from txosc import osc
from txosc import dispatch
from txosc import async

import time
import piglow

def pulse():
    for x in range(100):
        piglow.leg_bar(0, x / 100.0)
        piglow.leg_bar(1, x / 100.0)
        piglow.leg_bar(2, x / 100.0)
        piglow.white(0)
        piglow.show()
        time.sleep(0.01)
    for x in reversed(range(100)):
        piglow.leg_bar(0, x / 100.0)
        piglow.leg_bar(1, x / 100.0)
        piglow.leg_bar(2, x / 100.0)
        piglow.white(0)
        piglow.show()
        time.sleep(0.01)

def glow_handler(message, address):
    pulse()

class UDPReceiverApplication(object):
    def __init__(self, port):
        self.port = port
        self.receiver = dispatch.Receiver()
        self._server_port = reactor.listenUDP(self.port, async.DatagramServerProtocol(self.receiver))
        print("Listening on osc.udp://localhost:%s" % (self.port))
        self.receiver.addCallback("/cue/1/start", glow_handler)

        # fallback:
        self.receiver.fallback = self.fallback
    
    def fallback(self, message, address):
        print("  Got %s from %s" % (message, address))

if __name__ == "__main__":
    app = UDPReceiverApplication(17779)
    reactor.run()