#ifdef USE_ESP32MAIL

#include <ESP_Mail_Client.h>


#ifdef ESP8266
#ifndef SEND_MAIL32_MINRAM
#undef SEND_MAIL32_MINRAM
#define SEND_MAIL32_MINRAM 13*1024
#endif
#endif // ESP8266

#ifdef ESP32
#ifndef SEND_MAIL32_MINRAM
#undef SEND_MAIL32_MINRAM
#define SEND_MAIL32_MINRAM 30*1024
#endif
#endif // ESP32

#define xPSTR(a) a
#define MAX_ATTCHMENTS 8
char *attachments[MAX_ATTCHMENTS];
uint8_t num_attachments;
void script_send_email_body(void(*func)(char *));
String html_content = "";
SMTP_Message *email_mptr;
SMTPSession smtp;
void smtpCallback(SMTP_Status status);

//#define DEBUG_EMAIL_PORT

uint16_t SendMail(char *buffer) {
  char *params,*oparams = 0;
  const char *mserv;
  uint16_t port;
  const char *user;
  const char *pstr;
  const char *passwd;
  const char *from;
  const char *to;
  const char *subject;
  const char *cmd;
  uint16_t status = 0;
  uint16_t blen;
  char *endcmd;
  ESP_Mail_Session session;
  SMTP_Message message;
  email_mptr = &message;

  // return if not enough memory
  uint32_t mem = ESP.getFreeHeap();
  //AddLog(LOG_LEVEL_INFO, PSTR("heap: %d"),mem);
  if (mem < SEND_MAIL32_MINRAM) {
    return 4;
  }
  #ifdef DEBUG_EMAIL_PORT
      AddLog(LOG_LEVEL_INFO, PSTR("heap: %d"),mem);
  #endif

  while (*buffer==' ') buffer++;

  if (*buffer != '[') {
      goto exit;
  }

  buffer++;

  endcmd = strchr(buffer, ']');
  if (!endcmd) {
    goto exit;
  }

  // copy params
  blen = (uint32_t)endcmd - (uint32_t)buffer;
  oparams = (char*)calloc(blen+2, 1);
  if (!oparams) return 4;
  params = oparams;
  strncpy(oparams, buffer, blen+2);
  oparams[blen] = 0;

  cmd = endcmd + 1;


  for (uint32_t cnt = 0; cnt < MAX_ATTCHMENTS; cnt++) {
    attachments[cnt] = 0;
  }
  num_attachments = 0;

#ifdef DEBUG_EMAIL_PORT
    AddLog(LOG_LEVEL_INFO, PSTR("mailsize: %d"),blen);
#endif

  mserv = strtok(params, ":");
  if (!mserv) {
      goto exit;
  }

  // port
  pstr = strtok(NULL, ":");
  if (!pstr) {
      goto exit;
  }

#ifdef EMAIL_PORT
  if (*pstr == '*') {
    port = EMAIL_PORT;
  } else {
    port = atoi(pstr);
  }
#else
  port = atoi(pstr);
#endif

  user = strtok(NULL, ":");
  if (!user) {
      goto exit;
  }

  passwd = strtok(NULL, ":");
  if (!passwd) {
      goto exit;
  }

  from = strtok(NULL, ":");
  if (!from) {
      goto exit;
  }

  to = strtok(NULL, ":");
  if (!to) {
      goto exit;
  }

  subject = strtok(NULL, "]");
  if (!subject) {
      goto exit;
  }

#ifdef EMAIL_USER
  if (*user == '*') {
    user = xPSTR(EMAIL_USER);
  }
#endif

#ifdef EMAIL_PASSWORD
  if (*passwd == '*') {
    passwd = xPSTR(EMAIL_PASSWORD);
  }
#endif

#ifdef EMAIL_SERVER
  if (*mserv == '*') {
    mserv = xPSTR(EMAIL_SERVER);
  }
#endif

#ifdef DEBUG_EMAIL_PORT
  AddLog_P(LOG_LEVEL_INFO, PSTR("%s - %d - %s - %s"), mserv, port, user, passwd);
#endif

#ifdef EMAIL_FROM
  if (*from == '*') {
    from = xPSTR(EMAIL_FROM);
  }
#endif

#ifdef DEBUG_EMAIL_PORT
  AddLog_P(LOG_LEVEL_INFO, PSTR("%s - %s - %s - %s"), from, to, subject, cmd);
#endif


  //smtp.debug(true);
  smtp.debug(false);
//  smtp.callback(smtpCallback);

  message.clearRecipients();
  message.clearCc();
  message.clearBcc();

  session.server.host_name = mserv;
  session.server.port = port;
  session.login.email = user;
  session.login.password = passwd;
  session.login.user_domain = "googlemail.com";


  message.enable.chunking = true;
  char sname[32];
  strlcpy(sname, SettingsText(SET_FRIENDLYNAME1), sizeof(sname));
  message.sender.name = sname;
  message.sender.email = from;
  message.subject = subject;
  message.addRecipient("user1", to);
  message.html.charSet = "utf-8";
  message.text.charSet = "utf-8";
  message.text.transfer_encoding = Content_Transfer_Encoding::enc_base64;
  message.priority = esp_mail_smtp_priority::esp_mail_smtp_priority_normal;
  //message.response.notify = esp_mail_smtp_notify_success | esp_mail_smtp_notify_failure | esp_mail_smtp_notify_delay;
  message.response.notify = esp_mail_smtp_notify_failure;
  message.html.charSet = "us-ascii";
  message.html.transfer_encoding = Content_Transfer_Encoding::enc_7bit;
  message.addHeader("Message-ID: <user1@gmail.com>");

  #ifdef USE_SCRIPT
    if (*cmd == '*' && *(cmd + 1) == 0) {
      script_send_email_body(send_message_txt);
    } else {
      html_content += cmd;
      message.html.content  = html_content.c_str();
    }
  #else
    html_content += cmd;
    message.html.content  = html_content.c_str();
  #endif

  /* Connect to server with the session config */
  delay(0);
  if (!smtp.connect(&session))
    goto exit;

  /* Start sending the Email and close the session */
  delay(0);

  if (!MailClient.sendMail(&smtp, &message, true)) {
    Serial.println("Error sending Email, " + smtp.errorReason());
  }

exit:
  for (uint32_t cnt = 0; cnt < MAX_ATTCHMENTS; cnt++) {
    if (attachments[cnt]) {
      free(attachments[cnt]);
      attachments[cnt] = 0;
    }
  }
  html_content = "";
  if (oparams) free(oparams);
  return status;
}


