#include <TinyGPS++.h>
#include <SPIFFS.h>
#include "notification_utils.h"
#include "bluetooth_utils.h"
#include "configuration.h"
#include "station_utils.h"
#include "lora_utils.h"
#include "msg_utils.h"
#include "gps_utils.h"
#include "display.h"
#include "logger.h"

#include "APRSPacketLib.h"

extern Beacon               *currentBeacon;
extern logging::Logger      logger;
extern std::vector<String>  loadedAPRSMessages;
extern TinyGPSPlus          gps;
extern Configuration        Config;

extern int                  menuDisplay;
extern uint32_t             menuTime;

extern bool                 messageLed;
extern uint32_t             messageLedTime;

String   firstNearTracker            = "";
String   secondNearTracker           = "";
String   thirdNearTracker            = "";
String   fourthNearTracker           = "";

String   lastMessageAPRS             = "";
int      numAPRSMessages             = 0;
bool     noMessageWarning            = false;
String   lastHeardTracker            = "NONE";
uint32_t lastDeleteListenedTracker   = millis();

APRSPacket aprsPacket;

namespace MSG_Utils {

  bool warnNoMessages() {
      return noMessageWarning;
  }

  String getLastHeardTracker() {
      return lastHeardTracker;
  }

  int getNumAPRSMessages() {
      return numAPRSMessages;
  }

  void loadNumMessages() {
    if(!SPIFFS.begin(true)){
      Serial.println("An Error has occurred while mounting SPIFFS");
      return;
    }

    File fileToReadAPRS = SPIFFS.open("/aprsMessages.txt");
    if(!fileToReadAPRS){
      Serial.println("Failed to open APRS_Msg for reading");
      return;
    }

    std::vector<String> v1;
    while (fileToReadAPRS.available()) {
      v1.push_back(fileToReadAPRS.readStringUntil('\n'));
    }
    fileToReadAPRS.close();

    numAPRSMessages = 0;
    for (String s1 : v1) {
      numAPRSMessages++;
    }
    logger.log(logging::LoggerLevel::LOGGER_LEVEL_INFO, "Main", "Number of APRS Messages : %s", String(numAPRSMessages));
  }

  void loadMessagesFromMemory() {
    File fileToRead;
    noMessageWarning = false;
    if (numAPRSMessages == 0) {
      noMessageWarning = true;
    } else {
      loadedAPRSMessages.clear();
      fileToRead = SPIFFS.open("/aprsMessages.txt");
    }
    if (noMessageWarning) {
      show_display("__INFO____", "", "NO MESSAGES IN MEMORY", 1500);
    } else {
      if(!fileToRead){
        Serial.println("Failed to open file for reading");
        return;
      }
      while (fileToRead.available()) {
        loadedAPRSMessages.push_back(fileToRead.readStringUntil('\n'));
      }
      fileToRead.close();
    }
  }

  void ledNotification() {
    uint32_t ledTimeDelta = millis() - messageLedTime;
    if (messageLed && ledTimeDelta > 5*1000) {
      digitalWrite(Config.notification.ledMessagePin, HIGH);
      messageLedTime = millis();
    }
    uint32_t ledOnDelta = millis() - messageLedTime;
    if (messageLed && ledOnDelta > 1*1000) {
      digitalWrite(Config.notification.ledMessagePin, LOW);
    }
    if (!messageLed && digitalRead(Config.notification.ledMessagePin)==HIGH) {
      digitalWrite(Config.notification.ledMessagePin, LOW);
    }
  }

  void deleteFile() {
    if(!SPIFFS.begin(true)){
      Serial.println("An Error has occurred while mounting SPIFFS");
      return;
    }
    SPIFFS.remove("/aprsMessages.txt");
    if (Config.notification.ledMessage){
      messageLed = false;
    }
  }

  void saveNewMessage(String typeMessage, String station, String newMessage) {
    if (typeMessage == "APRS" && lastMessageAPRS != newMessage) {
      File fileToAppendAPRS = SPIFFS.open("/aprsMessages.txt", FILE_APPEND);
      if(!fileToAppendAPRS){
        Serial.println("There was an error opening the file for appending");
        return;
      }
      newMessage.trim();
      if(!fileToAppendAPRS.println("1," + station + "," + newMessage)){
        Serial.println("File append failed");
      }
      lastMessageAPRS = newMessage;
      numAPRSMessages++;
      fileToAppendAPRS.close();
      if (Config.notification.ledMessage){
        messageLed = true;
      }
    }
  }

