kopia lustrzana https://gitlab.com/eliggett/wfview
108 wiersze
2.1 KiB
C++
108 wiersze
2.1 KiB
C++
#ifndef TCISERVER_H
|
|
#define TCISERVER_H
|
|
|
|
#include <QObject>
|
|
#include <QtWebSockets/QtWebSockets>
|
|
#include <QtWebSockets/QWebSocketServer>
|
|
|
|
#include "audioconverter.h"
|
|
#include "cachingqueue.h"
|
|
|
|
/* Opus and Eigen */
|
|
#ifdef Q_OS_WIN
|
|
#include <Eigen/Eigen>
|
|
#else
|
|
#include <eigen3/Eigen/Eigen>
|
|
#endif
|
|
|
|
#define TCI_AUDIO_LENGTH 4096
|
|
struct tciCommandStruct
|
|
{
|
|
const char *str;
|
|
funcs func;
|
|
valueType arg1;
|
|
valueType arg2;
|
|
valueType arg3;
|
|
};
|
|
|
|
|
|
class tciServer : public QObject
|
|
{
|
|
Q_OBJECT
|
|
|
|
static constexpr quint32 iqHeaderSize = 16u*sizeof(quint32);
|
|
static constexpr quint32 iqBufferSize = 2048u;
|
|
|
|
typedef enum
|
|
{
|
|
IqInt16 = 0,
|
|
IqInt24,
|
|
IqInt32,
|
|
IqFloat32,
|
|
IqFloat64
|
|
}iqDataType;
|
|
|
|
typedef enum
|
|
{
|
|
IqStream = 0,
|
|
RxAudioStream,
|
|
TxAudioStream,
|
|
TxChrono,
|
|
}streamType;
|
|
|
|
typedef struct
|
|
{
|
|
quint32 receiver;
|
|
quint32 sampleRate;
|
|
quint32 format;
|
|
quint32 codec;
|
|
quint32 crc;
|
|
quint32 length;
|
|
quint32 type;
|
|
quint32 reserv[9];
|
|
float data[TCI_AUDIO_LENGTH];
|
|
}dataStream;
|
|
|
|
struct connStatus {
|
|
bool connected=true;
|
|
bool rxaudio=false;
|
|
bool txaudio=false;
|
|
};
|
|
|
|
|
|
public:
|
|
explicit tciServer(QObject *parent = nullptr);
|
|
~tciServer();
|
|
|
|
signals:
|
|
void closed();
|
|
void sendTCIAudio(QByteArray audio);
|
|
|
|
public slots:
|
|
void receiveTCIAudio(audioPacket audio);
|
|
void receiveRigCaps(rigCapabilities* caps);
|
|
void init(quint16 port);
|
|
|
|
|
|
private slots:
|
|
void onNewConnection();
|
|
void processIncomingTextMessage(QString message);
|
|
void processIncomingBinaryMessage(QByteArray message);
|
|
void socketDisconnected();
|
|
void receiveCache(cacheItem item);
|
|
void setupTxPacket(int packetLen);
|
|
|
|
private:
|
|
QWebSocketServer *server;
|
|
QMap<QWebSocket *, connStatus> clients;
|
|
cachingQueue *queue;
|
|
QByteArray rxAudioData;
|
|
QByteArray txAudioData;
|
|
QByteArray txChrono;
|
|
rigCapabilities* rigCaps = Q_NULLPTR;
|
|
QString tciMode(modeInfo m);
|
|
modeInfo rigMode(QString);
|
|
};
|
|
|
|
#endif // TCISERVER_H
|