using Tinkerforge;

class SmokeDetector
{
	private static string HOST = "localhost";
	private static int PORT = 4223;

	private static IPConnection ipcon = null;
	private static BrickletIndustrialDigitalIn4 brickletIndustrialDigitalIn4 = null;

	static void InterruptCB(BrickletIndustrialDigitalIn4 sender, int interruptMask, int valueMask)
	{
		if(valueMask > 0) {
			System.Console.WriteLine("Fire! Fire!");
		}
	}

	static void EnumerateCB(IPConnection sender, string UID, string connectedUID, char position,
	                        short[] hardwareVersion, short[] firmwareVersion,
	                        int deviceIdentifier, short enumerationType)
	{
		if(enumerationType == IPConnection.ENUMERATION_TYPE_CONNECTED ||
		   enumerationType == IPConnection.ENUMERATION_TYPE_AVAILABLE)
		{
			if(deviceIdentifier == BrickletIndustrialDigitalIn4.DEVICE_IDENTIFIER)
			{
				try
				{
					brickletIndustrialDigitalIn4 = new BrickletIndustrialDigitalIn4(UID, ipcon);
					brickletIndustrialDigitalIn4.SetDebouncePeriod(10000);
					brickletIndustrialDigitalIn4.SetInterrupt(15);
					brickletIndustrialDigitalIn4.Interrupt += InterruptCB;
					System.Console.WriteLine("Industrial Digital In 4 initialized");
				}
				catch(TinkerforgeException e)
				{
					System.Console.WriteLine("Industrial Digital In 4 init failed: " + e.Message);
					brickletIndustrialDigitalIn4 = null;
				}
			}
		}
	}

	static void ConnectedCB(IPConnection sender, short connectedReason)
	{
		if(connectedReason == IPConnection.CONNECT_REASON_AUTO_RECONNECT)
		{
			System.Console.WriteLine("Auto Reconnect");

			while(true)
			{
				try
				{
					ipcon.Enumerate();
					break;
				}
				catch(NotConnectedException e)
				{
					System.Console.WriteLine("Enumeration Error: " + e.Message);
					System.Threading.Thread.Sleep(1000);
				}
			}
		}
	}

	static void Main()
	{
		ipcon = new IPConnection();
		while(true)
		{
			try
			{
				ipcon.Connect(HOST, PORT);
				break;
			}
			catch(System.Net.Sockets.SocketException e)
			{
				System.Console.WriteLine("Connection Error: " + e.Message);
				System.Threading.Thread.Sleep(1000);
			}
		}

		ipcon.EnumerateCallback += EnumerateCB;
		ipcon.Connected += ConnectedCB;

		while(true)
		{
			try
			{
				ipcon.Enumerate();
				break;
			}
			catch(NotConnectedException e)
			{
				System.Console.WriteLine("Enumeration Error: " + e.Message);
				System.Threading.Thread.Sleep(1000);
			}
		}

		System.Console.WriteLine("Press enter to exit");
		System.Console.ReadLine();
		ipcon.Disconnect();
	}
}