/* $Id: OSCPacketDispatcher.java,v 1.2 2008/07/01 15:29:46 modin Exp $
 * Created on 28.10.2003
 */
package com.illposed.osc.utility;

import com.illposed.osc.*;

import java.util.Date;
import java.util.Enumeration;
import java.util.Hashtable;

/**
 * @author cramakrishnan
 *
 * Copyright (C) 2003, C. Ramakrishnan / Auracle
 * All rights reserved.
 * 
 * See license.txt (or license.rtf) for license information.
 * 
 * Dispatches OSCMessages to registered listeners.
 * 
 */

public class OSCPacketDispatcher {
    private Hashtable<String,OSCListener> addressToClassTable = new Hashtable<String,OSCListener>();
    
    /**
     * 
     */
    public OSCPacketDispatcher() {
        super();
    }

    public void addListener(String address, OSCListener listener) {
        addressToClassTable.put(address, listener);
    }
    
    public void dispatchPacket(OSCPacket packet) {
        if (packet instanceof OSCBundle)
            dispatchBundle((OSCBundle) packet);
        else
            dispatchMessage((OSCMessage) packet);
    }
    
    public void dispatchPacket(OSCPacket packet, Date timestamp) {
        if (packet instanceof OSCBundle)
            dispatchBundle((OSCBundle) packet);
        else
            dispatchMessage((OSCMessage) packet, timestamp);
    }
    
    private void dispatchBundle(OSCBundle bundle) {
        Date timestamp = bundle.getTimestamp();
        OSCPacket[] packets = bundle.getPackets();
        for (int i = 0; i < packets.length; i++) {
            dispatchPacket(packets[i], timestamp);
        }
    }
    
    private void dispatchMessage(OSCMessage message) {
        dispatchMessage(message, null);
    }
    
    private void dispatchMessage(OSCMessage message, Date time) {
        Enumeration keys = addressToClassTable.keys();
        while (keys.hasMoreElements()) {
            String key = (String) keys.nextElement();
            // this supports the OSC regexp facility, but it
            // only works in JDK 1.4, so don't support it right now
            // if (key.matches(message.getAddress())) {
            if (key.equals(message.getAddress())) {
                OSCListener listener = (OSCListener) addressToClassTable.get(key);
                listener.acceptMessage(time, message);
            }
        }
    }
}