How to turn on V_LIGHT with MQQT manually?

[tekkninja]

Trying to figure out how to turn on a light by publishing a MQTT command manually (via MQTTLens).

Device ID is 101 on node 0. Serial monitor on the Arduino shows: 0;255;3;0;9;Sending message on topic: P/0/101/1/0/2

I'm also curious about the Receive function at the end

if (message.type==V_LIGHT)

Where does it get the message type from? where would it find V_LIGHT?

Full sketch:

// This MQTT gateway works on Arduino Mega2560 only!

// Enable debug prints to serial monitor
#define MY_DEBUG 

// Enables and select radio type (if attached)
//#define MY_RADIO_NRF24
//#define MY_RADIO_RFM69

#define MY_GATEWAY_MQTT_CLIENT

// Set this nodes subscripe and publish topic prefix
#define MY_MQTT_PUBLISH_TOPIC_PREFIX "P"
#define MY_MQTT_SUBSCRIBE_TOPIC_PREFIX "S"

// Set MQTT client id
#define MY_MQTT_CLIENT_ID "M1"

#define MY_GATEWAY_W5100
#define MY_MAC_ADDRESS 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0xED

// W5100 Ethernet module SPI enable (optional if using a shield/module that manages SPI_EN signal)
//#define MY_W5100_SPI_EN 4  

// Enable Soft SPI for NRF radio (note different radio wiring is required)
// The W5100 ethernet module seems to have a hard time co-operate with 
// radio on the same spi bus.
// The PINs mentioned here are for Arduino Mega2560 ! Color code is from MySensor site
#if !defined(MY_W5100_SPI_EN)
  #define MY_SOFTSPI
  #define MY_SOFT_SPI_SCK_PIN 14 // Green
  #define MY_SOFT_SPI_MISO_PIN 16  // Violet
  #define MY_SOFT_SPI_MOSI_PIN 15  // Blue
#endif  

// When W5100 is connected we have to move CE/CSN pins for NRF radio
#define MY_RF24_CE_PIN 17  // Orange
#define MY_RF24_CS_PIN 18  // Yellow

// Enable these if your MQTT broker requires usenrame/password
//#define MY_MQTT_USER "username"
//#define MY_MQTT_PASSWORD "password"

// Enable MY_IP_ADDRESS here if you want a static ip address (no DHCP)
//#define MY_IP_ADDRESS 192,168,178,87

// If using static ip you need to define Gateway and Subnet address as well
//#define MY_IP_GATEWAY_ADDRESS 192,168,178,1
//#define MY_IP_SUBNET_ADDRESS 255,255,255,0


// MQTT broker ip address.  
#define MY_CONTROLLER_IP_ADDRESS 192,168,1,16

// The MQTT broker port to to open 
#define MY_PORT 1883      

/*
// Flash leds on rx/tx/err
#define MY_LEDS_BLINKING_FEATURE
// Set blinking period
#define MY_DEFAULT_LED_BLINK_PERIOD 300
// Enable inclusion mode
#define MY_INCLUSION_MODE_FEATURE
// Enable Inclusion mode button on gateway
#define MY_INCLUSION_BUTTON_FEATURE
// Set inclusion mode duration (in seconds)
#define MY_INCLUSION_MODE_DURATION 60 
// Digital pin used for inclusion mode button
#define MY_INCLUSION_MODE_BUTTON_PIN  3 
#define MY_DEFAULT_ERR_LED_PIN 16  // Error led pin
#define MY_DEFAULT_RX_LED_PIN  16  // Receive led pin
#define MY_DEFAULT_TX_LED_PIN  16  // the PCB, on board LED
*/

#include <Ethernet.h>
#include <SPI.h>
#include <MySensor.h>
#include <DallasTemperature.h>
#include <OneWire.h>
#include <DHT.h> 

#define CHILD_ID_Analog1 1
#define CHILD_ID_PIR 2
#define CHILD_ID_GAS 3
#define CHILD_ID_T1 4
#define CHILD_ID_REL1 101
#define CHILD_ID_REL2 102
#define CHILD_ID_HUM 7
#define CHILD_ID_TEMP 8

/*
Ethernet use the following PINs, do not use them:
Mega: 4, 10, 50, 51, 52, 53
*/
#define Analog_PIN A5
#define PIR_PIN 2
#define MQ_PIN A4
#define ONE_WIRE_BUS 3
#define REL1_PIN 7
#define REL2_PIN 8
#define HUMIDITY_SENSOR_DIGITAL_PIN 33

#define TEMPERATURE_PRECISION 12
OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature sensors(&oneWire);

