peer to peer rx terminal
Dependencies: ISL29011 libxDot-dev-mbed5-deprecated
Fork of peer-to-peer_rxtx by
main.cpp
- Committer:
- mbt1992
- Date:
- 2018-06-07
- Revision:
- 62:5a4266922385
- Parent:
- 61:ebe1838a9301
File content as of revision 62:5a4266922385:
#include "mbed.h"
#include "mDot.h"
#include "MTSLog.h"
#include "MTSText.h"
#include "RadioEvent.h"
#include "ChannelPlans.h"
#include <string>
#include <vector>
#define PEER_TO_PEER_SAMPLE 1
//#define OTA
using namespace mts;
#if defined(PEER_TO_PEER_SAMPLE)
static uint8_t network_address[] = { 0x01, 0x02, 0x03, 0x04 };
static uint8_t network_session_key[] = { 0x01, 0x02, 0x03, 0x04, 0x01, 0x02, 0x03, 0x04, 0x01, 0x02, 0x03, 0x04, 0x01, 0x02, 0x03, 0x04 };
static uint8_t data_session_key[] = { 0x01, 0x02, 0x03, 0x04, 0x01, 0x02, 0x03, 0x04, 0x01, 0x02, 0x03, 0x04, 0x01, 0x02, 0x03, 0x04 };
#else
static std::string config_network_name = "conduitUNSAM";
static std::string config_network_pass = "conduitUNSAM";
static uint8_t config_frequency_sub_band = 4;
#endif
mDot* dot;
lora::ChannelPlan* plan = NULL;
void update_peer_to_peer_config(uint8_t *network_address, uint8_t *network_session_key, uint8_t *data_session_key, uint32_t tx_frequency, uint8_t tx_datarate, uint8_t tx_power) {
std::vector<uint8_t> current_network_address = dot->getNetworkAddress();
std::vector<uint8_t> current_network_session_key = dot->getNetworkSessionKey();
std::vector<uint8_t> current_data_session_key = dot->getDataSessionKey();
uint32_t current_tx_frequency = dot->getTxFrequency();
uint8_t current_tx_datarate = dot->getTxDataRate();
uint8_t current_tx_power = dot->getTxPower();
std::vector<uint8_t> network_address_vector(network_address, network_address + 4);
std::vector<uint8_t> network_session_key_vector(network_session_key, network_session_key + 16);
std::vector<uint8_t> data_session_key_vector(data_session_key, data_session_key + 16);
if (current_network_address != network_address_vector) {
logInfo("changing network address from \"%s\" to \"%s\"", mts::Text::bin2hexString(current_network_address).c_str(), mts::Text::bin2hexString(network_address_vector).c_str());
if (dot->setNetworkAddress(network_address_vector) != mDot::MDOT_OK) {
logError("failed to set network address to \"%s\"", mts::Text::bin2hexString(network_address_vector).c_str());
}
}
if (current_network_session_key != network_session_key_vector) {
logInfo("changing network session key from \"%s\" to \"%s\"", mts::Text::bin2hexString(current_network_session_key).c_str(), mts::Text::bin2hexString(network_session_key_vector).c_str());
if (dot->setNetworkSessionKey(network_session_key_vector) != mDot::MDOT_OK) {
logError("failed to set network session key to \"%s\"", mts::Text::bin2hexString(network_session_key_vector).c_str());
}
}
if (current_data_session_key != data_session_key_vector) {
logInfo("changing data session key from \"%s\" to \"%s\"", mts::Text::bin2hexString(current_data_session_key).c_str(), mts::Text::bin2hexString(data_session_key_vector).c_str());
if (dot->setDataSessionKey(data_session_key_vector) != mDot::MDOT_OK) {
logError("failed to set data session key to \"%s\"", mts::Text::bin2hexString(data_session_key_vector).c_str());
}
}
if (current_tx_frequency != tx_frequency) {
logInfo("changing TX frequency from %lu to %lu", current_tx_frequency, tx_frequency);
if (dot->setTxFrequency(tx_frequency) != mDot::MDOT_OK) {
logError("failed to set TX frequency to %lu", tx_frequency);
}
}
if (current_tx_datarate != tx_datarate) {
logInfo("changing TX datarate from %u to %u", current_tx_datarate, tx_datarate);
if (dot->setTxDataRate(tx_datarate) != mDot::MDOT_OK) {
logError("failed to set TX datarate to %u", tx_datarate);
}
}
if (current_tx_power != tx_power) {
logInfo("changing TX power from %u to %u", current_tx_power, tx_power);
if (dot->setTxPower(tx_power) != mDot::MDOT_OK) {
logError("failed to set TX power to %u", tx_power);
}
}
}
int main() {
Serial debug(USBTX, USBRX);
debug.baud(115200);
RadioEvent events;
int32_t ret;
int32_t next_tx;
int32_t wait_time = 2;
std::vector<uint8_t> send_data;
std::vector<uint8_t> recv_data;
uint8_t recv = 0;
uint8_t recv_mismatch = 0;
uint8_t send_failure = 0;
uint8_t iterations = 5;
send_data.push_back(0x00);
send_data.push_back('N');
send_data.push_back('A');
send_data.push_back('T');
send_data.push_back('I');
send_data.push_back(' ');
send_data.push_back(' ');
send_data.push_back(' ');
plan = new lora::ChannelPlan_US915();
dot = mDot::getInstance(plan);
logInfo("defaulting Dot configuration");
dot->resetConfig();
//si se hace un deep sleep la aplicacion inicia desde el principio.
//Y no desde el punto donde se ejecuto el deep_sleep
//Por esto es necesario salvar la sesion y luego recuperarla para continuar trabajando
//dot->resetNetworkSession();
//dot->restoreNetworkSession();
//dot->saveNetworkSession();
dot->setLogLevel(MTSLog::INFO_LEVEL);
#if defined(PEER_TO_PEER_SAMPLE)
// attach the custom events handler
dot->setEvents(&events);
//Peer-to-peer
// Actualizamos la configuracion de Join unicamente si es diferente
//( 0= Manual, 1 = OTA, 2= AUTO_OTA, 3=Peer to Peer)
if (dot->getJoinMode() != mDot::PEER_TO_PEER) {
logInfo("changing network join mode to PEER_TO_PEER");
if (dot->setJoinMode(mDot::PEER_TO_PEER) != mDot::MDOT_OK) {
logError("failed to set network join mode to PEER_TO_PEER");
}
}
uint32_t tx_frequency= 915500000;
uint8_t tx_datarate = lora::DR_13;
uint8_t tx_power = 20;
update_peer_to_peer_config(network_address, network_session_key, data_session_key, tx_frequency, tx_datarate, tx_power);
#else
// Actualizamos la configuracion de Join unicamente si es diferente
//( 0= Manual, 1 = OTA, 2= AUTO_OTA, 3=Peer to Peer)
if (dot->getJoinMode() != mDot::AUTO_OTA) {
logInfo("changing network join mode to AUTO_OTA");
if (dot->setJoinMode(mDot::AUTO_OTA) != mDot::MDOT_OK) {
logError("failed to set network join mode to AUTO_OTA");
}
}
while ((ret = dot->setFrequencySubBand(config_frequency_sub_band)) != mDot::MDOT_OK) {
logError("failed to set frequency sub band: [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
}
while ((ret = dot->setNetworkName(config_network_name)) != mDot::MDOT_OK) {
logError("failed to set network name: [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
}
while ((ret = dot->setNetworkPassphrase(config_network_pass)) != mDot::MDOT_OK) {
logError("failed to set network password: [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
}
while ((ret = dot->setPublicNetwork(1)) != mDot::MDOT_OK) {
logError("failed to set public network : [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
}
#endif
// save changes to configuration
logInfo("saving configuration");
if (!dot->saveConfig()) {
logError("failed to save configuration");
}
//logInfo("enabling activity LED");
dot->setActivityLedEnable(true);
logInfo("joining network");
while ((ret = dot->joinNetwork()) != mDot::MDOT_OK) {
logError("failed to join network: [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
wait_ms(dot->getNextTxMs() + 1);
}
logInfo("joined");
while(1) {
std::string rxxdata = events.print();
next_tx = dot->getNextTxMs() + 1;
logInfo("Datos : %s", rxxdata);
wait_ms(5000);
logInfo("waiting data \n");
wait_ms(100);
}
logInfo("Version: %s", dot->getId().c_str());
logInfo("Recv: %d/%d", recv, iterations);
logInfo("Recv Mismatch: %d/%d", recv_mismatch, iterations);
logInfo("Send Failure: %d/%d", send_failure, iterations);
logInfo("Dropped: %d/%d", iterations - (recv + recv_mismatch + send_failure), iterations);
return 0;
}