void send_message_txt(char *txt) {
  if (*txt == '@') {
    txt++;
    attach_File(txt);
  } else if (*txt == '&') {
    txt++;
    attach_Array(txt);
  } else if (*txt == '$') {
    txt++;
#if defined(ESP32) && defined(USE_WEBCAM)
    if (num_attachments < MAX_ATTCHMENTS) {
      attachments[num_attachments] = (char*)malloc(32);
      uint32_t cnt;
      uint8_t *buff;
      uint32_t len, picmax;
      picmax = WcGetPicstore(-1, 0);
      cnt = *txt&7;
      if (cnt < 1 || cnt > picmax) cnt = 1;
      len = WcGetPicstore(cnt - 1, &buff);
      if (len) {
        sprintf(attachments[num_attachments], "img_%1d.jpg", cnt);
        attach_Data(attachments[num_attachments], buff, len);
      }
      num_attachments++;
    }
#endif
  } else {
    html_content += txt;
    email_mptr->html.content  = html_content.c_str();
  }
}

void attach_File(char *path) {
  SMTP_Attachment att;
  if (num_attachments < MAX_ATTCHMENTS) {
    attachments[num_attachments] = (char*)malloc(32);
    strcpy(attachments[num_attachments], path);

    char *cp = attachments[num_attachments];
    att.file.path = cp;
    if (*cp == '/') {
      cp++;
    }
    att.descr.filename = cp;
    att.descr.mime = "application/octet-stream"; //binary data
    att.file.storage_type = esp_mail_file_storage_type_univ;
    att.descr.transfer_encoding = Content_Transfer_Encoding::enc_base64;
    email_mptr->addAttachment(att);
    email_mptr->resetAttachItem(att);
    num_attachments++;
  }
}

float *get_array_by_name(char *name, uint16_t *alen);
void flt2char(float num, char *nbuff);

void attach_Array(char *aname) {
  float *array = 0;
  uint16_t alen;
  String ttstr = "";
  array = get_array_by_name(aname, &alen);
  if (array && alen) {
    float *fp = array;
    for (uint32_t cnt = 0; cnt < alen; cnt++) {
      // export array as tab gelimited text
      char nbuff[16];
      flt2char(*fp++, nbuff);
      if (cnt < (alen - 1)) {
        strcat(nbuff, "\t");
      } else {
        strcat(nbuff, "\n");
      }
      ttstr += nbuff;
    }

    if (num_attachments < MAX_ATTCHMENTS) {
      attachments[num_attachments] = (char*)malloc(ttstr.length() + 1 + 32);
      strcpy(attachments[num_attachments] + 32, ttstr.c_str());
      sprintf(attachments[num_attachments], "%s.txt", aname);
      attach_Data(attachments[num_attachments], (uint8_t*)attachments[num_attachments]+32, ttstr.length());
      num_attachments++;
    }
  } else {
    //g_client->print(F("\r\n\r\narray not found!\r\n"));
  }
}

void attach_Data(char *name, uint8_t *buff, uint32_t len) {
  SMTP_Attachment att;
  att.descr.filename = name;
  att.descr.mime = "application/octet-stream";
  att.blob.data = buff;
  att.blob.size = len;
  att.descr.transfer_encoding = Content_Transfer_Encoding::enc_base64;
  email_mptr->addAttachment(att);
  email_mptr->resetAttachItem(att);
}

/* Callback function to get the Email sending status */
void smtpCallback(SMTP_Status status)
{
/* Print the current status */
Serial.println(status.info());

/* Print the sending result */
if (status.success())
{
  Serial.println("----------------");
  Serial.printf("Message sent success: %d\n", status.completedCount());
  Serial.printf("Message sent failled: %d\n", status.failedCount());
  Serial.println("----------------\n");
  struct tm dt;

  for (size_t i = 0; i < smtp.sendingResult.size(); i++)
  {
    /* Get the result item */
    SMTP_Result result = smtp.sendingResult.getItem(i);
    localtime_r(&result.timesstamp, &dt);

    Serial.printf("Message No: %d\n", i + 1);
    Serial.printf("Status: %s\n", result.completed ? "success" : "failed");
    Serial.printf("Date/Time: %d/%d/%d %d:%d:%d\n", dt.tm_year + 1900, dt.tm_mon + 1, dt.tm_mday, dt.tm_hour, dt.tm_min, dt.tm_sec);
    Serial.printf("Recipient: %s\n", result.recipients);
    Serial.printf("Subject: %s\n", result.subject);
  }
  Serial.println("----------------\n");
}

}
#endif // USE_ESP32MAIL