/* -*- mode: c++ -*-
 * Kaleidoscope-FocusSerial -- Bidirectional communication plugin
 * Copyright (C) 2017, 2018, 2021  Keyboard.io, Inc
 *
 * This program is free software: you can redistribute it and/or modify it under
 * the terms of the GNU General Public License as published by the Free Software
 * Foundation, version 3.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
 * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
 * details.
 *
 * You should have received a copy of the GNU General Public License along with
 * this program. If not, see <http://www.gnu.org/licenses/>.
 */

#include <Kaleidoscope-FocusSerial.h>

#ifdef __AVR__
#include <avr/pgmspace.h>
#endif

namespace kaleidoscope {
namespace plugin {

char FocusSerial::command_[32];
uint8_t FocusSerial::buf_cursor_ = 0;

EventHandlerResult FocusSerial::afterEachCycle() {
  // If the serial buffer is empty, we don't have any work to do
  if (Runtime.serialPort().available() == 0) {
    return EventHandlerResult::OK;
  }

  do {
    command_[buf_cursor_++] = Runtime.serialPort().read();
  } while (command_[buf_cursor_ - 1] != SEPARATOR
           && buf_cursor_ < sizeof(command_)
           && Runtime.serialPort().available()
           && (Runtime.serialPort().peek() != NEWLINE));


  // If there was no command, there's nothing to do
  if (command_[0] == '\0') {
    buf_cursor_ = 0;
    memset(command_, 0, sizeof(command_));
    return EventHandlerResult::OK;
  }

  if ((command_[buf_cursor_ - 1] != SEPARATOR)  && (Runtime.serialPort().peek() != NEWLINE)
      && buf_cursor_ < sizeof(command_)
     ) {
    // We don't have enough command to work with yet.
    // Let's leave the buffer around for another cycle
    return EventHandlerResult::OK;
  }

  // If this was a command with a space-delimited payload,
  // strip the space delimiter off
  if ((command_[buf_cursor_ - 1] == SEPARATOR)) {
    command_[buf_cursor_ - 1] = '\0';
  }

  // Then process the command
  Runtime.onFocusEvent(command_);
  while (Runtime.serialPort().available()) {
    char c =  Runtime.serialPort().read();
    if (c == NEWLINE) {
      // newline serves as an end-of-command marker
      // don't drain the buffer past there
      break;
    }
  }
  // End of command processing is signalled with a CRLF followed by a single period
  Runtime.serialPort().println(F("\r\n."));
  buf_cursor_ = 0;
  memset(command_, 0, sizeof(command_));
  return EventHandlerResult::OK;

}

bool FocusSerial::handleHelp(const char *command,
                             const char *help_message) {
  if (strcmp_P(command, PSTR("help")) != 0)
    return false;

  Runtime.serialPort().println((const __FlashStringHelper *)help_message);
  return true;
}

EventHandlerResult FocusSerial::onFocusEvent(const char *command) {
  if (handleHelp(command, PSTR("help\ndevice.reset\nplugins")))
    return EventHandlerResult::OK;

  if (strcmp_P(command, PSTR("device.reset")) == 0) {
    Runtime.device().rebootBootloader();
    return EventHandlerResult::EVENT_CONSUMED;
  }
  if (strcmp_P(command, PSTR("plugins")) == 0) {
    kaleidoscope::Hooks::onNameQuery();
    return EventHandlerResult::EVENT_CONSUMED;
  }

  return EventHandlerResult::OK;
}

void FocusSerial::printBool(bool b) {
  Runtime.serialPort().print((b) ? F("true") : F("false"));
}

}
}

kaleidoscope::plugin::FocusSerial Focus;