rfm69-gw.cc

/************************************************************************** 
|PC| <-serial-> |Moteino_Gw| <-RFM69W-> |Target_Moteino|

NOTE: Endian Conversion Required to properly read encoded data
https://docs.python.org/2/library/struct.html
Linux = Little Endian (Python conversion table)
Moteino =  Big endian
Data Type Cross Reference Table
--------------------------------
Type	Linux(python)	Moteino
byte 	char(1)			byte(1)
int 	short(2)		int(2)
long 	long(4) 		long(4)
float 	float(4)		float(4)

***************************************************************************/


#include <RFM69.h>
#include <SPI.h>
#include <NodeGwMsg.h> // Load Gateway Message structure:Task
#include <NodeConf.h>
// Initialize Redio
RFM69 radio;
byte buff[MAX_SERIAL_SIZE];
// BEGIN Function Prototypes
void Blink(byte PIN, int DELAY_MS);

// END Function Prototypes
void setup() {
  Serial.begin(SERIAL_BAUD);
  delay(10);
  radio.initialize(FREQUENCY,NODEID,NETWORKID);
  radio.encrypt(KEY);
}

void loop() {
	
	// READ Serial input if avaiable...
	if (Serial.available() > 0) {
		//Wait for serial buffer to fill
		delay(100);
		// Read serial data into buffer
		// METHOD 1 Blind read, no limit (Risky?)
		int count=0;

		// read until the serial buffer is empty
		while (Serial.available() > 0) {
			buff[count] = (byte)Serial.read();
			count++;
		}
		/*
		Serial.print("Count = ");
		Serial.println(count);
		*/
	 	// End read data from serial 
		// read Serial Message
		sMsg = *(SerialMsg*)buff;

		if (sMsg.SerialDelimiter == 0) {
			/*
			// Valid Message
			Serial.print("NodeID = ");
			Serial.println(sMsg.NodeID);
			Serial.print("Message Size = ");
			Serial.println(sMsg.SerialPayloadSize);
			// Load Message
			// Get Payload from Serial Payload
			payload = *(Payload*)sMsg.SerialPayload;
			Serial.print("Message ID = ");
			Serial.println(payload.MsgID);

			Serial.print("Message Type = ");
			Serial.println(payload.MsgType);

			Serial.print("LED Number = ");
			Serial.println(sMsg.SerialPayload[2]);

			Serial.print("LED State = ");
			Serial.println(sMsg.SerialPayload[3]);

				Turn on Light # 7
				\x00\x2a\x04\x05\x0a\x07\x01
				\x00\x2b\x04\x05\x0a\x06\x01
				Turn off Light # 7
				\x00\x2a\x04\x05\x0a\x07\x00
			*/
			//memcpy(o_payload.msg, &sMsg.SerialPayload, sizeof(sMsg.SerialPayloadSize));
			radio.sendWithRetry(sMsg.NodeID, (const void*)(&sMsg.SerialPayload), sMsg.SerialPayloadSize);
			// good Serial Message Blink Yellow Light
			Blink(PASS_LED, 10);
		} else {
			Blink(FAIL_LED, 10);
			/*		
			// !!!!!! Invalid message
			Serial.println("DEBUG Invalid Message Discard!");
			// Print debug info about message
			Serial.print("[DEBUG]Serial Delimiter = ");
			Serial.println(sMsg.SerialDelimiter);

			Serial.print("[DEBUG]NodeID = ");
			Serial.println(sMsg.NodeID);

			Serial.print("[DEBUG]Message Size = ");
			Serial.println(sMsg.SerialPayloadSize);
			*/
		}	
	}
	// Get incomming messages
	if ( radio.receiveDone() ) {


		payload.msg = *(Payload*)radio.DATA;
		nMsg.SerialDelimiter = 0x00;
		nMsg.NodeID = radio.SENDERID;
		nMsg.SerialPayloadSize = radio.DATALEN;

		memcpy(nMsg.SerialPayload, &radio.DATA, nMsg.SerialPayloadSize);

		Blink(LED,5);
		Blink(PASS_LED, 10);
	}	
}

void Blink(byte PIN, int DELAY_MS)
{
  pinMode(PIN, OUTPUT);
  digitalWrite(PIN,HIGH);
  delay(DELAY_MS);
  digitalWrite(PIN,LOW);
}