OLD | NEW |
(Empty) | |
| 1 // Copyright (c) 2009 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. |
| 4 |
| 5 // This file defines the "sync API", an interface to the syncer |
| 6 // backend that exposes (1) the core functionality of maintaining a consistent |
| 7 // local snapshot of a hierarchical object set; (2) a means to transactionally |
| 8 // access and modify those objects; (3) a means to control client/server |
| 9 // synchronization tasks, namely: pushing local object modifications to a |
| 10 // server, pulling nonlocal object modifications from a server to this client, |
| 11 // and resolving conflicts that may arise between the two; and (4) an |
| 12 // abstraction of some external functionality that is to be provided by the |
| 13 // host environment. |
| 14 // |
| 15 // This interface is used as the entry point into the syncer backend |
| 16 // when the backend is compiled as a library and embedded in another |
| 17 // application. A goal for this interface layer is to depend on very few |
| 18 // external types, so that an application can use the sync backend |
| 19 // without introducing a dependency on specific types. A non-goal is to |
| 20 // have binary compatibility across versions or compilers; this allows the |
| 21 // interface to use C++ classes. An application wishing to use the sync API |
| 22 // should ideally compile the syncer backend and this API as part of the |
| 23 // application's own build, to avoid e.g. mismatches in calling convention, |
| 24 // structure padding, or name mangling that could arise if there were a |
| 25 // compiler mismatch. |
| 26 // |
| 27 // The schema of the objects in the sync domain is based on the model, which |
| 28 // is essentially a hierarchy of items and folders similar to a filesystem, |
| 29 // but with a few important differences. The sync API contains fields |
| 30 // such as URL to easily allow the embedding application to store web |
| 31 // browser bookmarks. Also, the sync API allows duplicate titles in a parent. |
| 32 // Consequently, it does not support looking up an object by title |
| 33 // and parent, since such a lookup is not uniquely determined. Lastly, |
| 34 // unlike a filesystem model, objects in the Sync API model have a strict |
| 35 // ordering within a parent; the position is manipulable by callers, and |
| 36 // children of a node can be enumerated in the order of their position. |
| 37 |
| 38 #ifndef CHROME_BROWSER_SYNC_ENGINE_SYNCAPI_H_ |
| 39 #define CHROME_BROWSER_SYNC_ENGINE_SYNCAPI_H_ |
| 40 |
| 41 #include "base/basictypes.h" |
| 42 |
| 43 #if (defined(OS_WIN) || defined(OS_WINDOWS)) |
| 44 typedef wchar_t sync_char16; |
| 45 #else |
| 46 typedef uint16 sync_char16; |
| 47 #endif |
| 48 |
| 49 // The MSVC compiler for Windows requires that any classes exported by, or |
| 50 // imported from, a dynamic library be decorated with the following fanciness. |
| 51 #if (defined(OS_WIN) || defined(OS_WINDOWS)) |
| 52 #if COMPILING_SYNCAPI_LIBRARY |
| 53 #define SYNC_EXPORT __declspec(dllexport) |
| 54 #else |
| 55 #define SYNC_EXPORT __declspec(dllimport) |
| 56 #endif |
| 57 #else |
| 58 #define SYNC_EXPORT |
| 59 #endif // OS_WIN || OS_WINDOWS |
| 60 |
| 61 // Forward declarations of internal class types so that sync API objects |
| 62 // may have opaque pointers to these types. |
| 63 namespace syncable { |
| 64 class BaseTransaction; |
| 65 class DirectoryManager; |
| 66 class Entry; |
| 67 class MutableEntry; |
| 68 class ReadTransaction; |
| 69 class ScopedDirLookup; |
| 70 class WriteTransaction; |
| 71 } |
| 72 |
| 73 namespace sync_api { |
| 74 |
| 75 // Forward declarations of classes to be defined later in this file. |
| 76 class BaseTransaction; |
| 77 class HttpPostProviderFactory; |
| 78 class ModelSafeWorkerInterface; |
| 79 class SyncManager; |
| 80 class WriteTransaction; |
| 81 struct UserShare; |
| 82 |
| 83 // A valid BaseNode will never have an ID of zero. |
| 84 static const int64 kInvalidId = 0; |
| 85 |
| 86 // BaseNode wraps syncable::Entry, and corresponds to a single object's state. |
| 87 // This, like syncable::Entry, is intended for use on the stack. A valid |
| 88 // transaction is necessary to create a BaseNode or any of its children. |
| 89 // Unlike syncable::Entry, a sync API BaseNode is identified primarily by its |
| 90 // int64 metahandle, which we call an ID here. |
| 91 class SYNC_EXPORT BaseNode { |
| 92 public: |
| 93 // All subclasses of BaseNode must provide a way to initialize themselves by |
| 94 // doing an ID lookup. Returns false on failure. An invalid or deleted |
| 95 // ID will result in failure. |
| 96 virtual bool InitByIdLookup(int64 id) = 0; |
| 97 |
| 98 // Each object is identified by a 64-bit id (internally, the syncable |
| 99 // metahandle). These ids are strictly local handles. They will persist |
| 100 // on this client, but the same object on a different client may have a |
| 101 // different ID value. |
| 102 int64 GetId() const; |
| 103 |
| 104 // Nodes are hierarchically arranged into a single-rooted tree. |
| 105 // InitByRootLookup on ReadNode allows access to the root. GetParentId is |
| 106 // how you find a node's parent. |
| 107 int64 GetParentId() const; |
| 108 |
| 109 // Nodes are either folders or not. This corresponds to the IS_DIR property |
| 110 // of syncable::Entry. |
| 111 bool GetIsFolder() const; |
| 112 |
| 113 // Returns the title of the object as a C string. The memory is owned by |
| 114 // BaseNode and becomes invalid if GetTitle() is called a second time on this |
| 115 // node, or when the node is destroyed. A caller should convert this |
| 116 // immediately into e.g. a std::string. Uniqueness of the title is not |
| 117 // enforced on siblings -- it is not an error for two children to share |
| 118 // a title. |
| 119 const sync_char16* GetTitle() const; |
| 120 |
| 121 // Returns the URL of a bookmark object as a C string. The memory is owned |
| 122 // by BaseNode and becomes invalid if GetURL() is called a second time on |
| 123 // this node, or when the node is destroyed. A caller should convert this |
| 124 // immediately into e.g. a std::string. |
| 125 const sync_char16* GetURL() const; |
| 126 |
| 127 // Return a pointer to the byte data of the favicon image for this node. |
| 128 // Will return NULL if there is no favicon data associated with this node. |
| 129 // The length of the array is returned to the caller via |size_in_bytes|. |
| 130 // Favicons are expected to be PNG images, and though no verification is |
| 131 // done on the syncapi client of this, the server may reject favicon updates |
| 132 // that are invalid for whatever reason. |
| 133 const unsigned char* GetFaviconBytes(size_t* size_in_bytes); |
| 134 |
| 135 // Returns the local external ID associated with the node. |
| 136 int64 GetExternalId() const; |
| 137 |
| 138 // Return the ID of the node immediately before this in the sibling order. |
| 139 // For the first node in the ordering, return 0. |
| 140 int64 GetPredecessorId() const; |
| 141 |
| 142 // Return the ID of the node immediately after this in the sibling order. |
| 143 // For the last node in the ordering, return 0. |
| 144 int64 GetSuccessorId() const; |
| 145 |
| 146 // Return the ID of the first child of this node. If this node has no |
| 147 // children, return 0. |
| 148 int64 GetFirstChildId() const; |
| 149 |
| 150 // Get an array containing the IDs of this node's children. The memory is |
| 151 // owned by BaseNode and becomes invalid if GetChildIds() is called a second |
| 152 // time on this node, or when the node is destroyed. Return the array size |
| 153 // in the child_count parameter. |
| 154 const int64* GetChildIds(size_t* child_count) const; |
| 155 |
| 156 // These virtual accessors provide access to data members of derived classes. |
| 157 virtual const syncable::Entry* GetEntry() const = 0; |
| 158 virtual const BaseTransaction* GetTransaction() const = 0; |
| 159 |
| 160 protected: |
| 161 BaseNode(); |
| 162 virtual ~BaseNode(); |
| 163 |
| 164 private: |
| 165 struct BaseNodeInternal; |
| 166 |
| 167 // Node is meant for stack use only. |
| 168 void* operator new(size_t size); |
| 169 |
| 170 // Provides storage for member functions that return pointers to class |
| 171 // memory, e.g. C strings returned by GetTitle(). |
| 172 BaseNodeInternal* data_; |
| 173 |
| 174 DISALLOW_COPY_AND_ASSIGN(BaseNode); |
| 175 }; |
| 176 |
| 177 // WriteNode extends BaseNode to add mutation, and wraps |
| 178 // syncable::MutableEntry. A WriteTransaction is needed to create a WriteNode. |
| 179 class SYNC_EXPORT WriteNode : public BaseNode { |
| 180 public: |
| 181 // Create a WriteNode using the given transaction. |
| 182 explicit WriteNode(WriteTransaction* transaction); |
| 183 virtual ~WriteNode(); |
| 184 |
| 185 // A client must use one (and only one) of the following Init variants to |
| 186 // populate the node. |
| 187 |
| 188 // BaseNode implementation. |
| 189 virtual bool InitByIdLookup(int64 id); |
| 190 |
| 191 // Create a new node with the specified parent and predecessor. Use a NULL |
| 192 // |predecessor| to indicate that this is to be the first child. |
| 193 // |predecessor| must be a child of |new_parent| or NULL. Returns false on |
| 194 // failure. |
| 195 bool InitByCreation(const BaseNode& parent, const BaseNode* predecessor); |
| 196 |
| 197 // These Set() functions correspond to the Get() functions of BaseNode. |
| 198 void SetIsFolder(bool folder); |
| 199 void SetTitle(const sync_char16* title); |
| 200 void SetURL(const sync_char16* url); |
| 201 void SetFaviconBytes(const unsigned char* bytes, size_t size_in_bytes); |
| 202 // External ID is a client-only field, so setting it doesn't cause the item to |
| 203 // be synced again. |
| 204 void SetExternalId(int64 external_id); |
| 205 |
| 206 // Remove this node and its children. |
| 207 void Remove(); |
| 208 |
| 209 // Set a new parent and position. Position is specified by |predecessor|; if |
| 210 // it is NULL, the node is moved to the first position. |predecessor| must |
| 211 // be a child of |new_parent| or NULL. Returns false on failure.. |
| 212 bool SetPosition(const BaseNode& new_parent, const BaseNode* predecessor); |
| 213 |
| 214 // Implementation of BaseNode's abstract virtual accessors. |
| 215 virtual const syncable::Entry* GetEntry() const; |
| 216 |
| 217 virtual const BaseTransaction* GetTransaction() const; |
| 218 |
| 219 private: |
| 220 void* operator new(size_t size); // Node is meant for stack use only. |
| 221 |
| 222 // Helper to set the previous node. |
| 223 void PutPredecessor(const BaseNode* predecessor); |
| 224 |
| 225 // Sets IS_UNSYNCED and SYNCING to ensure this entry is considered in an |
| 226 // upcoming commit pass. |
| 227 void MarkForSyncing(); |
| 228 |
| 229 // The underlying syncable object which this class wraps. |
| 230 syncable::MutableEntry* entry_; |
| 231 |
| 232 // The sync API transaction that is the parent of this node. |
| 233 WriteTransaction* transaction_; |
| 234 |
| 235 DISALLOW_COPY_AND_ASSIGN(WriteNode); |
| 236 }; |
| 237 |
| 238 // ReadNode wraps a syncable::Entry to provide the functionality of a |
| 239 // read-only BaseNode. |
| 240 class SYNC_EXPORT ReadNode : public BaseNode { |
| 241 public: |
| 242 // Create an unpopulated ReadNode on the given transaction. Call some flavor |
| 243 // of Init to populate the ReadNode with a database entry. |
| 244 explicit ReadNode(const BaseTransaction* transaction); |
| 245 virtual ~ReadNode(); |
| 246 |
| 247 // A client must use one (and only one) of the following Init variants to |
| 248 // populate the node. |
| 249 |
| 250 // BaseNode implementation. |
| 251 virtual bool InitByIdLookup(int64 id); |
| 252 |
| 253 // There is always a root node, so this can't fail. The root node is |
| 254 // never mutable, so root lookup is only possible on a ReadNode. |
| 255 void InitByRootLookup(); |
| 256 |
| 257 // Each server-created permanent node is tagged with a unique string. |
| 258 // Look up the node with the particular tag. If it does not exist, |
| 259 // return false. Since these nodes are special, lookup is only |
| 260 // provided only through ReadNode. |
| 261 bool InitByTagLookup(const sync_char16* tag); |
| 262 |
| 263 // Implementation of BaseNode's abstract virtual accessors. |
| 264 virtual const syncable::Entry* GetEntry() const; |
| 265 virtual const BaseTransaction* GetTransaction() const; |
| 266 |
| 267 private: |
| 268 void* operator new(size_t size); // Node is meant for stack use only. |
| 269 |
| 270 // The underlying syncable object which this class wraps. |
| 271 syncable::Entry* entry_; |
| 272 |
| 273 // The sync API transaction that is the parent of this node. |
| 274 const BaseTransaction* transaction_; |
| 275 |
| 276 DISALLOW_COPY_AND_ASSIGN(ReadNode); |
| 277 }; |
| 278 |
| 279 // Sync API's BaseTransaction, ReadTransaction, and WriteTransaction allow for |
| 280 // batching of several read and/or write operations. The read and write |
| 281 // operations are performed by creating ReadNode and WriteNode instances using |
| 282 // the transaction. These transaction classes wrap identically named classes in |
| 283 // syncable, and are used in a similar way. Unlike syncable::BaseTransaction, |
| 284 // whose construction requires an explicit syncable::ScopedDirLookup, a sync |
| 285 // API BaseTransaction creates its own ScopedDirLookup implicitly. |
| 286 class SYNC_EXPORT BaseTransaction { |
| 287 public: |
| 288 // Provide access to the underlying syncable.h objects from BaseNode. |
| 289 virtual syncable::BaseTransaction* GetWrappedTrans() const = 0; |
| 290 const syncable::ScopedDirLookup& GetLookup() const { return *lookup_; } |
| 291 |
| 292 protected: |
| 293 // The ScopedDirLookup is created in the constructor and destroyed |
| 294 // in the destructor. Creation of the ScopedDirLookup is not expected |
| 295 // to fail. |
| 296 explicit BaseTransaction(UserShare* share); |
| 297 virtual ~BaseTransaction(); |
| 298 |
| 299 private: |
| 300 // A syncable ScopedDirLookup, which is the parent of syncable transactions. |
| 301 syncable::ScopedDirLookup* lookup_; |
| 302 |
| 303 DISALLOW_COPY_AND_ASSIGN(BaseTransaction); |
| 304 }; |
| 305 |
| 306 // Sync API's ReadTransaction is a read-only BaseTransaction. It wraps |
| 307 // a syncable::ReadTransaction. |
| 308 class SYNC_EXPORT ReadTransaction : public BaseTransaction { |
| 309 public: |
| 310 // Start a new read-only transaction on the specified repository. |
| 311 explicit ReadTransaction(UserShare* share); |
| 312 virtual ~ReadTransaction(); |
| 313 |
| 314 // BaseTransaction override. |
| 315 virtual syncable::BaseTransaction* GetWrappedTrans() const; |
| 316 private: |
| 317 void* operator new(size_t size); // Transaction is meant for stack use only. |
| 318 |
| 319 // The underlying syncable object which this class wraps. |
| 320 syncable::ReadTransaction* transaction_; |
| 321 |
| 322 DISALLOW_COPY_AND_ASSIGN(ReadTransaction); |
| 323 }; |
| 324 |
| 325 // Sync API's WriteTransaction is a read/write BaseTransaction. It wraps |
| 326 // a syncable::WriteTransaction. |
| 327 class SYNC_EXPORT WriteTransaction : public BaseTransaction { |
| 328 public: |
| 329 // Start a new read/write transaction. |
| 330 explicit WriteTransaction(UserShare* share); |
| 331 virtual ~WriteTransaction(); |
| 332 |
| 333 // Provide access to the syncable.h transaction from the API WriteNode. |
| 334 virtual syncable::BaseTransaction* GetWrappedTrans() const; |
| 335 syncable::WriteTransaction* GetWrappedWriteTrans() { return transaction_; } |
| 336 |
| 337 private: |
| 338 void* operator new(size_t size); // Transaction is meant for stack use only. |
| 339 |
| 340 // The underlying syncable object which this class wraps. |
| 341 syncable::WriteTransaction* transaction_; |
| 342 |
| 343 DISALLOW_COPY_AND_ASSIGN(WriteTransaction); |
| 344 }; |
| 345 |
| 346 // SyncManager encapsulates syncable::DirectoryManager and serves as the parent |
| 347 // of all other objects in the sync API. SyncManager is thread-safe. If |
| 348 // multiple threads interact with the same local sync repository (i.e. the |
| 349 // same sqlite database), they should share a single SyncManager instance. The |
| 350 // caller should typically create one SyncManager for the lifetime of a user |
| 351 // session. |
| 352 class SYNC_EXPORT SyncManager { |
| 353 public: |
| 354 // SyncInternal contains the implementation of SyncManager, while abstracting |
| 355 // internal types from clients of the interface. |
| 356 class SyncInternal; |
| 357 |
| 358 // ChangeRecord indicates a single item that changed as a result of a sync |
| 359 // operation. This gives the sync id of the node that changed, and the type |
| 360 // of change. To get the actual property values after an ADD or UPDATE, the |
| 361 // client should get the node with InitByIdLookup(), using the provided id. |
| 362 struct ChangeRecord { |
| 363 enum Action { |
| 364 ACTION_ADD, |
| 365 ACTION_DELETE, |
| 366 ACTION_UPDATE, |
| 367 }; |
| 368 ChangeRecord() : id(kInvalidId), action(ACTION_ADD) {} |
| 369 int64 id; |
| 370 Action action; |
| 371 }; |
| 372 |
| 373 // When the SyncManager is unable to initiate the syncing process due to a |
| 374 // failure during authentication, AuthProblem describes the actual problem |
| 375 // more precisely. |
| 376 enum AuthProblem { |
| 377 AUTH_PROBLEM_NONE = 0, |
| 378 // The credentials supplied to GAIA were either invalid, or the locally |
| 379 // cached credentials have expired. If this happens, the sync system |
| 380 // will continue as if offline until authentication is reattempted. |
| 381 AUTH_PROBLEM_INVALID_GAIA_CREDENTIALS, |
| 382 // The GAIA user is not authorized to use the sync service. |
| 383 AUTH_PROBLEM_USER_NOT_SIGNED_UP, |
| 384 // Could not connect to server to verify credentials. This could be in |
| 385 // response to either failure to connect to GAIA or failure to connect to |
| 386 // the sync service during authentication. |
| 387 AUTH_PROBLEM_CONNECTION_FAILED, |
| 388 }; |
| 389 |
| 390 // Status encapsulates detailed state about the internals of the SyncManager. |
| 391 struct Status { |
| 392 // Summary is a distilled set of important information that the end-user may |
| 393 // wish to be informed about (through UI, for example). Note that if a |
| 394 // summary state requires user interaction (such as auth failures), more |
| 395 // detailed information may be contained in additional status fields. |
| 396 enum Summary { |
| 397 // The internal instance is in an unrecognizable state. This should not |
| 398 // happen. |
| 399 INVALID = 0, |
| 400 // Can't connect to server, but there are no pending changes in |
| 401 // our local cache. |
| 402 OFFLINE, |
| 403 // Can't connect to server, and there are pending changes in our |
| 404 // local cache. |
| 405 OFFLINE_UNSYNCED, |
| 406 // Connected and syncing. |
| 407 SYNCING, |
| 408 // Connected, no pending changes. |
| 409 READY, |
| 410 // User has chosen to pause syncing. |
| 411 PAUSED, |
| 412 // Internal sync error. |
| 413 CONFLICT, |
| 414 // Can't connect to server, and we haven't completed the initial |
| 415 // sync yet. So there's nothing we can do but wait for the server. |
| 416 OFFLINE_UNUSABLE, |
| 417 }; |
| 418 Summary summary; |
| 419 |
| 420 // Various server related information. |
| 421 bool authenticated; // Successfully authenticated via GAIA. |
| 422 bool server_up; // True if we have received at least one good |
| 423 // reply from the server. |
| 424 bool server_reachable; // True if we received any reply from the server. |
| 425 bool server_broken; // True of the syncer is stopped because of server |
| 426 // issues. |
| 427 |
| 428 bool notifications_enabled; // True only if subscribed for notifications. |
| 429 int notifications_received; |
| 430 int notifications_sent; |
| 431 |
| 432 // Various Syncer data. |
| 433 int unsynced_count; |
| 434 int conflicting_count; |
| 435 bool syncing; |
| 436 bool syncer_paused; |
| 437 bool initial_sync_ended; |
| 438 bool syncer_stuck; |
| 439 int64 updates_available; |
| 440 int64 updates_received; |
| 441 bool disk_full; |
| 442 bool invalid_store; |
| 443 int max_consecutive_errors; // The max number of errors from any component. |
| 444 }; |
| 445 |
| 446 // An interface the embedding application implements to receive notifications |
| 447 // from the SyncManager. Register an observer via SyncManager::AddObserver. |
| 448 // This observer is an event driven model as the events may be raised from |
| 449 // different internal threads, and simply providing an "OnStatusChanged" type |
| 450 // notification complicates things such as trying to determine "what changed", |
| 451 // if different members of the Status object are modified from different |
| 452 // threads. This way, the event is explicit, and it is safe for the Observer |
| 453 // to dispatch to a native thread or synchronize accordingly. |
| 454 class Observer { |
| 455 public: |
| 456 Observer() { } |
| 457 virtual ~Observer() { } |
| 458 // Notify the observer that changes have been applied to the sync model. |
| 459 // This will be invoked on the same thread as on which ApplyChanges was |
| 460 // called. |changes| is an array of size |change_count|, and contains the ID |
| 461 // of each individual item that was changed. |changes| exists only |
| 462 // for the duration of the call. Because the observer is passed a |trans|, |
| 463 // the observer can assume a read lock on the database that will be released |
| 464 // after the function returns. |
| 465 // |
| 466 // The SyncManager constructs |changes| in the following guaranteed order: |
| 467 // |
| 468 // 1. Deletions, from leaves up to parents. |
| 469 // 2. Updates to existing items with synced parents & predecessors. |
| 470 // 3. New items with synced parents & predecessors. |
| 471 // 4. Items with parents & predecessors in |changes|. |
| 472 // 5. Repeat #4 until all items are in |changes|. |
| 473 // |
| 474 // Thus, an implementation of OnChangesApplied should be able to |
| 475 // process the change records in the order without having to worry about |
| 476 // forward dependencies. But since deletions come before reparent |
| 477 // operations, a delete may temporarily orphan a node that is |
| 478 // updated later in the list. |
| 479 virtual void OnChangesApplied(const BaseTransaction* trans, |
| 480 const ChangeRecord* changes, |
| 481 int change_count) = 0; |
| 482 |
| 483 // A round-trip sync-cycle took place and the syncer has resolved any |
| 484 // conflicts that may have arisen. This is kept separate from |
| 485 // OnStatusChanged as there isn't really any state update; it is plainly |
| 486 // a notification of a state transition. |
| 487 virtual void OnSyncCycleCompleted() = 0; |
| 488 |
| 489 // Called when user interaction may be required due to an auth problem. |
| 490 virtual void OnAuthProblem(AuthProblem auth_problem) = 0; |
| 491 |
| 492 // Called when initialization is complete to the point that SyncManager can |
| 493 // process changes. This does not necessarily mean authentication succeeded |
| 494 // or that the SyncManager is online. |
| 495 // IMPORTANT: Creating any type of transaction before receiving this |
| 496 // notification is illegal! |
| 497 // WARNING: Calling methods on the SyncManager before receiving this |
| 498 // message, unless otherwise specified, produces undefined behavior. |
| 499 virtual void OnInitializationComplete() = 0; |
| 500 |
| 501 private: |
| 502 DISALLOW_COPY_AND_ASSIGN(Observer); |
| 503 }; |
| 504 |
| 505 // Create an uninitialized SyncManager. Callers must Init() before using. |
| 506 SyncManager(); |
| 507 virtual ~SyncManager(); |
| 508 |
| 509 // Initialize the sync manager. |database_location| specifies the path of |
| 510 // the directory in which to locate a sqlite repository storing the syncer |
| 511 // backend state. Initialization will open the database, or create it if it |
| 512 // does not already exist. Returns false on failure. |
| 513 // |sync_server_and_path| and |sync_server_port| represent the Chrome sync |
| 514 // server to use, and |use_ssl| specifies whether to communicate securely; |
| 515 // the default is false. |
| 516 // |gaia_service_id| is the service id used for GAIA authentication. If it's |
| 517 // null then default will be used. |
| 518 // |post_factory| will be owned internally and used to create |
| 519 // instances of an HttpPostProvider. |
| 520 // |auth_post_factory| will be owned internally and used to create |
| 521 // instances of an HttpPostProvider for communicating with GAIA. |
| 522 // TODO(timsteele): It seems like one factory should suffice, but for now to |
| 523 // avoid having to deal with threading issues since the auth code and syncer |
| 524 // code live on separate threads that run simultaneously, we just dedicate |
| 525 // one to each component. Long term we may want to reconsider the HttpBridge |
| 526 // API to take all the params in one chunk in a threadsafe manner.. which is |
| 527 // still suboptimal as there will be high contention between the two threads |
| 528 // on startup; so maybe what we have now is the best solution- it does mirror |
| 529 // the CURL implementation as each thread creates their own internet handle. |
| 530 // Investigate. |
| 531 // |model_safe_worker| ownership is given to the SyncManager. |
| 532 // |user_agent| is a 7-bit ASCII string suitable for use as the User-Agent |
| 533 // HTTP header. Used internally when collecting stats to classify clients. |
| 534 bool Init(const sync_char16* database_location, |
| 535 const char* sync_server_and_path, |
| 536 int sync_server_port, |
| 537 const char* gaia_service_id, |
| 538 const char* gaia_source, |
| 539 bool use_ssl, |
| 540 HttpPostProviderFactory* post_factory, |
| 541 HttpPostProviderFactory* auth_post_factory, |
| 542 ModelSafeWorkerInterface* model_safe_worker, |
| 543 bool attempt_last_user_authentication, |
| 544 const char* user_agent); |
| 545 |
| 546 // Returns the username last used for a successful authentication as a |
| 547 // null-terminated string. Returns empty if there is no such username. |
| 548 // The memory is not owned by the caller and should be copied. |
| 549 const char* GetAuthenticatedUsername(); |
| 550 |
| 551 // Submit credentials to GAIA for verification and start the |
| 552 // syncing process on success. On success, both |username| and the obtained |
| 553 // auth token are persisted on disk for future re-use. |
| 554 // If authentication fails, OnAuthProblem is called on our Observer. |
| 555 // The Observer may, in turn, decide to try again with new |
| 556 // credentials. Calling this method again is the appropriate course of action |
| 557 // to "retry". |
| 558 // |username| and |password| are expected to be owned by the caller. |
| 559 void Authenticate(const char* username, const char* password); |
| 560 |
| 561 // Adds a listener to be notified of sync events. |
| 562 // NOTE: It is OK (in fact, it's probably a good idea) to call this before |
| 563 // having received OnInitializationCompleted. |
| 564 void SetObserver(Observer* observer); |
| 565 |
| 566 // Remove the observer set by SetObserver (no op if none was set). |
| 567 // Make sure to call this if the Observer set in SetObserver is being |
| 568 // destroyed so the SyncManager doesn't potentially dereference garbage. |
| 569 void RemoveObserver(); |
| 570 |
| 571 // Status-related getters. Typically GetStatusSummary will suffice, but |
| 572 // GetDetailedSyncStatus can be useful for gathering debug-level details of |
| 573 // the internals of the sync engine. |
| 574 Status::Summary GetStatusSummary() const; |
| 575 Status GetDetailedStatus() const; |
| 576 |
| 577 // Get the internal implementation for use by BaseTransaction, etc. |
| 578 SyncInternal* GetImpl() const; |
| 579 |
| 580 // Call periodically from a database-safe thread to persist recent changes |
| 581 // to the syncapi model. |
| 582 void SaveChanges(); |
| 583 |
| 584 // Invoking this method will result in the syncapi bypassing authentication |
| 585 // and opening a local store suitable for testing client code. When in this |
| 586 // mode, nothing will ever get synced to a server (in fact no HTTP |
| 587 // communication will take place). |
| 588 // Note: The SyncManager precondition that you must first call Init holds; |
| 589 // this will fail unless we're initialized. |
| 590 void SetupForTestMode(const sync_char16* test_username); |
| 591 |
| 592 // Issue a final SaveChanges, close sqlite handles, and stop running threads. |
| 593 // Must be called from the same thread that called Init(). |
| 594 void Shutdown(); |
| 595 |
| 596 UserShare* GetUserShare() const; |
| 597 |
| 598 private: |
| 599 // An opaque pointer to the nested private class. |
| 600 SyncInternal* data_; |
| 601 |
| 602 DISALLOW_COPY_AND_ASSIGN(SyncManager); |
| 603 }; |
| 604 |
| 605 // An interface the embedding application (e.g. Chromium) implements to |
| 606 // provide required HTTP POST functionality to the syncer backend. |
| 607 // This interface is designed for one-time use. You create one, use it, and |
| 608 // create another if you want to make a subsequent POST. |
| 609 // TODO(timsteele): Bug 1482576. Consider splitting syncapi.h into two files: |
| 610 // one for the API defining the exports, which doesn't need to be included from |
| 611 // anywhere internally, and another file for the interfaces like this one. |
| 612 class HttpPostProviderInterface { |
| 613 public: |
| 614 HttpPostProviderInterface() { } |
| 615 virtual ~HttpPostProviderInterface() { } |
| 616 |
| 617 // Use specified user agent string when POSTing. If not called a default UA |
| 618 // may be used. |
| 619 virtual void SetUserAgent(const char* user_agent) = 0; |
| 620 |
| 621 // Set the URL to POST to. |
| 622 virtual void SetURL(const char* url, int port) = 0; |
| 623 |
| 624 // Set the type, length and content of the POST payload. |
| 625 // |content_type| is a null-terminated MIME type specifier. |
| 626 // |content| is a data buffer; Do not interpret as a null-terminated string. |
| 627 // |content_length| is the total number of chars in |content|. It is used to |
| 628 // assign/copy |content| data. |
| 629 virtual void SetPostPayload(const char* content_type, int content_length, |
| 630 const char* content) = 0; |
| 631 |
| 632 // Add the specified cookie to the request context using the url set by |
| 633 // SetURL as the key. |cookie| should be a standard cookie line |
| 634 // [e.g "name=val; name2=val2"]. |cookie| should be copied. |
| 635 virtual void AddCookieForRequest(const char* cookie) = 0; |
| 636 |
| 637 // Returns true if the URL request succeeded. If the request failed, |
| 638 // os_error() may be non-zero and hence contain more information. |
| 639 virtual bool MakeSynchronousPost(int* os_error_code, int* response_code) = 0; |
| 640 |
| 641 // Get the length of the content returned in the HTTP response. |
| 642 // This does not count the trailing null-terminating character returned |
| 643 // by GetResponseContent, so it is analogous to calling string.length. |
| 644 virtual int GetResponseContentLength() const = 0; |
| 645 |
| 646 // Get the content returned in the HTTP response. |
| 647 // This is a null terminated string of characters. |
| 648 // Value should be copied. |
| 649 virtual const char* GetResponseContent() const = 0; |
| 650 |
| 651 // To simplify passing a vector<string> across this API, we provide the |
| 652 // following two methods. Use GetResponseCookieCount to bound a loop calling |
| 653 // GetResponseCookieAt once for each integer in the range |
| 654 // [0, GetNumCookiesInResponse). The char* returned should be copied. |
| 655 virtual int GetResponseCookieCount() const = 0; |
| 656 virtual const char* GetResponseCookieAt(int cookie_number) const = 0; |
| 657 |
| 658 private: |
| 659 DISALLOW_COPY_AND_ASSIGN(HttpPostProviderInterface); |
| 660 }; |
| 661 |
| 662 // A factory to create HttpPostProviders to hide details about the |
| 663 // implementations and dependencies. |
| 664 // A factory instance itself should be owned by whomever uses it to create |
| 665 // HttpPostProviders. |
| 666 class HttpPostProviderFactory { |
| 667 public: |
| 668 // Obtain a new HttpPostProviderInterface instance, owned by caller. |
| 669 virtual HttpPostProviderInterface* Create() = 0; |
| 670 |
| 671 // When the interface is no longer needed (ready to be cleaned up), clients |
| 672 // must call Destroy(). |
| 673 // This allows actual HttpPostProvider subclass implementations to be |
| 674 // reference counted, which is useful if a particular implementation uses |
| 675 // multiple threads to serve network requests. |
| 676 virtual void Destroy(HttpPostProviderInterface* http) = 0; |
| 677 virtual ~HttpPostProviderFactory() { } |
| 678 }; |
| 679 |
| 680 // A class syncapi clients should use whenever the underlying model is bound to |
| 681 // a particular thread in the embedding application. This exposes an interface |
| 682 // by which any model-modifying invocations will be forwarded to the |
| 683 // appropriate thread in the embedding application. |
| 684 // "model safe" refers to not allowing an embedding application model to fall |
| 685 // out of sync with the syncable::Directory due to race conditions. |
| 686 class ModelSafeWorkerInterface { |
| 687 public: |
| 688 virtual ~ModelSafeWorkerInterface() { } |
| 689 // A Visitor is passed to CallDoWorkFromModelSafeThreadAndWait invocations, |
| 690 // and it's sole purpose is to provide a way for the ModelSafeWorkerInterface |
| 691 // implementation to actually _do_ the work required, by calling the only |
| 692 // method on this class, DoWork(). |
| 693 class Visitor { |
| 694 public: |
| 695 virtual ~Visitor() { } |
| 696 // When on a model safe thread, this should be called to have the syncapi |
| 697 // actually perform the work needing to be done. |
| 698 virtual void DoWork() = 0; |
| 699 }; |
| 700 // Subclasses should implement to invoke DoWork on |visitor| once on a thread |
| 701 // appropriate for data model modifications. |
| 702 // While it doesn't hurt, the impl does not need to be re-entrant (for now). |
| 703 // Note: |visitor| is owned by caller. |
| 704 virtual void CallDoWorkFromModelSafeThreadAndWait(Visitor* visitor) = 0; |
| 705 }; |
| 706 |
| 707 } // namespace sync_api |
| 708 |
| 709 #endif // CHROME_BROWSER_SYNC_ENGINE_SYNCAPI_H_ |
OLD | NEW |