source: smplayer/trunk/src/myclient.cpp@ 112

/*  smplayer, GUI front-end for mplayer.
    Copyright (C) 2006-2010 Ricardo Villalba <rvm@escomposlinux.org>

    This program is free software; you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation; either version 2 of the License, or
    (at your option) any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program; if not, write to the Free Software
    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
*/

#include "myclient.h"
#include <QTcpSocket>
#include <QTextStream>
#include <QHostAddress>
#include <QRegExp>

MyClient::MyClient(quint16 port, QObject * parent) : QObject(parent) 
{
        qDebug("MyClient::MyClient");

        this->port = port;
        timeout = 200;

        socket = new QTcpSocket(this);
}

MyClient::~MyClient() {
        delete socket;
}

QString MyClient::readLine() {
        QString line;

        int n = 0;
        while (!socket->canReadLine() && n < 5) {
                //qDebug("Bytes available: %d", (int) socket->bytesAvailable());
                socket->waitForReadyRead( timeout );
                n++;
        }
        if (socket->canReadLine()) {
                line = QString::fromUtf8(socket->readLine());
                line.remove( QRegExp("[\r\n]") );
        qDebug("MyClient::readLine: '%s'", line.toUtf8().data());
        } 

        return line;
}

void MyClient::writeLine(QString l) {
        socket->write( l.toUtf8() );
        socket->flush();
        socket->waitForBytesWritten( timeout );
}

bool MyClient::openConnection() {
        socket->connectToHost( QHostAddress::LocalHost, port, QIODevice::ReadWrite);
        if (!socket->waitForConnected( timeout )) return false; // Can't connect

        QString line = readLine();
        if (!line.startsWith("SMPlayer")) return false;
        qDebug("MyClient::sendFiles: connected to a SMPlayer instance!");

        line = readLine(); // Read help message

        return true;
}


bool MyClient::sendFiles( const QStringList & files, bool addToPlaylist) {
        QString line;

        writeLine("open_files_start\r\n");
        line = readLine();
        if (!line.startsWith("OK")) return false;

        for (int n=0; n < files.count(); n++) {
                writeLine("open_files " + files[n] + "\r\n");
                line = readLine();
                if (!line.startsWith("OK")) return false;
        }

        if (!addToPlaylist) 
                writeLine("open_files_end\r\n");
        else
                writeLine("add_files_end\r\n");

        writeLine("quit\r\n");

        do {
                line = readLine();
        } while (!line.isNull());

        /*
        socket->disconnectFromHost();
        socket->waitForDisconnected( timeout );
        */

        return true;
}

bool MyClient::sendAction( const QString & action ) {
        QString line;

        writeLine("f " + action + "\r\n");
        line = readLine();
        if (!line.startsWith("OK")) return false;

        /*
        socket->disconnectFromHost();
        socket->waitForDisconnected( timeout );
        */

        return true;
}

bool MyClient::sendSubtitleFile(const QString & file) {
        QString line;

        writeLine("load_sub " + file + "\r\n");
        line = readLine();
        if (!line.startsWith("OK")) return false;

        return true;
}

void MyClient::closeConnection() {
        socket->disconnectFromHost();
        socket->waitForDisconnected( timeout );
}