Laboratoire ICAR » Plateforme TXM

package org.txm.backtomedia.editors.player;

import java.io.File;

import java.net.Authenticator;

import java.net.PasswordAuthentication;

import java.time.LocalTime;

import java.time.format.DateTimeFormatter;

import java.util.concurrent.Semaphore;

import org.eclipse.swt.SWT;

import org.eclipse.swt.events.MouseEvent;

import org.eclipse.swt.events.MouseListener;

import org.eclipse.swt.events.SelectionEvent;

import org.eclipse.swt.events.SelectionListener;

import org.eclipse.swt.graphics.Point;

import org.eclipse.swt.layout.GridData;

import org.eclipse.swt.layout.GridLayout;

import org.eclipse.swt.widgets.Button;

import org.eclipse.swt.widgets.Composite;

import org.eclipse.swt.widgets.Event;

import org.eclipse.swt.widgets.FileDialog;

import org.eclipse.swt.widgets.Label;

import org.eclipse.swt.widgets.Listener;

import org.eclipse.swt.widgets.Scale;

import org.txm.backtomedia.commands.function.TripleRangeSlider;

import org.txm.backtomedia.preferences.BackToMediaPreferences;

import org.txm.utils.logger.Log;

import javafx.application.Platform;

import javafx.beans.InvalidationListener;

import javafx.beans.Observable;

import javafx.embed.swt.FXCanvas;

import javafx.geometry.Insets;

import javafx.scene.Group;

import javafx.scene.Scene;

import javafx.scene.layout.HBox;

import javafx.scene.media.Media;

import javafx.scene.media.MediaPlayer;

import javafx.scene.media.MediaPlayer.Status;

import javafx.scene.media.MediaView;

import javafx.scene.paint.Color;

import javafx.util.Duration;

import vlcplayerrcp.MessagesMP;

public class JFXPlayer extends Composite implements IPlayer {

        protected static final String NOMEDIA = ""; //$NON-NLS-1$

        private MediaPlayer jfxPlayer;

        //private GLComposite videoComposite;

        private Scale rateField;

        private Label rateValueLabel;

        private Scale volumeField;

        private Label volumeValueLabel;

        private Button playButton;

        private Button repeatButton;

        protected String currentlyPlayed = ""; //$NON-NLS-1$

        // private String startTime, endTime;

        private int start, end;

        protected boolean hasEnded = false;

        private String previouslyPlayed = ""; //$NON-NLS-1$

        private boolean repeat = false;

        protected int volume = 100;

        private Button stopButton;

        Label timeLabel;

        TripleRangeSlider timeRange;

        boolean firstLengthEvent = true;

        long previous = 0;

        long time, mins, secs;

        public MediaPlayer getEmbeddedMediaPlayer() {

                return jfxPlayer;

        }

        Semaphore s = new Semaphore(1);

        private FXCanvas fxCanvas;

        Point previousP;

        protected boolean userStopped;

