[Sync] //components/sync internal changes [DO NOT SUBMIT]

components/sync/tools/sync_client.cc

 // 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.
 
 #include <stdint.h>
 
 #include <cstddef>
 #include <cstdio>
 #include <memory>
 #include <string>
@@ skipping 10 matching lines @@
 #include "base/memory/ref_counted.h"
 #include "base/memory/weak_ptr.h"
 #include "base/message_loop/message_loop.h"
 #include "base/rand_util.h"
 #include "base/run_loop.h"
 #include "base/task_runner.h"
 #include "base/threading/thread.h"
 #include "build/build_config.h"
 #include "components/invalidation/impl/non_blocking_invalidator.h"
 #include "components/invalidation/public/object_id_invalidation_map.h"
+#include "components/sync/base/cancelation_signal.h"
+#include "components/sync/base/model_type.h"
+#include "components/sync/base/unrecoverable_error_handler.h"
+#include "components/sync/base/weak_handle.h"
+#include "components/sync/core/base_node.h"
+#include "components/sync/core/http_bridge.h"
+#include "components/sync/core/http_post_provider_factory.h"
+#include "components/sync/core/internal_components_factory_impl.h"
+#include "components/sync/core/read_node.h"
+#include "components/sync/core/sync_manager.h"
+#include "components/sync/core/sync_manager_factory.h"
+#include "components/sync/engine/passive_model_worker.h"
+#include "components/sync/js/js_event_details.h"
+#include "components/sync/js/js_event_handler.h"
+#include "components/sync/test/fake_encryptor.h"
+#include "components/sync/tools/null_invalidation_state_tracker.h"
 #include "components/sync_driver/invalidation_helper.h"
 #include "jingle/notifier/base/notification_method.h"
 #include "jingle/notifier/base/notifier_options.h"
 #include "net/base/host_port_pair.h"
 #include "net/base/network_change_notifier.h"
 #include "net/dns/host_resolver.h"
 #include "net/http/transport_security_state.h"
 #include "net/url_request/url_request_test_util.h"
-#include "sync/internal_api/public/base/cancelation_signal.h"
-#include "sync/internal_api/public/base/model_type.h"
-#include "sync/internal_api/public/base_node.h"
-#include "sync/internal_api/public/engine/passive_model_worker.h"
-#include "sync/internal_api/public/http_bridge.h"
-#include "sync/internal_api/public/http_post_provider_factory.h"
-#include "sync/internal_api/public/internal_components_factory_impl.h"
-#include "sync/internal_api/public/read_node.h"
-#include "sync/internal_api/public/sync_manager.h"
-#include "sync/internal_api/public/sync_manager_factory.h"
-#include "sync/internal_api/public/util/unrecoverable_error_handler.h"
-#include "sync/internal_api/public/util/weak_handle.h"
-#include "sync/js/js_event_details.h"
-#include "sync/js/js_event_handler.h"
-#include "sync/test/fake_encryptor.h"
-#include "sync/tools/null_invalidation_state_tracker.h"
 #include "url/gurl.h"
 
 #if defined(OS_MACOSX)
 #include "base/mac/scoped_nsautorelease_pool.h"
 #endif
 
 // This is a simple utility that initializes a sync client and
 // prints out any events.
 
 // TODO(akalin): Refactor to combine shared code with
