/******************************************************************************* Copyright(c) 2015-2018 LORD Corporation. All rights reserved. MIT Licensed. See the included LICENSE.txt for a copy of the full MIT License. *******************************************************************************/ #include "mscl/MicroStrain/Wireless/Packets/SyncSamplingPacket.h" #include "mscl/MicroStrain/Wireless/Packets/WirelessPacket.h" #include "mscl/MicroStrain/Wireless/Packets/WirelessPacketCollector.h" #include "mscl/MicroStrain/Wireless/Packets/WirelessDataPacket.h" #include "mscl/Exceptions.h" #include using namespace mscl; BOOST_AUTO_TEST_SUITE(SyncPacket_Test) BOOST_AUTO_TEST_CASE(SyncPacket_Constructor_4ByteFloat) { Bytes payloadBytes; payloadBytes.push_back(2); //app id payloadBytes.push_back(1); //channel mask - 1 channel payloadBytes.push_back(112); //sample rate payloadBytes.push_back(WirelessTypes::dataType_float32); //data type - 4 byte float payloadBytes.push_back(0); //tick msb payloadBytes.push_back(1); //tick lsb payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); //channel data b1 payloadBytes.push_back(0); //channel data b2 payloadBytes.push_back(0); //channel data b3 payloadBytes.push_back(0); //channel data b4 payloadBytes.push_back(1); //channel data b1 payloadBytes.push_back(1); //channel data b2 payloadBytes.push_back(1); //channel data b3 payloadBytes.push_back(1); //channel data b4 //build a WirelessPacket WirelessPacket packet; packet.nodeAddress(345); packet.deliveryStopFlags(DeliveryStopFlags::fromInvertedByte(0)); packet.type(WirelessPacket::packetType_SyncSampling); packet.nodeRSSI(1); packet.baseRSSI(1); packet.payload(payloadBytes); //give the packet the payload bytes we created //call the addDataPacket() function to parse the packet as an LDC Packet WirelessPacketCollector collector; collector.addDataPacket(packet); DataSweeps sweeps; collector.getDataSweeps(sweeps); BOOST_CHECK_EQUAL(sweeps.size(), 2); DataSweep sweep = sweeps.at(0); //check that the sweep data matches the packet we added BOOST_CHECK_EQUAL(sweep.nodeAddress(), 345); BOOST_CHECK_EQUAL(sweep.tick(), 1); BOOST_CHECK_EQUAL(sweep.timestamp().nanoseconds(), 0); BOOST_CHECK_EQUAL(sweep.nodeRssi(), 1); BOOST_CHECK_EQUAL(sweep.baseRssi(), 1); BOOST_CHECK_EQUAL(sweep.sampleRate().prettyStr(), "2Hz"); BOOST_CHECK_EQUAL(sweep.data()[0].storedAs(), valueType_float); sweep = sweeps.at(1); //check that the sweep data matches the packet we added BOOST_CHECK_EQUAL(sweep.nodeAddress(), 345); BOOST_CHECK_EQUAL(sweep.tick(), 2); //check that the tick incremented (by MSCL, not by the packet) BOOST_CHECK_EQUAL(sweep.data()[0].storedAs(), valueType_float); } BOOST_AUTO_TEST_CASE(SyncPacket_Constructor_2ByteUint) { Bytes payloadBytes; payloadBytes.push_back(1); //app id payloadBytes.push_back(1); //channel mask - 1 channel payloadBytes.push_back(112); //sample rate payloadBytes.push_back(WirelessTypes::dataType_uint16_12bitRes); //data type - 2 byte uint payloadBytes.push_back(0); //tick msb payloadBytes.push_back(1); //tick lsb payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); //channel data b1 payloadBytes.push_back(254); //channel data b2 //build a WirelessPacket WirelessPacket packet; packet.nodeAddress(345); packet.deliveryStopFlags(DeliveryStopFlags::fromInvertedByte(0)); packet.type(WirelessPacket::packetType_SyncSampling); packet.nodeRSSI(1); packet.baseRSSI(1); packet.payload(payloadBytes); //give the packet the payload bytes we created //call the addDataPacket() function to parse the packet as an LDC Packet WirelessPacketCollector collector; collector.addDataPacket(packet); DataSweeps sweeps; collector.getDataSweeps(sweeps); BOOST_CHECK_EQUAL(sweeps.size(), 1); DataSweep sweep = sweeps.at(0); //check that the sweep data matches the packet we added BOOST_CHECK_EQUAL(sweep.nodeAddress(), 345); BOOST_CHECK_EQUAL(sweep.tick(), 1); BOOST_CHECK_EQUAL(sweep.samplingType(), DataSweep::samplingType_SyncSampling_Burst); BOOST_CHECK_EQUAL(sweep.data()[0].storedAs(), valueType_uint16); BOOST_CHECK_EQUAL(sweep.data()[0].as_uint16(), 254); } BOOST_AUTO_TEST_CASE(SyncPacket_Constructor_2ByteUintShifted) { Bytes payloadBytes; payloadBytes.push_back(2); //app id payloadBytes.push_back(1); //channel mask - 1 channel payloadBytes.push_back(112); //sample rate payloadBytes.push_back(WirelessTypes::dataType_uint16_shifted); //data type - 2 byte uint shifted payloadBytes.push_back(0); //tick msb payloadBytes.push_back(1); //tick lsb payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); //channel data b1 payloadBytes.push_back(254); //channel data b2 //build a WirelessPacket WirelessPacket packet; packet.nodeAddress(345); packet.deliveryStopFlags(DeliveryStopFlags::fromInvertedByte(0)); packet.type(WirelessPacket::packetType_SyncSampling); packet.nodeRSSI(1); packet.baseRSSI(1); packet.payload(payloadBytes); //give the packet the payload bytes we created //call the addDataPacket() function to parse the packet as an LDC Packet WirelessPacketCollector collector; collector.addDataPacket(packet); DataSweeps sweeps; collector.getDataSweeps(sweeps); BOOST_CHECK_EQUAL(sweeps.size(), 1); DataSweep sweep = sweeps.at(0); //check that the sweep data matches the packet we added BOOST_CHECK_EQUAL(sweep.nodeAddress(), 345); BOOST_CHECK_EQUAL(sweep.tick(), 1); BOOST_CHECK_EQUAL(sweep.data()[0].storedAs(), valueType_uint16); BOOST_CHECK_EQUAL(sweep.data()[0].as_uint16(), 127); //check that the data was shifted (divided by 2) } BOOST_AUTO_TEST_CASE(SyncPacket_Constructor_NoChannelMask) { Bytes payloadBytes; payloadBytes.push_back(1); //app id payloadBytes.push_back(0); //channel mask - NO CHANNELS payloadBytes.push_back(112); //sample rate payloadBytes.push_back(WirelessTypes::dataType_uint16_12bitRes); //data type - 2 byte uint payloadBytes.push_back(0); //tick msb payloadBytes.push_back(1); //tick lsb payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); //build a WirelessPacket WirelessPacket packet; packet.nodeAddress(345); packet.deliveryStopFlags(DeliveryStopFlags::fromInvertedByte(0)); packet.type(WirelessPacket::packetType_SyncSampling); packet.nodeRSSI(1); packet.baseRSSI(1); packet.payload(payloadBytes); //give the packet the payload bytes we created //call the addDataPacket() function to parse the packet as an LDC Packet WirelessPacketCollector collector; collector.addDataPacket(packet); DataSweeps sweeps; collector.getDataSweeps(sweeps); BOOST_CHECK_EQUAL(sweeps.size(), 1); DataSweep sweep = sweeps.at(0); //check that the sweep data matches the packet we added BOOST_CHECK_EQUAL(sweep.nodeAddress(), 345); BOOST_CHECK_EQUAL(sweep.tick(), 1); BOOST_CHECK_EQUAL(sweep.samplingType(), DataSweep::samplingType_SyncSampling_Burst); BOOST_CHECK_EQUAL(sweep.data().size(), 0); } BOOST_AUTO_TEST_CASE(SyncPacket_IntegrityCheck_SmallPayload) { Bytes payloadBytes; payloadBytes.push_back(2); //app id payloadBytes.push_back(1); //channel mask - 1 channel payloadBytes.push_back(112); //sample rate //build a WirelessPacket WirelessPacket packet; packet.nodeAddress(345); packet.deliveryStopFlags(DeliveryStopFlags::fromInvertedByte(0)); packet.type(WirelessPacket::packetType_SyncSampling); packet.nodeRSSI(1); packet.baseRSSI(1); packet.payload(payloadBytes); //give the packet the payload bytes we created //check that the integrity check failed BOOST_CHECK_EQUAL(SyncSamplingPacket::integrityCheck(packet), false); } BOOST_AUTO_TEST_CASE(SyncPacket_IntegrityCheck_BadAppID) { Bytes payloadBytes; payloadBytes.push_back(0xFF); //app id (INVALID) payloadBytes.push_back(1); //channel mask - 1 channel payloadBytes.push_back(112); //sample rate payloadBytes.push_back(WirelessTypes::dataType_uint16_12bitRes); //data type - 2 byte uint32 shifted payloadBytes.push_back(0); //tick msb payloadBytes.push_back(1); //tick lsb payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); //channel data b1 payloadBytes.push_back(0); //channel data b2 //build a WirelessPacket WirelessPacket packet; packet.nodeAddress(345); packet.deliveryStopFlags(DeliveryStopFlags::fromInvertedByte(0)); packet.type(WirelessPacket::packetType_SyncSampling); packet.nodeRSSI(1); packet.baseRSSI(1); packet.payload(payloadBytes); //give the packet the payload bytes we created //check that the integrity check failed BOOST_CHECK_EQUAL(SyncSamplingPacket::integrityCheck(packet), false); } BOOST_AUTO_TEST_CASE(SyncPacket_IntegrityCheck_BadStopFlags) { Bytes payloadBytes; payloadBytes.push_back(2); //app id payloadBytes.push_back(1); //channel mask - 1 channel payloadBytes.push_back(112); //sample rate payloadBytes.push_back(WirelessTypes::dataType_uint16_12bitRes); //data type - 2 byte uint32 shifted payloadBytes.push_back(0); //tick msb payloadBytes.push_back(1); //tick lsb payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); //channel data b1 payloadBytes.push_back(0); //channel data b2 //build a WirelessPacket WirelessPacket packet; packet.nodeAddress(345); packet.deliveryStopFlags(DeliveryStopFlags::fromInvertedByte(15)); //INVALID DELIVERY STOP FLAGS packet.type(WirelessPacket::packetType_SyncSampling); packet.nodeRSSI(1); packet.baseRSSI(1); packet.payload(payloadBytes); //give the packet the payload bytes we created //check that the integrity check failed BOOST_CHECK_EQUAL(SyncSamplingPacket::integrityCheck(packet), false); } BOOST_AUTO_TEST_CASE(SyncPacket_IntegrityCheck_BadDataType) { Bytes payloadBytes; payloadBytes.push_back(2); payloadBytes.push_back(1); //channel mask - 1 channel payloadBytes.push_back(112); //sample rate payloadBytes.push_back(8); //(INVALID DATA TYPE) payloadBytes.push_back(0); //tick msb payloadBytes.push_back(1); //tick lsb payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); //channel data b1 payloadBytes.push_back(0); //channel data b2 //build a WirelessPacket WirelessPacket packet; packet.nodeAddress(345); packet.deliveryStopFlags(DeliveryStopFlags::fromInvertedByte(0)); packet.type(WirelessPacket::packetType_SyncSampling); packet.nodeRSSI(1); packet.baseRSSI(1); packet.payload(payloadBytes); //give the packet the payload bytes we created //check that the integrity check failed BOOST_CHECK_EQUAL(SyncSamplingPacket::integrityCheck(packet), false); } BOOST_AUTO_TEST_CASE(SyncPacket_IntegrityCheck_BadPacketType) { Bytes payloadBytes; payloadBytes.push_back(2); payloadBytes.push_back(1); //channel mask - 1 channel payloadBytes.push_back(112); //sample rate payloadBytes.push_back(WirelessTypes::dataType_uint16_12bitRes); //data type - 2 byte uint32 shifted payloadBytes.push_back(0); //tick msb payloadBytes.push_back(1); //tick lsb payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); //channel data b1 payloadBytes.push_back(0); //channel data b2 //build a WirelessPacket WirelessPacket packet; packet.nodeAddress(345); packet.deliveryStopFlags(DeliveryStopFlags::fromInvertedByte(0)); packet.type(WirelessPacket::packetType_LDC); //INVALID packet type packet.nodeRSSI(1); packet.baseRSSI(1); packet.payload(payloadBytes); //give the packet the payload bytes we created //check that the integrity check failed BOOST_CHECK_EQUAL(SyncSamplingPacket::integrityCheck(packet), false); } BOOST_AUTO_TEST_CASE(SyncPacket_IntegrityCheck_NoChannelsActive) { Bytes payloadBytes; payloadBytes.push_back(2); payloadBytes.push_back(0); //channel mask (NO CHANNELS) payloadBytes.push_back(112); //sample rate payloadBytes.push_back(WirelessTypes::dataType_uint16_12bitRes); //data type - 2 byte uint32 shifted payloadBytes.push_back(0); //tick msb payloadBytes.push_back(1); //tick lsb payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); //build a WirelessPacket WirelessPacket packet; packet.nodeAddress(345); packet.deliveryStopFlags(DeliveryStopFlags::fromInvertedByte(0)); packet.type(WirelessPacket::packetType_SyncSampling); packet.nodeRSSI(1); packet.baseRSSI(1); packet.payload(payloadBytes); //give the packet the payload bytes we created //check that the integrity check failed BOOST_CHECK_EQUAL(SyncSamplingPacket::integrityCheck(packet), false); } BOOST_AUTO_TEST_CASE(SyncPacket_IntegrityCheck_InvalidPayloadBytes) { Bytes payloadBytes; payloadBytes.push_back(2); payloadBytes.push_back(3); //channel mask - 2 channels but not enough data for 2 channels payloadBytes.push_back(112); //sample rate payloadBytes.push_back(WirelessTypes::dataType_uint16_12bitRes); //data type - 2 byte uint32 shifted payloadBytes.push_back(0); //tick msb payloadBytes.push_back(1); //tick lsb payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); //channel data b1 payloadBytes.push_back(0); //channel data b2 //build a WirelessPacket WirelessPacket packet; packet.nodeAddress(345); packet.deliveryStopFlags(DeliveryStopFlags::fromInvertedByte(0)); packet.type(WirelessPacket::packetType_SyncSampling); packet.nodeRSSI(1); packet.baseRSSI(1); packet.payload(payloadBytes); //give the packet the payload bytes we created //check that the integrity check failed BOOST_CHECK_EQUAL(SyncSamplingPacket::integrityCheck(packet), false); } BOOST_AUTO_TEST_CASE(SyncPacket_futureTimestamp) { //build the bytes for the timestamp 2 hours in the future uint8 b1, b2, b3, b4, b5, b6, b7, b8; uint64 timestamp = Utils::getCurrentSystemTime() + 7200000000000; uint32 seconds = static_cast(timestamp / 1000000000L); uint32 nanosPart = static_cast(timestamp - seconds); Utils::split_uint32(seconds, b1, b2, b3, b4); Utils::split_uint32(nanosPart, b5, b6, b7, b8); Bytes payloadBytes; payloadBytes.push_back(1); //app id payloadBytes.push_back(1); //channel mask - 1 channel payloadBytes.push_back(112); //sample rate payloadBytes.push_back(WirelessTypes::dataType_uint16_12bitRes); //data type - 2 byte uint payloadBytes.push_back(0); //tick msb payloadBytes.push_back(1); //tick lsb payloadBytes.push_back(b1); payloadBytes.push_back(b2); payloadBytes.push_back(b3); payloadBytes.push_back(b4); payloadBytes.push_back(b5); payloadBytes.push_back(b6); payloadBytes.push_back(b7); payloadBytes.push_back(b8); payloadBytes.push_back(0); //channel data b1 payloadBytes.push_back(254); //channel data b2 WirelessPacket packet; packet.nodeAddress(345); packet.deliveryStopFlags(DeliveryStopFlags::fromInvertedByte(0)); packet.type(WirelessPacket::packetType_SyncSampling); packet.nodeRSSI(1); packet.baseRSSI(1); packet.payload(payloadBytes); //give the packet the payload bytes we created //call the addDataPacket() function to parse the packet as an LDC Packet WirelessPacketCollector collector; collector.addDataPacket(packet); BOOST_CHECK_THROW(new SyncSamplingPacket(packet), Error); } //tests that timestamps are calculated correctly for sample rates 1khz and above BOOST_AUTO_TEST_CASE(SyncPacket_Constructor_TimestampIncrementFastRates) { Bytes payloadBytes; payloadBytes.push_back(2); //app id payloadBytes.push_back(1); //channel mask - 1 channel payloadBytes.push_back(WirelessTypes::sampleRate_1024Hz); //sample rate payloadBytes.push_back(WirelessTypes::dataType_float32); //data type - 4 byte float payloadBytes.push_back(0); //tick msb payloadBytes.push_back(1); //tick lsb payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); payloadBytes.push_back(0); //channel data b1 payloadBytes.push_back(0); //channel data b2 payloadBytes.push_back(0); //channel data b3 payloadBytes.push_back(0); //channel data b4 payloadBytes.push_back(1); //channel data b1 payloadBytes.push_back(1); //channel data b2 payloadBytes.push_back(1); //channel data b3 payloadBytes.push_back(1); //channel data b4 payloadBytes.push_back(2); //channel data b1 payloadBytes.push_back(2); //channel data b2 payloadBytes.push_back(2); //channel data b3 payloadBytes.push_back(2); //channel data b4 WirelessPacket packet; packet.nodeAddress(345); packet.deliveryStopFlags(DeliveryStopFlags::fromInvertedByte(0)); packet.type(WirelessPacket::packetType_SyncSampling); packet.nodeRSSI(1); packet.baseRSSI(1); packet.payload(payloadBytes); WirelessPacketCollector collector; collector.addDataPacket(packet); DataSweeps sweeps; collector.getDataSweeps(sweeps); BOOST_CHECK_EQUAL(sweeps.size(), 3); BOOST_CHECK_EQUAL(sweeps.at(0).timestamp().nanoseconds(), 0); BOOST_CHECK_EQUAL(sweeps.at(1).timestamp().nanoseconds(), 976562); //actually 976562.5 but we can't represent that in nanoseconds BOOST_CHECK_EQUAL(sweeps.at(2).timestamp().nanoseconds(), 1953125); //takes into account the 0.5 nanoseconds from the last incremental } BOOST_AUTO_TEST_SUITE_END()