#include <AirNgin.h>

#define KEY_OF_CENTER "AIRN"  // IT'S PRODUCER CENTER CODE

#define Pushbotton 23  // PIN FOR GO TO Config Panel and AP MODE
#define RELAY1 16      // RELAY ONE
#define RELAY2 17      // RELAY TWO

#define Pushbutton_RELAY1 32  // push botton RELAY ONE
#define Pushbutton_RELAY2 33  // push botton RELAY TWO

#define CALL_Global_Mqtt_CALLBACK true  // if is true just call this airnginClient.setOnMessageCallback(myMqttCallback); \
                                        // else is false desn't call airnginClient.setOnMessageCallback(myMqttCallback); and call other callback

AirNginClient airnginClient;

String _SerialNo = "";

unsigned long _TimerSecCurrent, _TimerSecOld = 0;
byte _TimerSecDef = 0;
byte _TimerKeyPush = 0;


void MqttSend(String topic, String data) {

  airnginClient.Mqtt_Send(topic, data);
}



void setup() {

  Serial.begin(9600);
  Tools__SerialBarcodeReload();
  airnginClient.begin("", "", _SerialNo);
  airnginClient.setOnMessageCallback(myMqttCallback);
  airnginClient.setOnSaveScenarioCallback(saveScenarioCallback);
  airnginClient.setOnDebuggerCallback(debuggerCallback);
  airnginClient.setOnMessage_From_Topic_DeviceToDevice_Callback(message_From_Topic_DeviceToDevice_Callback);
  airnginClient.setOnMessage_From_Topic_ServerToDevice_Callback(message_From_Topic_ServerToDevice_Callback);

  pinMode(Pushbotton, INPUT_PULLUP);
  pinMode(Pushbutton_RELAY1, INPUT_PULLUP);
  pinMode(Pushbutton_RELAY2, INPUT_PULLUP);

  pinMode(RELAY1, OUTPUT);
  pinMode(RELAY2, OUTPUT);
}


void loop() {
  delay(1000);
  airnginClient.client_Loop();
  TimerSec_Refresh();  //read Time
  if (digitalRead(Pushbutton_RELAY1) == LOW) {
    _TimerKeyPush += _TimerSecDef;
  } else
    _TimerKeyPush = 0;
  if (_TimerKeyPush >= 5) {  //
    _TimerKeyPush = 0;
    if (airnginClient.isConfigMode) {
      airnginClient.Tools__SetMode(airnginClient._StartMode == "config_panel" ? "normal" : "config_panel", false);
      airnginClient.isConfigMode = false;
      airnginClient._Mqtt_TryConnecting = false;

    } else {
      airnginClient.Tools__SetMode(airnginClient._StartMode == "config_panel" ? "normal" : "config_panel", false);
      airnginClient.isConfigMode = true;
      airnginClient._Mqtt_TryConnecting = true;
      airnginClient.Config__Setup();
    }
  }


  if (digitalRead(Pushbutton_RELAY1) == LOW) {
    if (digitalRead(RELAY1) == LOW) {
      digitalWrite(RELAY1, HIGH);
      MqttSend("DeviceToServer", "ch1on");
      Serial.println("relay 1 : on");
    } else {
      digitalWrite(RELAY1, LOW);
      MqttSend("DeviceToServer", "ch1off");
      Serial.println("relay 1 : off");
    }
  }

  if (digitalRead(Pushbutton_RELAY2) == LOW) {
    if (digitalRead(RELAY2) == LOW) {
      digitalWrite(RELAY2, HIGH);
      MqttSend("DeviceToServer", "ch2on");
      Serial.println("relay 2 : on");
    } else {
      digitalWrite(RELAY2, LOW);
      MqttSend("DeviceToServer", "ch2off");
      Serial.println("relay 2 : off");
    }
  }
}


void Tools__SerialBarcodeReload() {

  String chip = (String(airnginClient.Tools__GetChipID()) + "0000000").substring(0, 7);
  if (chip == "0000000")
    chip = (String(airnginClient.Tools__Random(1000000, 9999998)) + "0000000").substring(0, 7);
  _SerialNo = KEY_OF_CENTER + ("000" + chip).substring(0, 10);


  Serial.println("_SerialNo : " + _SerialNo);
}


void TimerSec_Refresh() {
  //-------------------------------------------- TIMER
  try {
    _TimerSecCurrent = millis();
    _TimerSecDef = ((_TimerSecCurrent - _TimerSecOld) / 1000) & 0xFF;
    if (_TimerSecDef < 0)
      _TimerSecDef = 1;
    if (_TimerSecDef >= 1)
      _TimerSecOld = _TimerSecCurrent;
  } catch (...) {
  }
}