@@ skipping 68 matching lines @@
 }
 
 class LoggingChangeDelegate : public SyncManager::ChangeDelegate {
  public:
   ~LoggingChangeDelegate() override {}
 
   void OnChangesApplied(ModelType model_type,
                         int64_t model_version,
                         const BaseTransaction* trans,
                         const ImmutableChangeRecordList& changes) override {
-    LOG(INFO) << "Changes applied for "
-              << ModelTypeToString(model_type);
+    LOG(INFO) << "Changes applied for " << ModelTypeToString(model_type);
     size_t i = 1;
     size_t change_count = changes.Get().size();
-    for (ChangeRecordList::const_iterator it =
-             changes.Get().begin(); it != changes.Get().end(); ++it) {
+    for (ChangeRecordList::const_iterator it = changes.Get().begin();
+         it != changes.Get().end(); ++it) {
       std::unique_ptr<base::DictionaryValue> change_value(it->ToValue());
-      LOG(INFO) << "Change (" << i << "/" << change_count << "): "
-                << ValueToString(*change_value);
+      LOG(INFO) << "Change (" << i << "/" << change_count
+                << "): " << ValueToString(*change_value);
       if (it->action != ChangeRecord::ACTION_DELETE) {
         ReadNode node(trans);
         CHECK_EQ(node.InitByIdLookup(it->id), BaseNode::INIT_OK);
         std::unique_ptr<base::DictionaryValue> details(node.ToValue());
         VLOG(1) << "Details: " << ValueToString(*details);
       }
       ++i;
     }
   }
 
   void OnChangesComplete(ModelType model_type) override {
-    LOG(INFO) << "Changes complete for "
-              << ModelTypeToString(model_type);
+    LOG(INFO) << "Changes complete for " << ModelTypeToString(model_type);
   }
 };
 
-class LoggingUnrecoverableErrorHandler
-    : public UnrecoverableErrorHandler {
+class LoggingUnrecoverableErrorHandler : public UnrecoverableErrorHandler {
  public:
   ~LoggingUnrecoverableErrorHandler() override {}
 
   void OnUnrecoverableError(const tracked_objects::Location& from_here,
                             const std::string& message) override {
     if (LOG_IS_ON(ERROR)) {
       logging::LogMessage(from_here.file_name(), from_here.line_number(),
-                          logging::LOG_ERROR).stream()
+                          logging::LOG_ERROR)
+              .stream()
           << message;
     }
   }
 };
 
 class LoggingJsEventHandler
     : public JsEventHandler,
       public base::SupportsWeakPtr<LoggingJsEventHandler> {
  public:
   ~LoggingJsEventHandler() override {}
@@ skipping 34 matching lines @@
       : sync_manager_(sync_manager) {}
 
   void OnInvalidatorStateChange(InvalidatorState state) override {
     sync_manager_->SetInvalidatorEnabled(state == INVALIDATIONS_ENABLED);
   }
 
   void OnIncomingInvalidation(
       const ObjectIdInvalidationMap& invalidation_map) override {
     syncer::ObjectIdSet ids = invalidation_map.GetObjectIds();
     for (syncer::ObjectIdSet::const_iterator ids_it = ids.begin();
-         ids_it != ids.end();
-         ++ids_it) {
+         ids_it != ids.end(); ++ids_it) {
       syncer::ModelType type;
       if (!NotificationTypeToRealModelType(ids_it->name(), &type)) {
         DLOG(WARNING) << "Notification has invalid id: "
                       << syncer::ObjectIdToString(*ids_it);
       } else {
         syncer::SingleObjectInvalidationSet invalidation_set =
             invalidation_map.ForObject(*ids_it);
         for (syncer::SingleObjectInvalidationSet::const_iterator inv_it =
                  invalidation_set.begin();
-             inv_it != invalidation_set.end();
-             ++inv_it) {
+             inv_it != invalidation_set.end(); ++inv_it) {
           std::unique_ptr<syncer::InvalidationInterface> inv_adapter(
               new InvalidationAdapter(*inv_it));
           sync_manager_->OnIncomingInvalidation(type, std::move(inv_adapter));
         }
       }
     }
   }
 
   std::string GetOwnerName() const override { return "InvalidatorShim"; }
 
  private:
   SyncManager* sync_manager_;
 };
 
 void LogUnrecoverableErrorContext() {
   base::debug::StackTrace().Print();
 }
 
 notifier::NotifierOptions ParseNotifierOptions(
     const base::CommandLine& command_line,
     const scoped_refptr<net::URLRequestContextGetter>& request_context_getter) {
   notifier::NotifierOptions notifier_options;
   notifier_options.request_context_getter = request_context_getter;
   notifier_options.auth_mechanism = "X-OAUTH2";
 
   if (command_line.HasSwitch(kXmppHostPortSwitch)) {
-    notifier_options.xmpp_host_port =
-        net::HostPortPair::FromString(
-            command_line.GetSwitchValueASCII(kXmppHostPortSwitch));
+    notifier_options.xmpp_host_port = net::HostPortPair::FromString(
+        command_line.GetSwitchValueASCII(kXmppHostPortSwitch));
     LOG(INFO) << "Using " << notifier_options.xmpp_host_port.ToString()
               << " for test sync notification server.";
   }
 
   notifier_options.try_ssltcp_first =
       command_line.HasSwitch(kXmppTrySslTcpFirstSwitch);
   LOG_IF(INFO, notifier_options.try_ssltcp_first)
       << "Trying SSL/TCP port before XMPP port for notifications.";
 
   notifier_options.allow_insecure_connection =
       command_line.HasSwitch(kXmppAllowInsecureConnectionSwitch);
   LOG_IF(INFO, notifier_options.allow_insecure_connection)
       << "Allowing insecure XMPP connections.";
 
   return notifier_options;
 }
 
 void StubNetworkTimeUpdateCallback(const base::Time&,
                                    const base::TimeDelta&,
-                                   const base::TimeDelta&) {
-}
+                                   const base::TimeDelta&) {}
 
 int SyncClientMain(int argc, char* argv[]) {
 #if defined(OS_MACOSX)
   base::mac::ScopedNSAutoreleasePool pool;
 #endif
   base::AtExitManager exit_manager;
   base::CommandLine::Init(argc, argv);
   logging::LoggingSettings settings;
   settings.logging_dest = logging::LOG_TO_SYSTEM_DEBUG_LOG;
   logging::InitLogging(settings);
 
   base::MessageLoop sync_loop;
   base::Thread io_thread("IO thread");
   base::Thread::Options options;
   options.message_loop_type = base::MessageLoop::TYPE_IO;
   io_thread.StartWithOptions(options);
 
   // Parse command line.
   const base::CommandLine& command_line =
       *base::CommandLine::ForCurrentProcess();
   SyncCredentials credentials;
   credentials.account_id = command_line.GetSwitchValueASCII(kEmailSwitch);
   credentials.email = command_line.GetSwitchValueASCII(kEmailSwitch);
   credentials.sync_token = command_line.GetSwitchValueASCII(kTokenSwitch);
   // TODO(akalin): Write a wrapper script that gets a token for an
   // email and password and passes that in to this utility.
   if (credentials.email.empty() || credentials.sync_token.empty()) {
-    std::printf("Usage: %s --%s=foo@bar.com --%s=token\n"
-                "[--%s=host:port] [--%s] [--%s]\n"
-                "Run chrome and set a breakpoint on\n"
-                "syncer::SyncManagerImpl::UpdateCredentials() "
-                "after logging into\n"
-                "sync to get the token to pass into this utility.\n",
-                argv[0],
-                kEmailSwitch, kTokenSwitch, kXmppHostPortSwitch,
-                kXmppTrySslTcpFirstSwitch,
-                kXmppAllowInsecureConnectionSwitch);
+    std::printf(
+        "Usage: %s --%s=foo@bar.com --%s=token\n"
+        "[--%s=host:port] [--%s] [--%s]\n"
+        "Run chrome and set a breakpoint on\n"
+        "syncer::SyncManagerImpl::UpdateCredentials() "
+        "after logging into\n"
+        "sync to get the token to pass into this utility.\n",
+        argv[0], kEmailSwitch, kTokenSwitch, kXmppHostPortSwitch,
+        kXmppTrySslTcpFirstSwitch, kXmppAllowInsecureConnectionSwitch);
     return -1;
   }
 
   // Set up objects that monitor the network.
   std::unique_ptr<net::NetworkChangeNotifier> network_change_notifier(
       net::NetworkChangeNotifier::Create());
 
   // Set up sync notifier factory.
   const scoped_refptr<MyTestURLRequestContextGetter> context_getter =
       new MyTestURLRequestContextGetter(io_thread.task_runner());
@@ skipping 38 matching lines @@
   model_types.Put(SYNCED_NOTIFICATIONS);
   model_types.Put(SYNCED_NOTIFICATION_APP_INFO);
   model_types.Put(DEVICE_INFO);
   model_types.Put(EXPERIMENTS);
   model_types.Put(PRIORITY_PREFERENCES);
   model_types.Put(DICTIONARY);
   model_types.Put(FAVICON_IMAGES);
   model_types.Put(FAVICON_TRACKING);
 
   ModelSafeRoutingInfo routing_info;
-  for (ModelTypeSet::Iterator it = model_types.First();
-       it.Good(); it.Inc()) {
+  for (ModelTypeSet::Iterator it = model_types.First(); it.Good(); it.Inc()) {
     routing_info[it.Get()] = GROUP_PASSIVE;
   }
   scoped_refptr<PassiveModelWorker> passive_model_safe_worker =
       new PassiveModelWorker(nullptr);
-  std::vector<scoped_refptr<ModelSafeWorker> > workers;
+  std::vector<scoped_refptr<ModelSafeWorker>> workers;
   workers.push_back(passive_model_safe_worker);
 
   // Set up sync manager.
   SyncManagerFactory sync_manager_factory;
   std::unique_ptr<SyncManager> sync_manager =
       sync_manager_factory.CreateSyncManager("sync_client manager");
   LoggingJsEventHandler js_event_handler;
   // Used only by InitialProcessMetadata(), so it's okay to leave this as NULL.
   const scoped_refptr<base::TaskRunner> blocking_task_runner = NULL;
   const char kUserAgent[] = "sync_client";
   // TODO(akalin): Replace this with just the context getter once
   // HttpPostProviderFactory is removed.
   CancelationSignal factory_cancelation_signal;
   std::unique_ptr<HttpPostProviderFactory> post_factory(new HttpBridgeFactory(
       context_getter.get(), base::Bind(&StubNetworkTimeUpdateCallback),
       &factory_cancelation_signal));
   post_factory->Init(kUserAgent, BindToTrackerCallback());
   // Used only when committing bookmarks, so it's okay to leave this
   // as NULL.
   ExtensionsActivity* extensions_activity = NULL;
   LoggingChangeDelegate change_delegate;
   const char kRestoredKeyForBootstrapping[] = "";
   const char kRestoredKeystoreKeyForBootstrapping[] = "";
   NullEncryptor null_encryptor;
   InternalComponentsFactoryImpl::Switches factory_switches = {
       InternalComponentsFactory::ENCRYPTION_KEYSTORE,
-      InternalComponentsFactory::BACKOFF_NORMAL
-  };
+      InternalComponentsFactory::BACKOFF_NORMAL};
   CancelationSignal scm_cancelation_signal;
 
   SyncManager::InitArgs args;
   args.database_location = database_dir.path();
   args.event_handler = WeakHandle<JsEventHandler>(js_event_handler.AsWeakPtr());
   args.service_url = GURL(kSyncServiceURL);
   args.post_factory = std::move(post_factory);
   args.workers = workers;
   args.extensions_activity = extensions_activity;
   args.change_delegate = &change_delegate;
@@ skipping 25 matching lines @@
   io_thread.Stop();
   return 0;
 }
 
 }  // namespace
 }  // namespace syncer
 
 int main(int argc, char* argv[]) {
   return syncer::SyncClientMain(argc, argv);
 }