From 690dd7a33ddc90678367d73adf313533536e10f2 Mon Sep 17 00:00:00 2001 From: Alexey Sokolov Date: Fri, 29 Apr 2016 23:57:30 +0100 Subject: Apply clang-format --- src/modules/objects/KvsObject_http.cpp | 511 ++++++++++++++++++--------------- 1 file changed, 276 insertions(+), 235 deletions(-) (limited to 'src/modules/objects/KvsObject_http.cpp') 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 #ifndef QT_NO_OPENSSL - #include - - 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" - }; +#include + +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) - - // 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_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 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))); - - 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 & )),this,SLOT(slotSslErrors(const QList & ))); - #endif - connect(m_pHttp,SIGNAL(stateChanged(int)),this,SLOT(slotStateChanged(int))); +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 &)), this, SLOT(slotSslErrors(const QList &))); +#endif +connect(m_pHttp, SIGNAL(stateChanged(int)), this, SLOT(slotStateChanged(int))); KVSO_END_CONSTRUCTOR(KvsObject_http) KVSO_BEGIN_DESTRUCTOR(KvsObject_http) - QHashIterator 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 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 t(getDict); - while (t.hasNext()) + m_bAbort = false; + QHashIterator 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"; - - else if (state==QHttp::Closing) szState="Closing"; + 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"; 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 sslerrors) { - KviKvsArray *pArray=0; - pArray=new KviKvsArray(); - for(int i=0;iset(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 -- cgit v1.3.1-10-gc9f91