        public JFXPlayer(Composite parent, int style) {

                super(parent, style);

                this.setLayout(new GridLayout(11, false));

                // very important to avoid error when re-opening the player

                javafx.application.Platform.setImplicitExit(false);

                // THE PLAYER

                // if (RuntimeUtil.isMac()) {

                // try {

                // LibC.INSTANCE.setenv("VLC_PLUGIN_PATH", "/Applications/VLC.app/Contents/MacOS/plugins", 1);

                // }

                // catch (Exception ex) {

                // ex.printStackTrace();

                // }

                // }

//                videoComposite = new GLComposite(this, SWT.NONE, "Video");

//                GridData gdata = new GridData(SWT.FILL, SWT.FILL, true, true);

//                gdata.horizontalSpan = 11;

//                videoComposite.setLayoutData(gdata);

//                jfxPlayer = null;

//

//                fxCanvas.addDisposeListener(new DisposeListener() {

//

//                        @Override

//                        public void widgetDisposed(DisposeEvent e) {

//                                if (jfxPlayer != null) {

//                                        jfxPlayer.dispose();

//                                        jfxPlayer = null;

//                                        fxCanvas.setScene(null);

//                                }

//                        }

//                });

                fxCanvas = new FXCanvas(this, SWT.BORDER);

                GridData gdata2 = new GridData(SWT.FILL, SWT.FILL, true, true);

                gdata2.horizontalSpan = 11;

                fxCanvas.setLayoutData(gdata2);

                fxCanvas.addMouseListener(new MouseListener() {

                        @Override

                        public void mouseUp(MouseEvent e) {

                                if (jfxPlayer != null) {

                                        if (jfxPlayer.getStatus().equals(Status.PAUSED)) {

                                                resume();

                                        }

                                        else if (jfxPlayer.getStatus().equals(Status.PLAYING)) {

                                                pause();

                                        }

                                }

                        }

                        @Override

                        public void mouseDown(MouseEvent e) {}

                        @Override

                        public void mouseDoubleClick(MouseEvent e) {}

                });

                fxCanvas.addListener(SWT.Resize, new Listener() {

                        @Override

                        public void handleEvent(Event e) {

                                resizeView();

                        }

                });

                // THE CONTROL BUTTONS

                playButton = new Button(this, SWT.PUSH);

                GridData playLayoutData = new GridData(SWT.FILL, SWT.CENTER, false, false);

                playButton.setLayoutData(playLayoutData);

                playButton.setText(MessagesMP.play);

                playButton.addSelectionListener(new SelectionListener() {

                        @Override

                        public void widgetSelected(SelectionEvent e) {

                                userStopped = false;

                                if (currentlyPlayed.length() == 0) {

                                        selectMedia();

                                        playButton.setText(MessagesMP.pause);

                                        playButton.getParent().layout();

                                }

                                else if (jfxPlayer != null && jfxPlayer.getStatus().equals(Status.PLAYING)) {

                                        pause();

                                }

                                else if (jfxPlayer != null && hasEnded) {

                                        if (jfxPlayer == null) return;

                                        replay();

                                }

                                else {

                                        resume();

                                }

                        }

                        @Override

                        public void widgetDefaultSelected(SelectionEvent e) {}

                });

                // Button browseButton = new Button(this,SWT.PUSH);

                // browseButton.setLayoutData(new GridData(SWT.CENTER, SWT.CENTER, false, false));

                // browseButton.setText("Open...");

                // browseButton.addSelectionListener(new SelectionListener() {

                // @Override

                // public void widgetSelected(SelectionEvent e) {

                // selectMedia();

                // }

                //

                // @Override

                // public void widgetDefaultSelected(SelectionEvent e) {}

                // });

                stopButton = new Button(this, SWT.PUSH);

                stopButton.setLayoutData(new GridData(SWT.FILL, SWT.CENTER, false, false));

                stopButton.setText(MessagesMP.stop);

                stopButton.addSelectionListener(new SelectionListener() {

                        @Override

                        public void widgetSelected(SelectionEvent e) {

                                if (jfxPlayer != null) {

                                        userStopped = true;

                                        jfxPlayer.stop();

                                }

                        }

                        @Override

                        public void widgetDefaultSelected(SelectionEvent e) {}

                });

                timeLabel = new Label(this, SWT.NONE);

                timeLabel.setText("00:00"); //$NON-NLS-1$

                timeRange = new TripleRangeSlider(this, SWT.None);

                timeRange.setLayoutData(new GridData(SWT.FILL, SWT.CENTER, true, false));

                timeRange.setToolTipText(MessagesMP.time_range);

                timeRange.addSelectionListener(new SelectionListener() {

                        @Override

                        public void widgetSelected(SelectionEvent e) {

                                TripleRangeSlider.SELECTED_KNOB sk = timeRange.getLastSelectedKnob();

                                switch (sk) {

                                        case UPPER:

                                                end = timeRange.getUpperValue();

                                                jfxPlayer.setStopTime(Duration.seconds(end));

                                                if (end < time) {

                                                        // System.out.println("Upper changed: fix time");

                                                        time = end;

                                                        jfxPlayer.seek(Duration.seconds(time));

                                                }

                                                break;

                                        case LOWER:

                                                start = timeRange.getLowerValue();

                                                jfxPlayer.setStartTime(Duration.seconds(start));

                                                if (start > time) {

                                                        // System.out.println("Lower changed: fix time");

                                                        time = start;

                                                        jfxPlayer.seek(Duration.seconds(time));

                                                }

                                                break;

                                        case MIDDLE:

                                                time = timeRange.getMiddleValue();

                                                // System.out.println("Middle changed: fix time: " + time);

                                                jfxPlayer.seek(Duration.seconds(time));

                                                break;

                                        default:

                                                // nothing

                                }

                                // System.out.println("time range: "+start+" -> "+end+" time="+time);

                        }

                        @Override

                        public void widgetDefaultSelected(SelectionEvent e) {}

                });

                repeatButton = new Button(this, SWT.CHECK);

                repeatButton.setText(MessagesMP.repeat);

                repeat = BackToMediaPreferences.getInstance().getBoolean(BackToMediaPreferences.REPEAT);

                repeatButton.setSelection(repeat);

                repeatButton.addSelectionListener(new SelectionListener() {

                        @Override

                        public void widgetSelected(SelectionEvent e) {

                                repeat = repeatButton.getSelection();

                        }

                        @Override

                        public void widgetDefaultSelected(SelectionEvent e) {}

                });

                Label l = new Label(this, SWT.NONE);

                l.setText(MessagesMP.rate);

                rateField = new Scale(this, SWT.BORDER);

                GridData gdata4 = new GridData(SWT.FILL, SWT.CENTER, false, false);

                gdata4.widthHint = 100;

                rateField.setLayoutData(gdata4);

                rateField.setMaximum(140);

                rateField.setMinimum(70);

                rateField.setSelection(100);

                rateField.setPageIncrement(5);

                rateField.addSelectionListener(new SelectionListener() {

                        @Override

                        public void widgetSelected(SelectionEvent e) {

                                float rate = rateField.getSelection() / 100.0f;

                                jfxPlayer.setRate(rate);

                                rateValueLabel.setText("" + rateField.getSelection() + "%");

                        }

                        @Override

                        public void widgetDefaultSelected(SelectionEvent e) {}

                });

                rateValueLabel = new Label(this, SWT.NONE);

                rateValueLabel.setText("100%");//$NON-NLS-1$

                l = new Label(this, SWT.NONE);

                l.setText(MessagesMP.volume);

                volumeField = new Scale(this, SWT.BORDER);

                gdata4 = new GridData(SWT.FILL, SWT.CENTER, false, false);

                gdata4.widthHint = 100;

                volumeField.setLayoutData(gdata4);

                volumeField.setMinimum(0);

                volumeField.setMaximum(100);

                volumeField.setSelection(volume);

                volumeField.setPageIncrement(5);

                volumeField.addSelectionListener(new SelectionListener() {

                        @Override

                        public void widgetSelected(SelectionEvent e) {

                                jfxPlayer.setVolume(volumeField.getSelection());

                                volume = volumeField.getSelection();

                                volumeValueLabel.setText("" + volume + "%");

                        }

                        @Override

                        public void widgetDefaultSelected(SelectionEvent e) {}

                });

                volumeValueLabel = new Label(this, SWT.NONE);

                volumeValueLabel.setText("100%");

                // vlcPlayer.events().addMediaPlayerEventListener(new MediaPlayerEventAdapter() {

                //

                // @Override

                // public void opening(MediaPlayer mediaPlayer) {

                // if (videoComposite.isDisposed()) return;

                // Log.finer("Opening media...");

                // }

                //

                // @Override

                // public void finished(MediaPlayer mediaPlayer) {

                // if (videoComposite.isDisposed()) return;

                // Log.finer("Finished playing media...");

                // if (repeat) {

                // replay();

                // }

                // else {

                // hasEnded = true;

                // }

                // }

                // });

                //

                // vlcPlayer.events().addMediaPlayerEventListener(new MediaPlayerEventAdapter() {

                //

                // @Override

                // public void timeChanged(MediaPlayer mediaPlayer, final long arg1) {

                //

                // }

                //

                // @Override

                // public void lengthChanged(MediaPlayer mediaPlayer, final long arg1) {

                // if (videoComposite.isDisposed()) return;

                //

                // if (firstLengthEvent) {

                // firstLengthEvent = false;

                //

                // // initialize time range widget limits

                // timeRange.getDisplay().syncExec(new Runnable() {

                //

                // @Override

                // public void run() {

                // if (timeRange.isDisposed()) return;

                // timeRange.setMaximum((int) arg1);

                // // if (start == end) end = (int)arg1;

                //

                // if (end > 0 && start != end) {

                // timeRange.setUpperValue(end);

                // }

                // else {

                // timeRange.setUpperValue((int) arg1);

                // }

                //

                // timeRange.setLowerValue(start);

                // // System.out.println("Range: "+start+" -> "+end+" song length "+arg1);

                // }

                // });

                // }

                // }

                // });

        }

