[Chromoting] Hook up host talkgadget policy checks.

remoting/host/signaling_connector.h

 // Copyright (c) 2012 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.
 
 #ifndef REMOTING_HOST_SIGNALING_CONNECTOR_H_
 #define REMOTING_HOST_SIGNALING_CONNECTOR_H_
 
 #include "base/basictypes.h"
 #include "base/memory/weak_ptr.h"
 #include "base/threading/non_thread_safe.h"
 #include "base/timer.h"
 #include "net/base/network_change_notifier.h"
+#include "net/url_request/url_fetcher_delegate.h"
 #include "remoting/host/gaia_oauth_client.h"
 #include "remoting/jingle_glue/xmpp_signal_strategy.h"
 
 namespace net {
+class URLFetcher;
 class URLRequestContextGetter;
 }  // namespace net
 
 namespace remoting {
 
+class ChromotingHostContext;
+
 // SignalingConnector listens for SignalStrategy status notifications
 // and attempts to keep it connected when possible. When signalling is
 // not connected it keeps trying to reconnect it until it is
 // connected. It limits connection attempt rate using exponential
 // backoff. It also monitors network state and reconnects signalling
 // whenever connection type changes or IP address changes.
 class SignalingConnector
     : public base::SupportsWeakPtr<SignalingConnector>,
       public base::NonThreadSafe,
       public SignalStrategy::Listener,
+      public net::URLFetcherDelegate,

[Sergey Ulanov, 2012/08/24 19:43:33]

Can you please move the new connectivity checking logic to a separate class
(e.g. call it ConnectionBlockChecker or something like that)?
This class is already complicated as is (it inherits from 6 classes already!). 
Also moving this logic outside of this class will allow to turn the new policy
off and on very easily by supplying different implementations of
ConnectionBlockChecker.

[garykac, 2012/08/27 22:34:57]

Done.

       public net::NetworkChangeNotifier::ConnectionTypeObserver,
       public net::NetworkChangeNotifier::IPAddressObserver,
       public GaiaOAuthClient::Delegate {
  public:
   // This structure contains information required to perform
   // authentication to OAuth2.
   struct OAuthCredentials {
     OAuthCredentials(const std::string& login_value,
                      const std::string& refresh_token_value,
                      const OAuthClientInfo& client_info);
 
     // The user's account name (i.e. their email address).
     std::string login;
 
     // Token delegating authority to us to act as the user.
     std::string refresh_token;
 
     // Credentials identifying the application to OAuth.
     OAuthClientInfo client_info;
   };
 
   // The |auth_failed_callback| is called when authentication fails.
   SignalingConnector(XmppSignalStrategy* signal_strategy,
+                     ChromotingHostContext* context,
+                     std::string talkgadget_prefix,
                      const base::Closure& auth_failed_callback);
   virtual ~SignalingConnector();
 
   // May be called immediately after the constructor to enable OAuth
   // access token updating.
-  void EnableOAuth(scoped_ptr<OAuthCredentials> oauth_credentials,
-                   net::URLRequestContextGetter* url_context);
+  void EnableOAuth(scoped_ptr<OAuthCredentials> oauth_credentials);
 
   // SignalStrategy::Listener interface.
   virtual void OnSignalStrategyStateChange(
       SignalStrategy::State state) OVERRIDE;
   virtual bool OnSignalStrategyIncomingStanza(
       const buzz::XmlElement* stanza) OVERRIDE;
 
-  // NetworkChangeNotifier::IPAddressObserver interface.
-  virtual void OnIPAddressChanged() OVERRIDE;
+  // net::URLFetcherDelegate interface.
+  virtual void OnURLFetchComplete(const net::URLFetcher* source) OVERRIDE;
 
   // NetworkChangeNotifier::ConnectionTypeObserver interface.
   virtual void OnConnectionTypeChanged(
       net::NetworkChangeNotifier::ConnectionType type) OVERRIDE;
 
+  // NetworkChangeNotifier::IPAddressObserver interface.
+  virtual void OnIPAddressChanged() OVERRIDE;
+
   // GaiaOAuthClient::Delegate interface.
   virtual void OnRefreshTokenResponse(const std::string& user_email,
                                       const std::string& access_token,
                                       int expires_seconds) OVERRIDE;
   virtual void OnOAuthError() OVERRIDE;
   virtual void OnNetworkError(int response_code) OVERRIDE;
 
  private:
   void ScheduleTryReconnect();
   void ResetAndTryReconnect();
   void TryReconnect();
 
   void RefreshOAuthToken();
 
   XmppSignalStrategy* signal_strategy_;
+  ChromotingHostContext* context_;
   base::Closure auth_failed_callback_;
 
   scoped_ptr<OAuthCredentials> oauth_credentials_;
   scoped_ptr<GaiaOAuthClient> gaia_oauth_client_;
 
+  // URL fetcher used to verify access to the host talkgadget.
+  scoped_ptr<net::URLFetcher> url_fetcher_;
+
+  // The string pre-pended to '.talkgadget.google.com' to create the full
+  // talkgadget domain name for the host.
+  std::string talkgadget_prefix_;
+
+  // Did we make a successful connection to the host talkgadget?
+  bool found_talkgadget_;
+
   // Number of times we tried to connect without success.
   int reconnect_attempts_;
 
   bool refreshing_oauth_token_;
   base::Time auth_token_expiry_time_;
 
   base::OneShotTimer<SignalingConnector> timer_;
 
   DISALLOW_COPY_AND_ASSIGN(SignalingConnector);
 };
 
 }  // namespace remoting
 
 #endif  // REMOTING_HOST_SIGNALING_CONNECTOR_H_