/*******************************************************************************
 * Copyright (c) 2014, 2016 Orange.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License 2.0
 * which accompanies this distribution, and is available at
 * https://www.eclipse.org/legal/epl-2.0/
 *******************************************************************************/
package org.eclipse.om2m.sdt.home.enocean;

import java.util.List;

import org.eclipse.om2m.sdt.Domain;
import org.eclipse.om2m.sdt.Event;
import org.eclipse.om2m.sdt.datapoints.BooleanDataPoint;
import org.eclipse.om2m.sdt.exceptions.DataPointException;
import org.eclipse.om2m.sdt.home.devices.Switch;
import org.eclipse.om2m.sdt.home.driver.Utils;
import org.eclipse.om2m.sdt.home.enocean.Activator.EnOceanSDTDevice;
import org.eclipse.om2m.sdt.home.modules.FaultDetection;
import org.eclipse.om2m.sdt.home.modules.PushButton;
import org.eclipse.om2m.sdt.home.modules.SmokeSensor;
import org.eclipse.om2m.sdt.home.types.DatapointType;
import org.osgi.framework.BundleContext;
import org.osgi.framework.ServiceRegistration;
import org.osgi.service.enocean.EnOceanDevice;
import org.osgi.service.enocean.EnOceanMessage;

@SuppressWarnings("rawtypes")
public class EOLightBlindControl extends Switch implements EnOceanSDTDevice {
	
	private final EnOceanDevice eoDevice;
	private Domain domain;
	private List<ServiceRegistration> registrations;
	private BundleContext context;
	
	static private final String[] NU1_MODES = new String[] {
		"Button A1: 'Switch light pushed' or 'Dim light down' or 'Move blind closed'",
		"Button A0: 'Switch light off' or 'Dim light up' or 'Move blind open'",
		"Button B1: 'Switch light pushed' or 'Dim light down' or 'Move blind closed'",
		"Button B0: 'Switch light off' or 'Dim light up' or 'Move blind open'",
	};
	static private final String[] NU0_MODES = new String[] {
		"no button",
		"invalid",
		"invalid",
		"3 or 4 buttons",
	};

	private FaultDetection faultDetection;
	private PushButton button;
	private SmokeSensor smokeSensor;
	
	private boolean val;
	private BooleanDataPoint pushed;
	private BooleanDataPoint status;

	public EOLightBlindControl(EnOceanDevice device, Domain domain,
			BundleContext context) {
		super(Integer.toHexString(device.getChipId()), "0x" + Integer.toHexString(device.getChipId()), domain);
		
		this.eoDevice = device;
		this.domain = domain;
		this.context = context;

		try {
			addPushButton();
		} catch (Exception e) {
			Activator.logger.warning("Error addBinarySwitch", e);
		}
//		try {
//			addFaultDetection();
//		} catch (Exception e) {
//			Activator.logger.warning("Error addFaultDetection", e);
//		}
	}

	@Override
	public void handleEvent(EnOceanMessage msg) {
		byte[] payload = msg.getPayloadBytes();
		if (payload == null) {
			Activator.logger.info("invalid null payload", getClass());
			return;
		}
		String s = "";
		for (int i = 0; i < payload.length; i++) s += payload[i] + ":";
		Activator.logger.info("payload: " + s, getClass());
		byte data = payload[0];
		byte status = (byte) msg.getStatus();
		Activator.logger.info("status: " + status, getClass());
		if (status == 48) { // T21 = 1, NU = 1
			try {
				Activator.logger.info("Rocker 1st action: " + NU1_MODES[(data & 0xe0) >> 5]);
				Activator.logger.info("Rocker 2nd action: " + NU1_MODES[(data & 0x1d) >> 4]);
			} catch (Exception ignored) {
			}
			Activator.logger.info(((data & 0x01) == 0) ? "No 2nd action" : "2nd action valid");
			val = ((data & 0x10) == 0x10); // pressed / released
			Activator.logger.info("" + data + " -> " + (val ? "pressed" : "released"));
		} else if (status == 32) { // T21 = 1, NU = 0
			try {
				Activator.logger.info("Number of buttons pressed simultaneously: " 
						+ NU0_MODES[(data & 0xe0) >> 5]);
			} catch (Exception ignored) {
			}
			val = ((data & 0x10) == 0x10); // pressed / released
			Activator.logger.info("" + data + " -> " + (val ? "pressed" : "released"));
		} else {
			Activator.logger.warning("Unknown status");
		}
		Event evt = new Event("Action");
		evt.setValue(val);
		evt.addDataPoint(pushed);
		button.addEvent(evt);
		evt = new Event("Alarm");
		evt.setValue(val);
		evt.addDataPoint(this.status);
		smokeSensor.addEvent(evt);
	}
	
	private void addPushButton() {
		pushed = new BooleanDataPoint(DatapointType.pushed) {
			@Override
			public void doSetValue(Boolean v) throws DataPointException {
				val = v;
			}
			@Override
			public Boolean doGetValue() throws DataPointException {
				return val;
			}
		};
		button = new PushButton("PushButton_" + eoDevice.getChipId(), domain, pushed);
		addModule(button);
	}

//	private void addFaultDetection() {
//		faultDetection = new FaultDetection("FaultDetection_" + eoDevice.getChipId(), domain, 
//				new BooleanDataPoint(DatapointType.status) {
//			@Override
//			public Boolean doGetValue() throws DataPointException {
//				return false;
//			}
//		});
//		addModule(faultDetection);
//	}
	
	private void addSmokeSensor() {
		status = new BooleanDataPoint(DatapointType.alarm) {
			@Override
			public Boolean doGetValue() throws DataPointException {
				Activator.logger.info("alarm: " + val);
				return val;
			}
		};
		smokeSensor = new SmokeSensor("SmokeSensor_" + eoDevice.getChipId(), domain, status);
		addModule(smokeSensor);
	}

	@Override
	public void register() {
		registrations = Utils.register(this, context);
	}

	@Override
	public void unregister() {
		for (ServiceRegistration reg : registrations) {
			reg.unregister();
		}
	}

	@Override
	public Integer getChipId() {
		return eoDevice.getChipId();
	}

}