        protected void resizeView() {

                if (view != null) {

                        Point p = fxCanvas.getSize();

                        // if (previousP == null || (p.x != previousP.x && p.y != previousP.y)) { // ensure size changed

                        view.setFitHeight(p.y);

                        view.setFitWidth(p.x);

                        previousP = p;

                        // }

                }

        }

        public void resume() {

                if (jfxPlayer != null) {

                        jfxPlayer.play();

                        playButton.setText(MessagesMP.pause);

                        playButton.getParent().layout();

                }

        }

        public void pause() {

                if (jfxPlayer != null) {

                        jfxPlayer.pause();

                        playButton.setText(MessagesMP.resume);

                        playButton.getParent().layout();

                }

        }

        private void updateTimeLabel() {

                mins = time / 60;

                secs = (time) % 60;

                timeLabel.setText(String.format("%02d:%02d", mins, secs)); //$NON-NLS-1$

                timeLabel.update();

        }

        public void replay() {

                if (currentlyPlayed.length() > 0) {

                        jfxPlayer.seek(Duration.seconds(start));

                        playButton.setText(MessagesMP.pause);

                        playButton.getParent().layout();

                }

        }

        protected void selectMedia() {

                Log.fine(MessagesMP.select_file);

                FileDialog fd = new FileDialog(JFXPlayer.this.getShell(), SWT.OPEN);

                fd.setText(MessagesMP.select_file_title);

                File f = new File(previouslyPlayed);

                if (f.isDirectory()) fd.setFilterPath(f.getPath());

                else fd.setFilterPath(f.getParent());

                String[] filterExt = { "*.*", "*.mp3", "*.mp4", "*.avi", "*.ogg", "*.ogv" }; //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ //$NON-NLS-4$

                fd.setFilterExtensions(filterExt);

                String selected = fd.open();

                if (selected == null) {

                        System.out.println(MessagesMP.cancel);

                        return;

                }

                currentlyPlayed = selected;

                previouslyPlayed = selected;

                Log.fine(MessagesMP.opening + currentlyPlayed);

                play(new File(currentlyPlayed).toURI().toString(), 0, 0);

        }

