plm100s/PLS100W_SSD1306-I2C/main.cpp

#include <cox.h>
#include <algorithm>
#include <LoRaMacKR920.hpp>
#include <nrf5x/nRF5xFlashPage.hpp>
#include <dev/Adafruit_SSD1306.hpp>
 
//#define SENSOR_TEST_MODE
 
nRF5xFlashPage configMemory(0x76000);
char keyBuf[128];
Timer timerKeyInput;
 
LoRaMacKR920 LoRaWAN = LoRaMacKR920(SX1276);
 
Timer timerSend;
 
Adafruit_SSD1306 display(128, 64, &Wire);
 
static uint8_t devEui[8];
static uint8_t appKey[16];
 
uint8_t numDisplayed = 0;
 
static void taskPeriodicSend(void *) {
  LoRaMacFrame *f = new LoRaMacFrame(20);
  if (!f) {
    printf("* Out of memory\n");
    return;
  }
 
  f->port = 1;
  f->type = LoRaMacFrame::UNCONFIRMED;
  f->len = snprintf((char *) f->buf, 20, "\"disp\":%u", numDisplayed);
 
  error_t err = LoRaWAN.send(f);
  printf("* Sending periodic report: %d\n", err);
  if (err != ERROR_SUCCESS) {
    delete f;
  }
}
 
static void eventLoRaWANJoin(
  LoRaMac &,
  bool joined,
  const uint8_t *joinedDevEui,
  const uint8_t *joinedAppEui,
  const uint8_t *joinedAppKey,
  const uint8_t *joinedNwkSKey,
  const uint8_t *joinedAppSKey,
  uint32_t joinedDevAddr,
  const RadioPacket &frame,
  uint32_t
) {
  display.clearDisplay();
  display.setCursor(0, 0);
 
  if (joined) {
    printf("* Joined to the network!\n");
    display.print("Joined!");
    LoRaWAN.setDeviceClass(LoRaMac::CLASS_C);
 
    postTask(taskPeriodicSend);
    timerSend.startPeriodic(30000);
  } else {
    printf("* Join failed. Retry to join\n");
    LoRaWAN.beginJoining(devEui, appKey);
    display.println("Join failed!");
    display.print("Retrying...");
  }
 
  display.display();
}
 
static void eventLoRaWANSendDone(LoRaMac &, LoRaMacFrame *frame) {
  printf("* Send done(%d): [%p] destined for port[%u], Freq:%lu Hz, Power:%d dBm, # of Tx:%u, ", frame->result, frame, frame->port, frame->freq, frame->power, frame->numTrials);
  if (frame->modulation == Radio::MOD_LORA) {
    const char *strBW[] = { "Unknown", "125kHz", "250kHz", "500kHz", "Unexpected value" };
    if (frame->meta.LoRa.bw > 3) {
      frame->meta.LoRa.bw = (Radio::LoRaBW_t) 4;
    }
    printf("LoRa, SF:%u, BW:%s, ", frame->meta.LoRa.sf, strBW[frame->meta.LoRa.bw]);
  } else if (frame->modulation == Radio::MOD_FSK) {
    printf("FSK, ");
  } else {
    printf("Unkndown modulation, ");
  }
  if (frame->type == LoRaMacFrame::UNCONFIRMED) {
    printf("UNCONFIRMED");
  } else if (frame->type == LoRaMacFrame::CONFIRMED) {
    printf("CONFIRMED");
  } else if (frame->type == LoRaMacFrame::MULTICAST) {
    printf("MULTICAST (error)");
  } else if (frame->type == LoRaMacFrame::PROPRIETARY) {
    printf("PROPRIETARY");
  } else {
    printf("unknown type");
  }
  if ( frame->result == RadioPacket::TOO_BIG){
    printf("- TOO BIG\n");
    delete frame;
    return;
  }
 
  printf(" frame\n");
  delete frame;
}
 
static void eventLoRaWANReceive(LoRaMac &lw, const LoRaMacFrame *frame) {
  printf("* Received:");
 
  if (frame->len > 0) {
    display.clearDisplay();
    display.setCursor(0, 0);
    display.println("Received:");
  }
 
  for (uint8_t i = 0; i < frame->len; i++) {
    printf(" %02X", frame->buf[i]);
    display.print((char) frame->buf[i]);
  }
  printf(" (");
  frame->printTo(Serial);
  printf(")\n");
 
  if (frame->len > 0) {
    display.display();
 
    numDisplayed = frame->len;
  }
 
  LoRaMacFrame *f = nullptr;
  if (frame->type == LoRaMacFrame::UNCONFIRMED && lw.framePending) {
    f = new LoRaMacFrame();
  } else if (frame->type == LoRaMacFrame::CONFIRMED) {
    f = new LoRaMacFrame(20);
    f->len = snprintf((char *) f->buf, 20, "\"disp\":%u", frame->len);
  }
 
  if (f) {
    f->port = 1;
    f->type = LoRaMacFrame::UNCONFIRMED;
 
    error_t err = LoRaWAN.send(f);
    if (err == ERROR_SUCCESS) {
      timerSend.startPeriodic(30000);
    } else {
      delete f;
    }
  }
}
 
