aboutsummaryrefslogtreecommitdiffstats
path: root/src/modules/objects/KvsObject_http.cpp
diff options
context:
space:
mode:
authorGravatar Alexey Sokolov2016-04-29 23:57:30 +0100
committerGravatar Alexey Sokolov2016-04-29 23:57:48 +0100
commit690dd7a33ddc90678367d73adf313533536e10f2 (patch)
tree2276fe7c384ebbc222b40a19c536d5c3c5606ce8 /src/modules/objects/KvsObject_http.cpp
parentAdd config for clang-format. (diff)
downloadKVIrc-690dd7a33ddc90678367d73adf313533536e10f2.tar.gz
KVIrc-690dd7a33ddc90678367d73adf313533536e10f2.tar.bz2
KVIrc-690dd7a33ddc90678367d73adf313533536e10f2.zip
Apply clang-format
Diffstat (limited to 'src/modules/objects/KvsObject_http.cpp')
-rw-r--r--src/modules/objects/KvsObject_http.cpp503
1 files changed, 272 insertions, 231 deletions
diff --git a/src/modules/objects/KvsObject_http.cpp b/src/modules/objects/KvsObject_http.cpp
index 7a83bbc10..2840b08d3 100644
--- a/src/modules/objects/KvsObject_http.cpp
+++ b/src/modules/objects/KvsObject_http.cpp
@@ -35,35 +35,35 @@
#include <QUrl>
#ifndef QT_NO_OPENSSL
- #include <QSslError>
+#include <QSslError>
- const char * const ssl_errors_tbl[] = {
- "NoError",
- "UnableToGetIssuerCertificate",
- "UnableToDecryptCertificateSignature",
- "UnableToDecodeIssuerPublicKey",
- "CertificateSignatureFailed",
- "CertificateNotYetValid",
- "CertificateExpired",
- "InvalidNotBeforeField",
- "InvalidNotAfterField",
- "SelfSignedCertificate",
- "SelfSignedCertificateInChain",
- "UnableToGetLocalIssuerCertificate",
- "UnableToVerifyFirstCertificate",
- "CertificateRevoked",
- "InvalidCaCertificate",
- "PathLengthExceeded",
- "InvalidPurpose",
- "CertificateUntrusted",
- "CertificateRejected",
- "SubjectIssuerMismatch",
- "AuthorityIssuerSerialNumberMismatch",
- "NoPeerCertificate",
- "HostNameMismatch",
- "UnspecifiedError",
- "NoSslSupport"
- };
+const char * const ssl_errors_tbl[] = {
+ "NoError",
+ "UnableToGetIssuerCertificate",
+ "UnableToDecryptCertificateSignature",
+ "UnableToDecodeIssuerPublicKey",
+ "CertificateSignatureFailed",
+ "CertificateNotYetValid",
+ "CertificateExpired",
+ "InvalidNotBeforeField",
+ "InvalidNotAfterField",
+ "SelfSignedCertificate",
+ "SelfSignedCertificateInChain",
+ "UnableToGetLocalIssuerCertificate",
+ "UnableToVerifyFirstCertificate",
+ "CertificateRevoked",
+ "InvalidCaCertificate",
+ "PathLengthExceeded",
+ "InvalidPurpose",
+ "CertificateUntrusted",
+ "CertificateRejected",
+ "SubjectIssuerMismatch",
+ "AuthorityIssuerSerialNumberMismatch",
+ "NoPeerCertificate",
+ "HostNameMismatch",
+ "UnspecifiedError",
+ "NoSslSupport"
+};
#endif
/*
@@ -151,410 +151,451 @@
This signal is emitted by the default implementation of [classfnc]$responseHeaderReceivedEvent[/classfnc].
*/
-KVSO_BEGIN_REGISTERCLASS(KvsObject_http,"http","object")
- KVSO_REGISTER_HANDLER(KvsObject_http,"get",functionGet)
- KVSO_REGISTER_HANDLER(KvsObject_http,"post",functionPost)
- KVSO_REGISTER_HANDLER(KvsObject_http,"abort",functionAbort)
- KVSO_REGISTER_HANDLER(KvsObject_http,"setHost",functionSetHost)
- KVSO_REGISTER_HANDLER(KvsObject_http,"setProxy",functionSetProxy)
- KVSO_REGISTER_HANDLER(KvsObject_http,"currentId",functionCurrentId)
- KVSO_REGISTER_HANDLER(KvsObject_http,"setUser",functionSetUser)
- KVSO_REGISTER_HANDLER(KvsObject_http,"readAll",functionReadAll)
- KVSO_REGISTER_HANDLER(KvsObject_http,"errorString",functionErrorString)
- KVSO_REGISTER_HANDLER(KvsObject_http,"setFollowRedirect",functionFollowRedirect)
+KVSO_BEGIN_REGISTERCLASS(KvsObject_http, "http", "object")
+KVSO_REGISTER_HANDLER(KvsObject_http, "get", functionGet)
+KVSO_REGISTER_HANDLER(KvsObject_http, "post", functionPost)
+KVSO_REGISTER_HANDLER(KvsObject_http, "abort", functionAbort)
+KVSO_REGISTER_HANDLER(KvsObject_http, "setHost", functionSetHost)
+KVSO_REGISTER_HANDLER(KvsObject_http, "setProxy", functionSetProxy)
+KVSO_REGISTER_HANDLER(KvsObject_http, "currentId", functionCurrentId)
+KVSO_REGISTER_HANDLER(KvsObject_http, "setUser", functionSetUser)
+KVSO_REGISTER_HANDLER(KvsObject_http, "readAll", functionReadAll)
+KVSO_REGISTER_HANDLER(KvsObject_http, "errorString", functionErrorString)
+KVSO_REGISTER_HANDLER(KvsObject_http, "setFollowRedirect", functionFollowRedirect)
- // events
- KVSO_REGISTER_HANDLER(KvsObject_http,"doneEvent",functionDoneEvent)
- KVSO_REGISTER_HANDLER(KvsObject_http,"requestFinishedEvent",functionRequestFinishedEvent)
- KVSO_REGISTER_HANDLER(KvsObject_http,"requestStartedEvent",functionRequestStartedEvent)
- KVSO_REGISTER_HANDLER(KvsObject_http,"responseHeaderReceivedEvent",functionResponseHeaderReceivedEvent)
- KVSO_REGISTER_HANDLER(KvsObject_http,"dataReadProgressEvent",functionDataReadProgressEvent)
- KVSO_REGISTER_HANDLER(KvsObject_http,"dataSendProgressEvent",functionDataSendProgressEvent)
- KVSO_REGISTER_HANDLER(KvsObject_http,"stateChangedEvent",functionStateChangedEvent)
- KVSO_REGISTER_HANDLER(KvsObject_http,"readyReadEvent",functionReadyReadEvent)
- #ifndef QT_NO_OPENSSL
- KVSO_REGISTER_HANDLER(KvsObject_http,"sslErrorsEvent",functionSslErrorsEvent)
- KVSO_REGISTER_HANDLER(KvsObject_http,"ignoreSSlErrors",functionIgnoreSslErrors)
- #endif
+// events
+KVSO_REGISTER_HANDLER(KvsObject_http, "doneEvent", functionDoneEvent)
+KVSO_REGISTER_HANDLER(KvsObject_http, "requestFinishedEvent", functionRequestFinishedEvent)
+KVSO_REGISTER_HANDLER(KvsObject_http, "requestStartedEvent", functionRequestStartedEvent)
+KVSO_REGISTER_HANDLER(KvsObject_http, "responseHeaderReceivedEvent", functionResponseHeaderReceivedEvent)
+KVSO_REGISTER_HANDLER(KvsObject_http, "dataReadProgressEvent", functionDataReadProgressEvent)
+KVSO_REGISTER_HANDLER(KvsObject_http, "dataSendProgressEvent", functionDataSendProgressEvent)
+KVSO_REGISTER_HANDLER(KvsObject_http, "stateChangedEvent", functionStateChangedEvent)
+KVSO_REGISTER_HANDLER(KvsObject_http, "readyReadEvent", functionReadyReadEvent)
+#ifndef QT_NO_OPENSSL
+KVSO_REGISTER_HANDLER(KvsObject_http, "sslErrorsEvent", functionSslErrorsEvent)
+KVSO_REGISTER_HANDLER(KvsObject_http, "ignoreSSlErrors", functionIgnoreSslErrors)
+#endif
KVSO_END_REGISTERCLASS(KvsObject_http)
+KVSO_BEGIN_CONSTRUCTOR(KvsObject_http, KviKvsObject)
+m_pHttp = new QHttp();
+m_bAbort = false;
+m_bEnableForceRedirect = false;
+connect(m_pHttp, SIGNAL(requestFinished(int, bool)), this, SLOT(slotRequestFinished(int, bool)));
+connect(m_pHttp, SIGNAL(done(bool)), this, SLOT(slotDone(bool)));
-KVSO_BEGIN_CONSTRUCTOR(KvsObject_http,KviKvsObject)
- m_pHttp = new QHttp();
- m_bAbort=false;
- m_bEnableForceRedirect=false;
- connect(m_pHttp,SIGNAL(requestFinished(int,bool)),this,SLOT(slotRequestFinished(int,bool)));
- connect(m_pHttp,SIGNAL(done(bool)),this,SLOT(slotDone(bool)));
-
- connect(m_pHttp,SIGNAL(requestStarted(int)),this,SLOT(slotRequestStarted(int)));
- connect(m_pHttp,SIGNAL(dataSendProgress(int,int)),this,SLOT(slotDataSendProgress(int,int)));
- connect(m_pHttp,SIGNAL(dataReadProgress(int,int)),this,SLOT(slotDataReadProgress(int,int)));
- connect(m_pHttp,SIGNAL(responseHeaderReceived ( const QHttpResponseHeader & )),this,SLOT(slotResponseHeaderReceived(const QHttpResponseHeader &)));
- connect(m_pHttp,SIGNAL(readyRead ( const QHttpResponseHeader & )),this,SLOT(slotReadyRead(const QHttpResponseHeader &)));
- #ifndef QT_NO_OPENSSL
- connect(m_pHttp,SIGNAL(sslErrors ( const QList<QSslError> & )),this,SLOT(slotSslErrors(const QList<QSslError> & )));
- #endif
- connect(m_pHttp,SIGNAL(stateChanged(int)),this,SLOT(slotStateChanged(int)));
+connect(m_pHttp, SIGNAL(requestStarted(int)), this, SLOT(slotRequestStarted(int)));
+connect(m_pHttp, SIGNAL(dataSendProgress(int, int)), this, SLOT(slotDataSendProgress(int, int)));
+connect(m_pHttp, SIGNAL(dataReadProgress(int, int)), this, SLOT(slotDataReadProgress(int, int)));
+connect(m_pHttp, SIGNAL(responseHeaderReceived(const QHttpResponseHeader &)), this, SLOT(slotResponseHeaderReceived(const QHttpResponseHeader &)));
+connect(m_pHttp, SIGNAL(readyRead(const QHttpResponseHeader &)), this, SLOT(slotReadyRead(const QHttpResponseHeader &)));
+#ifndef QT_NO_OPENSSL
+connect(m_pHttp, SIGNAL(sslErrors(const QList<QSslError> &)), this, SLOT(slotSslErrors(const QList<QSslError> &)));
+#endif
+connect(m_pHttp, SIGNAL(stateChanged(int)), this, SLOT(slotStateChanged(int)));
KVSO_END_CONSTRUCTOR(KvsObject_http)
KVSO_BEGIN_DESTRUCTOR(KvsObject_http)
- QHashIterator<int,QFile *> t(getDict);
- while (t.hasNext())
- {
- t.next();
- int key=t.key();
- QFile *pFile=getDict.value(key);
- pFile->close();
- delete pFile;
- }
- getDict.clear();
- delete m_pHttp;
+QHashIterator<int, QFile *> t(getDict);
+while(t.hasNext())
+{
+ t.next();
+ int key = t.key();
+ QFile * pFile = getDict.value(key);
+ pFile->close();
+ delete pFile;
+}
+getDict.clear();
+delete m_pHttp;
KVSO_END_DESTRUCTOR(KvsObject_http)
//----------------------
-
-bool KvsObject_http::functionSetHost(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionSetHost(KviKvsObjectFunctionCall * c)
{
CHECK_INTERNAL_POINTER(m_pHttp)
QString szHost;
QString szConnectionType;
kvs_uint_t uRemotePort;
KVSO_PARAMETERS_BEGIN(c)
- KVSO_PARAMETER("host",KVS_PT_STRING,0,szHost)
- KVSO_PARAMETER("remote_port",KVS_PT_UNSIGNEDINTEGER,KVS_PF_OPTIONAL,uRemotePort)
+ KVSO_PARAMETER("host", KVS_PT_STRING, 0, szHost)
+ KVSO_PARAMETER("remote_port", KVS_PT_UNSIGNEDINTEGER, KVS_PF_OPTIONAL, uRemotePort)
KVSO_PARAMETERS_END(c)
QUrl url(szHost);
- if (!url.isValid())
+ if(!url.isValid())
{
- c->warning(__tr2qs_ctx("Host '%Q' is not a valid URL","objects"),&szHost);
+ c->warning(__tr2qs_ctx("Host '%Q' is not a valid URL", "objects"), &szHost);
return true;
}
- if (!szHost.isEmpty() && url.host().isEmpty()) url.setHost(szHost);
- if (!uRemotePort) uRemotePort=80;
- kvs_uint_t id=0;
+ if(!szHost.isEmpty() && url.host().isEmpty())
+ url.setHost(szHost);
+ if(!uRemotePort)
+ uRemotePort = 80;
+ kvs_uint_t id = 0;
QHttp::ConnectionMode mode;
- if(url.scheme().toLower()=="https") mode=QHttp::ConnectionModeHttps;
- else {mode=QHttp::ConnectionModeHttp;url.setScheme("http");}
- if (mode==QHttp::ConnectionModeHttps) uRemotePort=443;
- id=m_pHttp->setHost(url.host(), mode, uRemotePort);
+ if(url.scheme().toLower() == "https")
+ mode = QHttp::ConnectionModeHttps;
+ else
+ {
+ mode = QHttp::ConnectionModeHttp;
+ url.setScheme("http");
+ }
+ if(mode == QHttp::ConnectionModeHttps)
+ uRemotePort = 443;
+ id = m_pHttp->setHost(url.host(), mode, uRemotePort);
c->returnValue()->setInteger(id);
return true;
}
-bool KvsObject_http::functionCurrentId(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionCurrentId(KviKvsObjectFunctionCall * c)
{
CHECK_INTERNAL_POINTER(m_pHttp)
c->returnValue()->setInteger(m_pHttp->currentId());
return true;
}
-bool KvsObject_http::functionSetUser(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionSetUser(KviKvsObjectFunctionCall * c)
{
CHECK_INTERNAL_POINTER(m_pHttp)
QString szUser;
QString szPass;
KVSO_PARAMETERS_BEGIN(c)
- KVSO_PARAMETER("user",KVS_PT_STRING,0,szUser)
- KVSO_PARAMETER("password",KVS_PT_STRING,0,szPass)
+ KVSO_PARAMETER("user", KVS_PT_STRING, 0, szUser)
+ KVSO_PARAMETER("password", KVS_PT_STRING, 0, szPass)
KVSO_PARAMETERS_END(c)
- m_pHttp->setUser(szUser,szPass);
+ m_pHttp->setUser(szUser, szPass);
return true;
}
-bool KvsObject_http::functionSetProxy(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionSetProxy(KviKvsObjectFunctionCall * c)
{
CHECK_INTERNAL_POINTER(m_pHttp)
QString szHost;
- QString szUser,szPass;
+ QString szUser, szPass;
kvs_uint_t uRemotePort;
KVSO_PARAMETERS_BEGIN(c)
- KVSO_PARAMETER("host",KVS_PT_STRING,0,szHost)
- KVSO_PARAMETER("remote_port",KVS_PT_UNSIGNEDINTEGER,KVS_PF_OPTIONAL,uRemotePort)
- KVSO_PARAMETER("user",KVS_PT_STRING,KVS_PF_OPTIONAL,szUser)
- KVSO_PARAMETER("pass",KVS_PT_STRING,KVS_PF_OPTIONAL,szPass)
+ KVSO_PARAMETER("host", KVS_PT_STRING, 0, szHost)
+ KVSO_PARAMETER("remote_port", KVS_PT_UNSIGNEDINTEGER, KVS_PF_OPTIONAL, uRemotePort)
+ KVSO_PARAMETER("user", KVS_PT_STRING, KVS_PF_OPTIONAL, szUser)
+ KVSO_PARAMETER("pass", KVS_PT_STRING, KVS_PF_OPTIONAL, szPass)
KVSO_PARAMETERS_END(c)
- m_pHttp->setProxy(szHost,uRemotePort,szUser,szPass);
+ m_pHttp->setProxy(szHost, uRemotePort, szUser, szPass);
return true;
}
-bool KvsObject_http::functionGet(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionGet(KviKvsObjectFunctionCall * c)
{
CHECK_INTERNAL_POINTER(m_pHttp)
- QString szPath,szDest;
+ QString szPath, szDest;
KVSO_PARAMETERS_BEGIN(c)
- KVSO_PARAMETER("remote_path",KVS_PT_STRING,0,szPath)
- KVSO_PARAMETER("local_filename",KVS_PT_STRING,KVS_PF_OPTIONAL,szDest)
+ KVSO_PARAMETER("remote_path", KVS_PT_STRING, 0, szPath)
+ KVSO_PARAMETER("local_filename", KVS_PT_STRING, KVS_PF_OPTIONAL, szDest)
KVSO_PARAMETERS_END(c)
- QFile * pFile=0;
- if (!szDest.isEmpty())
+ QFile * pFile = 0;
+ if(!szDest.isEmpty())
{
- pFile=new QFile(szDest);
- if (pFile)
+ pFile = new QFile(szDest);
+ if(pFile)
{
pFile->open(QIODevice::WriteOnly);
- } else {
- c->warning(__tr2qs_ctx("'%Q' is not a valid file path","objects"),&szDest);
+ }
+ else
+ {
+ c->warning(__tr2qs_ctx("'%Q' is not a valid file path", "objects"), &szDest);
c->returnValue()->setInteger(-1);
return true;
}
}
- if (szPath.isEmpty()) szPath="/";
- int id=m_pHttp->get(szPath,pFile);
- if (pFile) getDict[id]=pFile;
+ if(szPath.isEmpty())
+ szPath = "/";
+ int id = m_pHttp->get(szPath, pFile);
+ if(pFile)
+ getDict[id] = pFile;
c->returnValue()->setInteger(id);
return true;
}
-bool KvsObject_http::functionPost(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionPost(KviKvsObjectFunctionCall * c)
{
CHECK_INTERNAL_POINTER(m_pHttp)
- QString szPath,szDest,szData;
+ QString szPath, szDest, szData;
KVSO_PARAMETERS_BEGIN(c)
- KVSO_PARAMETER("remote_path",KVS_PT_STRING,0,szPath)
- KVSO_PARAMETER("post_data",KVS_PT_STRING,0,szData)
- KVSO_PARAMETER("local_filename",KVS_PT_STRING,0,szDest)
+ KVSO_PARAMETER("remote_path", KVS_PT_STRING, 0, szPath)
+ KVSO_PARAMETER("post_data", KVS_PT_STRING, 0, szData)
+ KVSO_PARAMETER("local_filename", KVS_PT_STRING, 0, szDest)
KVSO_PARAMETERS_END(c)
- QFile *pFile=0;
- if (!szDest.isEmpty()){
- pFile=new QFile(szDest);
- if (pFile)
+ QFile * pFile = 0;
+ if(!szDest.isEmpty())
+ {
+ pFile = new QFile(szDest);
+ if(pFile)
{
pFile->open(QIODevice::WriteOnly);
}
}
- if (szPath.isEmpty()) szPath="/";
- int id=m_pHttp->post(szPath,szDest.toUtf8(),pFile);
- if (pFile) getDict[id]=pFile;
+ if(szPath.isEmpty())
+ szPath = "/";
+ int id = m_pHttp->post(szPath, szDest.toUtf8(), pFile);
+ if(pFile)
+ getDict[id] = pFile;
c->returnValue()->setInteger(id);
return true;
}
-bool KvsObject_http::functionAbort(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionAbort(KviKvsObjectFunctionCall * c)
{
CHECK_INTERNAL_POINTER(m_pHttp)
- m_bAbort=true;
+ m_bAbort = true;
m_pHttp->abort();
return true;
}
-bool KvsObject_http::functionReadAll(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionReadAll(KviKvsObjectFunctionCall * c)
{
CHECK_INTERNAL_POINTER(m_pHttp)
c->returnValue()->setString(m_pHttp->readAll());
return true;
}
-bool KvsObject_http::functionErrorString(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionErrorString(KviKvsObjectFunctionCall * c)
{
CHECK_INTERNAL_POINTER(m_pHttp)
c->returnValue()->setString(m_pHttp->errorString());
return true;
}
-bool KvsObject_http::functionFollowRedirect(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionFollowRedirect(KviKvsObjectFunctionCall * c)
{
bool bEnabled;
KVSO_PARAMETERS_BEGIN(c)
- KVSO_PARAMETER("enable",KVS_PT_BOOLEAN,0,bEnabled)
+ KVSO_PARAMETER("enable", KVS_PT_BOOLEAN, 0, bEnabled)
KVSO_PARAMETERS_END(c)
- m_bEnableForceRedirect=bEnabled;
+ m_bEnableForceRedirect = bEnabled;
return true;
}
//signals & slots
-bool KvsObject_http::functionRequestFinishedEvent(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionRequestFinishedEvent(KviKvsObjectFunctionCall * c)
{
- emitSignal("requestFinished",c,c->params());
+ emitSignal("requestFinished", c, c->params());
return true;
}
-void KvsObject_http::slotRequestFinished ( int id, bool error )
+void KvsObject_http::slotRequestFinished(int id, bool error)
{
- if (m_bAbort)
+ if(m_bAbort)
{
- m_bAbort=false;
- QHashIterator<int,QFile *> t(getDict);
- while (t.hasNext())
+ m_bAbort = false;
+ QHashIterator<int, QFile *> t(getDict);
+ while(t.hasNext())
{
t.next();
- int key=t.key();
- QFile *pFile=getDict.value(key);
+ int key = t.key();
+ QFile * pFile = getDict.value(key);
pFile->close();
delete pFile;
}
getDict.clear();
return;
}
- QFile *pFile=getDict.value(id);
- if (pFile)
+ QFile * pFile = getDict.value(id);
+ if(pFile)
{
- QString name=pFile->fileName();
+ QString name = pFile->fileName();
pFile->close();
getDict.remove(id);
- int res=m_pHttp->lastResponse().statusCode();
- if ((res==301 || res==302 || res==307) && m_bEnableForceRedirect)
- redirect(name,m_pHttp->lastResponse());
+ int res = m_pHttp->lastResponse().statusCode();
+ if((res == 301 || res == 302 || res == 307) && m_bEnableForceRedirect)
+ redirect(name, m_pHttp->lastResponse());
delete pFile;
}
KviKvsVariantList lParams;
- lParams.append(new KviKvsVariant((kvs_int_t) id));
+ lParams.append(new KviKvsVariant((kvs_int_t)id));
lParams.append(new KviKvsVariant(error));
- callFunction(this,"requestFinishedEvent",0,&lParams);
+ callFunction(this, "requestFinishedEvent", 0, &lParams);
}
-bool KvsObject_http::functionRequestStartedEvent(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionRequestStartedEvent(KviKvsObjectFunctionCall * c)
{
- emitSignal("requestStarted",c,c->params());
+ emitSignal("requestStarted", c, c->params());
return true;
}
-void KvsObject_http::slotRequestStarted ( int id )
+void KvsObject_http::slotRequestStarted(int id)
{
KviKvsVariantList lParams;
- lParams.append(new KviKvsVariant((kvs_int_t) id));
- callFunction(this,"requestStartedEvent",0,&lParams);
+ lParams.append(new KviKvsVariant((kvs_int_t)id));
+ callFunction(this, "requestStartedEvent", 0, &lParams);
}
-void KvsObject_http::slotDataReadProgress ( int done,int total )
+void KvsObject_http::slotDataReadProgress(int done, int total)
{
KviKvsVariantList lParams;
- lParams.append(new KviKvsVariant((kvs_int_t) done));
- lParams.append(new KviKvsVariant((kvs_int_t) total));
- callFunction(this,"dataReadProgressEvent",0,&lParams);
+ lParams.append(new KviKvsVariant((kvs_int_t)done));
+ lParams.append(new KviKvsVariant((kvs_int_t)total));
+ callFunction(this, "dataReadProgressEvent", 0, &lParams);
}
-bool KvsObject_http::functionDataReadProgressEvent(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionDataReadProgressEvent(KviKvsObjectFunctionCall * c)
{
- emitSignal("dataReadProgress",c,c->params());
+ emitSignal("dataReadProgress", c, c->params());
return true;
}
-void KvsObject_http::slotDataSendProgress ( int done,int total )
+void KvsObject_http::slotDataSendProgress(int done, int total)
{
KviKvsVariantList lParams;
- lParams.append(new KviKvsVariant((kvs_int_t) done));
- lParams.append(new KviKvsVariant((kvs_int_t) total));
- callFunction(this,"dataSendProgressEvent",0,&lParams);
+ lParams.append(new KviKvsVariant((kvs_int_t)done));
+ lParams.append(new KviKvsVariant((kvs_int_t)total));
+ callFunction(this, "dataSendProgressEvent", 0, &lParams);
}
-bool KvsObject_http::functionDataSendProgressEvent(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionDataSendProgressEvent(KviKvsObjectFunctionCall * c)
{
- emitSignal("dataSendProgress",c,c->params());
+ emitSignal("dataSendProgress", c, c->params());
return true;
}
-bool KvsObject_http::functionDoneEvent(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionDoneEvent(KviKvsObjectFunctionCall * c)
{
- emitSignal("done",c,c->params());
+ emitSignal("done", c, c->params());
return true;
}
-void KvsObject_http::slotDone ( bool error )
+void KvsObject_http::slotDone(bool error)
{
KviKvsVariantList lParams;
lParams.append(new KviKvsVariant(error));
- callFunction(this,"doneEvent",0,&lParams);
+ callFunction(this, "doneEvent", 0, &lParams);
}
-bool KvsObject_http::functionResponseHeaderReceivedEvent(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionResponseHeaderReceivedEvent(KviKvsObjectFunctionCall * c)
{
- emitSignal("responseHeaderReceived",c,c->params());
+ emitSignal("responseHeaderReceived", c, c->params());
return true;
}
-bool KvsObject_http::functionReadyReadEvent(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionReadyReadEvent(KviKvsObjectFunctionCall * c)
{
- emitSignal("readyRead",c,c->params());
+ emitSignal("readyRead", c, c->params());
return true;
}
-void KvsObject_http::redirect(QString &file,const QHttpResponseHeader &r)
+void KvsObject_http::redirect(QString & file, const QHttpResponseHeader & r)
{
QUrl url(r.value("location"));
m_pHttp->setHost(url.host());
- QFile *pFile=0;
- pFile=new QFile(file);
+ QFile * pFile = 0;
+ pFile = new QFile(file);
pFile->open(QIODevice::WriteOnly);
- int id=m_pHttp->get(url.path(),pFile);
- getDict[id]=pFile;
+ int id = m_pHttp->get(url.path(), pFile);
+ getDict[id] = pFile;
}
-void KvsObject_http::slotResponseHeaderReceived(const QHttpResponseHeader &r)
+void KvsObject_http::slotResponseHeaderReceived(const QHttpResponseHeader & r)
{
QString szResponse;
- switch (r.statusCode()) {
- case 200: szResponse="OK" ;break;
- case 301: szResponse="Moved Permanently" ;break;
- case 302: szResponse="Found" ;break;
- case 303: szResponse="See Other" ;break;
- case 307: szResponse="Temporary Redirect" ;break;
- default: szResponse=r.reasonPhrase();
- m_bAbort=true;
+ switch(r.statusCode())
+ {
+ case 200:
+ szResponse = "OK";
+ break;
+ case 301:
+ szResponse = "Moved Permanently";
+ break;
+ case 302:
+ szResponse = "Found";
+ break;
+ case 303:
+ szResponse = "See Other";
+ break;
+ case 307:
+ szResponse = "Temporary Redirect";
+ break;
+ default:
+ szResponse = r.reasonPhrase();
+ m_bAbort = true;
}
- if (r.statusCode()==400)
+ if(r.statusCode() == 400)
{
- m_bAbort=true;
+ m_bAbort = true;
m_pHttp->abort();
}
KviKvsVariantList lParams;
lParams.append(new KviKvsVariant(szResponse));
- callFunction(this,"responseHeaderReceivedEvent",0,&lParams);
-
+ callFunction(this, "responseHeaderReceivedEvent", 0, &lParams);
}
-void KvsObject_http::slotReadyRead(const QHttpResponseHeader &r)
+void KvsObject_http::slotReadyRead(const QHttpResponseHeader & r)
{
QString szResponse;
- switch (r.statusCode()) {
- case 200: szResponse="OK" ;break;
- case 301: szResponse="Moved Permanently" ;break;
- case 302: szResponse="Found" ;break;
- case 303: szResponse="See Other" ;break;
- case 307: szResponse="Temporary Redirect" ;break;
- default: szResponse=r.reasonPhrase();
- m_bAbort=true;
+ switch(r.statusCode())
+ {
+ case 200:
+ szResponse = "OK";
+ break;
+ case 301:
+ szResponse = "Moved Permanently";
+ break;
+ case 302:
+ szResponse = "Found";
+ break;
+ case 303:
+ szResponse = "See Other";
+ break;
+ case 307:
+ szResponse = "Temporary Redirect";
+ break;
+ default:
+ szResponse = r.reasonPhrase();
+ m_bAbort = true;
}
KviKvsVariantList lParams;
lParams.append(new KviKvsVariant(szResponse));
- callFunction(this,"readyreadEvent",0,&lParams);
+ callFunction(this, "readyreadEvent", 0, &lParams);
}
-
-
-
-void KvsObject_http::slotStateChanged ( int state)
+void KvsObject_http::slotStateChanged(int state)
{
- QString szState="";
- if (state==QHttp::Unconnected) szState="Unconnected";
- else if (state==QHttp::HostLookup) szState="HostLookup";
- else if (state==QHttp::Connecting) szState="Connecting";
- else if (state==QHttp::Connected) szState="Connected";
- else if (state==QHttp::Sending) szState="Sending";
- else if (state==QHttp::Reading) szState="Reading";
+ QString szState = "";
+ if(state == QHttp::Unconnected)
+ szState = "Unconnected";
+ else if(state == QHttp::HostLookup)
+ szState = "HostLookup";
+ else if(state == QHttp::Connecting)
+ szState = "Connecting";
+ else if(state == QHttp::Connected)
+ szState = "Connected";
+ else if(state == QHttp::Sending)
+ szState = "Sending";
+ else if(state == QHttp::Reading)
+ szState = "Reading";
- else if (state==QHttp::Closing) szState="Closing";
+ else if(state == QHttp::Closing)
+ szState = "Closing";
KviKvsVariantList lParams;
lParams.append(new KviKvsVariant(szState));
- callFunction(this,"stateChangedEvent",0,&lParams);
+ callFunction(this, "stateChangedEvent", 0, &lParams);
}
-bool KvsObject_http::functionStateChangedEvent(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionStateChangedEvent(KviKvsObjectFunctionCall * c)
{
- emitSignal("stateChanged",c,c->params());
+ emitSignal("stateChanged", c, c->params());
return true;
}
#ifndef QT_NO_OPENSSL
-bool KvsObject_http::functionIgnoreSslErrors(KviKvsObjectFunctionCall *)
+bool KvsObject_http::functionIgnoreSslErrors(KviKvsObjectFunctionCall *)
{
- if (m_pHttp) m_pHttp->ignoreSslErrors();
+ if(m_pHttp)
+ m_pHttp->ignoreSslErrors();
return true;
}
void KvsObject_http::slotSslErrors(QList<QSslError> sslerrors)
{
- KviKvsArray *pArray=0;
- pArray=new KviKvsArray();
- for(int i=0;i<sslerrors.count();i++)
+ KviKvsArray * pArray = 0;
+ pArray = new KviKvsArray();
+ for(int i = 0; i < sslerrors.count(); i++)
{
- pArray->set(i,new KviKvsVariant(ssl_errors_tbl[sslerrors.at(i).error()]));
+ pArray->set(i, new KviKvsVariant(ssl_errors_tbl[sslerrors.at(i).error()]));
}
KviKvsVariantList lParams;
lParams.append(new KviKvsVariant(pArray));
- callFunction(this,"sslErrorEvent",0,&lParams);
- }
+ callFunction(this, "sslErrorEvent", 0, &lParams);
+}
-bool KvsObject_http::functionSslErrorsEvent(KviKvsObjectFunctionCall *c)
+bool KvsObject_http::functionSslErrorsEvent(KviKvsObjectFunctionCall * c)
{
- emitSignal("sslErrors",c,c->params());
+ emitSignal("sslErrors", c, c->params());
return true;
}
#endif