/*
 * GpInPort.cpp
 *
 *  Created on: 11 Feb 2020
 *      Author: David
 */

#include "GpInPort.h"
#include <GCodes/GCodeBuffer/GCodeBuffer.h>
#include <Platform/RepRap.h>
#include <Platform/Platform.h>

#if SUPPORT_CAN_EXPANSION
# include <CAN/CanInterface.h>
# include <CAN/CanMessageGenericConstructor.h>
#endif

#if SUPPORT_OBJECT_MODEL

// Object model table and functions
// Note: if using GCC version 7.3.1 20180622 and lambda functions are used in this table, you must compile this file with option -std=gnu++17.
// Otherwise the table will be allocated in RAM instead of flash, which wastes too much RAM.

// Macro to build a standard lambda function that includes the necessary type conversions
#define OBJECT_MODEL_FUNC(...) OBJECT_MODEL_FUNC_BODY(GpInputPort, __VA_ARGS__)
#define OBJECT_MODEL_FUNC_IF(_condition,...) OBJECT_MODEL_FUNC_IF_BODY(GpInputPort, _condition,__VA_ARGS__)

constexpr ObjectModelTableEntry GpInputPort::objectModelTable[] =
{
	// Within each group, these entries must be in alphabetical order
	// Return 'value' as an integer, not a boolean, because we may allow analog inputs in future
	{ "value",	OBJECT_MODEL_FUNC((int32_t)((self->GetState()) ? 1 : 0)),	ObjectModelEntryFlags::live },
};

constexpr uint8_t GpInputPort::objectModelTableDescriptor[] = { 1, 1 };

DEFINE_GET_OBJECT_MODEL_TABLE(GpInputPort)

#endif

bool GpInputPort::GetState() const noexcept
{
	// Temporary implementation until we use interrupts to track input pin state changes
#if SUPPORT_CAN_EXPANSION
	if (boardAddress != CanInterface::GetCanAddress())
	{
		return currentState;
	}
#endif
	return port.ReadDigital();
}

// Return true if the port is not configured
bool GpInputPort::IsUnused() const noexcept
{
	return
#if SUPPORT_CAN_EXPANSION
		boardAddress == CanInterface::GetCanAddress() &&
#endif
		!port.IsValid();
}

GCodeResult GpInputPort::Configure(uint32_t gpinNumber, GCodeBuffer &gb, const StringRef &reply)
{
	if (gb.Seen('C'))
	{
		String<StringLength50> pinName;
		gb.GetReducedString(pinName.GetRef());

		// Remove any existing assignment
#if SUPPORT_CAN_EXPANSION
		if (boardAddress != CanInterface::GetCanAddress())
		{
			const GCodeResult rslt = CanInterface::DeleteHandle(boardAddress, handle, reply);
			if (rslt != GCodeResult::ok)
			{
				reply.cat('\n');
				const MessageType mtype = (rslt == GCodeResult::warning) ? AddWarning(gb.GetResponseMessageType()) : AddError(gb.GetResponseMessageType());
				reprap.GetPlatform().Message(mtype, reply.c_str());
				reply.Clear();
			}
			boardAddress = CanInterface::GetCanAddress();
		}
#endif
		port.Release();
		currentState = false;

		GCodeResult rslt;

#if SUPPORT_CAN_EXPANSION
		const CanAddress newBoard = IoPort::RemoveBoardAddress(pinName.GetRef());
		if (newBoard != CanInterface::GetCanAddress())
		{
			handle.Set(RemoteInputHandle::typeGpIn, gpinNumber, 0);
			rslt = CanInterface::CreateHandle(newBoard, handle, pinName.c_str(), 0, MinimumGpinReportInterval, currentState, reply);
			if (rslt == GCodeResult::ok)
			{
				boardAddress = newBoard;
			}
			else
			{
				currentState = false;
			}
		}
		else
#endif
		{
			if (port.AssignPort(pinName.c_str(), reply, PinUsedBy::gpin, PinAccess::read))
			{
				currentState = port.ReadDigital();
				rslt = GCodeResult::ok;
			}
			else
			{
				rslt = GCodeResult::error;
			}
		}

		reprap.InputsUpdated();
		return rslt;
	}
	else
	{
		// Report the pin details
#if SUPPORT_CAN_EXPANSION
		if (boardAddress != CanInterface::GetCanAddress())
		{
			const GCodeResult rslt = CanInterface::GetHandlePinName(boardAddress, handle, currentState, reply);
			if (rslt != GCodeResult::ok)
			{
				return rslt;
			}
			reply.Prepend("Pin ");
		}
		else
#endif
		{
			reply.copy("Pin ");
			port.AppendPinName(reply);
		}
		reply.catf(", active: %s", (GetState()) ? "true" : "false");
	}
	return GCodeResult::ok;
}

// End