Yveaux
f03f4f9412
Added support fot multiple sessions (Currently 5 max. Each connection costs RAM!) Each session can send data to the gateway. Data from the gateway will be broadcasted to all connected clients. Added serial logging of client (dis)connections. Inspect serial terminal in case of problems.
137 lines
3.6 KiB
C
137 lines
3.6 KiB
C
#ifndef __GATEWAYUTIL_H__
|
|
#define __GATEWAYUTIL_H__
|
|
|
|
#ifdef ARDUINO
|
|
|
|
static uint8_t inclusionTime = 1; // Number of minutes inclusion mode is enabled
|
|
static uint8_t pinInclusion = 3; // Input pin that should trigger inclusion mode
|
|
|
|
#define MAX_RECEIVE_LENGTH 100 // Max buffersize needed for messages coming from controller
|
|
#define MAX_SEND_LENGTH 120 // Max buffersize needed for messages destined for controller
|
|
|
|
|
|
typedef struct
|
|
{
|
|
char string[MAX_RECEIVE_LENGTH];
|
|
uint8_t idx;
|
|
} inputBuffer;
|
|
|
|
static volatile boolean buttonTriggeredInclusion;
|
|
static boolean inclusionMode; // Keeps track on inclusion mode
|
|
bool inclusionButtonSupported = false;
|
|
void (*serial)(const char *fmt, ... );
|
|
|
|
MyParserSerial parser;
|
|
|
|
void setInclusionMode(boolean newMode);
|
|
|
|
char convBuf[MAX_PAYLOAD*2+1];
|
|
unsigned long inclusionStartTime;
|
|
|
|
|
|
void startInclusionInterrupt() {
|
|
buttonTriggeredInclusion = true;
|
|
}
|
|
|
|
void setupGateway(uint8_t _inc, uint8_t _incTime, void (* _serial)(const char *, ... )) {
|
|
inclusionMode = 0;
|
|
buttonTriggeredInclusion = false;
|
|
serial = _serial;
|
|
|
|
inclusionTime = _incTime;
|
|
inclusionButtonSupported = (_inc != 255);
|
|
if (inclusionButtonSupported)
|
|
{
|
|
pinInclusion = _inc;
|
|
|
|
// Setup digital in that triggers inclusion mode
|
|
pinMode(pinInclusion, INPUT_PULLUP);
|
|
|
|
// Add interrupt for inclusion button to pin
|
|
attachInterrupt(pinInclusion, startInclusionInterrupt, FALLING);
|
|
}
|
|
}
|
|
|
|
void incomingMessage(const MyMessage &message) {
|
|
// if (mGetCommand(message) == C_PRESENTATION && inclusionMode) {
|
|
// gw.rxBlink(3);
|
|
// } else {
|
|
// gw.rxBlink(1);
|
|
// }
|
|
// Pass along the message from sensors to serial line
|
|
serial(PSTR("%d;%d;%d;%d;%d;%s\n"),message.sender, message.sensor, mGetCommand(message), mGetAck(message), message.type, message.getString(convBuf));
|
|
}
|
|
|
|
|
|
|
|
void checkButtonTriggeredInclusion() {
|
|
if (inclusionButtonSupported)
|
|
{
|
|
if (buttonTriggeredInclusion) {
|
|
// Ok, someone pressed the inclusion button on the gateway
|
|
// start inclusion mode for 1 munute.
|
|
#ifdef DEBUG
|
|
serial(PSTR("0;0;%d;0;%d;Inclusion started by button.\n"), C_INTERNAL, I_LOG_MESSAGE);
|
|
#endif
|
|
buttonTriggeredInclusion = false;
|
|
setInclusionMode(true);
|
|
}
|
|
}
|
|
}
|
|
|
|
void checkInclusionFinished() {
|
|
if (inclusionMode && millis()-inclusionStartTime>60000UL*inclusionTime) {
|
|
// inclusionTimeInMinutes minute(s) has passed.. stop inclusion mode
|
|
setInclusionMode(false);
|
|
}
|
|
}
|
|
|
|
void parseAndSend(MySensor &gw, char *commandBuffer) {
|
|
boolean ok;
|
|
MyMessage &msg = gw.getLastMessage();
|
|
|
|
if (parser.parse(msg, commandBuffer)) {
|
|
uint8_t command = mGetCommand(msg);
|
|
|
|
if (msg.destination==GATEWAY_ADDRESS && command==C_INTERNAL) {
|
|
// Handle messages directed to gateway
|
|
if (msg.type == I_VERSION) {
|
|
// Request for version
|
|
serial(PSTR("0;0;%d;0;%d;%s\n"), C_INTERNAL, I_VERSION, LIBRARY_VERSION);
|
|
} else if (msg.type == I_INCLUSION_MODE) {
|
|
// Request to change inclusion mode
|
|
setInclusionMode(atoi(msg.data) == 1);
|
|
}
|
|
} else {
|
|
#ifdef WITH_LEDS_BLINKING
|
|
gw.txBlink(1);
|
|
#endif
|
|
ok = gw.sendRoute(msg);
|
|
if (!ok) {
|
|
#ifdef WITH_LEDS_BLINKING
|
|
gw.errBlink(1);
|
|
#endif
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
void setInclusionMode(boolean newMode) {
|
|
if (newMode != inclusionMode) {
|
|
inclusionMode = newMode;
|
|
// Send back mode change on serial line to ack command
|
|
serial(PSTR("0;0;%d;0;%d;%d\n"), C_INTERNAL, I_INCLUSION_MODE, inclusionMode?1:0);
|
|
|
|
if (inclusionMode) {
|
|
inclusionStartTime = millis();
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
#else
|
|
#error This example is only for use on Arduino.
|
|
#endif // ARDUINO
|
|
|
|
#endif
|