void myMqttCallback(char *topic, uint8_t *payload, unsigned int length) {

  Serial.print("Received data from topic: ");
  Serial.println(topic);

  Serial.print("Data: ");
  for (unsigned int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);  // تبدیل هر بایت به کاراکتر
  }
  Serial.println();

  String projectTopic = String(topic);
  int p = projectTopic.indexOf('/');
  if (projectTopic.substring(0, p) != airnginClient._ProjectCode)  // فرض بر این است که متدی برای گرفتن ProjectCode وجود دارد
    return;
  projectTopic = projectTopic.substring(p + 1);


  JsonDocument doc;
  doc.clear();

  DeserializationError error = deserializeJson(doc, payload, length);
  if (error) {
    Serial.println("JSON parse failed!");
    return;
  }

  if (projectTopic == "DeviceSetting") {
    String opr = doc["operationName"].as<String>();
    if (opr == "save_scenario" || opr == "delete_scenario") {
      // کد مربوط به ذخیره یا حذف سناریو
    } else if (opr == "save_setting") {
      if (doc["deviceSerial"].as<String>() == airnginClient._SerialCloud) {
        String cmd, d = doc["value"].as<String>();
        if (d != "") {
          deserializeJson(doc, d);
          if (doc["request"]["commandName"] && doc["request"]["commandData"]) {
            cmd = doc["request"]["commandName"].as<String>();
            if (cmd == "saveScenarioOperation") {
              JsonVariant inp = doc["scenarioOperation"].as<JsonVariant>();
              // پردازش سناریو
            }
            // سایر دستورات...
          }
        }
      }
    }
  } else if (projectTopic == "ServerToDevice") { // اگر داده ارسالی از سمت سرور باشد
    
    // خروجی ما بصورت زیر است 
    //{"data":"{\"type\":\"command\",\"value\":\"ch2on\"}","deviceSerial":"AIRN0001208520"}
    // دقت نمایید همیشه خروجی شما از طریق js generate 
    // درون یک json بصورت بالا 
    // در کلید data
    // قرار می گیرد

    // اسختراج سریال ابزاری که سرور برای آن داده را ارسال کرده ، جهت اینکه بدانید برای کدام ابزار است و با سریال خودتان در ادامه قیاس نمایید.
    String deviceSerial = doc["deviceSerial"].as<String>();

    if ((doc["data"])) {

        if (deviceSerial == airnginClient._SerialCloud) { // مطمین شویم که این داده برای ما ارسال شده است.

      String cmd = doc["data"].as<String>(); // اگر دیتا داشت چون خروجی فایل جاوااسکریپت ما هم یک json بوده 
                                           // تشکیل یک json در json داده ایم
                                           // پس نیاز است ابتدا json خودمان را
                                           // از json درون data
                                           // استخراج نماییم و سپس json خودمان را
      if (cmd != "") {
          doc.clear();
          deserializeJson(doc, cmd);
          String type = doc["type"].as<String>();
          String value = doc["value"].as<String>();
          Serial.println(" type > " + type);
          Serial.println(" value > " + value);

          if (type == "command") {
            if (value == "ch1on") {
              digitalWrite(RELAY1, HIGH);
              Serial.println(" with command from server  >  Relay 1 : on");

            } else if (value == "ch1off") {
              digitalWrite(RELAY1, LOW);
              Serial.println(" with command from server  >  Relay 1 : OFF");

            } else if (value == "ch2on") {
              digitalWrite(RELAY2, HIGH);
              Serial.println(" with command from server  >  Relay 2 : on");

            } else if (value == "ch2off") {
              digitalWrite(RELAY2, LOW);
              Serial.println(" with command from server  >  Relay 2 : OFF");
            }
              MqttSend("DeviceToServer", value); // حتما تغییرات را برای ثبت در سرور و ایجاد تغییر در اپلیکیشن ها به سمت سرور ارسال می نماییم.
          }
        }
      }
    }
  } else if (projectTopic == "Time/Tehran") {
    Serial.println(String((char *)payload));
  }
}


// تعریف Callback برای ذخیره سناریو
void saveScenarioCallback(JsonDocument &doc) {
  Serial.println("Save scenario callback triggered!");
  // پردازش مربوط به ذخیره سناریو
}

// تعریف Callback برای دیباگر
void debuggerCallback(String value) {
  Serial.println("Debugger callback triggered with value: " + value);
  // فقط حالت زمانی که operationNme == "debugger" و value == "special"
  // مابقی عملیات ها را کتابخانه اجرا می نماید
}

// تعریف Callback برای دریافت داده از DeviceToDevice
void message_From_Topic_DeviceToDevice_Callback(uint8_t *payload) {
  Serial.println("message on DeviceToDevice Callback with value: " + String((char *)payload));
}


// تعریف Callback برای دریافت داده از سرور جهت اجرای دستورات
void message_From_Topic_ServerToDevice_Callback(String value) {
  Serial.println("message on ServerToDevice Callback with value: " + value);
}


//Mqtt_Send(String topic, String data);