| Index: net/http/http_auth_controller.cc
|
| ===================================================================
|
| --- net/http/http_auth_controller.cc (revision 50667)
|
| +++ net/http/http_auth_controller.cc (working copy)
|
| @@ -1,331 +0,0 @@
|
| -// Copyright (c) 2010 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "net/http/http_auth_controller.h"
|
| -
|
| -#include "base/string_util.h"
|
| -#include "net/base/host_resolver.h"
|
| -#include "net/base/net_util.h"
|
| -#include "net/http/http_auth_handler_factory.h"
|
| -#include "net/http/http_network_session.h"
|
| -#include "net/http/http_request_headers.h"
|
| -#include "net/http/http_request_info.h"
|
| -
|
| -namespace net {
|
| -
|
| -namespace {
|
| -
|
| -// Returns a log message for all the response headers related to the auth
|
| -// challenge.
|
| -std::string AuthChallengeLogMessage(HttpResponseHeaders* headers) {
|
| - std::string msg;
|
| - std::string header_val;
|
| - void* iter = NULL;
|
| - while (headers->EnumerateHeader(&iter, "proxy-authenticate", &header_val)) {
|
| - msg.append("\n Has header Proxy-Authenticate: ");
|
| - msg.append(header_val);
|
| - }
|
| -
|
| - iter = NULL;
|
| - while (headers->EnumerateHeader(&iter, "www-authenticate", &header_val)) {
|
| - msg.append("\n Has header WWW-Authenticate: ");
|
| - msg.append(header_val);
|
| - }
|
| -
|
| - // RFC 4559 requires that a proxy indicate its support of NTLM/Negotiate
|
| - // authentication with a "Proxy-Support: Session-Based-Authentication"
|
| - // response header.
|
| - iter = NULL;
|
| - while (headers->EnumerateHeader(&iter, "proxy-support", &header_val)) {
|
| - msg.append("\n Has header Proxy-Support: ");
|
| - msg.append(header_val);
|
| - }
|
| -
|
| - return msg;
|
| -}
|
| -
|
| -} // namespace
|
| -
|
| -HttpAuthController::HttpAuthController(
|
| - HttpAuth::Target target,
|
| - const GURL& auth_url,
|
| - scoped_refptr<HttpNetworkSession> session,
|
| - const BoundNetLog& net_log)
|
| - : target_(target),
|
| - auth_url_(auth_url),
|
| - auth_origin_(auth_url.GetOrigin()),
|
| - auth_path_(HttpAuth::AUTH_PROXY ? std::string() : auth_url.path()),
|
| - embedded_identity_used_(false),
|
| - default_credentials_used_(false),
|
| - session_(session),
|
| - net_log_(net_log) {
|
| -}
|
| -
|
| -int HttpAuthController::MaybeGenerateAuthToken(const HttpRequestInfo* request,
|
| - CompletionCallback* callback) {
|
| - bool needs_auth = HaveAuth() || SelectPreemptiveAuth();
|
| - if (!needs_auth)
|
| - return OK;
|
| - const std::wstring* username = NULL;
|
| - const std::wstring* password = NULL;
|
| - if (identity_.source != HttpAuth::IDENT_SRC_DEFAULT_CREDENTIALS) {
|
| - username = &identity_.username;
|
| - password = &identity_.password;
|
| - }
|
| - DCHECK(auth_token_.empty());
|
| - return handler_->GenerateAuthToken(username, password, request, callback,
|
| - &auth_token_);
|
| -}
|
| -
|
| -bool HttpAuthController::SelectPreemptiveAuth() {
|
| - DCHECK(!HaveAuth());
|
| - DCHECK(identity_.invalid);
|
| -
|
| - // Don't do preemptive authorization if the URL contains a username/password,
|
| - // since we must first be challenged in order to use the URL's identity.
|
| - if (auth_url_.has_username())
|
| - return false;
|
| -
|
| - // SelectPreemptiveAuth() is on the critical path for each request, so it
|
| - // is expected to be fast. LookupByPath() is fast in the common case, since
|
| - // the number of http auth cache entries is expected to be very small.
|
| - // (For most users in fact, it will be 0.)
|
| - HttpAuthCache::Entry* entry = session_->auth_cache()->LookupByPath(
|
| - auth_origin_, auth_path_);
|
| - if (!entry)
|
| - return false;
|
| -
|
| - // Try to create a handler using the previous auth challenge.
|
| - scoped_ptr<HttpAuthHandler> handler_preemptive;
|
| - int rv_create = session_->http_auth_handler_factory()->
|
| - CreatePreemptiveAuthHandlerFromString(entry->auth_challenge(), target_,
|
| - auth_origin_,
|
| - entry->IncrementNonceCount(),
|
| - net_log_, &handler_preemptive);
|
| - if (rv_create != OK)
|
| - return false;
|
| -
|
| - // Set the state
|
| - identity_.source = HttpAuth::IDENT_SRC_PATH_LOOKUP;
|
| - identity_.invalid = false;
|
| - identity_.username = entry->username();
|
| - identity_.password = entry->password();
|
| - handler_.swap(handler_preemptive);
|
| - return true;
|
| -}
|
| -
|
| -void HttpAuthController::AddAuthorizationHeader(
|
| - HttpRequestHeaders* authorization_headers) {
|
| - DCHECK(HaveAuth());
|
| - DCHECK(!auth_token_.empty());
|
| - authorization_headers->SetHeader(
|
| - HttpAuth::GetAuthorizationHeaderName(target_), auth_token_);
|
| - auth_token_.clear();
|
| -}
|
| -
|
| -int HttpAuthController::HandleAuthChallenge(
|
| - scoped_refptr<HttpResponseHeaders> headers,
|
| - int load_flags,
|
| - bool establishing_tunnel) {
|
| - DCHECK(headers);
|
| - DCHECK(auth_origin_.is_valid());
|
| -
|
| - LOG(INFO) << "The " << HttpAuth::GetAuthTargetString(target_) << " "
|
| - << auth_origin_ << " requested auth"
|
| - << AuthChallengeLogMessage(headers.get());
|
| -
|
| - // The auth we tried just failed, hence it can't be valid. Remove it from
|
| - // the cache so it won't be used again.
|
| - // TODO(wtc): IsFinalRound is not the right condition. In a multi-round
|
| - // auth sequence, the server may fail the auth in round 1 if our first
|
| - // authorization header is broken. We should inspect response_.headers to
|
| - // determine if the server already failed the auth or wants us to continue.
|
| - // See http://crbug.com/21015.
|
| - if (HaveAuth() && handler_->IsFinalRound()) {
|
| - InvalidateRejectedAuthFromCache();
|
| - handler_.reset();
|
| - identity_ = HttpAuth::Identity();
|
| - }
|
| -
|
| - identity_.invalid = true;
|
| -
|
| - if (target_ != HttpAuth::AUTH_SERVER ||
|
| - !(load_flags & LOAD_DO_NOT_SEND_AUTH_DATA)) {
|
| - // Find the best authentication challenge that we support.
|
| - HttpAuth::ChooseBestChallenge(session_->http_auth_handler_factory(),
|
| - headers, target_, auth_origin_, net_log_,
|
| - &handler_);
|
| - }
|
| -
|
| - if (!handler_.get()) {
|
| - if (establishing_tunnel) {
|
| - LOG(ERROR) << "Can't perform auth to the "
|
| - << HttpAuth::GetAuthTargetString(target_) << " "
|
| - << auth_origin_ << " when establishing a tunnel"
|
| - << AuthChallengeLogMessage(headers.get());
|
| -
|
| - // We are establishing a tunnel, we can't show the error page because an
|
| - // active network attacker could control its contents. Instead, we just
|
| - // fail to establish the tunnel.
|
| - DCHECK(target_ == HttpAuth::AUTH_PROXY);
|
| - return ERR_PROXY_AUTH_REQUESTED;
|
| - }
|
| - // We found no supported challenge -- let the transaction continue
|
| - // so we end up displaying the error page.
|
| - return OK;
|
| - }
|
| -
|
| - if (handler_->NeedsIdentity()) {
|
| - // Pick a new auth identity to try, by looking to the URL and auth cache.
|
| - // If an identity to try is found, it is saved to identity_.
|
| - SelectNextAuthIdentityToTry();
|
| - } else {
|
| - // Proceed with the existing identity or a null identity.
|
| - //
|
| - // TODO(wtc): Add a safeguard against infinite transaction restarts, if
|
| - // the server keeps returning "NTLM".
|
| - identity_.invalid = false;
|
| - }
|
| -
|
| - // From this point on, we are restartable.
|
| -
|
| - if (identity_.invalid) {
|
| - // We have exhausted all identity possibilities, all we can do now is
|
| - // pass the challenge information back to the client.
|
| - PopulateAuthChallenge();
|
| - }
|
| -
|
| - // SPN determination (for Negotiate) requires a DNS lookup to find the
|
| - // canonical name. This needs to be done asynchronously to prevent blocking
|
| - // the IO thread.
|
| - if (handler_->NeedsCanonicalName())
|
| - return ERR_AUTH_NEEDS_CANONICAL_NAME;
|
| -
|
| - return OK;
|
| -}
|
| -
|
| -int HttpAuthController::ResolveCanonicalName(CompletionCallback* callback) {
|
| - DCHECK(handler_.get());
|
| - return handler_->ResolveCanonicalName(session_->host_resolver(), callback);
|
| -}
|
| -
|
| -void HttpAuthController::ResetAuth(const std::wstring& username,
|
| - const std::wstring& password) {
|
| - DCHECK(identity_.invalid || (username.empty() && password.empty()));
|
| -
|
| - if (identity_.invalid) {
|
| - // Update the username/password.
|
| - identity_.source = HttpAuth::IDENT_SRC_EXTERNAL;
|
| - identity_.invalid = false;
|
| - identity_.username = username;
|
| - identity_.password = password;
|
| - }
|
| -
|
| - DCHECK(identity_.source != HttpAuth::IDENT_SRC_PATH_LOOKUP);
|
| -
|
| - // Add the auth entry to the cache before restarting. We don't know whether
|
| - // the identity is valid yet, but if it is valid we want other transactions
|
| - // to know about it. If an entry for (origin, handler->realm()) already
|
| - // exists, we update it.
|
| - //
|
| - // If identity_.source is HttpAuth::IDENT_SRC_NONE or
|
| - // HttpAuth::IDENT_SRC_DEFAULT_CREDENTIALS, identity_ contains no
|
| - // identity because identity is not required yet or we're using default
|
| - // credentials.
|
| - //
|
| - // TODO(wtc): For NTLM_SSPI, we add the same auth entry to the cache in
|
| - // round 1 and round 2, which is redundant but correct. It would be nice
|
| - // to add an auth entry to the cache only once, preferrably in round 1.
|
| - // See http://crbug.com/21015.
|
| - switch (identity_.source) {
|
| - case HttpAuth::IDENT_SRC_NONE:
|
| - case HttpAuth::IDENT_SRC_DEFAULT_CREDENTIALS:
|
| - break;
|
| - default:
|
| - session_->auth_cache()->Add(auth_origin_, handler_->realm(),
|
| - handler_->scheme(), handler_->challenge(),
|
| - identity_.username, identity_.password,
|
| - auth_path_);
|
| - break;
|
| - }
|
| -}
|
| -
|
| -void HttpAuthController::InvalidateRejectedAuthFromCache() {
|
| - DCHECK(HaveAuth());
|
| -
|
| - // TODO(eroman): this short-circuit can be relaxed. If the realm of
|
| - // the preemptively used auth entry matches the realm of the subsequent
|
| - // challenge, then we can invalidate the preemptively used entry.
|
| - // Otherwise as-is we may send the failed credentials one extra time.
|
| - if (identity_.source == HttpAuth::IDENT_SRC_PATH_LOOKUP)
|
| - return;
|
| -
|
| - // Clear the cache entry for the identity we just failed on.
|
| - // Note: we require the username/password to match before invalidating
|
| - // since the entry in the cache may be newer than what we used last time.
|
| - session_->auth_cache()->Remove(auth_origin_, handler_->realm(),
|
| - handler_->scheme(), identity_.username,
|
| - identity_.password);
|
| -}
|
| -
|
| -bool HttpAuthController::SelectNextAuthIdentityToTry() {
|
| - DCHECK(handler_.get());
|
| - DCHECK(identity_.invalid);
|
| -
|
| - // Try to use the username/password encoded into the URL first.
|
| - if (target_ == HttpAuth::AUTH_SERVER && auth_url_.has_username() &&
|
| - !embedded_identity_used_) {
|
| - identity_.source = HttpAuth::IDENT_SRC_URL;
|
| - identity_.invalid = false;
|
| - // Extract the username:password from the URL.
|
| - GetIdentityFromURL(auth_url_,
|
| - &identity_.username,
|
| - &identity_.password);
|
| - embedded_identity_used_ = true;
|
| - // TODO(eroman): If the password is blank, should we also try combining
|
| - // with a password from the cache?
|
| - return true;
|
| - }
|
| -
|
| - // Check the auth cache for a realm entry.
|
| - HttpAuthCache::Entry* entry =
|
| - session_->auth_cache()->Lookup(auth_origin_, handler_->realm(),
|
| - handler_->scheme());
|
| -
|
| - if (entry) {
|
| - identity_.source = HttpAuth::IDENT_SRC_REALM_LOOKUP;
|
| - identity_.invalid = false;
|
| - identity_.username = entry->username();
|
| - identity_.password = entry->password();
|
| - return true;
|
| - }
|
| -
|
| - // Use default credentials (single sign on) if this is the first attempt
|
| - // at identity. Do not allow multiple times as it will infinite loop.
|
| - // We use default credentials after checking the auth cache so that if
|
| - // single sign-on doesn't work, we won't try default credentials for future
|
| - // transactions.
|
| - if (!default_credentials_used_ && handler_->AllowsDefaultCredentials()) {
|
| - identity_.source = HttpAuth::IDENT_SRC_DEFAULT_CREDENTIALS;
|
| - identity_.invalid = false;
|
| - default_credentials_used_ = true;
|
| - return true;
|
| - }
|
| -
|
| - return false;
|
| -}
|
| -
|
| -void HttpAuthController::PopulateAuthChallenge() {
|
| - // Populates response_.auth_challenge with the authentication challenge info.
|
| - // This info is consumed by URLRequestHttpJob::GetAuthChallengeInfo().
|
| -
|
| - auth_info_ = new AuthChallengeInfo;
|
| - auth_info_->is_proxy = target_ == HttpAuth::AUTH_PROXY;
|
| - auth_info_->host_and_port = ASCIIToWide(GetHostAndPort(auth_origin_));
|
| - auth_info_->scheme = ASCIIToWide(handler_->scheme());
|
| - // TODO(eroman): decode realm according to RFC 2047.
|
| - auth_info_->realm = ASCIIToWide(handler_->realm());
|
| -}
|
| -
|
| -} // namespace net
|
|
|