1c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath// Copyright (c) 2012 The Chromium Authors. All rights reserved. 2c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath// Use of this source code is governed by a BSD-style license that can be 3c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath// found in the LICENSE file. 4c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 5c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include <cstddef> 6c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include <cstdio> 7c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include <string> 8c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 9c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "base/at_exit.h" 10c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "base/command_line.h" 11c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "base/compiler_specific.h" 12c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "base/debug/stack_trace.h" 13c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "base/files/scoped_temp_dir.h" 14c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "base/json/json_writer.h" 15c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "base/logging.h" 16c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "base/memory/ref_counted.h" 17c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "base/memory/scoped_ptr.h" 18c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "base/memory/weak_ptr.h" 19c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "base/message_loop/message_loop.h" 20c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "base/rand_util.h" 21c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "base/task_runner.h" 22c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "base/threading/thread.h" 23c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "components/invalidation/non_blocking_invalidator.h" 24c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "components/invalidation/object_id_invalidation_map.h" 25c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "jingle/notifier/base/notification_method.h" 26c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "jingle/notifier/base/notifier_options.h" 27c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "net/base/host_port_pair.h" 28c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "net/base/network_change_notifier.h" 29c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "net/dns/host_resolver.h" 30c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "net/http/transport_security_state.h" 31c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "net/url_request/url_request_test_util.h" 32c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/internal_api/public/base/cancelation_signal.h" 33c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/internal_api/public/base/model_type.h" 34c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/internal_api/public/base_node.h" 35c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/internal_api/public/engine/passive_model_worker.h" 36c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/internal_api/public/http_bridge.h" 37c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/internal_api/public/internal_components_factory_impl.h" 38c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/internal_api/public/read_node.h" 39c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/internal_api/public/sync_manager.h" 40c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/internal_api/public/sync_manager_factory.h" 41c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/internal_api/public/util/report_unrecoverable_error_function.h" 42c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/internal_api/public/util/unrecoverable_error_handler.h" 43c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/internal_api/public/util/weak_handle.h" 44c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/js/js_event_details.h" 45c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/js/js_event_handler.h" 46c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/test/fake_encryptor.h" 47c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/tools/invalidation_helper.h" 48c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "sync/tools/null_invalidation_state_tracker.h" 49c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "url/gurl.h" 50c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 51c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#if defined(OS_MACOSX) 52c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#include "base/mac/scoped_nsautorelease_pool.h" 53c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#endif 54c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 55c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath// This is a simple utility that initializes a sync client and 56c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath// prints out any events. 57c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 58c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath// TODO(akalin): Refactor to combine shared code with 59c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath// sync_listen_notifications. 60c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathnamespace syncer { 61c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathnamespace { 62c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 63c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathconst char kEmailSwitch[] = "email"; 64c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathconst char kTokenSwitch[] = "token"; 65c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathconst char kXmppHostPortSwitch[] = "xmpp-host-port"; 66c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathconst char kXmppTrySslTcpFirstSwitch[] = "xmpp-try-ssltcp-first"; 67c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathconst char kXmppAllowInsecureConnectionSwitch[] = 68c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath "xmpp-allow-insecure-connection"; 69c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathconst char kSyncServiceURL[] = "https://clients4.google.com/chrome-sync/dev"; 70c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 71c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath// Needed to use a real host resolver. 72c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathclass MyTestURLRequestContext : public net::TestURLRequestContext { 73c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath public: 74c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath MyTestURLRequestContext() : TestURLRequestContext(true) { 75c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath context_storage_.set_host_resolver( 76c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath net::HostResolver::CreateDefaultResolver(NULL)); 77c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath context_storage_.set_transport_security_state( 78c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath new net::TransportSecurityState()); 79c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath Init(); 80c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 81c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 82c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual ~MyTestURLRequestContext() {} 83c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath}; 84c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 85c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathclass MyTestURLRequestContextGetter : public net::TestURLRequestContextGetter { 86c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath public: 87c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath explicit MyTestURLRequestContextGetter( 88c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath const scoped_refptr<base::SingleThreadTaskRunner>& io_task_runner) 89c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath : TestURLRequestContextGetter(io_task_runner) {} 90c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 91c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual net::TestURLRequestContext* GetURLRequestContext() OVERRIDE { 92c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath // Construct |context_| lazily so it gets constructed on the right 93c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath // thread (the IO thread). 94c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath if (!context_) 95c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath context_.reset(new MyTestURLRequestContext()); 96c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath return context_.get(); 97c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 98c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 99c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath private: 100c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual ~MyTestURLRequestContextGetter() {} 101c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 102c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath scoped_ptr<MyTestURLRequestContext> context_; 103c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath}; 104c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 105c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath// TODO(akalin): Use system encryptor once it's moved to sync/. 106c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathclass NullEncryptor : public Encryptor { 107c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath public: 108c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual ~NullEncryptor() {} 109c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 110c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual bool EncryptString(const std::string& plaintext, 111c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath std::string* ciphertext) OVERRIDE { 112c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath *ciphertext = plaintext; 113c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath return true; 114c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 115c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 116c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual bool DecryptString(const std::string& ciphertext, 117c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath std::string* plaintext) OVERRIDE { 118c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath *plaintext = ciphertext; 119c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath return true; 120c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 121c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath}; 122c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 123c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathstd::string ValueToString(const base::Value& value) { 124c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath std::string str; 125c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath base::JSONWriter::Write(&value, &str); 126c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath return str; 127c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath} 128c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 129c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathclass LoggingChangeDelegate : public SyncManager::ChangeDelegate { 130c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath public: 131c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual ~LoggingChangeDelegate() {} 132c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 133c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual void OnChangesApplied( 134c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath ModelType model_type, 135c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath int64 model_version, 136c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath const BaseTransaction* trans, 137c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath const ImmutableChangeRecordList& changes) OVERRIDE { 138c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath LOG(INFO) << "Changes applied for " 139c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath << ModelTypeToString(model_type); 140c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath size_t i = 1; 141c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath size_t change_count = changes.Get().size(); 142c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath for (ChangeRecordList::const_iterator it = 143c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath changes.Get().begin(); it != changes.Get().end(); ++it) { 144c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath scoped_ptr<base::DictionaryValue> change_value(it->ToValue()); 145c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath LOG(INFO) << "Change (" << i << "/" << change_count << "): " 146c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath << ValueToString(*change_value); 147c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath if (it->action != ChangeRecord::ACTION_DELETE) { 148c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath ReadNode node(trans); 149c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath CHECK_EQ(node.InitByIdLookup(it->id), BaseNode::INIT_OK); 150c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath scoped_ptr<base::DictionaryValue> details(node.ToValue()); 151c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath VLOG(1) << "Details: " << ValueToString(*details); 152c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 153c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath ++i; 154c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 155c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 156c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 157c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual void OnChangesComplete(ModelType model_type) OVERRIDE { 158c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath LOG(INFO) << "Changes complete for " 159c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath << ModelTypeToString(model_type); 160c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 161c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath}; 162c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 163c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathclass LoggingUnrecoverableErrorHandler 164c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath : public UnrecoverableErrorHandler { 165c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath public: 166c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual ~LoggingUnrecoverableErrorHandler() {} 167c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 168c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual void OnUnrecoverableError(const tracked_objects::Location& from_here, 169c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath const std::string& message) OVERRIDE { 170c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath if (LOG_IS_ON(ERROR)) { 171c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath logging::LogMessage(from_here.file_name(), from_here.line_number(), 172c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath logging::LOG_ERROR).stream() 173c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath << message; 174c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 175c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 176c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath}; 177c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 178c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathclass LoggingJsEventHandler 179c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath : public JsEventHandler, 180c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath public base::SupportsWeakPtr<LoggingJsEventHandler> { 181c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath public: 182c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual ~LoggingJsEventHandler() {} 183c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 184c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual void HandleJsEvent( 185c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath const std::string& name, 186c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath const JsEventDetails& details) OVERRIDE { 187c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath VLOG(1) << name << ": " << details.ToString(); 188c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 189c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath}; 190c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 191c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathclass InvalidationAdapter : public syncer::InvalidationInterface { 192c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath public: 193c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath explicit InvalidationAdapter(const syncer::Invalidation& invalidation) 194c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath : invalidation_(invalidation) {} 195c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual ~InvalidationAdapter() {} 196c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 197c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual bool IsUnknownVersion() const OVERRIDE { 198c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath return invalidation_.is_unknown_version(); 199c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 200c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 201c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual const std::string& GetPayload() const OVERRIDE { 202c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath return invalidation_.payload(); 203c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 204c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 205c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual int64 GetVersion() const OVERRIDE { 206c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath return invalidation_.version(); 207c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 208c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 209c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual void Acknowledge() OVERRIDE { 210c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath invalidation_.Acknowledge(); 211c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 212c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 213c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual void Drop() OVERRIDE { 214c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath invalidation_.Drop(); 215c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 216c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 217c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath private: 218c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath syncer::Invalidation invalidation_; 219c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath}; 220c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 221c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathclass InvalidatorShim : public InvalidationHandler { 222c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath public: 223c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath explicit InvalidatorShim(SyncManager* sync_manager) 224c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath : sync_manager_(sync_manager) {} 225c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 226c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual void OnInvalidatorStateChange(InvalidatorState state) OVERRIDE { 227c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath sync_manager_->SetInvalidatorEnabled(state == INVALIDATIONS_ENABLED); 228c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 229c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 230c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual void OnIncomingInvalidation( 231c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath const ObjectIdInvalidationMap& invalidation_map) OVERRIDE { 232c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath syncer::ObjectIdSet ids = invalidation_map.GetObjectIds(); 233c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath for (syncer::ObjectIdSet::const_iterator ids_it = ids.begin(); 234c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath ids_it != ids.end(); 235c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath ++ids_it) { 236c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath syncer::ModelType type; 237c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath if (!NotificationTypeToRealModelType(ids_it->name(), &type)) { 238c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath DLOG(WARNING) << "Notification has invalid id: " 239c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath << syncer::ObjectIdToString(*ids_it); 240c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } else { 241c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath syncer::SingleObjectInvalidationSet invalidation_set = 242c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath invalidation_map.ForObject(*ids_it); 243c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath for (syncer::SingleObjectInvalidationSet::const_iterator inv_it = 244c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath invalidation_set.begin(); 245c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath inv_it != invalidation_set.end(); 246c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath ++inv_it) { 247c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath scoped_ptr<syncer::InvalidationInterface> inv_adapter( 248c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath new InvalidationAdapter(*inv_it)); 249c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath sync_manager_->OnIncomingInvalidation(type, inv_adapter.Pass()); 250c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 251c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 252c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 253c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 254c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 255c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath virtual std::string GetOwnerName() const OVERRIDE { 256c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath return "InvalidatorShim"; 257c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 258c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 259c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath private: 260c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath SyncManager* sync_manager_; 261c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath}; 262c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 263c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathvoid LogUnrecoverableErrorContext() { 264c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath base::debug::StackTrace().Print(); 265c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath} 266c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 267c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathnotifier::NotifierOptions ParseNotifierOptions( 268c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath const CommandLine& command_line, 269c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath const scoped_refptr<net::URLRequestContextGetter>& 270c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath request_context_getter) { 271c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath notifier::NotifierOptions notifier_options; 272c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath notifier_options.request_context_getter = request_context_getter; 273c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath notifier_options.auth_mechanism = "X-OAUTH2"; 274c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 275c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath if (command_line.HasSwitch(kXmppHostPortSwitch)) { 276c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath notifier_options.xmpp_host_port = 277c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath net::HostPortPair::FromString( 278c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath command_line.GetSwitchValueASCII(kXmppHostPortSwitch)); 279c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath LOG(INFO) << "Using " << notifier_options.xmpp_host_port.ToString() 280c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath << " for test sync notification server."; 281c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 282c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 283c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath notifier_options.try_ssltcp_first = 284c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath command_line.HasSwitch(kXmppTrySslTcpFirstSwitch); 285c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath LOG_IF(INFO, notifier_options.try_ssltcp_first) 286c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath << "Trying SSL/TCP port before XMPP port for notifications."; 287c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 288c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath notifier_options.allow_insecure_connection = 289c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath command_line.HasSwitch(kXmppAllowInsecureConnectionSwitch); 290c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath LOG_IF(INFO, notifier_options.allow_insecure_connection) 291c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath << "Allowing insecure XMPP connections."; 292c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 293c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath return notifier_options; 294c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath} 295c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 296c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathvoid StubNetworkTimeUpdateCallback(const base::Time&, 297c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath const base::TimeDelta&, 298c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath const base::TimeDelta&) { 299c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath} 300c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 301c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamathint SyncClientMain(int argc, char* argv[]) { 302c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#if defined(OS_MACOSX) 303c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath base::mac::ScopedNSAutoreleasePool pool; 304c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath#endif 305c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath base::AtExitManager exit_manager; 306c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath CommandLine::Init(argc, argv); 307c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath logging::LoggingSettings settings; 308c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath settings.logging_dest = logging::LOG_TO_SYSTEM_DEBUG_LOG; 309c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath logging::InitLogging(settings); 310c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 311c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath base::MessageLoop sync_loop; 312c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath base::Thread io_thread("IO thread"); 313c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath base::Thread::Options options; 314c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath options.message_loop_type = base::MessageLoop::TYPE_IO; 315c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath io_thread.StartWithOptions(options); 316c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 317c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath // Parse command line. 318c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath const CommandLine& command_line = *CommandLine::ForCurrentProcess(); 319c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath SyncCredentials credentials; 320c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath credentials.email = command_line.GetSwitchValueASCII(kEmailSwitch); 321c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath credentials.sync_token = command_line.GetSwitchValueASCII(kTokenSwitch); 322c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath // TODO(akalin): Write a wrapper script that gets a token for an 323c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath // email and password and passes that in to this utility. 324c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath if (credentials.email.empty() || credentials.sync_token.empty()) { 325c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath std::printf("Usage: %s --%s=foo@bar.com --%s=token\n" 326c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath "[--%s=host:port] [--%s] [--%s]\n" 327c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath "Run chrome and set a breakpoint on\n" 328c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath "syncer::SyncManagerImpl::UpdateCredentials() " 329c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath "after logging into\n" 330c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath "sync to get the token to pass into this utility.\n", 331c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath argv[0], 332c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath kEmailSwitch, kTokenSwitch, kXmppHostPortSwitch, 333c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath kXmppTrySslTcpFirstSwitch, 334c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath kXmppAllowInsecureConnectionSwitch); 335c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath return -1; 336c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath } 337c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 338c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath // Set up objects that monitor the network. 339c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath scoped_ptr<net::NetworkChangeNotifier> network_change_notifier( 340c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath net::NetworkChangeNotifier::Create()); 341c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath 342c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath // Set up sync notifier factory. 343c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath const scoped_refptr<MyTestURLRequestContextGetter> context_getter = 344c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath new MyTestURLRequestContextGetter(io_thread.message_loop_proxy()); 345c981c48f5bc9aefeffc0bcb0cc3934c2fae179ddNarayan Kamath const notifier::NotifierOptions& notifier_options = 346 ParseNotifierOptions(command_line, context_getter); 347 syncer::NetworkChannelCreator network_channel_creator = 348 syncer::NonBlockingInvalidator::MakePushClientChannelCreator( 349 notifier_options); 350 const char kClientInfo[] = "standalone_sync_client"; 351 std::string invalidator_id = base::RandBytesAsString(8); 352 NullInvalidationStateTracker null_invalidation_state_tracker; 353 scoped_ptr<Invalidator> invalidator(new NonBlockingInvalidator( 354 network_channel_creator, 355 invalidator_id, 356 null_invalidation_state_tracker.GetSavedInvalidations(), 357 null_invalidation_state_tracker.GetBootstrapData(), 358 &null_invalidation_state_tracker, 359 kClientInfo, 360 notifier_options.request_context_getter)); 361 362 // Set up database directory for the syncer. 363 base::ScopedTempDir database_dir; 364 CHECK(database_dir.CreateUniqueTempDir()); 365 366 // Developers often add types to ModelTypeSet::All() before the server 367 // supports them. We need to be explicit about which types we want here. 368 ModelTypeSet model_types; 369 model_types.Put(BOOKMARKS); 370 model_types.Put(PREFERENCES); 371 model_types.Put(PASSWORDS); 372 model_types.Put(AUTOFILL); 373 model_types.Put(THEMES); 374 model_types.Put(TYPED_URLS); 375 model_types.Put(EXTENSIONS); 376 model_types.Put(NIGORI); 377 model_types.Put(SEARCH_ENGINES); 378 model_types.Put(SESSIONS); 379 model_types.Put(APPS); 380 model_types.Put(AUTOFILL_PROFILE); 381 model_types.Put(APP_SETTINGS); 382 model_types.Put(EXTENSION_SETTINGS); 383 model_types.Put(APP_NOTIFICATIONS); 384 model_types.Put(HISTORY_DELETE_DIRECTIVES); 385 model_types.Put(SYNCED_NOTIFICATIONS); 386 model_types.Put(SYNCED_NOTIFICATION_APP_INFO); 387 model_types.Put(DEVICE_INFO); 388 model_types.Put(EXPERIMENTS); 389 model_types.Put(PRIORITY_PREFERENCES); 390 model_types.Put(DICTIONARY); 391 model_types.Put(FAVICON_IMAGES); 392 model_types.Put(FAVICON_TRACKING); 393 394 ModelSafeRoutingInfo routing_info; 395 for (ModelTypeSet::Iterator it = model_types.First(); 396 it.Good(); it.Inc()) { 397 routing_info[it.Get()] = GROUP_PASSIVE; 398 } 399 scoped_refptr<PassiveModelWorker> passive_model_safe_worker = 400 new PassiveModelWorker(&sync_loop, NULL); 401 std::vector<scoped_refptr<ModelSafeWorker> > workers; 402 workers.push_back(passive_model_safe_worker); 403 404 // Set up sync manager. 405 SyncManagerFactory sync_manager_factory(SyncManagerFactory::NORMAL); 406 scoped_ptr<SyncManager> sync_manager = 407 sync_manager_factory.CreateSyncManager("sync_client manager"); 408 LoggingJsEventHandler js_event_handler; 409 // Used only by InitialProcessMetadata(), so it's okay to leave this as NULL. 410 const scoped_refptr<base::TaskRunner> blocking_task_runner = NULL; 411 const char kUserAgent[] = "sync_client"; 412 // TODO(akalin): Replace this with just the context getter once 413 // HttpPostProviderFactory is removed. 414 CancelationSignal factory_cancelation_signal; 415 scoped_ptr<HttpPostProviderFactory> post_factory( 416 new HttpBridgeFactory(context_getter.get(), 417 base::Bind(&StubNetworkTimeUpdateCallback), 418 &factory_cancelation_signal)); 419 post_factory->Init(kUserAgent); 420 // Used only when committing bookmarks, so it's okay to leave this 421 // as NULL. 422 ExtensionsActivity* extensions_activity = NULL; 423 LoggingChangeDelegate change_delegate; 424 const char kRestoredKeyForBootstrapping[] = ""; 425 const char kRestoredKeystoreKeyForBootstrapping[] = ""; 426 NullEncryptor null_encryptor; 427 InternalComponentsFactoryImpl::Switches factory_switches = { 428 InternalComponentsFactory::ENCRYPTION_KEYSTORE, 429 InternalComponentsFactory::BACKOFF_NORMAL 430 }; 431 CancelationSignal scm_cancelation_signal; 432 433 SyncManager::InitArgs args; 434 args.database_location = database_dir.path(); 435 args.event_handler = WeakHandle<JsEventHandler>(js_event_handler.AsWeakPtr()); 436 args.service_url = GURL(kSyncServiceURL); 437 args.post_factory = post_factory.Pass(); 438 args.workers = workers; 439 args.extensions_activity = extensions_activity; 440 args.change_delegate = &change_delegate; 441 args.credentials = credentials; 442 args.invalidator_client_id = invalidator_id; 443 args.restored_key_for_bootstrapping = kRestoredKeyForBootstrapping; 444 args.restored_keystore_key_for_bootstrapping = 445 kRestoredKeystoreKeyForBootstrapping; 446 args.internal_components_factory.reset( 447 new InternalComponentsFactoryImpl(factory_switches)); 448 args.encryptor = &null_encryptor; 449 args.unrecoverable_error_handler.reset(new LoggingUnrecoverableErrorHandler); 450 args.report_unrecoverable_error_function = &LogUnrecoverableErrorContext; 451 args.cancelation_signal = &scm_cancelation_signal; 452 sync_manager->Init(&args); 453 // TODO(akalin): Avoid passing in model parameters multiple times by 454 // organizing handling of model types. 455 invalidator->UpdateCredentials(credentials.email, credentials.sync_token); 456 scoped_ptr<InvalidatorShim> shim(new InvalidatorShim(sync_manager.get())); 457 invalidator->RegisterHandler(shim.get()); 458 invalidator->UpdateRegisteredIds( 459 shim.get(), ModelTypeSetToObjectIdSet(model_types)); 460 sync_manager->StartSyncingNormally(routing_info); 461 462 sync_loop.Run(); 463 464 io_thread.Stop(); 465 return 0; 466} 467 468} // namespace 469} // namespace syncer 470 471int main(int argc, char* argv[]) { 472 return syncer::SyncClientMain(argc, argv); 473} 474