Added a device listener

[kaka/cakelight.git] / src / kaka / cakelight / VideoMode.java

package kaka.cakelight;

import java.io.File;
import java.io.IOException;
import java.util.Optional;
import java.util.function.Consumer;

public class VideoMode implements Mode, Consumer<Optional<File>> {
    private Configuration config;
    private Thread thread;
    private Consumer<Frame> frameConsumer;
    private VideoDeviceListener deviceListener;

    public VideoMode() {
        deviceListener = new VideoDeviceListener();
        deviceListener.onVideoDeviceChange(this);
    }

    @Override
    public void enter(Configuration config) {
        this.config = config;
        deviceListener.startListening();
    }

    @Override
    public void exit() {
        thread.interrupt();
        deviceListener.stopListening();
    }

    private void startGrabberThread(File videoDevice) {
        assert frameConsumer != null;
        thread = new Thread() {
            public void run() {
                try (FrameGrabber grabber = FrameGrabber.from(videoDevice, config)) {
                    while (!isInterrupted()) {
//                        Optional<Frame> frame = grabber.grabFrame();
                        grabber.grabFrame().ifPresent(frameConsumer);
//                        timeIt("frame", grabber::grabFrame);
                        // TODO: process frame
                        // TODO: save where the LedController can access it
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        };
        thread.start();
    }

    public void onFrame(Consumer<Frame> consumer) {
        frameConsumer = consumer;
    }

    @Override
    public void accept(Optional<File> videoDevice) {
        // Should only happen when this mode is active!
        if (thread != null) {
            thread.interrupt();
        }
        videoDevice.ifPresent(this::startGrabberThread);
    }
}