SLIPStream.hpp

Go to the documentation of this file.

#pragma once
 
#include <SLIPStream/SLIPParser.hpp>
#include <SLIPStream/SLIPSender.hpp>
#include <Stream.h>
 
 
class SLIPStream {
  public:
    struct StreamSender {
        StreamSender(Stream &stream) : stream(&stream) {}
        StreamSender(Stream *stream) : stream(stream) {}
        size_t operator()(uint8_t c) const { return stream->write(c); }
        Stream *stream;
    };
 
  public:
    SLIPStream(Stream &stream, const SLIPParser &parser)
        : stream(&stream), parser(parser) {}
    SLIPStream(Stream &stream) : stream(&stream), parser(nullptr, 0) {}
 
    size_t writePacket(const uint8_t *data, size_t len);
 
    size_t beginPacket();
    size_t write(const uint8_t *data, size_t len);
    size_t endPacket();
 
    size_t readPacket();
 
    bool wasTruncated() const { return parser.wasTruncated(); }
 
    size_t numTruncated() const { return parser.numTruncated(); }
 
  private:
    Stream *stream;
    SLIPParser parser;
};
 
 
 
template <class CRC>
class SLIPStreamCRC {
  public:
    using StreamSender = SLIPStream::StreamSender;
 
    SLIPStreamCRC(Stream &stream, CRC &&senderCRC, const SLIPParser &parser,
                  CRC &&parserCRC)
        : stream(&stream), sender(stream, std::forward<CRC>(senderCRC)),
          parser(parser, std::forward<CRC>(parserCRC)) {}
 
    size_t writePacket(const uint8_t *data, size_t len);
 
    size_t beginPacket();
    size_t write(const uint8_t *data, size_t len);
    size_t endPacket();
 
    size_t readPacket();
 
    bool wasTruncated() const { return parser.wasTruncated(); }
    size_t numTruncated() const { return parser.numTruncated(); }
 
    using checksum_t = typename SLIPParserCRC<CRC>::checksum_t;
 
    checksum_t checksum() const { return parser.checksum(); }
 
  private:
    Stream *stream;
    SLIPSenderCRC<StreamSender, CRC> sender;
    SLIPParserCRC<CRC> parser;
};
 
 
#include "SLIPStream.ipp"