openrtx_link.hh

#ifndef OPENRTXLINK_HH
#define OPENRTXLINK_HH
 
#include <QObject>
#include <QHash>
#include <QIODevice>
#include "packetstream.hh"
 
// Forward declaration
class OpenRTXLink;
class OpenRTXLinkStream;
class OpenRTXLinkDatagram;
class OpenRTXCAT;
 

class OpenRTXLink: public QObject
{
  Q_OBJECT
 
protected:
  enum class Protocol {
    Stdio = 0, CAT = 1, FMP = 2, XMODEM = 3
  };
 
public:
  explicit OpenRTXLink(PacketStream *link, QObject *parent = nullptr);
  virtual ~OpenRTXLink();
 
  virtual bool isOpen() const;
  virtual void close();

  OpenRTXLinkStream *stdio() const;
  OpenRTXCAT *cat() const;
  OpenRTXLinkDatagram *fmp() const;
  OpenRTXLinkStream *xmodem() const;

  unsigned int timeout() const;
 
protected:
  bool receive(Protocol proto, QByteArray &data, int timeout=-1, const ErrorStack &err=ErrorStack());
  bool send(Protocol proto, const QByteArray &data, int timeout=-1, const ErrorStack &err=ErrorStack());
 
  static uint16_t crc16(const QByteArray &data);
 
protected:
  PacketStream *_link;
  QHash<unsigned int, QList<QByteArray>> _inBuffers;
  OpenRTXLinkStream *_stdio;
  OpenRTXCAT        *_cat;
  OpenRTXLinkDatagram *_fmp;
  OpenRTXLinkStream *_xmodem;
  unsigned int _timeout;
 
  friend class OpenRTXLinkStream;
  friend class OpenRTXLinkDatagram;
  friend class OpenRTXCAT;
};
 

class OpenRTXLinkStream: public QIODevice
{
  Q_OBJECT
 
protected:
  OpenRTXLinkStream(OpenRTXLink::Protocol proto, OpenRTXLink *link);
 
protected:
  qint64 writeData(const char *data, qint64 len);
  qint64 readData(char *data, qint64 maxlen);
 
protected:
  OpenRTXLink::Protocol _proto;
  QByteArray _inBuffer;
  OpenRTXLink *_link;
 
  friend class OpenRTXLink;
};
 
 
class OpenRTXLinkDatagram: public PacketStream
{
  Q_OBJECT
 
protected:
  OpenRTXLinkDatagram(OpenRTXLink::Protocol proto, OpenRTXLink *link);
 
public:
  bool isOpen() const override;
  void close() override;
  bool receive(QByteArray &buffer, int timeout, const ErrorStack &err) override;
  bool send(const QByteArray &buffer, int timeout, const ErrorStack &err) override;
 
protected:
  OpenRTXLink::Protocol _proto;
  OpenRTXLink *_link;
 
  friend class OpenRTXLink;
};
 

class OpenRTXCAT: public OpenRTXLinkDatagram
{
  Q_OBJECT
 
protected:
  explicit OpenRTXCAT(OpenRTXLink *link);
 
public:
  QByteArray info(const ErrorStack &err=ErrorStack());
  bool enterFMPMode(const ErrorStack &err=ErrorStack());
 
protected:
  friend class OpenRTXLink;
};
 
#endif // OPENRTXLINK_HH