        /**

         *

         * @param mrl

         * @param time msec start time

         * @param endtime msec end time

         */

        @Override

        public boolean play(String mrl, int time, int endtime) {

                Log.fine(MessagesMP.bind(MessagesMP.playing, new Object[] { mrl, time, endtime }));

                return play(mrl, "" + time, "" + endtime); //$NON-NLS-1$ //$NON-NLS-2$

        }

        @Override

        public boolean play(String mrl, int time) {

                return play(mrl, time, time);

        }

        public void hideStopButton() {

                if (this.stopButton != null && !this.stopButton.isDisposed()) {

                        this.stopButton.dispose();

                }

        }

        DateTimeFormatter hhmmssFormatter = DateTimeFormatter.ISO_LOCAL_TIME;

        private MediaView view;

        private Group group;

        private Scene scene;

        private String mrl;

        private Media media;

        @Override

        public final void setCredentials(String login, String mdp) {

                Authenticator.setDefault(new Authenticator() {

                        @Override

                        public PasswordAuthentication getPasswordAuthentication() {

                                // System.out.println("PA: login=" + login + " mdp=" + mdp + " mrl=" + mrl + " req=" + getRequestingHost());

                                if (login != null && mdp != null && mrl.contains("://" + getRequestingHost() + "/")) {

                                        return new PasswordAuthentication(login, mdp.toCharArray());

                                }

                                return null;

                        }

                });

        }

