qpidserversession.cpp

Go to the documentation of this file.

#include <QHostAddress>
#include "qpidserversession.h"
#include "qpiddebug.h"
#include "qpidcontroller.h"
#include "qpidserver.h"

QPidServerSession::QPidServerSession(QPidServerWPtr server, QPidControllerWPtr ctrl, QTcpSocketPtr socket) :
  QObject(),
  m_Server(server),
  m_Controller(ctrl),
  m_Socket(socket)
{
  connect(m_Socket.data(), SIGNAL(readyRead()), this,     SLOT(clientRead()));

  if (qcepDebug(DEBUG_SERVER)) {
    printMessage(tr("New connection from %1").arg(m_Socket->peerAddress().toString()) );
  }

  connect(m_Socket.data(), SIGNAL(disconnected()), this,     SLOT(connectionClosed()));
//  connect(m_Socket.data(), SIGNAL(disconnected()), m_Socket.data(), SLOT(deleteLater()));
}

void QPidServerSession::printMessage(QString msg, QDateTime ts)
{
  QPidControllerPtr ctl(m_Controller);

  if (ctl) {
    ctl->printMessage(msg, ts);
  }
}

void QPidServerSession::clientRead()
{
  QTextStream ts( m_Socket.data() );

  while ( m_Socket->canReadLine() ) {
    QString str = ts.readLine();

    if (qcepDebug(DEBUG_SERVER)) {
      printMessage(tr("Command: %1 received").arg(str));
    }

    QPidControllerPtr ctl(m_Controller);

    if (ctl) {
      INVOKE_CHECK(
            QMetaObject::invokeMethod(ctl.data(), "executeServerCommand",
                                      Q_ARG(QPidServerSessionWPtr, QPidServerSessionPtr(this)),
                                      Q_ARG(QString, str)));
    }
  }
}

void QPidServerSession::finishedCommand(QScriptValue result)
{
  if (qcepDebug(DEBUG_SERVER)) {
    printMessage(tr("Result: %1").arg(result.toString()));
  }

  if (m_Socket && (m_Socket->isWritable())) {
    m_Socket -> write(qPrintable(result.toString()+"\n"));
  }
}

void QPidServerSession::connectionClosed()
{
  if (qcepDebug(DEBUG_SERVER)) {
    printMessage("Client closed connection");
  }

  QPidServerPtr server(m_Server);

  if (server) {
    server->deleteSession(QPidServerSessionPtr(this));
  }
}