/*
 * This file is part of libbluray
 * Copyright (C) 2013  VideoLAN
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library. If not, see
 * <http://www.gnu.org/licenses/>.
 */
package org.videolan;

import java.util.EventObject;
import java.util.Iterator;
import java.util.LinkedList;

import javax.media.ControllerEvent;
import javax.media.ControllerListener;
import javax.media.GainChangeEvent;
import javax.media.GainChangeListener;
import javax.tv.media.MediaSelectEvent;
import javax.tv.media.MediaSelectListener;
import javax.tv.service.selection.ServiceContextEvent;
import javax.tv.service.selection.ServiceContextListener;

import org.bluray.bdplus.StatusListener;

import org.bluray.media.AngleChangeEvent;
import org.bluray.media.AngleChangeListener;
import org.bluray.media.PanningChangeListener;
import org.bluray.media.PanningChangeEvent;
import org.bluray.media.PiPStatusEvent;
import org.bluray.media.PiPStatusListener;
import org.bluray.media.PlaybackListener;
import org.bluray.media.PlaybackMarkEvent;
import org.bluray.media.PlaybackPlayItemEvent;
import org.bluray.media.UOMaskTableListener;
import org.bluray.media.UOMaskTableChangedEvent;
import org.bluray.media.UOMaskedEvent;

import org.davic.resources.ResourceStatusEvent;
import org.davic.resources.ResourceStatusListener;

import org.dvb.application.AppsDatabaseEvent;
import org.dvb.application.AppsDatabaseEventListener;
import org.dvb.media.SubtitleAvailableEvent;
import org.dvb.media.SubtitleListener;
import org.dvb.media.SubtitleNotAvailableEvent;
import org.dvb.media.SubtitleNotSelectedEvent;
import org.dvb.media.SubtitleSelectedEvent;
import org.dvb.media.VideoFormatListener;
import org.dvb.media.VideoFormatEvent;

public class BDJListeners {
    private LinkedList listeners = new LinkedList();

    public void add(Object listener) {
        if (listener != null) {
            BDJXletContext ctx = BDJXletContext.getCurrentContext();
            if (ctx == null) {
                logger.error("Listener added from wrong thread: " + Logger.dumpStack());
                return;
            }
            synchronized (listeners) {
                remove(listener);
                listeners.add(new BDJListener(ctx, listener));
            }
        }
    }

    public void remove(Object listener) {
        synchronized (listeners) {
            for (Iterator it = listeners.iterator(); it.hasNext(); ) {
                BDJListener item = (BDJListener)it.next();
                if (item.listener == listener)
                    it.remove();
            }
        }
    }

    public void clear() {
        if (null != BDJXletContext.getCurrentContext()) {
            logger.error("clear() from wrong thread: " + Logger.dumpStack());
            return;
        }
        synchronized (listeners) {
            listeners.clear();
        }
    }

    public void putCallback(Object event) {
        boolean mediaQueue = true;
        /*
        if (event instanceof PlaybackMarkEvent) {
        } else if (event instanceof PlaybackPlayItemEvent) {
        } else if (event instanceof UOMaskTableChangedEvent) {
        } else if (event instanceof UOMaskedEvent) {
        } else if (event instanceof PiPStatusEvent) {
        } else if (event instanceof PanningChangeEvent) {
        } else if (event instanceof AngleChangeEvent) {
        } else if (event instanceof MediaSelectEvent) {
        } else if (event instanceof GainChangeEvent) {
        } else if (event instanceof ControllerEvent) {
        }
        */
        if (event instanceof ServiceContextEvent) {
            mediaQueue = false;
        } else if (event instanceof ResourceStatusEvent) {
            mediaQueue = false;
        } else if (event instanceof AppsDatabaseEvent) {
            mediaQueue = false;
        } else if (event instanceof PSR102Status) {
            mediaQueue = false;
        }
        putCallback(event, mediaQueue);
    }

    public void putCallback(Object event, boolean mediaQueue) {
        synchronized (listeners) {
            for (Iterator it = listeners.iterator(); it.hasNext(); ) {
                BDJListener item = (BDJListener)it.next();
                if (item.ctx == null || item.ctx.isReleased()) {
                    logger.info("Listener terminated: " + item.ctx);
                    it.remove();
                } else {
                    if (mediaQueue) {
                        item.ctx.putMediaCallback(new Callback(event, item.listener));
                    } else {
                        item.ctx.putCallback(new Callback(event, item.listener));
                    }
                }
            }
        }
    }

