Chromium Code Reviews| Index: remoting/protocol/third_party_client_authenticator.cc |
| diff --git a/remoting/protocol/third_party_client_authenticator.cc b/remoting/protocol/third_party_client_authenticator.cc |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..17da58b4fa93d048fcf2a16ed66fc5ac355e1744 |
| --- /dev/null |
| +++ b/remoting/protocol/third_party_client_authenticator.cc |
| @@ -0,0 +1,80 @@ |
| +// Copyright 2013 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 "remoting/protocol/third_party_client_authenticator.h" |
| + |
| +#include "base/base64.h" |
| +#include "base/bind.h" |
| +#include "base/callback.h" |
| +#include "base/logging.h" |
| +#include "remoting/base/constants.h" |
| +#include "remoting/base/rsa_key_pair.h" |
| +#include "remoting/protocol/channel_authenticator.h" |
| +#include "remoting/protocol/v2_authenticator.h" |
| +#include "third_party/libjingle/source/talk/xmllite/xmlelement.h" |
| + |
| +namespace remoting { |
| +namespace protocol { |
| + |
| +ThirdPartyClientAuthenticator::ThirdPartyClientAuthenticator( |
| + const std::string& host_public_key, |
| + const FetchTokenCallback& fetch_token_callback) |
| + : ThirdPartyAuthenticatorBase(WAITING_MESSAGE), |
| + host_public_key_(host_public_key), |
| + fetch_token_callback_(fetch_token_callback), |
| + weak_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)) { |
| +} |
| + |
| +ThirdPartyClientAuthenticator::~ThirdPartyClientAuthenticator() { |
| +} |
| + |
| +void ThirdPartyClientAuthenticator::ProcessTokenMessage( |
| + const buzz::XmlElement* message, |
| + const base::Closure& resume_callback) { |
| + std::string token_url = message->TextNamed(kTokenUrlTag); |
| + std::string token_scope = message->TextNamed(kTokenScopeTag); |
| + if (!token_url.empty() && !token_scope.empty()) { |
| + token_state_ = PROCESSING_MESSAGE; |
| + fetch_token_callback_.Run( |
| + GURL(token_url), host_public_key_, token_scope, base::Bind( |
| + &ThirdPartyClientAuthenticator::OnThirdPartyTokenFetched, |
| + weak_factory_.GetWeakPtr(), resume_callback)); |
| + return; |
| + } |
| + |
| + LOG(ERROR) << "Third-party authentication protocol error: " |
| + "missing token verification URL or scope."; |
| + token_state_ = REJECTED; |
| + rejection_reason_ = PROTOCOL_ERROR; |
| + resume_callback.Run(); |
| +} |
| + |
| +void ThirdPartyClientAuthenticator::AddTokenElements( |
| + buzz::XmlElement* message) { |
| + DCHECK(token_state_ == MESSAGE_READY); |
| + DCHECK(!token_.empty()); |
| + |
| + buzz::XmlElement* token_tag = new buzz::XmlElement(kTokenTag); |
| + token_tag->SetBodyText(token_); |
| + message->AddElement(token_tag); |
| + token_state_ = ACCEPTED; |
| +} |
| + |
| +void ThirdPartyClientAuthenticator::OnThirdPartyTokenFetched( |
| + const base::Closure& resume_callback, const std::string& third_party_token, |
|
Sergey Ulanov
2013/03/20 07:24:12
nit: one argument per line please
rmsousa
2013/03/21 01:23:25
Done.
|
| + const std::string& shared_secret) { |
| + token_ = third_party_token; |
| + if (!token_.empty() && !shared_secret.empty()) { |
| + token_state_ = MESSAGE_READY; |
| + underlying_ = V2Authenticator::CreateForClient( |
| + shared_secret, MESSAGE_READY); |
| + } else { |
| + token_state_ = REJECTED; |
| + rejection_reason_ = INVALID_CREDENTIALS; |
| + } |
| + resume_callback.Run(); |
| +} |
| + |
| +} // namespace protocol |
| +} // namespace remoting |