mirror of
https://github.com/YACReader/yacreader
synced 2025-06-04 01:28:55 -04:00
116 lines
2.7 KiB
C++
116 lines
2.7 KiB
C++
#include "yacreader_local_client.h"
|
|
#include "comic_db.h"
|
|
#include "yacreader_global.h"
|
|
|
|
#include <QLocalSocket>
|
|
|
|
YACReaderLocalClient::YACReaderLocalClient(QObject *parent) :
|
|
QObject(parent)
|
|
{
|
|
localSocket = new QLocalSocket(this);
|
|
|
|
//connect(localSocket, SIGNAL(readyRead()), this, SLOT(readMessage()));
|
|
|
|
/*connect(socket, SIGNAL(error(QLocalSocket::LocalSocketError)),
|
|
this, SLOT(displayError(QLocalSocket::LocalSocketError)));*/
|
|
}
|
|
|
|
//información de comic recibida...
|
|
void YACReaderLocalClient::readMessage()
|
|
{
|
|
|
|
}
|
|
|
|
bool YACReaderLocalClient::requestComicInfo(quint64 libraryId, ComicDB & comic, QList<ComicDB> & siblings)
|
|
{
|
|
localSocket->connectToServer(YACREADERLIBRARY_GUID);
|
|
if(localSocket->isOpen())
|
|
{
|
|
QByteArray block;
|
|
QDataStream out(&block, QIODevice::WriteOnly);
|
|
out.setVersion(QDataStream::Qt_4_8);
|
|
out << (quint16)0;
|
|
out << (quint8)YACReaderIPCMessages::RequestComicInfo;
|
|
out << libraryId;
|
|
out << comic;
|
|
out.device()->seek(0);
|
|
out << (quint16)(block.size() - sizeof(quint16));
|
|
|
|
int written = 0;
|
|
int tries = 0;
|
|
while(written != block.size() && tries < 200)
|
|
{
|
|
written += localSocket->write(block);
|
|
localSocket->flush();
|
|
tries++;
|
|
}
|
|
if(tries == 200)
|
|
return false;
|
|
|
|
//QByteArray data;
|
|
tries = 0;
|
|
while(localSocket->bytesAvailable() < sizeof(quint16) && tries < 200)
|
|
{
|
|
localSocket->waitForReadyRead(10);
|
|
tries++;
|
|
}
|
|
if(tries == 200)
|
|
return false;
|
|
QDataStream sizeStream(localSocket->read(sizeof(quint16)));
|
|
sizeStream.setVersion(QDataStream::Qt_4_8);
|
|
quint16 totalSize = 0;
|
|
sizeStream >> totalSize;
|
|
|
|
tries = 0;
|
|
while(localSocket->bytesAvailable() < totalSize && tries < 200 )
|
|
{
|
|
localSocket->waitForReadyRead(10);
|
|
tries++;
|
|
}
|
|
if(tries == 200)
|
|
return false;
|
|
QDataStream dataStream(localSocket->read(totalSize));
|
|
dataStream >> comic;
|
|
dataStream >> siblings;
|
|
return true;
|
|
}
|
|
else
|
|
return false;
|
|
}
|
|
|
|
bool YACReaderLocalClient::sendComicInfo(quint64 libraryId, ComicDB & comic)
|
|
{
|
|
localSocket->connectToServer(YACREADERLIBRARY_GUID);
|
|
if(localSocket->isOpen())
|
|
{
|
|
QByteArray block;
|
|
QDataStream out(&block, QIODevice::WriteOnly);
|
|
out.setVersion(QDataStream::Qt_4_8);
|
|
out << (quint16)0;
|
|
out << (quint8)YACReaderIPCMessages::SendComicInfo;
|
|
out << libraryId;
|
|
out << comic;
|
|
out.device()->seek(0);
|
|
out << (quint16)(block.size() - sizeof(quint16));
|
|
|
|
int written = 0;
|
|
int tries = 0;
|
|
while(written != block.size() && tries < 100)
|
|
{
|
|
written += localSocket->write(block);
|
|
tries++;
|
|
}
|
|
if(tries == 100 && written != block.size())
|
|
{
|
|
emit finished();
|
|
return false;
|
|
}
|
|
emit finished();
|
|
return true;
|
|
}
|
|
|
|
emit finished();
|
|
return false;
|
|
|
|
}
|