#pragma once
#include "AftrConfig.h"
#ifdef AFTR_CONFIG_USE_BOOST
#include "AftrSerialPortGeneralByteData.h"
#include <boost/asio.hpp>
#include <boost/thread.hpp>
#include <queue>
#include <string>
#include "AftrADSBComMsg.h"
#include "NetMessengerStreamBuffer.h"

namespace Aftr
{

class AftrSerialPortADSBComBinary : public AftrSerialPortGeneralByteData
{
public:
   static AftrSerialPortADSBComBinary* New();
   virtual ~AftrSerialPortADSBComBinary();
   
   /**
      Returns true iff outMsg is updated to the latest valid unread packet. If no unread valid packet 
      exists, false is returned and the parameter is not modified.
   */
   bool getLatestUnreadPacket( AftrADSBComMsg& outMsg );

   virtual void sendADSBMsgAsync( const AftrADSBComMsg& msg );

   static void AftrSerialPortADSBComTEST(  const std::string& s );


protected:
   AftrSerialPortADSBComBinary();
   virtual void onCreate();
   virtual void start();
   virtual void onRecvData( const boost::system::error_code& error, size_t bytesReceived );

   /// hasUnreadPacket has validated the input to be in the correct format; this method
   /// verifies that the data is actually correct according to a summation checksum over
   /// the packet data.
   /// Returns true if a valid packet has been received. If true, newMsg is updated to hold
   /// the new data. If false, newMsg is NOT modified and false is returned.
   bool validateChecksum( const std::string& s, AftrADSBComMsg& newMsg );

   bool processMsg( std::vector< unsigned char >& data, size_t startIdx, AftrADSBComMsg& outMsg );

   bool HasUnreadPacket;
   //AftrADSBComMsg lastCompleteMsg; ///< Stores that last fully received and checksummed received packet
   static const unsigned int MAX_ADSB_MSG_LEN = AftrADSBComMsg::BINARY_MSG_LEN_BYTES; ///< Max number of bytes a message may be
   std::vector< unsigned char > latestIncompletePkt;

   unsigned char* msgBuf;
};

} //namespace Aftr

#endif