static void beginLoRaWAN(void *) {
  LoRaWAN.begin();
  LoRaWAN.onSendDone(eventLoRaWANSendDone);
  LoRaWAN.onReceive(eventLoRaWANReceive);
  LoRaWAN.onJoin(eventLoRaWANJoin);
  LoRaWAN.setPublicNetwork(true);
  LoRaWAN.beginJoining(devEui, appKey);
 
  display.clearDisplay();
  display.setCursor(0, 0);
  display.print("Joining...");
  display.display();
}
 
static void eventAppKeyInput(SerialPort &) {
  uint8_t numOctets = strlen(keyBuf);
  if (numOctets == 32) {
    numOctets /= 2;
    char strOctet[3];
 
    for (uint8_t j = 0; j < numOctets; j++) {
      strOctet[0] = keyBuf[2 * j];
      strOctet[1] = keyBuf[2 * j + 1];
      strOctet[2] = '\0';
 
      appKey[j] = strtoul(strOctet, NULL, 16);
    }
 
    printf("* New AppKey:");
    for (uint8_t j = 0; j < numOctets; j++) {
      printf(" %02X", appKey[j]);
    }
    printf(" (%u byte)\n", numOctets);
    configMemory.write(appKey, 0, numOctets);
    postTask(beginLoRaWAN);
    return;
  } else {
    printf("* HEX string length MUST be 32-byte.");
  }
 
  Serial.inputKeyboard(keyBuf, sizeof(keyBuf) - 1);
}
 
static void eventKeyInput(SerialPort &) {
  timerKeyInput.stop();
  while (Serial.available() > 0) {
    Serial.read();
  }
 
  display.clearDisplay();
  display.setCursor(0, 0);
  display.println("Configuring...");
  display.print("Please connect this by using a serial port.");
  display.display();
 
  Serial.onReceive(eventAppKeyInput);
  Serial.listen();
  Serial.inputKeyboard(keyBuf, sizeof(keyBuf) - 1);
  Serial.println(
    "* Enter a new appKey as a hexadecimal string "
    "[ex. 00112233445566778899aabbccddeeff]"
  );
}
 
void setup() {
  Serial.begin(115200);
  Serial.printf("\n*** [PLS100W] SSD1306 OLED Display + LoRaWAN ***\n");
  System.getEUI(devEui);
  Serial.printf("* EUI: %02X-%02X-%02X-%02X-%02X-%02X-%02X-%02X\n",
                devEui[0], devEui[1], devEui[2], devEui[3], devEui[4], devEui[5], devEui[6], devEui[7]);
 
  configMemory.read(appKey, 0, 16);
  Serial.printf("* AppKey: %02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x\n",
                appKey[0], appKey[1], appKey[2], appKey[3],
                appKey[4], appKey[5], appKey[6], appKey[7],
                appKey[8], appKey[9], appKey[10], appKey[11],
                appKey[12], appKey[13], appKey[14], appKey[15]);
 
  Serial.printf("* Last reset reason:0x%02X\n", System.getResetReason());
  if (System.getResetReason() & (System.RESET_REASON_DOG | System.RESET_REASON_SREQ)) {
    const McuARMCortexM::CoreRegisterDump *last = System.getLastCoreRegisterDump();
    Serial.printf(" - R0: 0x%08lx, R1: 0x%08lx, R2: 0x%08lx, R3: 0x%08lx\n", last->r0, last->r1, last->r2, last->r3);
    Serial.printf(" - R12: 0x%08lx, LR: 0x%08lx, PC: 0x%08lx, PSR: 0x%08lx\n", last->r12, last->lr, last->pc, last->psr);
  }
 
  timerSend.onFired(taskPeriodicSend);
 
  display.begin(SSD1306_SWITCHCAPVCC, 0x3C); // Address 0x3C for 128x32
  display.display();
  delay(1000);
  display.clearDisplay();
  display.setTextSize(1);
  display.setTextColor(WHITE);
  display.setCursor(0, 0);
  display.println("*** [PLS100W] ***");
#ifdef SENSOR_TEST_MODE
  display.print("SSD1306 OLED Test");
  display.display();
#else
  display.println("Initializing...");
  display.display();
  if (memcmp(appKey, "\xFF\xFF\xFF\xFF\xFF\xFF\xFF\xFF\xFF\xFF\xFF\xFF\xFF\xFF\xFF\xFF", 16) == 0) {
    /* The appKey is required to be entered by user.*/
    eventKeyInput(Serial);
  } else {
    Serial.println("* Press any key to enter a new AppKey in 3 seconds...");
    timerKeyInput.onFired(beginLoRaWAN);
    timerKeyInput.startOneShot(3000);
    Serial.listen();
    Serial.onReceive(eventKeyInput);
  }
#endif
}