qavrgserver.cpp

Go to the documentation of this file.

#include "qavrgserver.h"

#include <QTcpSocket>
#include <QTextStream>
#include "qavrgscriptingengine.h"

QavrgServer::QavrgServer(QObject *parent)
  : inherited(parent),
    m_Socket(NULL)
{
  connect(this, SIGNAL(newConnection()),
          this, SLOT(openNewConnection()));
}

void
QavrgServer::startServer(QHostAddress addr, int port)
{
  setMaxPendingConnections(1);

  if (isListening()) {
    close();
  }

  if (!listen(addr, port)) {
    emit printMessage(tr("Failed to bind to address %1 port %2")
                      .arg(addr.toString()).arg(port));
  }
}

void
QavrgServer::openNewConnection()
{
  m_Socket = nextPendingConnection();

  connect(m_Socket, SIGNAL(disconnected()),
          m_Socket, SLOT(deleteLater()));

  connect(m_Socket, SIGNAL(readyRead()),
          this,     SLOT(clientRead()));

  emit printMessage(tr("New connection from %1")
                     .arg(m_Socket->peerAddress().toString()) );

  connect(m_Socket, SIGNAL(disconnected()),
          this,     SLOT(connectionClosed()));
}

void
QavrgServer::connectionClosed()
{
  emit printMessage("Client closed connection");
}

void
QavrgServer::clientRead()
{
  QTextStream ts( m_Socket );

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

    emit printMessage(tr("Command: %1 received").arg(str));
    
    emit executeCommand(str);
  }
}

void
QavrgServer::finishedCommand(QScriptValue result)
{
  emit printMessage(tr("Result: %1").arg(result.toString()));

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