Ejemplo de Peer-to-Peer y OTA

Dependencies:   ISL29011 libxDot-dev-mbed5-deprecated

Fork of mbed-os-example-mbed5-blinky by mbed-os-examples

main.cpp

Committer:
NataliaRequejo
Date:
2018-03-10
Revision:
61:ebe1838a9301
Parent:
29:0b58d21e87d6

File content as of revision 61:ebe1838a9301:

#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::TRACE_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");
 
    for (uint8_t i = 0; i < iterations; i++) {
        send_data[0] = i;//Envio en que iteracion estoy
        if ((ret = dot->send(send_data)) != mDot::MDOT_OK) {
            logError("failed to send: [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
            send_failure++;
        } else {
            logInfo("send data: %s", Text::bin2hexString(send_data).c_str());
            //La funcion RECV() No funciona en peer to peer. La ventana de tiempo en que esta abierto 
            //el canal despues de hacer el send, para escuchar la respuesta es
            //muy corta y seria muy dificil hacer la sincronizacion 
            //En peer to peer el dispositivo nunca se pone en deep sleep y esta escuchando continumente.
            //Por lo tanto la respuesta unicamente vendra a traves de un evento.
            //Por el contrario cuando la comunicacion es OTA, con el gateway aqui si deberiamos obtener el mensaje.
            if ((ret = dot->recv(recv_data)) != mDot::MDOT_OK) {
                logError("failed to recv: [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
            } else {
                logInfo("recv data: %s", Text::bin2hexString(recv_data).c_str());
                if (recv_data == send_data) {
                    recv++;
                } else {
                    recv_mismatch++;
                }
            }
            recv_data.clear();
        }
        
        next_tx = dot->getNextTxMs() + 1;
        logInfo("waiting %ld ms to transmit again", next_tx);
        wait_ms(next_tx);
        logInfo("waiting another %d seconds", wait_time);
        wait(wait_time);
    }
    
    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;
}