        /**

         *

         * @param mrl

         * @param startTime "0.0" or ""hh:mm:ss" format

         * @param endTime "0.0" or ""hh:mm:ss" format

         */

        @Override

        public boolean play(String mrl, String startTime, String endTime) {

                if (mrl.contains("{0}:{1}@")) {

                        mrl = mrl.replace("{0}:{1}@", "");

                }

                this.mrl = mrl;

                if (startTime.matches("[0-9]+.[0-9]+")) {

                        start = (int) (Float.parseFloat(startTime));

                }

                else if (startTime.matches("[0-9]+:[0-9]+:[0-9]+")) {

                        if (startTime.indexOf(":") == 1) {

                                startTime = "0" + startTime;

                        }

                        LocalTime time1 = LocalTime.parse(startTime, hhmmssFormatter);

                        start = ((time1.getHour() * 60 * 60) + (time1.getMinute() * 60) + time1.getSecond());

                }

                if (endTime.matches("[0-9]+.[0-9]+")) {

                        end = (int) (Float.parseFloat(endTime));

                }

                else if (endTime.matches("[0-9]+:[0-9]+:[0-9]+")) {

                        if (endTime.indexOf(":") == 1) endTime = "0" + endTime;

                        LocalTime time1 = LocalTime.parse(endTime, hhmmssFormatter);

                        end = ((time1.getHour() * 60 * 60) + (time1.getMinute() * 60) + time1.getSecond());

                }

                // if (start == end) end = -1;

                Log.finer(MessagesMP.bind(MessagesMP.playing, new Object[] { mrl, startTime, endTime }));

                // vlcPlayer.submit(new Runnable() {

                //

                // @Override

                // public void run() {

                // String[] options = { " :live-caching=200" }; // reduce video stream cache duration to 200ms

                Log.finer("Preparing media...");

                try {

                        javafx.application.Platform.runLater(new Runnable() {

                                @Override

                                public void run() {

                                        Thread.setDefaultUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {

                                                @Override

                                                public void uncaughtException(Thread t, Throwable e) {

                                                        System.out.println("JavaFX uncaught exception: " + e);

                                                }

                                        });

                                }

                        });

                        media = new Media(mrl);

                        if (jfxPlayer != null) {

                                try {

                                        jfxPlayer.stop();

                                }

                                catch (Exception e) {

                                }

                        }

                        Platform.setImplicitExit(false); // This is important to avoid Thread exception when re-opening a player

                        jfxPlayer = new MediaPlayer(media);

                        if (jfxPlayer.getError() == null) {

                                jfxPlayer.setOnError(new Runnable() {

                                        @Override

                                        public void run() {

                                                System.out.println("JFX Player Error:");

                                                jfxPlayer.getError().printStackTrace();

                                        }

                                });

                        }

                        else {

                                System.out.println("Warning: could not retrieve media error logger");

                        }

                        //initializePlayerListeners();

                        jfxPlayer.setAutoPlay(false);

                        view = new MediaView(jfxPlayer);

                        HBox buttonSection = new HBox(view);

                    buttonSection.setPadding(new Insets(2));

                        group = new Group(buttonSection);

                        //group.setAutoSizeChildren(true);

                        // scene = new Scene(group, Color.rgb(fxCanvas.getBackground().getRed(), fxCanvas.getBackground().getGreen(), fxCanvas.getBackground().getBlue()));

                        scene = new Scene(group, Color.rgb(0, 0, 0));

                        fxCanvas.setScene(scene);

                        //view.setPreserveRatio(true);

                }

                catch (Exception e) {

                        e.printStackTrace();

                        return false;

                }