MyMessage msgAnalog1(CHILD_ID_Analog1, V_VAR1); //24 .. 28
MyMessage msgPir(CHILD_ID_PIR, V_TRIPPED); // 16
MyMessage msgGas(CHILD_ID_GAS, V_VAR1); //24
MyMessage msgT1(CHILD_ID_T1, V_TEMP); // 0
MyMessage msgREL1(CHILD_ID_REL1, V_LIGHT);  // 2
MyMessage msgREL2(CHILD_ID_REL2, V_LIGHT);  // 2
MyMessage msgHum(CHILD_ID_HUM, V_HUM); // 1
MyMessage msgTemp(CHILD_ID_TEMP, V_TEMP); // 0

DHT dht;
// address must be updated
DeviceAddress addrTemp1 = { 0x28, 0xFF, 0x57, 0x98, 0x80, 0x15, 0x42, 0x17 };

const unsigned long tUpdate=60000; //update interval
unsigned long t0;
int InA1;
byte StatePIR=0;
byte oldStatePIR=0;
int InAnalog1;
int valMQ=0;
int refMQ=1023; // refference value will be the lowest value read from the sensor
float Temp1;
float Temp, Hum;
byte StateREL=0, StateREL1=0, StateREL2=0;

void setup() { 
  pinMode(PIR_PIN, INPUT_PULLUP);
  sensors.begin();
  sensors.setResolution(addrTemp1, TEMPERATURE_PRECISION);
  pinMode(REL1_PIN, OUTPUT);
  digitalWrite(REL1_PIN, StateREL1);
  pinMode(REL2_PIN, OUTPUT);
  digitalWrite(REL2_PIN, StateREL2);
  dht.setup(HUMIDITY_SENSOR_DIGITAL_PIN); 
  t0=millis();
}

void presentation() {
  present(CHILD_ID_Analog1, S_CUSTOM);
  present(CHILD_ID_PIR, S_MOTION);
  present(CHILD_ID_GAS, S_CUSTOM);
  present(CHILD_ID_T1, S_TEMP);
  present(CHILD_ID_REL1, S_LIGHT);
  present(CHILD_ID_REL2, S_LIGHT);
  present(CHILD_ID_HUM, S_HUM);
  present(CHILD_ID_TEMP, S_TEMP);  
}

void loop() {
  StatePIR=digitalRead(PIR_PIN);
  if (StatePIR != oldStatePIR) {
    oldStatePIR=StatePIR;
    ServerUpdate();
  }
  if ((millis()-t0) > tUpdate) ServerUpdate();
}

void ServerUpdate() {
  InA1=analogRead(Analog_PIN);
  send(msgAnalog1.set(InA1));
  
  send(msgPir.set(StatePIR ? "ON" : "OFF"));
  
  InAnalog1=analogRead(MQ_PIN);
  if (InAnalog1<refMQ) refMQ=InAnalog1; // if read value is lower that actual, change the 0 refference with the actual one
  valMQ=InAnalog1-refMQ;
  send(msgGas.set(valMQ));
  
  sensors.requestTemperatures();
  Temp1 = sensors.getTempC(addrTemp1);
  send(msgT1.set(Temp1,1));

  Hum = dht.getHumidity();
  Temp = dht.getTemperature();
  send(msgTemp.set(Temp, 1));
  send(msgHum.set(Hum, 1));
  send(msgREL1.set(StateREL1 ? "ON":"OFF"));
  t0=millis();
}

void receive(const MyMessage &message) {
  // We only expect one type of message from controller. But we better check anyway.
  if (message.type==V_LIGHT) {
    StateREL=strcmp(message.data,"ON")==0;
    switch(message.sensor) {
      case 101: {
        StateREL1=StateREL;
        if (StateREL) {
          digitalWrite(REL1_PIN, HIGH);
        }
        else {
          digitalWrite(REL1_PIN, LOW);
        }
        send(msgREL1.set(StateREL1 ? "ON":"OFF"));
      }
      break;
      case 102: {
        StateREL2=StateREL;
        if (StateREL) {
          digitalWrite(REL2_PIN, HIGH);
        }
        else {
          digitalWrite(REL2_PIN, LOW);
        }
        send(msgREL2.set(StateREL2 ? "ON":"OFF"));
      }
      break;
    }

   } 
}

[tekkninja]

Never mind figured it out.
There was a problem somewhere in that sketch. basically started from scratch again. merged the W5100 MQTT client gateway sketch and the relay sketch. then referred to here for serial MQTT syntax.

Hope anyone else thats struggling finds this info useful.