  void sendMessage(String station, String textMessage) {
    String messageToSend;
    for(int i = station.length(); i < 9; i++) {
      station += ' ';
    }
    messageToSend = currentBeacon->callsign + ">APLRT1";
    if (Config.path != "") {
      messageToSend += "," + Config.path;
    }
    messageToSend += "::" + station + ":" + textMessage;
    if (textMessage.indexOf("ack")== 0) {
      show_display("<<ACK Tx>>", 500);
    } else if (station.indexOf("CD2RXU-15") == 0 && textMessage.indexOf("wrl")==0) {
      show_display("<WEATHER>","", "--- Sending Query ---",  1000);
    } else {
      show_display("MSG Tx >>", "", messageToSend, 1000);
    }
    LoRa_Utils::sendNewPacket(messageToSend);
  }

  void checkReceivedMessage(String packetReceived) {
    if(packetReceived.isEmpty()) {
      return;
    }
    if (packetReceived.substring(0,3) == "\x3c\xff\x01") {              // its an APRS packet
      BLUETOOTH_Utils::sendPacket(packetReceived.substring(3));
      aprsPacket = APRSPacketLib::processReceivedPacket(packetReceived.substring(3));
      //Serial.println(packetReceived); // only for debug
      if (aprsPacket.type=="message" && aprsPacket.sender!=currentBeacon->callsign && aprsPacket.addressee==currentBeacon->callsign) {
        if (aprsPacket.message.indexOf("{")>0) {
          String ackMessage = "ack" + aprsPacket.message.substring(aprsPacket.message.indexOf("{")+1);
          ackMessage.trim();
          delay(4000);
          sendMessage(aprsPacket.sender, ackMessage);
          aprsPacket.message = aprsPacket.message.substring(aprsPacket.message.indexOf(":")+1, aprsPacket.message.indexOf("{"));
        } else {
          aprsPacket.message = aprsPacket.message.substring(aprsPacket.message.indexOf(":")+1);
        }
        if (Config.notification.buzzerActive && Config.notification.messageRxBeep) {
          NOTIFICATION_Utils::messageBeep();
        }
        if (aprsPacket.message.indexOf("ping")==0 || aprsPacket.message.indexOf("Ping")==0 || aprsPacket.message.indexOf("PING")==0) {
          delay(4000);
          sendMessage(aprsPacket.sender, "pong, 73!");
        }
        if (aprsPacket.sender == "CD2RXU-15" && aprsPacket.message.indexOf("WX")==0) {                   // WX = WeatherReport
          Serial.println("Weather Report Received");
          String wxCleaning     = aprsPacket.message.substring(aprsPacket.message.indexOf("WX ")+3);
          String place          = wxCleaning.substring(0,wxCleaning.indexOf(","));
          String placeCleaning  = wxCleaning.substring(wxCleaning.indexOf(",")+1);
          String summary        = placeCleaning.substring(0,placeCleaning.indexOf(","));
          String sumCleaning    = placeCleaning.substring(placeCleaning.indexOf(",")+2);
          String temperature    = sumCleaning.substring(0,sumCleaning.indexOf("P"));
          String tempCleaning   = sumCleaning.substring(sumCleaning.indexOf("P")+1);
          String pressure       = tempCleaning.substring(0,tempCleaning.indexOf("H"));
          String presCleaning   = tempCleaning.substring(tempCleaning.indexOf("H")+1);
          String humidity       = presCleaning.substring(0,presCleaning.indexOf("W"));
          String humCleaning    = presCleaning.substring(presCleaning.indexOf("W")+1);
          String windSpeed      = humCleaning.substring(0,humCleaning.indexOf(","));
          String windCleaning   = humCleaning.substring(humCleaning.indexOf(",")+1);
          String windDegrees    = windCleaning.substring(windCleaning.indexOf(",")+1,windCleaning.indexOf("\n"));

          String fifthLineWR    = temperature + "C  " + pressure + "hPa  " + humidity +"%";
          String sixthLineWR    = "(wind " + windSpeed + "m/s " + windDegrees + "deg)";
          show_display("<WEATHER>", "From --> " + aprsPacket.sender, place, summary, fifthLineWR, sixthLineWR);
          menuDisplay = 40;
          menuTime = millis();
        } else {
          show_display("< MSG Rx >", "From --> " + aprsPacket.sender, "", aprsPacket.message , 3000);
          if (!Config.simplifiedTrackerMode) {
            saveNewMessage("APRS", aprsPacket.sender, aprsPacket.message);
          }
        } 
      } else if (aprsPacket.type == "gps") {
        lastHeardTracker = aprsPacket.sender;
        if (!Config.simplifiedTrackerMode) {
          GPS_Utils::calculateDistanceCourse(aprsPacket.sender, aprsPacket.latitude, aprsPacket.longitude);
          if (Config.notification.buzzerActive && Config.notification.stationBeep) {
            NOTIFICATION_Utils::stationHeardBeep();
          }
        }
      }
    }
  }

}