Client plugin changes to support third party authentication.

remoting/protocol/negotiating_client_authenticator.cc

 // 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/negotiating_client_authenticator.h"
 
 #include <algorithm>
 #include <sstream>
 
 #include "base/bind.h"
 #include "base/callback.h"
 #include "base/logging.h"
 #include "base/strings/string_split.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 {
 
 NegotiatingClientAuthenticator::NegotiatingClientAuthenticator(
     const std::string& authentication_tag,
     const FetchSecretCallback& fetch_secret_callback,
+    scoped_ptr<ThirdPartyClientAuthenticator::TokenFetcher> token_fetcher,
     const std::vector<AuthenticationMethod>& methods)
     : NegotiatingAuthenticatorBase(MESSAGE_READY),
       authentication_tag_(authentication_tag),
       fetch_secret_callback_(fetch_secret_callback),
+      token_fetcher_(token_fetcher.Pass()),
       method_set_by_host_(false),
       weak_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)) {
   DCHECK(!methods.empty());
   for (std::vector<AuthenticationMethod>::const_iterator it = methods.begin();
        it != methods.end(); ++it) {
     AddMethod(*it);
   }
 }
 
 NegotiatingClientAuthenticator::~NegotiatingClientAuthenticator() {
@@ skipping 52 matching lines @@
     result->AddAttr(kSupportedMethodsAttributeQName, supported_methods.str());
     state_ = WAITING_MESSAGE;
     return result.Pass();
   }
   return GetNextMessageInternal();
 }
 
 void NegotiatingClientAuthenticator::CreateAuthenticator(
     Authenticator::State preferred_initial_state,
     const base::Closure& resume_callback) {
-  fetch_secret_callback_.Run(base::Bind(
-      &NegotiatingClientAuthenticator::CreateV2AuthenticatorWithSecret,
-      weak_factory_.GetWeakPtr(), preferred_initial_state, resume_callback));
+  DCHECK(current_method_.is_valid());
+  if (current_method_.type() == AuthenticationMethod::THIRD_PARTY) {
+    // |ThirdPartyClientAuthenticator| takes ownership of |token_fetcher_|.
+    // The authentication method negotiation logic should guarantee that only
+    // one |ThirdPartyClientAuthenticator| will need to be created per session.
+    DCHECK(token_fetcher_);
+    current_authenticator_.reset(new ThirdPartyClientAuthenticator(
+        token_fetcher_.Pass()));
+    resume_callback.Run();
+  } else {
+    fetch_secret_callback_.Run(base::Bind(
+        &NegotiatingClientAuthenticator::CreateV2AuthenticatorWithSecret,
+        weak_factory_.GetWeakPtr(), preferred_initial_state, resume_callback));
+  }
 }
 
 void NegotiatingClientAuthenticator::CreateV2AuthenticatorWithSecret(
     Authenticator::State initial_state,
     const base::Closure& resume_callback,
     const std::string& shared_secret) {
   current_authenticator_ = V2Authenticator::CreateForClient(
       AuthenticationMethod::ApplyHashFunction(
           current_method_.hash_function(), authentication_tag_, shared_secret),
       initial_state);
   resume_callback.Run();
 }
 
 }  // namespace protocol
 }  // namespace remoting