    private static class PSR102Status {
        public int value;

        private PSR102Status(int value) {
            this.value = value;
        }
    }

    public void putPSR102Callback(int value) {
        putCallback(new PSR102Status(value));
    }

    private static class BDJListener {
        public BDJXletContext ctx;
        public Object listener;

        BDJListener(BDJXletContext ctx, Object listener) {
            this.ctx = ctx;
            this.listener = listener;
        }
    }

    private static class Callback extends BDJAction {
        private Callback(Object event, Object listener) {
            this.event = event;
            this.listener = listener;
        }

        public String toString() {
            return this.getClass().getName() + "[event=" + event + ", listener=" + listener;
        }

        protected void doAction() {
            if (event instanceof PlaybackMarkEvent) {
                ((PlaybackListener)listener).markReached((PlaybackMarkEvent)event);
            } else if (event instanceof PlaybackPlayItemEvent) {
                ((PlaybackListener)listener).playItemReached((PlaybackPlayItemEvent)event);
            } else if (event instanceof ServiceContextEvent) {
                ((ServiceContextListener)listener).receiveServiceContextEvent((ServiceContextEvent)event);
            } else if (event instanceof UOMaskTableChangedEvent) {
                ((UOMaskTableListener)listener).receiveUOMaskTableChangedEvent((UOMaskTableChangedEvent)event);
            } else if (event instanceof UOMaskedEvent) {
                ((UOMaskTableListener)listener).receiveUOMaskedEvent((UOMaskedEvent)event);
            } else if (event instanceof PiPStatusEvent) {
                ((PiPStatusListener)listener).piPStatusChange((PiPStatusEvent)event);
            } else if (event instanceof PanningChangeEvent) {
                ((PanningChangeListener)listener).panningChange((PanningChangeEvent)event);
            } else if (event instanceof AngleChangeEvent) {
                ((AngleChangeListener)listener).angleChange((AngleChangeEvent)event);
            } else if (event instanceof MediaSelectEvent) {
                ((MediaSelectListener)listener).selectionComplete((MediaSelectEvent)event);

            } else if (event instanceof GainChangeEvent) {
                ((GainChangeListener)listener).gainChange((GainChangeEvent)event);
            } else if (event instanceof ControllerEvent) {
                ((ControllerListener)listener).controllerUpdate((ControllerEvent)event);

            } else if (event instanceof ResourceStatusEvent) {
                ((ResourceStatusListener)listener).statusChanged((ResourceStatusEvent)event);

            } else if (event instanceof AppsDatabaseEvent) {
                AppsDatabaseEvent dbevent = (AppsDatabaseEvent)event;
                AppsDatabaseEventListener dblistener = (AppsDatabaseEventListener)listener;
                switch (dbevent.getEventId()) {
                case AppsDatabaseEvent.APP_ADDED:
                    dblistener.entryAdded(dbevent);
                    break;
                case AppsDatabaseEvent.APP_CHANGED:
                    dblistener.entryChanged(dbevent);
                    break;
                case AppsDatabaseEvent.APP_DELETED:
                    dblistener.entryRemoved(dbevent);
                    break;
                case AppsDatabaseEvent.NEW_DATABASE:
                    dblistener.newDatabase(dbevent);
                    break;
                }

            } else if (event instanceof SubtitleAvailableEvent || event instanceof SubtitleNotAvailableEvent ||
                       event instanceof SubtitleNotSelectedEvent || event instanceof SubtitleSelectedEvent) {
                ((SubtitleListener)listener).subtitleStatusChanged((EventObject)event);

            } else if (event instanceof VideoFormatEvent) {
                ((VideoFormatListener)listener).receiveVideoFormatEvent((VideoFormatEvent)event);

            } else if (event instanceof PSR102Status) {
                ((StatusListener)listener).receive(((PSR102Status)event).value);

            } else {
                System.err.println("Unknown event type: " + event.getClass().getName());
            }
        }

        private Object listener;
        private Object event;
    }

    private static final Logger logger = Logger.getLogger(BDJListeners.class.getName());
}