Receive.cpp

//- -----------------------------------------------------------------------------------------------------------------------
// AskSin driver implementation
// 2013-08-03 <trilu@gmx.de> Creative Commons - http://creativecommons.org/licenses/by-nc-sa/3.0/de/
//- -----------------------------------------------------------------------------------------------------------------------
//- AskSin receive function -----------------------------------------------------------------------------------------------
//- with a lot of support from martin876 at FHEM forum
//- -----------------------------------------------------------------------------------------------------------------------

#define RV_DBG
//#define RV_DBG_EX
#include "Receive.h"
#include "AS.h"


// private:		//---------------------------------------------------------------------------------------------------------
RV::RV() {
}
void    RV::init(AS *ptrMain) {
	
	#ifdef RV_DBG																			// only if ee debug is set
		dbgStart();																			// serial setup
		dbg << F("RV.\n");																	// ...and some information
	#endif

	pHM = ptrMain;
	buf = (uint8_t*)&mBdy;
}
void	RV::poll(void) {
	static uint8_t last_rCnt;

	if (this->bufLen > 10) {																// create search string for peer
		memcpy(this->peerId, this->mBdy.reID, 3);
		this->peerId[3] = (this->buf[10] & 0x3f);											// mask out long and battery low
	}
	
	uint8_t bIntend = pHM->ee.getIntend(this->mBdy.reID,this->mBdy.toID, this->peerId);		// get the intend of the message

	// some debugs
	#ifdef RV_DBG																			// only if AS debug is set
		dbg << (char)bIntend << F("> ") << _HEX(this->buf, this->bufLen) << ' ' << _TIME << '\n';
	#endif
	
	#ifdef RV_DBG_EX																		// only if extended AS debug is set
		pHM->explainMessage(this->buf);
	#endif
	
	// filter out unknown or not for us
	if ((bIntend == 'l') || (bIntend == 'u')) {												// not for us, or sender unknown
		this->mBdy.mLen = 0;																// clear receive buffer
		return;
	}

	// filter out repeated messages
	if ((this->mBdy.mFlg.RPTED) && (last_rCnt == this->mBdy.mLen)) {						// check if message was already received
		#ifdef RV_DBG																		// only if AS debug is set
			dbg << F("  repeated message\n");
		#endif

		this->mBdy.mLen = 0;																// clear receive buffer
		return;																				// wait for next message
	}
	last_rCnt = this->mBdy.mLen;

	pHM->recvMessage();

	this->mBdy.mLen = 0;
}