                jfxPlayer.setOnReady(new Runnable() {

                        @Override

                        public void run() {

                                timeRange.setMinimum(0);

                                Duration d = jfxPlayer.getMedia().getDuration();

                                if (d.toSeconds() > 0) {

                                        timeRange.setMaximum((int) d.toSeconds());

                                }

                                timeRange.setLowerValue(start);

                                timeRange.setMiddleValue(start);

                                jfxPlayer.setVolume(volume);

                                jfxPlayer.setStartTime(Duration.seconds(start));

                                //jfxPlayer.seek(Duration.seconds(start));

                                if (end > start) {

                                        timeRange.setUpperValue(end);

                                        jfxPlayer.setStopTime(Duration.seconds(end));

                                }

                                else if (d.toSeconds() > 0) {

                                        timeRange.setUpperValue((int) jfxPlayer.getMedia().getDuration().toSeconds());

                                }

                                Log.info("Playing media: "+media.getSource());

                                jfxPlayer.play();

                                //resizeView();

                                // if (new File(mrl + ".srt").exists()) { //$NON-NLS-1$

                                // vlcPlayer.sub.subpictures().setSubTitleFile(mrl + ".srt"); //$NON-NLS-1$

                                // }

                                currentlyPlayed = JFXPlayer.this.mrl;

                                previouslyPlayed = JFXPlayer.this.mrl;

                                if (!playButton.isDisposed()) {

                                        playButton.setText(MessagesMP.pause);

                                        playButton.getParent().layout(true);

                                }

                                firstLengthEvent = true;

                        }

                });

                return true;

        }

        private void initializePlayerListeners() {

                jfxPlayer.currentTimeProperty().addListener(new InvalidationListener() {

                        @Override

                        public void invalidated(Observable ov) {

                                if (fxCanvas.isDisposed()) return;

                                if (jfxPlayer == null) return;

                                Duration currentTime = jfxPlayer.getCurrentTime();

                                time = (int) currentTime.toSeconds();

                                if (previous == time) {

                                        return;

                                }

                                previous = time;

                                timeLabel.getDisplay().syncExec(new Runnable() {

                                        @Override

                                        public void run() {

                                                if (timeRange.isDisposed()) {

                                                        return;

                                                }

                                                if (!timeRange.isDragMiddleKnob()) {

                                                        timeRange.setMiddleValue((int) time);

                                                }

                                                updateTimeLabel();

                                                // if (time >= end && end != start) {

                                                // if (repeat) {

                                                // vlcPlayer.seek(Duration.seconds(start));

                                                // }

                                                // else {

                                                // vlcPlayer.stop();

                                                // }

                                                // }

                                        }

                                });

                        }

                });

        }

        @Override

        public void setRepeat(boolean repeat) {

                this.repeat = repeat;

                if (this.repeat) {

                        jfxPlayer.setCycleCount(Integer.MAX_VALUE);

                }

                else {

                        jfxPlayer.setCycleCount(0);

                }

                if (!repeatButton.isDisposed()) {

                        repeatButton.setSelection(repeat);

                }

        }

        @Override

        public void stop() {

                if (jfxPlayer == null) return; // nothing to do

                userStopped = true;

                jfxPlayer.stop();

                jfxPlayer.dispose();

                jfxPlayer = null;

                if (!fxCanvas.isDisposed()) {

                        fxCanvas.setScene(null);

                }

                currentlyPlayed = NOMEDIA;

                if (!playButton.isDisposed()) {

                        playButton.setText(MessagesMP.play);

                        playButton.getParent().layout();

                }

        }

        @Override

        public boolean isMediaLoaded() {

                return jfxPlayer != null && jfxPlayer.getStatus().equals(Status.READY);

        }

        @Override

        public void seek(float time) {

                this.jfxPlayer.seek(Duration.seconds(time));

        }

        @Override

        public void setVolume(double volume) {

                this.jfxPlayer.setVolume(volume);

        }

        @Override

        public void setRate(float rate) {

                this.jfxPlayer.setRate(rate);

        }

        @Override

        public boolean isPlaying() {

                return jfxPlayer.getStatus().equals(Status.PLAYING);

        }

        @Override

        public void setStartTime(float seconds) {

                this.jfxPlayer.setStartTime(Duration.seconds(seconds));

        }

        @Override

        public void setStopTime(float seconds) {

                this.jfxPlayer.setStopTime(Duration.seconds(seconds));

        }

}