X-Git-Url: http://vcs.maemo.org/git/?a=blobdiff_plain;f=libkqoauth%2Fkqoauthmanager.cpp;fp=libkqoauth%2Fkqoauthmanager.cpp;h=0000000000000000000000000000000000000000;hb=ca759b3fd3b64ad976c4917e93513b3d05999f13;hp=b133ff701d71fcb379717427dbd35ddfadeecb8f;hpb=0274061406db78bb79ef433c5c438178103aaa58;p=googlelatitude

diff --git a/libkqoauth/kqoauthmanager.cpp b/libkqoauth/kqoauthmanager.cpp
deleted file mode 100644
index b133ff7..0000000
--- a/libkqoauth/kqoauthmanager.cpp
+++ /dev/null
@@ -1,650 +0,0 @@
-/**
- * KQOAuth - An OAuth authentication library for Qt.
- *
- * Author: Johan Paul (johan.paul@d-pointer.com)
- *         http://www.d-pointer.com
- *
- *  KQOAuth is free software: you can redistribute it and/or modify
- *  it under the terms of the GNU Lesser General Public License as published by
- *  the Free Software Foundation, either version 3 of the License, or
- *  (at your option) any later version.
- *
- *  KQOAuth 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 Lesser General Public License for more details.
- *
- *  You should have received a copy of the GNU Lesser General Public License
- *  along with KQOAuth.  If not, see <http://www.gnu.org/licenses/>.
- */
-#include <QtCore>
-
-#include "kqoauthmanager.h"
-#include "kqoauthmanager_p.h"
-
-
-////////////// Private d_ptr implementation ////////////////
-
-KQOAuthManagerPrivate::KQOAuthManagerPrivate(KQOAuthManager *parent) :
-    error(KQOAuthManager::NoError) ,
-    r(0) ,
-    opaqueRequest(new KQOAuthRequest) ,
-    q_ptr(parent) ,
-    callbackServer(new KQOAuthAuthReplyServer(parent)) ,
-    isVerified(false) ,
-    isAuthorized(false) ,
-    autoAuth(false),
-    networkManager(new QNetworkAccessManager),
-    managerUserSet(false)
-{
-
-}
-
-KQOAuthManagerPrivate::~KQOAuthManagerPrivate() {
-    delete opaqueRequest;
-    opaqueRequest = 0;
-
-    if (!managerUserSet) {
-        delete networkManager;
-        networkManager = 0;
-    }
-}
-
-QList< QPair<QString, QString> > KQOAuthManagerPrivate::createQueryParams(const KQOAuthParameters &requestParams) {
-    QList<QString> requestKeys = requestParams.keys();
-    QList<QString> requestValues = requestParams.values();
-
-    QList< QPair<QString, QString> > result;
-    for(int i=0; i<requestKeys.size(); i++) {
-        result.append( qMakePair(requestKeys.at(i),
-                                 requestValues.at(i))
-                      );
-    }
-
-    return result;
-}
-
-QMultiMap<QString, QString> KQOAuthManagerPrivate::createTokensFromResponse(QByteArray reply) {
-    QMultiMap<QString, QString> result;
-    QString replyString(reply);
-
-    QStringList parameterPairs = replyString.split('&', QString::SkipEmptyParts);
-    foreach (const QString &parameterPair, parameterPairs) {
-        QStringList parameter = parameterPair.split('=');
-        result.insert(parameter.value(0), parameter.value(1));
-    }
-
-    return result;
-}
-
-bool KQOAuthManagerPrivate::setSuccessfulRequestToken(const QMultiMap<QString, QString> &request) {
-    if (currentRequestType == KQOAuthRequest::TemporaryCredentials) {
-        hasTemporaryToken = (!QString(request.value("oauth_token")).isEmpty() && !QString(request.value("oauth_token_secret")).isEmpty());
-    } else {
-        return false;
-    }
-
-    if (hasTemporaryToken) {
-        requestToken = QUrl::fromPercentEncoding( QString(request.value("oauth_token")).toLocal8Bit() );
-        requestTokenSecret =  QUrl::fromPercentEncoding( QString(request.value("oauth_token_secret")).toLocal8Bit() );
-    }
-
-    return hasTemporaryToken;
-}
-
-bool KQOAuthManagerPrivate::setSuccessfulAuthorized(const QMultiMap<QString, QString> &request ) {
-    if (currentRequestType == KQOAuthRequest::AccessToken) {
-        isAuthorized = (!QString(request.value("oauth_token")).isEmpty() && !QString(request.value("oauth_token_secret")).isEmpty());
-    } else {
-        return false;
-    }
-
-    if (isAuthorized) {
-        requestToken = QUrl::fromPercentEncoding( QString(request.value("oauth_token")).toLocal8Bit() );
-        requestTokenSecret =  QUrl::fromPercentEncoding( QString(request.value("oauth_token_secret")).toLocal8Bit() );
-    }
-
-    return isAuthorized;
-}
-
-void KQOAuthManagerPrivate::emitTokens() {
-    Q_Q(KQOAuthManager);
-
-    if (this->requestToken.isEmpty() || this->requestTokenSecret.isEmpty()) {
-        error = KQOAuthManager::RequestUnauthorized;
-    }
-
-    if (currentRequestType == KQOAuthRequest::TemporaryCredentials) {
-        // Signal that we are ready to use the protected resources.
-        emit q->temporaryTokenReceived(this->requestToken, this->requestTokenSecret);
-    }
-
-    if (currentRequestType == KQOAuthRequest::AccessToken) {
-        // Signal that we are ready to use the protected resources.
-        emit q->accessTokenReceived(this->requestToken, this->requestTokenSecret);
-    }
-
-    emit q->receivedToken(this->requestToken, this->requestTokenSecret);
-}
-
-bool KQOAuthManagerPrivate::setupCallbackServer() {
-    return callbackServer->listen();
-}
-
-
-/////////////// Public implementation ////////////////
-
-KQOAuthManager::KQOAuthManager(QObject *parent) :
-    QObject(parent) ,
-    d_ptr(new KQOAuthManagerPrivate(this))
-{
-
-}
-
-KQOAuthManager::~KQOAuthManager()
-{
-    delete d_ptr;
-}
-
-void KQOAuthManager::executeRequest(KQOAuthRequest *request) {
-    Q_D(KQOAuthManager);
-
-    d->r = request;
-
-    if (request == 0) {
-        qWarning() << "Request is NULL. Cannot proceed.";
-        d->error = KQOAuthManager::RequestError;
-        return;
-    }
-
-    if (!request->requestEndpoint().isValid()) {
-        qWarning() << "Request endpoint URL is not valid. Cannot proceed.";
-        d->error = KQOAuthManager::RequestEndpointError;
-        return;
-    }
-
-    if (!request->isValid()) {
-        qWarning() << "Request is not valid. Cannot proceed.";
-        d->error = KQOAuthManager::RequestValidationError;
-        return;
-    }
-
-    d->currentRequestType = request->requestType();
-
-    QNetworkRequest networkRequest;
-    networkRequest.setUrl( request->requestEndpoint() );
-
-    if (d->autoAuth && d->currentRequestType == KQOAuthRequest::TemporaryCredentials) {
-        d->setupCallbackServer();
-        connect(d->callbackServer, SIGNAL(verificationReceived(QMultiMap<QString, QString>)),
-                this, SLOT( onVerificationReceived(QMultiMap<QString, QString>)));
-
-        QString serverString = "http://localhost:";
-        serverString.append(QString::number(d->callbackServer->serverPort()));
-        request->setCallbackUrl(QUrl(serverString));
-    }
-
-    // And now fill the request with "Authorization" header data.
-    QList<QByteArray> requestHeaders = request->requestParameters();
-    QByteArray authHeader;
-
-    bool first = true;
-    foreach (const QByteArray header, requestHeaders) {
-        if (!first) {
-            authHeader.append(", ");
-        } else {
-            authHeader.append("OAuth ");
-            first = false;
-        }
-
-        authHeader.append(header);
-    }
-    networkRequest.setRawHeader("Authorization", authHeader);
-
-    connect(d->networkManager, SIGNAL(finished(QNetworkReply *)),
-            this, SLOT(onRequestReplyReceived(QNetworkReply *)), Qt::UniqueConnection);
-    disconnect(d->networkManager, SIGNAL(finished(QNetworkReply *)),
-            this, SLOT(onAuthorizedRequestReplyReceived(QNetworkReply *)));
-
-    if (request->httpMethod() == KQOAuthRequest::GET) {
-        // Get the requested additional params as a list of pairs we can give QUrl
-        QList< QPair<QString, QString> > urlParams = d->createQueryParams(request->additionalParameters());
-
-        // Take the original URL and append the query params to it.
-        QUrl urlWithParams = networkRequest.url();
-        urlWithParams.setQueryItems(urlParams);
-        networkRequest.setUrl(urlWithParams);
-
-        // Submit the request including the params.
-        QNetworkReply *reply = d->networkManager->get(networkRequest);
-        connect(reply, SIGNAL(error(QNetworkReply::NetworkError)),
-                 this, SLOT(slotError(QNetworkReply::NetworkError)));
-
-    } else if (request->httpMethod() == KQOAuthRequest::POST) {
-
-        networkRequest.setHeader(QNetworkRequest::ContentTypeHeader, request->contentType());
-
-        qDebug() << networkRequest.rawHeaderList();
-        qDebug() << networkRequest.rawHeader("Authorization");
-        qDebug() << networkRequest.rawHeader("Content-Type");
-
-        QNetworkReply *reply;
-        if (request->contentType() == "application/x-www-form-urlencoded") {
-          reply = d->networkManager->post(networkRequest, request->requestBody());
-        } else {
-          reply = d->networkManager->post(networkRequest, request->rawData());
-        }
-
-        connect(reply, SIGNAL(error(QNetworkReply::NetworkError)),
-                 this, SLOT(slotError(QNetworkReply::NetworkError)));
-    }
-
-    d->r->requestTimerStart();
-}
-
-void KQOAuthManager::executeAuthorizedRequest(KQOAuthRequest *request, int id) {
-    Q_D(KQOAuthManager);
-
-    d->r = request;
-
-    if (request == 0) {
-        qWarning() << "Request is NULL. Cannot proceed.";
-        d->error = KQOAuthManager::RequestError;
-        return;
-    }
-
-    if (!request->requestEndpoint().isValid()) {
-        qWarning() << "Request endpoint URL is not valid. Cannot proceed.";
-        d->error = KQOAuthManager::RequestEndpointError;
-        return;
-    }
-
-    if (!request->isValid()) {
-        qWarning() << "Request is not valid. Cannot proceed.";
-        d->error = KQOAuthManager::RequestValidationError;
-        return;
-    }
-
-    d->currentRequestType = request->requestType();
-
-    QNetworkRequest networkRequest;
-    networkRequest.setUrl( request->requestEndpoint() );
-
-    if ( d->currentRequestType != KQOAuthRequest::AuthorizedRequest){
-        qWarning() << "Not Authorized Request. Cannot proceed";
-        d->error = KQOAuthManager::RequestError;
-        return;
-    }
-
-
-    // And now fill the request with "Authorization" header data.
-    QList<QByteArray> requestHeaders = request->requestParameters();
-    QByteArray authHeader;
-
-    bool first = true;
-    foreach (const QByteArray header, requestHeaders) {
-        if (!first) {
-            authHeader.append(", ");
-        } else {
-            authHeader.append("OAuth ");
-            first = false;
-        }
-
-        authHeader.append(header);
-    }
-    networkRequest.setRawHeader("Authorization", authHeader);
-
-
-    disconnect(d->networkManager, SIGNAL(finished(QNetworkReply *)),
-            this, SLOT(onRequestReplyReceived(QNetworkReply *)));
-    connect(d->networkManager, SIGNAL(finished(QNetworkReply *)),
-            this, SLOT(onAuthorizedRequestReplyReceived(QNetworkReply*)), Qt::UniqueConnection);
-
-    if (request->httpMethod() == KQOAuthRequest::GET) {
-        // Get the requested additional params as a list of pairs we can give QUrl
-        QList< QPair<QString, QString> > urlParams = d->createQueryParams(request->additionalParameters());
-
-        // Take the original URL and append the query params to it.
-        QUrl urlWithParams = networkRequest.url();
-        urlWithParams.setQueryItems(urlParams);
-        networkRequest.setUrl(urlWithParams);
-
-        // Submit the request including the params.
-        QNetworkReply *reply = d->networkManager->get(networkRequest);
-        connect(reply, SIGNAL(error(QNetworkReply::NetworkError)),
-                 this, SLOT(slotError(QNetworkReply::NetworkError)));
-
-    } else if (request->httpMethod() == KQOAuthRequest::POST) {
-
-        networkRequest.setHeader(QNetworkRequest::ContentTypeHeader, request->contentType());
-
-        /*
-        qDebug() << networkRequest.rawHeaderList();
-        qDebug() << networkRequest.rawHeader("Authorization");
-        qDebug() << networkRequest.rawHeader("Content-Type");
-        */
-        QNetworkReply *reply;
-        if (request->contentType() == "application/x-www-form-urlencoded") {
-          reply = d->networkManager->post(networkRequest, request->requestBody());
-        } else {
-          reply = d->networkManager->post(networkRequest, request->rawData());
-        }
-
-        d->requestIds.insert(reply, id);
-
-        connect(reply, SIGNAL(error(QNetworkReply::NetworkError)),
-                 this, SLOT(slotError(QNetworkReply::NetworkError)));
-    }
-
-    d->r->requestTimerStart();
-}
-
-
-void KQOAuthManager::setHandleUserAuthorization(bool set) {
-    Q_D(KQOAuthManager);
-
-    d->autoAuth = set;
-}
-
-bool KQOAuthManager::hasTemporaryToken() {
-    Q_D(KQOAuthManager);
-
-    return d->hasTemporaryToken;
-}
-
-bool KQOAuthManager::isVerified() {
-    Q_D(KQOAuthManager);
-
-    return d->isVerified;
-}
-
-bool KQOAuthManager::isAuthorized() {
-    Q_D(KQOAuthManager);
-
-    return d->isAuthorized;
-}
-
-KQOAuthManager::KQOAuthError KQOAuthManager::lastError() {
-    Q_D(KQOAuthManager);
-
-    return d->error;
-}
-
-void KQOAuthManager::setNetworkManager(QNetworkAccessManager *manager) {
-    Q_D(KQOAuthManager);
-
-    if (manager == 0) {
-        d->error = KQOAuthManager::ManagerError;
-        return;
-    }
-
-    if (!d->managerUserSet) {
-        delete d->networkManager;
-    }
-
-    d->managerUserSet = true;
-    d->networkManager = manager;
-}
-
-QNetworkAccessManager * KQOAuthManager::networkManager() const {
-    Q_D(const KQOAuthManager);
-
-    if (d->managerUserSet) {
-        return d->networkManager;
-    } else {
-        return NULL;
-    }
-
-}
-
-
-//////////// Public convenience API /////////////
-
-QUrl KQOAuthManager::getUserAuthorization(QUrl authorizationEndpoint) {
-    Q_D(KQOAuthManager);
-
-    if (!d->hasTemporaryToken) {
-        qWarning() << "No temporary tokens retreieved. Cannot get user authorization.";
-        d->error = KQOAuthManager::RequestUnauthorized;
-        return QString();
-    }
-
-    if (!authorizationEndpoint.isValid()) {
-        qWarning() << "Authorization endpoint not valid. Cannot proceed.";
-        d->error = KQOAuthManager::RequestEndpointError;
-        return QString();
-    }
-
-    d->error = KQOAuthManager::NoError;
-
-    QPair<QString, QString> tokenParam = qMakePair(QString("oauth_token"), QString(d->requestToken));
-    QUrl openWebPageUrl(authorizationEndpoint.toString(), QUrl::StrictMode);
-    openWebPageUrl.addQueryItem(tokenParam.first, tokenParam.second);
-
-    // Return the resource authorization page provided by the service.
-    qDebug() << "KQOAuthManager::getUserAuthorization " << openWebPageUrl;
-    return openWebPageUrl;
-}
-
-void KQOAuthManager::getUserAccessTokens(QUrl accessTokenEndpoint) {
-    Q_D(KQOAuthManager);
-
-    if (!d->isVerified) {
-        qWarning() << "Not verified. Cannot get access tokens.";
-        d->error = KQOAuthManager::RequestUnauthorized;
-        return;
-    }
-
-    if (!accessTokenEndpoint.isValid()) {
-        qWarning() << "Endpoint for access token exchange is not valid. Cannot proceed.";
-        d->error = KQOAuthManager::RequestEndpointError;
-        return;
-    }
-
-    d->error = KQOAuthManager::NoError;
-
-    d->opaqueRequest->clearRequest();
-    d->opaqueRequest->initRequest(KQOAuthRequest::AccessToken, accessTokenEndpoint);
-    d->opaqueRequest->setToken(d->requestToken);
-    d->opaqueRequest->setTokenSecret(d->requestTokenSecret);
-    d->opaqueRequest->setVerifier(d->requestVerifier);
-    d->opaqueRequest->setConsumerKey(d->consumerKey);
-    d->opaqueRequest->setConsumerSecretKey(d->consumerKeySecret);
-
-    executeRequest(d->opaqueRequest);
-}
-
-void KQOAuthManager::sendAuthorizedRequest(QUrl requestEndpoint, const KQOAuthParameters &requestParameters) {
-    Q_D(KQOAuthManager);
-
-    if (!d->isAuthorized) {
-        qWarning() << "No access tokens retrieved. Cannot send authorized requests.";
-        d->error = KQOAuthManager::RequestUnauthorized;
-        return;
-    }
-
-    if (!requestEndpoint.isValid()) {
-        qWarning() << "Endpoint for authorized request is not valid. Cannot proceed.";
-        d->error = KQOAuthManager::RequestEndpointError;
-        return;
-    }
-
-    d->error = KQOAuthManager::NoError;
-
-    d->opaqueRequest->clearRequest();
-    d->opaqueRequest->initRequest(KQOAuthRequest::AuthorizedRequest, requestEndpoint);
-    d->opaqueRequest->setAdditionalParameters(requestParameters);
-    d->opaqueRequest->setToken(d->requestToken);
-    d->opaqueRequest->setTokenSecret(d->requestTokenSecret);
-    d->opaqueRequest->setConsumerKey(d->consumerKey);
-    d->opaqueRequest->setConsumerSecretKey(d->consumerKeySecret);
-
-    executeRequest(d->opaqueRequest);
-}
-
-
-/////////////// Private slots //////////////////
-
-void KQOAuthManager::onRequestReplyReceived( QNetworkReply *reply ) {
-    Q_D(KQOAuthManager);
-
-    QNetworkReply::NetworkError networkError = reply->error();
-    switch (networkError) {
-    case QNetworkReply::NoError:
-        d->error = KQOAuthManager::NoError;
-        break;
-
-    case QNetworkReply::ContentAccessDenied:
-    case QNetworkReply::AuthenticationRequiredError:
-        d->error = KQOAuthManager::RequestUnauthorized;
-        break;
-
-    default:
-        d->error = KQOAuthManager::NetworkError;
-        break;
-    }
-
-    // Let's disconnect this slot first
-    /*
-    disconnect(d->networkManager, SIGNAL(finished(QNetworkReply *)),
-            this, SLOT(onRequestReplyReceived(QNetworkReply *)));
-    */
-
-    // Read the content of the reply from the network.
-    QByteArray networkReply = reply->readAll();
-
-    // Stop any timer we have set on the request.
-    d->r->requestTimerStop();
-
-    // Just don't do anything if we didn't get anything useful.
-    if(networkReply.isEmpty()) {
-        reply->deleteLater();
-        return;
-    }
-    QMultiMap<QString, QString> responseTokens;
-
-    // We need to emit the signal even if we got an error.
-    if (d->error != KQOAuthManager::NoError) {
-        reply->deleteLater();
-        emit requestReady(networkReply);
-        d->emitTokens();
-        return;
-    }
-
-    responseTokens = d->createTokensFromResponse(networkReply);
-    d->opaqueRequest->clearRequest();
-    d->opaqueRequest->setHttpMethod(KQOAuthRequest::POST);   // XXX FIXME: Convenient API does not support GET
-    if (!d->isAuthorized || !d->isVerified) {
-        if (d->setSuccessfulRequestToken(responseTokens)) {
-            qDebug() << "Successfully got request tokens.";
-            d->consumerKey = d->r->consumerKeyForManager();
-            d->consumerKeySecret = d->r->consumerKeySecretForManager();
-            d->opaqueRequest->setSignatureMethod(KQOAuthRequest::HMAC_SHA1);
-            d->opaqueRequest->setCallbackUrl(d->r->callbackUrlForManager());
-
-            d->emitTokens();
-
-        } else if (d->setSuccessfulAuthorized(responseTokens)) {
-              qDebug() << "Successfully got access tokens.";
-              d->opaqueRequest->setSignatureMethod(KQOAuthRequest::HMAC_SHA1);
-
-              d->emitTokens();
-          } else if (d->currentRequestType == KQOAuthRequest::AuthorizedRequest) {
-                emit authorizedRequestDone();
-            }
-    }
-
-    emit requestReady(networkReply);
-
-    reply->deleteLater();           // We need to clean this up, after the event processing is done.
-}
-
-void KQOAuthManager::onAuthorizedRequestReplyReceived( QNetworkReply *reply ) {
-    Q_D(KQOAuthManager);
-
-    QNetworkReply::NetworkError networkError = reply->error();
-    switch (networkError) {
-    case QNetworkReply::NoError:
-        d->error = KQOAuthManager::NoError;
-        break;
-
-    case QNetworkReply::ContentAccessDenied:
-    case QNetworkReply::AuthenticationRequiredError:
-        d->error = KQOAuthManager::RequestUnauthorized;
-        break;
-
-    default:
-        d->error = KQOAuthManager::NetworkError;
-        break;
-    }
-
-    /*
-    disconnect(d->networkManager, SIGNAL(finished(QNetworkReply *)),
-            this, SLOT(onAuthorizedRequestReplyReceived(QNetworkReply *)));
-    */
-
-    // Read the content of the reply from the network.
-    QByteArray networkReply = reply->readAll();
-
-    // Stop any timer we have set on the request.
-    d->r->requestTimerStop();
-
-    // Just don't do anything if we didn't get anything useful.
-    if(networkReply.isEmpty()) {
-        reply->deleteLater();
-        return;
-    }
-
-    // We need to emit the signal even if we got an error.
-    if (d->error != KQOAuthManager::NoError) {
-        qWarning() << "Network reply error";
-        return;
-    }
-
-
-    d->opaqueRequest->clearRequest();
-    d->opaqueRequest->setHttpMethod(KQOAuthRequest::POST);   // XXX FIXME: Convenient API does not support GET
-    if (d->currentRequestType == KQOAuthRequest::AuthorizedRequest) {
-                emit authorizedRequestDone();
-     }
-
-    int id = d->requestIds.take(reply);
-    emit authorizedRequestReady(networkReply, id);
-    reply->deleteLater();
-}
-
-
-void KQOAuthManager::onVerificationReceived(QMultiMap<QString, QString> response) {
-    Q_D(KQOAuthManager);
-
-    QString token = response.value("oauth_token");
-    QString verifier = response.value("oauth_verifier");
-    if (verifier.isEmpty()) {
-        d->error = KQOAuthManager::RequestUnauthorized;
-    }
-
-    verifier = QUrl::fromPercentEncoding(verifier.toUtf8());     // We get the raw URL response here so we need to convert it back
-                                                                 // to plain string so we can percent encode it again later in requests.
-
-    if (d->error == KQOAuthManager::NoError) {
-        d->requestVerifier = verifier;
-        d->isVerified = true;
-    }
-
-    emit authorizationReceived(token, verifier);
-}
-
-void KQOAuthManager::slotError(QNetworkReply::NetworkError error) {
-    Q_UNUSED(error)
-    Q_D(KQOAuthManager);
-
-    d->error = KQOAuthManager::NetworkError;
-    QByteArray emptyResponse;
-    emit requestReady(emptyResponse);
-    emit authorizedRequestDone();
-
-    QNetworkReply *reply = qobject_cast<QNetworkReply *>(sender());
-    d->requestIds.remove(reply);
-    reply->deleteLater();
-}
-