WarpPI/core/src/main/java/it/cavallium/warppi/WarpPI.java

package it.cavallium.warppi;

import java.io.IOException;

import it.cavallium.warppi.Platform.ConsoleUtils;
import it.cavallium.warppi.boot.StartupArguments;
import it.cavallium.warppi.device.Device;
import it.cavallium.warppi.device.display.BacklightOutputDevice;
import it.cavallium.warppi.device.display.DisplayOutputDevice;
import it.cavallium.warppi.device.input.InputManager;
import it.cavallium.warppi.device.input.Keyboard;
import it.cavallium.warppi.device.input.KeyboardInputDevice;
import it.cavallium.warppi.device.input.TouchInputDevice;
import it.cavallium.warppi.flow.BehaviorSubject;
import it.cavallium.warppi.flow.Observable;
import it.cavallium.warppi.gui.DisplayManager;
import it.cavallium.warppi.gui.HUD;
import it.cavallium.warppi.gui.HardwareDisplay;
import it.cavallium.warppi.gui.screens.Screen;
import it.cavallium.warppi.util.ClassUtils;

public class WarpPI {
	public static final WarpPI INSTANCE = new WarpPI();
	private static Platform platform;
	private static boolean running = false;
	private static BehaviorSubject<LoadingStatus> loadPhase = BehaviorSubject.create();
	private final BehaviorSubject<Boolean> loaded = BehaviorSubject.create(false);
	private Device device;

	private WarpPI() {}

	/**
	 * Start an instance of the calculator.
	 *
	 * @param platform
	 *            Platform implementation
	 * @param screen
	 *            Default screen to show at startup
	 * @param hud
	 *            Head-up display
	 * @param args
	 *            Startup arguments
	 * @throws InterruptedException
	 * @throws IOException
	 */
	public static void start(final Platform platform, final Screen screen, final HUD hud, final StartupArguments args)
			throws InterruptedException, IOException {
		if (WarpPI.running) {
			throw new RuntimeException("Already running!");
		} else {
			WarpPI.running = true;
			WarpPI.INSTANCE.startEngine(platform, screen, hud, args);
		}
	}

	private void startEngine(final Platform platform, final Screen screen,
			final HUD hud, final StartupArguments args)
			throws InterruptedException, IOException {
		WarpPI.platform = platform;
		platform.getConsoleUtils().out().println("WarpPI Calculator");
		initializeEnvironment(args);

		final Thread currentThread = Thread.currentThread();
		currentThread.setPriority(Thread.MAX_PRIORITY);
		WarpPI.getPlatform().setThreadName(currentThread, "Main thread");
		final DisplayOutputDevice display = platform.getDisplayOutputDevice();
		final BacklightOutputDevice backlight = platform.getBacklightOutputDevice();
		final DisplayManager dm = new DisplayManager(display, backlight, hud, screen, "WarpPI Calculator by Andrea Cavalli (@Cavallium)");
		final KeyboardInputDevice keyboard = platform.getKeyboardInputDevice();
		final TouchInputDevice touchscreen = platform.getTouchInputDevice();
		final InputManager im = new InputManager(keyboard, touchscreen);
		device = new Device(dm, im);

		device.setup(() -> WarpPI.loadPhase.onNext(new LoadingStatus()));
	}

	private void onShutdown() {
		WarpPI.platform.getConsoleUtils().out().println(1, "Shutdown...");
		beforeShutdown();
		WarpPI.platform.getConsoleUtils().out().println(1, "");
		WarpPI.platform.getConsoleUtils().out().println(1, "Closed.");
		WarpPI.getPlatform().exit(0);
	}

	private void initializeEnvironment(final StartupArguments args) throws IOException {
		ClassUtils.classLoader = this.getClass();
		StaticVars.startupArguments = args;
		StaticVars.debugWindow2x = args.isZoomed();
		if (args.isVerboseLoggingEnabled() || args.isDebugEnabled()) {
			StaticVars.outputLevel = ConsoleUtils.OUTPUTLEVEL_DEBUG_VERBOSE;
		}
		WarpPI.platform.getConsoleUtils().out().println(ConsoleUtils.OUTPUTLEVEL_DEBUG_MIN, args);
		checkDeviceType();
		if (args.isRaspberryModeAllowed() == false) {
			WarpPI.getPlatform().setRunningOnRaspberry(false);
		}
		if (WarpPI.getPlatform().isRunningOnRaspberry()) {
			WarpPI.getPlatform().getGpio().wiringPiSetupPhys();
			WarpPI.getPlatform().getGpio().pinMode(12, WarpPI.getPlatform().getGpio().valuePwmOutput());
		} else {
			if (WarpPI.getPlatform().isJavascript() == false) {
				WarpPI.getPlatform().getSettings().setDebugEnabled(true);
			}
		}
	}

	private void checkDeviceType() {
		// TODO Auto-generated method stub

	}

	public void beforeShutdown() {
		Keyboard.stopKeyboard();
	}

	public Observable<Boolean> isLoaded() {
		return loaded;
	}

	public Observable<LoadingStatus> getLoadPhase() {
		return WarpPI.loadPhase;
	}

	public Device getHardwareDevice() {
		return device;
	}

	public static Platform getPlatform() {
		return WarpPI.platform;
	}

	public static class LoadingStatus {
		protected LoadingStatus() {

		}

		public void done() {
			WarpPI.INSTANCE.loaded.onNext(true);
			WarpPI.INSTANCE.device.getDisplayManager().waitForExit();
			WarpPI.INSTANCE.onShutdown();
		}

		public void failed() {
			WarpPI.INSTANCE.onShutdown();
		}
	}
}