rt_cmd_client.h

Go to the documentation of this file.

//=============================================================================================================
 
#ifndef RTCMDCLIENT_H
#define RTCMDCLIENT_H
 
//=============================================================================================================
// INCLUDES
//=============================================================================================================
 
#include "../com_global.h"
#include "../rt_command/command_manager.h"
#include "../rt_command/command.h"
 
//=============================================================================================================
// QT INCLUDES
//=============================================================================================================
 
#include <QDataStream>
#include <QMutex>
#include <QSharedPointer>
#include <QString>
#include <QTcpSocket>
 
//=============================================================================================================
// DEFINE NAMESPACE COMLIB
//=============================================================================================================
 
namespace COMLIB
{
 
//=============================================================================================================
class COMSHARED_EXPORT RtCmdClient : public QTcpSocket
{
    Q_OBJECT
 
public:
    typedef QSharedPointer<RtCmdClient> SPtr;            
    typedef QSharedPointer<const RtCmdClient> ConstSPtr; 
 
    //=========================================================================================================
    explicit RtCmdClient(QObject *parent = Q_NULLPTR);
 
    //=========================================================================================================
    inline bool hasCommand(const QString &p_sCommand) const;
 
    //=========================================================================================================
    QString sendCLICommand(const QString &p_sCommand);
 
    //=========================================================================================================
    void sendCommandJSON(const Command &p_command);
 
    //=========================================================================================================
    inline QString readAvailableData();
 
    //=========================================================================================================
    qint32 requestBufsize();
 
    //=========================================================================================================
    void requestCommands();
 
    //=========================================================================================================
    qint32 requestConnectors(QMap<qint32, QString> &p_qMapConnectors);
 
    //=========================================================================================================
    bool waitForDataAvailable(qint32 msecs = 30000) const;
 
    //=========================================================================================================
    Command& operator[] (const QString &key);
 
    //=========================================================================================================
    const Command operator[] (const QString &key) const;
 
signals:
    //=========================================================================================================
    void response(QString p_sResponse);
 
private:
    CommandManager  m_commandManager;   
    QMutex          m_qMutex;           
    QString         m_sAvailableData;   
};
 
//=============================================================================================================
// INLINE DEFINITIONS
//=============================================================================================================
 
inline QString RtCmdClient::readAvailableData()
{
    m_qMutex.lock();
    QString p_sResponse = m_sAvailableData;
    m_sAvailableData.clear();
    m_qMutex.unlock();
 
    return p_sResponse;
}
 
//=============================================================================================================
 
inline bool RtCmdClient::hasCommand(const QString &p_sCommand) const
{
    return m_commandManager.hasCommand(p_sCommand);
}
} // NAMESPACE
 
#endif // RTCMDCLIENT_H