101 lines
3.5 KiB
C++
101 lines
3.5 KiB
C++
#include "qnetwork.h"
|
|
|
|
#include <QCoreApplication>
|
|
#include <QMetaEnum>
|
|
|
|
const char *const FormBoundary = "----GangphonQtBoundary_.oOo._";
|
|
|
|
QNetworkAccessManager *netAccess() {
|
|
static QNetworkAccessManager access;
|
|
return &access;
|
|
};
|
|
|
|
QString errStr(QNetworkReply *reply) {
|
|
reply->deleteLater();
|
|
auto error = reply->error();
|
|
if(error != QNetworkReply::NoError) {
|
|
if(error==QNetworkReply::OperationCanceledError) return "TimeoutError ("+QString::number(QNetworkReply::TimeoutError)+") "+QCoreApplication::translate("Net","Connection Timeout");
|
|
auto errStr = reply->errorString();
|
|
if(error!=QNetworkReply::InternalServerError || ! errStr.endsWith("replied: Unknown")) return QString(QMetaEnum::fromType<QNetworkReply::NetworkError>().valueToKey(error))+" ("+QString::number(error)+") "+errStr;
|
|
}
|
|
auto status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
|
|
if(status != 200) return QString::number(status)+" "+reply->attribute(QNetworkRequest::HttpReasonPhraseAttribute).toString();
|
|
return "";
|
|
}
|
|
QString errStrWithData(QNetworkReply *reply, JValue *outJson) {
|
|
auto err = errStr(reply);
|
|
if(! err.isEmpty()) {
|
|
auto data = reply->readAll();
|
|
if(! data.isEmpty()) err += "\n"+data;
|
|
return err;
|
|
}
|
|
if(outJson) {
|
|
auto data = reply->readAll();
|
|
QString error;
|
|
*outJson = JFrom(data, &error);
|
|
if(! error.isEmpty()) return "JSON "+QCoreApplication::translate("Net","Error")+": "+error+"\n"+data;
|
|
}
|
|
return "";
|
|
}
|
|
|
|
QString errStrWithData(QNetworkReply *reply, QJsonDocument *outJson) {
|
|
auto err = errStr(reply);
|
|
if(! err.isEmpty()) {
|
|
auto data = reply->readAll();
|
|
if(! data.isEmpty()) err += "\n"+data;
|
|
return err;
|
|
}
|
|
if(outJson) {
|
|
auto data = reply->readAll();
|
|
QJsonParseError jsonErr;
|
|
*outJson = QJsonDocument::fromJson(data, &jsonErr);
|
|
if(jsonErr.error != QJsonParseError::NoError) return "JSON "+QCoreApplication::translate("Net","Error")+": "+jsonErr.errorString()+"\n"+data;
|
|
}
|
|
return "";
|
|
}
|
|
|
|
|
|
const char* socketErrKey(int value) {
|
|
static auto metaEnum = QMetaEnum::fromType<QAbstractSocket::SocketError>();
|
|
return metaEnum.valueToKey(value);
|
|
}
|
|
|
|
bool TcpSocket::waitForConnected(int msecs) {
|
|
if(state() == ConnectedState) return true;
|
|
QEventLoop loop;
|
|
connect(this, &QTcpSocket::connected, &loop, &QEventLoop::quit);
|
|
return connAndExec(msecs, &loop);
|
|
}
|
|
bool TcpSocket::waitForDisconnected(int msecs) {
|
|
if(state() == UnconnectedState) return true;
|
|
QEventLoop loop;
|
|
connect(this, &QTcpSocket::disconnected, &loop, &QEventLoop::quit);
|
|
return connAndExec(msecs, &loop);
|
|
}
|
|
bool TcpSocket::waitForBytesWritten(int msecs) {
|
|
if(bytesToWrite() == 0) return true;
|
|
QEventLoop loop;
|
|
connect(this, &QTcpSocket::bytesWritten, &loop, &QEventLoop::quit);
|
|
return connAndExec(msecs, &loop);
|
|
}
|
|
bool TcpSocket::waitForReadyRead(int msecs) {
|
|
if(bytesAvailable()) return true;
|
|
QEventLoop loop;
|
|
connect(this, &QTcpSocket::readyRead, &loop, &QEventLoop::quit);
|
|
return connAndExec(msecs, &loop);
|
|
}
|
|
|
|
bool TcpSocket::connAndExec(int msecs, QEventLoop *loop) {
|
|
connect(this, &QTcpSocket::errorOccurred, loop, [loop] {
|
|
loop->exit(1);
|
|
});
|
|
if(timerId) {
|
|
killTimer(timerId);
|
|
timerId = 0;
|
|
}
|
|
if(msecs > 0) startTimer(msecs);
|
|
auto res = loop->exec();
|
|
stopTimer();
|
|
return res==0;
|
|
}
|