OLD | NEW |
1 // Copyright 2012 The Chromium Authors. All rights reserved. | 1 // Copyright 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 // Unit tests for the SyncApi. Note that a lot of the underlying | 5 // Unit tests for the SyncApi. Note that a lot of the underlying |
6 // functionality is provided by the Syncable layer, which has its own | 6 // functionality is provided by the Syncable layer, which has its own |
7 // unit tests. We'll test SyncApi specific things in this harness. | 7 // unit tests. We'll test SyncApi specific things in this harness. |
8 | 8 |
9 #include <cstddef> | 9 #include <cstddef> |
10 #include <map> | 10 #include <map> |
(...skipping 192 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
203 public: | 203 public: |
204 virtual void SetUp() { | 204 virtual void SetUp() { |
205 test_user_share_.SetUp(); | 205 test_user_share_.SetUp(); |
206 } | 206 } |
207 | 207 |
208 virtual void TearDown() { | 208 virtual void TearDown() { |
209 test_user_share_.TearDown(); | 209 test_user_share_.TearDown(); |
210 } | 210 } |
211 | 211 |
212 protected: | 212 protected: |
213 // Create an entry with the given |model_type|, |client_tag| and | |
214 // |attachment_metadata|. | |
215 void CreateEntryWithAttachmentMetadata( | |
216 const ModelType& model_type, | |
217 const std::string& client_tag, | |
218 const sync_pb::AttachmentMetadata& attachment_metadata); | |
219 | |
220 // Attempts to load the entry specified by |model_type| and |client_tag| and | |
221 // returns the lookup result code. | |
222 BaseNode::InitByLookupResult LookupEntryByClientTag( | |
223 const ModelType& model_type, | |
224 const std::string& client_tag); | |
225 | |
226 // Replace the entry specified by |model_type| and |client_tag| with a | |
227 // tombstone. | |
228 void ReplaceWithTombstone(const ModelType& model_type, | |
229 const std::string& client_tag); | |
230 | |
231 // Save changes to the Directory, destroy it then reload it. | |
232 bool ReloadDir(); | |
233 | |
234 UserShare* user_share(); | |
235 syncable::Directory* dir(); | |
236 SyncEncryptionHandler* encryption_handler(); | |
237 | |
238 private: | |
239 base::MessageLoop message_loop_; | 213 base::MessageLoop message_loop_; |
240 TestUserShare test_user_share_; | 214 TestUserShare test_user_share_; |
241 }; | 215 }; |
242 | 216 |
243 UserShare* SyncApiTest::user_share() { | |
244 return test_user_share_.user_share(); | |
245 } | |
246 | |
247 syncable::Directory* SyncApiTest::dir() { | |
248 return test_user_share_.user_share()->directory.get(); | |
249 } | |
250 | |
251 SyncEncryptionHandler* SyncApiTest::encryption_handler() { | |
252 return test_user_share_.encryption_handler(); | |
253 } | |
254 | |
255 bool SyncApiTest::ReloadDir() { | |
256 return test_user_share_.Reload(); | |
257 } | |
258 | |
259 void SyncApiTest::CreateEntryWithAttachmentMetadata( | |
260 const ModelType& model_type, | |
261 const std::string& client_tag, | |
262 const sync_pb::AttachmentMetadata& attachment_metadata) { | |
263 syncer::WriteTransaction trans(FROM_HERE, user_share()); | |
264 syncer::ReadNode root_node(&trans); | |
265 root_node.InitByRootLookup(); | |
266 syncer::WriteNode node(&trans); | |
267 ASSERT_EQ(node.InitUniqueByCreation(model_type, root_node, client_tag), | |
268 syncer::WriteNode::INIT_SUCCESS); | |
269 node.SetAttachmentMetadata(attachment_metadata); | |
270 } | |
271 | |
272 BaseNode::InitByLookupResult SyncApiTest::LookupEntryByClientTag( | |
273 const ModelType& model_type, | |
274 const std::string& client_tag) { | |
275 syncer::ReadTransaction trans(FROM_HERE, user_share()); | |
276 syncer::ReadNode node(&trans); | |
277 return node.InitByClientTagLookup(model_type, client_tag); | |
278 } | |
279 | |
280 void SyncApiTest::ReplaceWithTombstone(const ModelType& model_type, | |
281 const std::string& client_tag) { | |
282 syncer::WriteTransaction trans(FROM_HERE, user_share()); | |
283 syncer::WriteNode node(&trans); | |
284 ASSERT_EQ(node.InitByClientTagLookup(model_type, client_tag), | |
285 syncer::WriteNode::INIT_OK); | |
286 node.Tombstone(); | |
287 } | |
288 | |
289 TEST_F(SyncApiTest, SanityCheckTest) { | 217 TEST_F(SyncApiTest, SanityCheckTest) { |
290 { | 218 { |
291 ReadTransaction trans(FROM_HERE, user_share()); | 219 ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
292 EXPECT_TRUE(trans.GetWrappedTrans()); | 220 EXPECT_TRUE(trans.GetWrappedTrans()); |
293 } | 221 } |
294 { | 222 { |
295 WriteTransaction trans(FROM_HERE, user_share()); | 223 WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
296 EXPECT_TRUE(trans.GetWrappedTrans()); | 224 EXPECT_TRUE(trans.GetWrappedTrans()); |
297 } | 225 } |
298 { | 226 { |
299 // No entries but root should exist | 227 // No entries but root should exist |
300 ReadTransaction trans(FROM_HERE, user_share()); | 228 ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
301 ReadNode node(&trans); | 229 ReadNode node(&trans); |
302 // Metahandle 1 can be root, sanity check 2 | 230 // Metahandle 1 can be root, sanity check 2 |
303 EXPECT_EQ(BaseNode::INIT_FAILED_ENTRY_NOT_GOOD, node.InitByIdLookup(2)); | 231 EXPECT_EQ(BaseNode::INIT_FAILED_ENTRY_NOT_GOOD, node.InitByIdLookup(2)); |
304 } | 232 } |
305 } | 233 } |
306 | 234 |
307 TEST_F(SyncApiTest, BasicTagWrite) { | 235 TEST_F(SyncApiTest, BasicTagWrite) { |
308 { | 236 { |
309 ReadTransaction trans(FROM_HERE, user_share()); | 237 ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
310 ReadNode root_node(&trans); | 238 ReadNode root_node(&trans); |
311 root_node.InitByRootLookup(); | 239 root_node.InitByRootLookup(); |
312 EXPECT_EQ(root_node.GetFirstChildId(), 0); | 240 EXPECT_EQ(root_node.GetFirstChildId(), 0); |
313 } | 241 } |
314 | 242 |
315 ignore_result(MakeNode(user_share(), BOOKMARKS, "testtag")); | 243 ignore_result(MakeNode(test_user_share_.user_share(), |
| 244 BOOKMARKS, "testtag")); |
316 | 245 |
317 { | 246 { |
318 ReadTransaction trans(FROM_HERE, user_share()); | 247 ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
319 ReadNode node(&trans); | 248 ReadNode node(&trans); |
320 EXPECT_EQ(BaseNode::INIT_OK, | 249 EXPECT_EQ(BaseNode::INIT_OK, |
321 node.InitByClientTagLookup(BOOKMARKS, "testtag")); | 250 node.InitByClientTagLookup(BOOKMARKS, "testtag")); |
322 | 251 |
323 ReadNode root_node(&trans); | 252 ReadNode root_node(&trans); |
324 root_node.InitByRootLookup(); | 253 root_node.InitByRootLookup(); |
325 EXPECT_NE(node.GetId(), 0); | 254 EXPECT_NE(node.GetId(), 0); |
326 EXPECT_EQ(node.GetId(), root_node.GetFirstChildId()); | 255 EXPECT_EQ(node.GetId(), root_node.GetFirstChildId()); |
327 } | 256 } |
328 } | 257 } |
329 | 258 |
330 TEST_F(SyncApiTest, ModelTypesSiloed) { | 259 TEST_F(SyncApiTest, ModelTypesSiloed) { |
331 { | 260 { |
332 WriteTransaction trans(FROM_HERE, user_share()); | 261 WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
333 ReadNode root_node(&trans); | 262 ReadNode root_node(&trans); |
334 root_node.InitByRootLookup(); | 263 root_node.InitByRootLookup(); |
335 EXPECT_EQ(root_node.GetFirstChildId(), 0); | 264 EXPECT_EQ(root_node.GetFirstChildId(), 0); |
336 } | 265 } |
337 | 266 |
338 ignore_result(MakeNode(user_share(), BOOKMARKS, "collideme")); | 267 ignore_result(MakeNode(test_user_share_.user_share(), |
339 ignore_result(MakeNode(user_share(), PREFERENCES, "collideme")); | 268 BOOKMARKS, "collideme")); |
340 ignore_result(MakeNode(user_share(), AUTOFILL, "collideme")); | 269 ignore_result(MakeNode(test_user_share_.user_share(), |
| 270 PREFERENCES, "collideme")); |
| 271 ignore_result(MakeNode(test_user_share_.user_share(), |
| 272 AUTOFILL, "collideme")); |
341 | 273 |
342 { | 274 { |
343 ReadTransaction trans(FROM_HERE, user_share()); | 275 ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
344 | 276 |
345 ReadNode bookmarknode(&trans); | 277 ReadNode bookmarknode(&trans); |
346 EXPECT_EQ(BaseNode::INIT_OK, | 278 EXPECT_EQ(BaseNode::INIT_OK, |
347 bookmarknode.InitByClientTagLookup(BOOKMARKS, | 279 bookmarknode.InitByClientTagLookup(BOOKMARKS, |
348 "collideme")); | 280 "collideme")); |
349 | 281 |
350 ReadNode prefnode(&trans); | 282 ReadNode prefnode(&trans); |
351 EXPECT_EQ(BaseNode::INIT_OK, | 283 EXPECT_EQ(BaseNode::INIT_OK, |
352 prefnode.InitByClientTagLookup(PREFERENCES, | 284 prefnode.InitByClientTagLookup(PREFERENCES, |
353 "collideme")); | 285 "collideme")); |
354 | 286 |
355 ReadNode autofillnode(&trans); | 287 ReadNode autofillnode(&trans); |
356 EXPECT_EQ(BaseNode::INIT_OK, | 288 EXPECT_EQ(BaseNode::INIT_OK, |
357 autofillnode.InitByClientTagLookup(AUTOFILL, | 289 autofillnode.InitByClientTagLookup(AUTOFILL, |
358 "collideme")); | 290 "collideme")); |
359 | 291 |
360 EXPECT_NE(bookmarknode.GetId(), prefnode.GetId()); | 292 EXPECT_NE(bookmarknode.GetId(), prefnode.GetId()); |
361 EXPECT_NE(autofillnode.GetId(), prefnode.GetId()); | 293 EXPECT_NE(autofillnode.GetId(), prefnode.GetId()); |
362 EXPECT_NE(bookmarknode.GetId(), autofillnode.GetId()); | 294 EXPECT_NE(bookmarknode.GetId(), autofillnode.GetId()); |
363 } | 295 } |
364 } | 296 } |
365 | 297 |
366 TEST_F(SyncApiTest, ReadMissingTagsFails) { | 298 TEST_F(SyncApiTest, ReadMissingTagsFails) { |
367 { | 299 { |
368 ReadTransaction trans(FROM_HERE, user_share()); | 300 ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
369 ReadNode node(&trans); | 301 ReadNode node(&trans); |
370 EXPECT_EQ(BaseNode::INIT_FAILED_ENTRY_NOT_GOOD, | 302 EXPECT_EQ(BaseNode::INIT_FAILED_ENTRY_NOT_GOOD, |
371 node.InitByClientTagLookup(BOOKMARKS, | 303 node.InitByClientTagLookup(BOOKMARKS, |
372 "testtag")); | 304 "testtag")); |
373 } | 305 } |
374 { | 306 { |
375 WriteTransaction trans(FROM_HERE, user_share()); | 307 WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
376 WriteNode node(&trans); | 308 WriteNode node(&trans); |
377 EXPECT_EQ(BaseNode::INIT_FAILED_ENTRY_NOT_GOOD, | 309 EXPECT_EQ(BaseNode::INIT_FAILED_ENTRY_NOT_GOOD, |
378 node.InitByClientTagLookup(BOOKMARKS, | 310 node.InitByClientTagLookup(BOOKMARKS, |
379 "testtag")); | 311 "testtag")); |
380 } | 312 } |
381 } | 313 } |
382 | 314 |
383 // TODO(chron): Hook this all up to the server and write full integration tests | 315 // TODO(chron): Hook this all up to the server and write full integration tests |
384 // for update->undelete behavior. | 316 // for update->undelete behavior. |
385 TEST_F(SyncApiTest, TestDeleteBehavior) { | 317 TEST_F(SyncApiTest, TestDeleteBehavior) { |
386 int64 node_id; | 318 int64 node_id; |
387 int64 folder_id; | 319 int64 folder_id; |
388 std::string test_title("test1"); | 320 std::string test_title("test1"); |
389 | 321 |
390 { | 322 { |
391 WriteTransaction trans(FROM_HERE, user_share()); | 323 WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
392 ReadNode root_node(&trans); | 324 ReadNode root_node(&trans); |
393 root_node.InitByRootLookup(); | 325 root_node.InitByRootLookup(); |
394 | 326 |
395 // we'll use this spare folder later | 327 // we'll use this spare folder later |
396 WriteNode folder_node(&trans); | 328 WriteNode folder_node(&trans); |
397 EXPECT_TRUE(folder_node.InitBookmarkByCreation(root_node, NULL)); | 329 EXPECT_TRUE(folder_node.InitBookmarkByCreation(root_node, NULL)); |
398 folder_id = folder_node.GetId(); | 330 folder_id = folder_node.GetId(); |
399 | 331 |
400 WriteNode wnode(&trans); | 332 WriteNode wnode(&trans); |
401 WriteNode::InitUniqueByCreationResult result = | 333 WriteNode::InitUniqueByCreationResult result = |
402 wnode.InitUniqueByCreation(BOOKMARKS, root_node, "testtag"); | 334 wnode.InitUniqueByCreation(BOOKMARKS, root_node, "testtag"); |
403 EXPECT_EQ(WriteNode::INIT_SUCCESS, result); | 335 EXPECT_EQ(WriteNode::INIT_SUCCESS, result); |
404 wnode.SetIsFolder(false); | 336 wnode.SetIsFolder(false); |
405 wnode.SetTitle(test_title); | 337 wnode.SetTitle(test_title); |
406 | 338 |
407 node_id = wnode.GetId(); | 339 node_id = wnode.GetId(); |
408 } | 340 } |
409 | 341 |
410 // Ensure we can delete something with a tag. | 342 // Ensure we can delete something with a tag. |
411 { | 343 { |
412 WriteTransaction trans(FROM_HERE, user_share()); | 344 WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
413 WriteNode wnode(&trans); | 345 WriteNode wnode(&trans); |
414 EXPECT_EQ(BaseNode::INIT_OK, | 346 EXPECT_EQ(BaseNode::INIT_OK, |
415 wnode.InitByClientTagLookup(BOOKMARKS, | 347 wnode.InitByClientTagLookup(BOOKMARKS, |
416 "testtag")); | 348 "testtag")); |
417 EXPECT_FALSE(wnode.GetIsFolder()); | 349 EXPECT_FALSE(wnode.GetIsFolder()); |
418 EXPECT_EQ(wnode.GetTitle(), test_title); | 350 EXPECT_EQ(wnode.GetTitle(), test_title); |
419 | 351 |
420 wnode.Tombstone(); | 352 wnode.Tombstone(); |
421 } | 353 } |
422 | 354 |
423 // Lookup of a node which was deleted should return failure, | 355 // Lookup of a node which was deleted should return failure, |
424 // but have found some data about the node. | 356 // but have found some data about the node. |
425 { | 357 { |
426 ReadTransaction trans(FROM_HERE, user_share()); | 358 ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
427 ReadNode node(&trans); | 359 ReadNode node(&trans); |
428 EXPECT_EQ(BaseNode::INIT_FAILED_ENTRY_IS_DEL, | 360 EXPECT_EQ(BaseNode::INIT_FAILED_ENTRY_IS_DEL, |
429 node.InitByClientTagLookup(BOOKMARKS, | 361 node.InitByClientTagLookup(BOOKMARKS, |
430 "testtag")); | 362 "testtag")); |
431 // Note that for proper function of this API this doesn't need to be | 363 // Note that for proper function of this API this doesn't need to be |
432 // filled, we're checking just to make sure the DB worked in this test. | 364 // filled, we're checking just to make sure the DB worked in this test. |
433 EXPECT_EQ(node.GetTitle(), test_title); | 365 EXPECT_EQ(node.GetTitle(), test_title); |
434 } | 366 } |
435 | 367 |
436 { | 368 { |
437 WriteTransaction trans(FROM_HERE, user_share()); | 369 WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
438 ReadNode folder_node(&trans); | 370 ReadNode folder_node(&trans); |
439 EXPECT_EQ(BaseNode::INIT_OK, folder_node.InitByIdLookup(folder_id)); | 371 EXPECT_EQ(BaseNode::INIT_OK, folder_node.InitByIdLookup(folder_id)); |
440 | 372 |
441 WriteNode wnode(&trans); | 373 WriteNode wnode(&trans); |
442 // This will undelete the tag. | 374 // This will undelete the tag. |
443 WriteNode::InitUniqueByCreationResult result = | 375 WriteNode::InitUniqueByCreationResult result = |
444 wnode.InitUniqueByCreation(BOOKMARKS, folder_node, "testtag"); | 376 wnode.InitUniqueByCreation(BOOKMARKS, folder_node, "testtag"); |
445 EXPECT_EQ(WriteNode::INIT_SUCCESS, result); | 377 EXPECT_EQ(WriteNode::INIT_SUCCESS, result); |
446 EXPECT_EQ(wnode.GetIsFolder(), false); | 378 EXPECT_EQ(wnode.GetIsFolder(), false); |
447 EXPECT_EQ(wnode.GetParentId(), folder_node.GetId()); | 379 EXPECT_EQ(wnode.GetParentId(), folder_node.GetId()); |
448 EXPECT_EQ(wnode.GetId(), node_id); | 380 EXPECT_EQ(wnode.GetId(), node_id); |
449 EXPECT_NE(wnode.GetTitle(), test_title); // Title should be cleared | 381 EXPECT_NE(wnode.GetTitle(), test_title); // Title should be cleared |
450 wnode.SetTitle(test_title); | 382 wnode.SetTitle(test_title); |
451 } | 383 } |
452 | 384 |
453 // Now look up should work. | 385 // Now look up should work. |
454 { | 386 { |
455 ReadTransaction trans(FROM_HERE, user_share()); | 387 ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
456 ReadNode node(&trans); | 388 ReadNode node(&trans); |
457 EXPECT_EQ(BaseNode::INIT_OK, | 389 EXPECT_EQ(BaseNode::INIT_OK, |
458 node.InitByClientTagLookup(BOOKMARKS, | 390 node.InitByClientTagLookup(BOOKMARKS, |
459 "testtag")); | 391 "testtag")); |
460 EXPECT_EQ(node.GetTitle(), test_title); | 392 EXPECT_EQ(node.GetTitle(), test_title); |
461 EXPECT_EQ(node.GetModelType(), BOOKMARKS); | 393 EXPECT_EQ(node.GetModelType(), BOOKMARKS); |
462 } | 394 } |
463 } | 395 } |
464 | 396 |
465 TEST_F(SyncApiTest, WriteAndReadPassword) { | 397 TEST_F(SyncApiTest, WriteAndReadPassword) { |
466 KeyParams params = {"localhost", "username", "passphrase"}; | 398 KeyParams params = {"localhost", "username", "passphrase"}; |
467 { | 399 { |
468 ReadTransaction trans(FROM_HERE, user_share()); | 400 ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
469 trans.GetCryptographer()->AddKey(params); | 401 trans.GetCryptographer()->AddKey(params); |
470 } | 402 } |
471 { | 403 { |
472 WriteTransaction trans(FROM_HERE, user_share()); | 404 WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
473 ReadNode root_node(&trans); | 405 ReadNode root_node(&trans); |
474 root_node.InitByRootLookup(); | 406 root_node.InitByRootLookup(); |
475 | 407 |
476 WriteNode password_node(&trans); | 408 WriteNode password_node(&trans); |
477 WriteNode::InitUniqueByCreationResult result = | 409 WriteNode::InitUniqueByCreationResult result = |
478 password_node.InitUniqueByCreation(PASSWORDS, | 410 password_node.InitUniqueByCreation(PASSWORDS, |
479 root_node, "foo"); | 411 root_node, "foo"); |
480 EXPECT_EQ(WriteNode::INIT_SUCCESS, result); | 412 EXPECT_EQ(WriteNode::INIT_SUCCESS, result); |
481 sync_pb::PasswordSpecificsData data; | 413 sync_pb::PasswordSpecificsData data; |
482 data.set_password_value("secret"); | 414 data.set_password_value("secret"); |
483 password_node.SetPasswordSpecifics(data); | 415 password_node.SetPasswordSpecifics(data); |
484 } | 416 } |
485 { | 417 { |
486 ReadTransaction trans(FROM_HERE, user_share()); | 418 ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
487 ReadNode root_node(&trans); | 419 ReadNode root_node(&trans); |
488 root_node.InitByRootLookup(); | 420 root_node.InitByRootLookup(); |
489 | 421 |
490 ReadNode password_node(&trans); | 422 ReadNode password_node(&trans); |
491 EXPECT_EQ(BaseNode::INIT_OK, | 423 EXPECT_EQ(BaseNode::INIT_OK, |
492 password_node.InitByClientTagLookup(PASSWORDS, "foo")); | 424 password_node.InitByClientTagLookup(PASSWORDS, "foo")); |
493 const sync_pb::PasswordSpecificsData& data = | 425 const sync_pb::PasswordSpecificsData& data = |
494 password_node.GetPasswordSpecifics(); | 426 password_node.GetPasswordSpecifics(); |
495 EXPECT_EQ("secret", data.password_value()); | 427 EXPECT_EQ("secret", data.password_value()); |
496 } | 428 } |
497 } | 429 } |
498 | 430 |
499 TEST_F(SyncApiTest, WriteEncryptedTitle) { | 431 TEST_F(SyncApiTest, WriteEncryptedTitle) { |
500 KeyParams params = {"localhost", "username", "passphrase"}; | 432 KeyParams params = {"localhost", "username", "passphrase"}; |
501 { | 433 { |
502 ReadTransaction trans(FROM_HERE, user_share()); | 434 ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
503 trans.GetCryptographer()->AddKey(params); | 435 trans.GetCryptographer()->AddKey(params); |
504 } | 436 } |
505 encryption_handler()->EnableEncryptEverything(); | 437 test_user_share_.encryption_handler()->EnableEncryptEverything(); |
506 int bookmark_id; | 438 int bookmark_id; |
507 { | 439 { |
508 WriteTransaction trans(FROM_HERE, user_share()); | 440 WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
509 ReadNode root_node(&trans); | 441 ReadNode root_node(&trans); |
510 root_node.InitByRootLookup(); | 442 root_node.InitByRootLookup(); |
511 | 443 |
512 WriteNode bookmark_node(&trans); | 444 WriteNode bookmark_node(&trans); |
513 ASSERT_TRUE(bookmark_node.InitBookmarkByCreation(root_node, NULL)); | 445 ASSERT_TRUE(bookmark_node.InitBookmarkByCreation(root_node, NULL)); |
514 bookmark_id = bookmark_node.GetId(); | 446 bookmark_id = bookmark_node.GetId(); |
515 bookmark_node.SetTitle("foo"); | 447 bookmark_node.SetTitle("foo"); |
516 | 448 |
517 WriteNode pref_node(&trans); | 449 WriteNode pref_node(&trans); |
518 WriteNode::InitUniqueByCreationResult result = | 450 WriteNode::InitUniqueByCreationResult result = |
519 pref_node.InitUniqueByCreation(PREFERENCES, root_node, "bar"); | 451 pref_node.InitUniqueByCreation(PREFERENCES, root_node, "bar"); |
520 ASSERT_EQ(WriteNode::INIT_SUCCESS, result); | 452 ASSERT_EQ(WriteNode::INIT_SUCCESS, result); |
521 pref_node.SetTitle("bar"); | 453 pref_node.SetTitle("bar"); |
522 } | 454 } |
523 { | 455 { |
524 ReadTransaction trans(FROM_HERE, user_share()); | 456 ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
525 ReadNode root_node(&trans); | 457 ReadNode root_node(&trans); |
526 root_node.InitByRootLookup(); | 458 root_node.InitByRootLookup(); |
527 | 459 |
528 ReadNode bookmark_node(&trans); | 460 ReadNode bookmark_node(&trans); |
529 ASSERT_EQ(BaseNode::INIT_OK, bookmark_node.InitByIdLookup(bookmark_id)); | 461 ASSERT_EQ(BaseNode::INIT_OK, bookmark_node.InitByIdLookup(bookmark_id)); |
530 EXPECT_EQ("foo", bookmark_node.GetTitle()); | 462 EXPECT_EQ("foo", bookmark_node.GetTitle()); |
531 EXPECT_EQ(kEncryptedString, | 463 EXPECT_EQ(kEncryptedString, |
532 bookmark_node.GetEntry()->GetNonUniqueName()); | 464 bookmark_node.GetEntry()->GetNonUniqueName()); |
533 | 465 |
534 ReadNode pref_node(&trans); | 466 ReadNode pref_node(&trans); |
535 ASSERT_EQ(BaseNode::INIT_OK, | 467 ASSERT_EQ(BaseNode::INIT_OK, |
536 pref_node.InitByClientTagLookup(PREFERENCES, | 468 pref_node.InitByClientTagLookup(PREFERENCES, |
537 "bar")); | 469 "bar")); |
538 EXPECT_EQ(kEncryptedString, pref_node.GetTitle()); | 470 EXPECT_EQ(kEncryptedString, pref_node.GetTitle()); |
539 } | 471 } |
540 } | 472 } |
541 | 473 |
542 TEST_F(SyncApiTest, BaseNodeSetSpecifics) { | 474 TEST_F(SyncApiTest, BaseNodeSetSpecifics) { |
543 int64 child_id = MakeNode(user_share(), BOOKMARKS, "testtag"); | 475 int64 child_id = MakeNode(test_user_share_.user_share(), |
544 WriteTransaction trans(FROM_HERE, user_share()); | 476 BOOKMARKS, "testtag"); |
| 477 WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
545 WriteNode node(&trans); | 478 WriteNode node(&trans); |
546 EXPECT_EQ(BaseNode::INIT_OK, node.InitByIdLookup(child_id)); | 479 EXPECT_EQ(BaseNode::INIT_OK, node.InitByIdLookup(child_id)); |
547 | 480 |
548 sync_pb::EntitySpecifics entity_specifics; | 481 sync_pb::EntitySpecifics entity_specifics; |
549 entity_specifics.mutable_bookmark()->set_url("http://www.google.com"); | 482 entity_specifics.mutable_bookmark()->set_url("http://www.google.com"); |
550 | 483 |
551 EXPECT_NE(entity_specifics.SerializeAsString(), | 484 EXPECT_NE(entity_specifics.SerializeAsString(), |
552 node.GetEntitySpecifics().SerializeAsString()); | 485 node.GetEntitySpecifics().SerializeAsString()); |
553 node.SetEntitySpecifics(entity_specifics); | 486 node.SetEntitySpecifics(entity_specifics); |
554 EXPECT_EQ(entity_specifics.SerializeAsString(), | 487 EXPECT_EQ(entity_specifics.SerializeAsString(), |
555 node.GetEntitySpecifics().SerializeAsString()); | 488 node.GetEntitySpecifics().SerializeAsString()); |
556 } | 489 } |
557 | 490 |
558 TEST_F(SyncApiTest, BaseNodeSetSpecificsPreservesUnknownFields) { | 491 TEST_F(SyncApiTest, BaseNodeSetSpecificsPreservesUnknownFields) { |
559 int64 child_id = MakeNode(user_share(), BOOKMARKS, "testtag"); | 492 int64 child_id = MakeNode(test_user_share_.user_share(), |
560 WriteTransaction trans(FROM_HERE, user_share()); | 493 BOOKMARKS, "testtag"); |
| 494 WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
561 WriteNode node(&trans); | 495 WriteNode node(&trans); |
562 EXPECT_EQ(BaseNode::INIT_OK, node.InitByIdLookup(child_id)); | 496 EXPECT_EQ(BaseNode::INIT_OK, node.InitByIdLookup(child_id)); |
563 EXPECT_TRUE(node.GetEntitySpecifics().unknown_fields().empty()); | 497 EXPECT_TRUE(node.GetEntitySpecifics().unknown_fields().empty()); |
564 | 498 |
565 sync_pb::EntitySpecifics entity_specifics; | 499 sync_pb::EntitySpecifics entity_specifics; |
566 entity_specifics.mutable_bookmark()->set_url("http://www.google.com"); | 500 entity_specifics.mutable_bookmark()->set_url("http://www.google.com"); |
567 entity_specifics.mutable_unknown_fields()->AddFixed32(5, 100); | 501 entity_specifics.mutable_unknown_fields()->AddFixed32(5, 100); |
568 node.SetEntitySpecifics(entity_specifics); | 502 node.SetEntitySpecifics(entity_specifics); |
569 EXPECT_FALSE(node.GetEntitySpecifics().unknown_fields().empty()); | 503 EXPECT_FALSE(node.GetEntitySpecifics().unknown_fields().empty()); |
570 | 504 |
571 entity_specifics.mutable_unknown_fields()->Clear(); | 505 entity_specifics.mutable_unknown_fields()->Clear(); |
572 node.SetEntitySpecifics(entity_specifics); | 506 node.SetEntitySpecifics(entity_specifics); |
573 EXPECT_FALSE(node.GetEntitySpecifics().unknown_fields().empty()); | 507 EXPECT_FALSE(node.GetEntitySpecifics().unknown_fields().empty()); |
574 } | 508 } |
575 | 509 |
576 TEST_F(SyncApiTest, EmptyTags) { | 510 TEST_F(SyncApiTest, EmptyTags) { |
577 WriteTransaction trans(FROM_HERE, user_share()); | 511 WriteTransaction trans(FROM_HERE, test_user_share_.user_share()); |
578 ReadNode root_node(&trans); | 512 ReadNode root_node(&trans); |
579 root_node.InitByRootLookup(); | 513 root_node.InitByRootLookup(); |
580 WriteNode node(&trans); | 514 WriteNode node(&trans); |
581 std::string empty_tag; | 515 std::string empty_tag; |
582 WriteNode::InitUniqueByCreationResult result = | 516 WriteNode::InitUniqueByCreationResult result = |
583 node.InitUniqueByCreation(TYPED_URLS, root_node, empty_tag); | 517 node.InitUniqueByCreation(TYPED_URLS, root_node, empty_tag); |
584 EXPECT_NE(WriteNode::INIT_SUCCESS, result); | 518 EXPECT_NE(WriteNode::INIT_SUCCESS, result); |
585 EXPECT_EQ(BaseNode::INIT_FAILED_PRECONDITION, | 519 EXPECT_EQ(BaseNode::INIT_FAILED_PRECONDITION, |
586 node.InitByTagLookup(empty_tag)); | 520 node.InitByTagLookup(empty_tag)); |
587 } | 521 } |
588 | 522 |
589 // Test counting nodes when the type's root node has no children. | 523 // Test counting nodes when the type's root node has no children. |
590 TEST_F(SyncApiTest, GetTotalNodeCountEmpty) { | 524 TEST_F(SyncApiTest, GetTotalNodeCountEmpty) { |
591 int64 type_root = MakeServerNodeForType(user_share(), BOOKMARKS); | 525 int64 type_root = MakeServerNodeForType(test_user_share_.user_share(), |
| 526 BOOKMARKS); |
592 { | 527 { |
593 ReadTransaction trans(FROM_HERE, user_share()); | 528 ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
594 ReadNode type_root_node(&trans); | 529 ReadNode type_root_node(&trans); |
595 EXPECT_EQ(BaseNode::INIT_OK, | 530 EXPECT_EQ(BaseNode::INIT_OK, |
596 type_root_node.InitByIdLookup(type_root)); | 531 type_root_node.InitByIdLookup(type_root)); |
597 EXPECT_EQ(1, type_root_node.GetTotalNodeCount()); | 532 EXPECT_EQ(1, type_root_node.GetTotalNodeCount()); |
598 } | 533 } |
599 } | 534 } |
600 | 535 |
601 // Test counting nodes when there is one child beneath the type's root. | 536 // Test counting nodes when there is one child beneath the type's root. |
602 TEST_F(SyncApiTest, GetTotalNodeCountOneChild) { | 537 TEST_F(SyncApiTest, GetTotalNodeCountOneChild) { |
603 int64 type_root = MakeServerNodeForType(user_share(), BOOKMARKS); | 538 int64 type_root = MakeServerNodeForType(test_user_share_.user_share(), |
604 int64 parent = MakeFolderWithParent(user_share(), BOOKMARKS, type_root, NULL); | 539 BOOKMARKS); |
| 540 int64 parent = MakeFolderWithParent(test_user_share_.user_share(), |
| 541 BOOKMARKS, |
| 542 type_root, |
| 543 NULL); |
605 { | 544 { |
606 ReadTransaction trans(FROM_HERE, user_share()); | 545 ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
607 ReadNode type_root_node(&trans); | 546 ReadNode type_root_node(&trans); |
608 EXPECT_EQ(BaseNode::INIT_OK, | 547 EXPECT_EQ(BaseNode::INIT_OK, |
609 type_root_node.InitByIdLookup(type_root)); | 548 type_root_node.InitByIdLookup(type_root)); |
610 EXPECT_EQ(2, type_root_node.GetTotalNodeCount()); | 549 EXPECT_EQ(2, type_root_node.GetTotalNodeCount()); |
611 ReadNode parent_node(&trans); | 550 ReadNode parent_node(&trans); |
612 EXPECT_EQ(BaseNode::INIT_OK, | 551 EXPECT_EQ(BaseNode::INIT_OK, |
613 parent_node.InitByIdLookup(parent)); | 552 parent_node.InitByIdLookup(parent)); |
614 EXPECT_EQ(1, parent_node.GetTotalNodeCount()); | 553 EXPECT_EQ(1, parent_node.GetTotalNodeCount()); |
615 } | 554 } |
616 } | 555 } |
617 | 556 |
618 // Test counting nodes when there are multiple children beneath the type root, | 557 // Test counting nodes when there are multiple children beneath the type root, |
619 // and one of those children has children of its own. | 558 // and one of those children has children of its own. |
620 TEST_F(SyncApiTest, GetTotalNodeCountMultipleChildren) { | 559 TEST_F(SyncApiTest, GetTotalNodeCountMultipleChildren) { |
621 int64 type_root = MakeServerNodeForType(user_share(), BOOKMARKS); | 560 int64 type_root = MakeServerNodeForType(test_user_share_.user_share(), |
622 int64 parent = MakeFolderWithParent(user_share(), BOOKMARKS, type_root, NULL); | 561 BOOKMARKS); |
623 ignore_result(MakeFolderWithParent(user_share(), BOOKMARKS, type_root, NULL)); | 562 int64 parent = MakeFolderWithParent(test_user_share_.user_share(), |
624 int64 child1 = MakeFolderWithParent(user_share(), BOOKMARKS, parent, NULL); | 563 BOOKMARKS, |
625 ignore_result(MakeBookmarkWithParent(user_share(), parent, NULL)); | 564 type_root, |
626 ignore_result(MakeBookmarkWithParent(user_share(), child1, NULL)); | 565 NULL); |
| 566 ignore_result(MakeFolderWithParent(test_user_share_.user_share(), |
| 567 BOOKMARKS, |
| 568 type_root, |
| 569 NULL)); |
| 570 int64 child1 = MakeFolderWithParent( |
| 571 test_user_share_.user_share(), |
| 572 BOOKMARKS, |
| 573 parent, |
| 574 NULL); |
| 575 ignore_result(MakeBookmarkWithParent( |
| 576 test_user_share_.user_share(), |
| 577 parent, |
| 578 NULL)); |
| 579 ignore_result(MakeBookmarkWithParent( |
| 580 test_user_share_.user_share(), |
| 581 child1, |
| 582 NULL)); |
627 | 583 |
628 { | 584 { |
629 ReadTransaction trans(FROM_HERE, user_share()); | 585 ReadTransaction trans(FROM_HERE, test_user_share_.user_share()); |
630 ReadNode type_root_node(&trans); | 586 ReadNode type_root_node(&trans); |
631 EXPECT_EQ(BaseNode::INIT_OK, | 587 EXPECT_EQ(BaseNode::INIT_OK, |
632 type_root_node.InitByIdLookup(type_root)); | 588 type_root_node.InitByIdLookup(type_root)); |
633 EXPECT_EQ(6, type_root_node.GetTotalNodeCount()); | 589 EXPECT_EQ(6, type_root_node.GetTotalNodeCount()); |
634 ReadNode node(&trans); | 590 ReadNode node(&trans); |
635 EXPECT_EQ(BaseNode::INIT_OK, | 591 EXPECT_EQ(BaseNode::INIT_OK, |
636 node.InitByIdLookup(parent)); | 592 node.InitByIdLookup(parent)); |
637 EXPECT_EQ(4, node.GetTotalNodeCount()); | 593 EXPECT_EQ(4, node.GetTotalNodeCount()); |
638 } | 594 } |
639 } | 595 } |
640 | 596 |
641 // Verify that Directory keeps track of which attachments are referenced by | |
642 // which entries. | |
643 TEST_F(SyncApiTest, AttachmentLinking) { | |
644 // Add an entry with an attachment. | |
645 std::string tag1("some tag"); | |
646 syncer::AttachmentId attachment_id(syncer::AttachmentId::Create()); | |
647 sync_pb::AttachmentMetadata attachment_metadata; | |
648 sync_pb::AttachmentMetadataRecord* record = attachment_metadata.add_record(); | |
649 *record->mutable_id() = attachment_id.GetProto(); | |
650 ASSERT_FALSE(dir()->IsAttachmentLinked(attachment_id.GetProto())); | |
651 CreateEntryWithAttachmentMetadata(PREFERENCES, tag1, attachment_metadata); | |
652 | |
653 // See that the directory knows it's linked. | |
654 ASSERT_TRUE(dir()->IsAttachmentLinked(attachment_id.GetProto())); | |
655 | |
656 // Add a second entry referencing the same attachment. | |
657 std::string tag2("some other tag"); | |
658 CreateEntryWithAttachmentMetadata(PREFERENCES, tag2, attachment_metadata); | |
659 | |
660 // See that the directory knows it's still linked. | |
661 ASSERT_TRUE(dir()->IsAttachmentLinked(attachment_id.GetProto())); | |
662 | |
663 // Tombstone the first entry. | |
664 ReplaceWithTombstone(syncer::PREFERENCES, tag1); | |
665 | |
666 // See that the attachment is still considered linked because the entry hasn't | |
667 // been purged from the Directory. | |
668 ASSERT_TRUE(dir()->IsAttachmentLinked(attachment_id.GetProto())); | |
669 | |
670 // Save changes and see that the entry is truly gone. | |
671 ASSERT_TRUE(dir()->SaveChanges()); | |
672 ASSERT_EQ(LookupEntryByClientTag(PREFERENCES, tag1), | |
673 syncer::WriteNode::INIT_FAILED_ENTRY_NOT_GOOD); | |
674 | |
675 // However, the attachment is still linked. | |
676 ASSERT_TRUE(dir()->IsAttachmentLinked(attachment_id.GetProto())); | |
677 | |
678 // Save, destroy, and recreate the directory. See that it's still linked. | |
679 ASSERT_TRUE(ReloadDir()); | |
680 ASSERT_TRUE(dir()->IsAttachmentLinked(attachment_id.GetProto())); | |
681 | |
682 // Tombstone the second entry, save changes, see that it's truly gone. | |
683 ReplaceWithTombstone(syncer::PREFERENCES, tag2); | |
684 ASSERT_TRUE(dir()->SaveChanges()); | |
685 ASSERT_EQ(LookupEntryByClientTag(PREFERENCES, tag2), | |
686 syncer::WriteNode::INIT_FAILED_ENTRY_NOT_GOOD); | |
687 | |
688 // Finally, the attachment is no longer linked. | |
689 ASSERT_FALSE(dir()->IsAttachmentLinked(attachment_id.GetProto())); | |
690 } | |
691 | |
692 namespace { | 597 namespace { |
693 | 598 |
694 class TestHttpPostProviderInterface : public HttpPostProviderInterface { | 599 class TestHttpPostProviderInterface : public HttpPostProviderInterface { |
695 public: | 600 public: |
696 virtual ~TestHttpPostProviderInterface() {} | 601 virtual ~TestHttpPostProviderInterface() {} |
697 | 602 |
698 virtual void SetExtraRequestHeaders(const char* headers) OVERRIDE {} | 603 virtual void SetExtraRequestHeaders(const char* headers) OVERRIDE {} |
699 virtual void SetURL(const char* url, int port) OVERRIDE {} | 604 virtual void SetURL(const char* url, int port) OVERRIDE {} |
700 virtual void SetPostPayload(const char* content_type, | 605 virtual void SetPostPayload(const char* content_type, |
701 int content_length, | 606 int content_length, |
(...skipping 2433 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3135 // SyncManagerInitInvalidStorageTest::GetFactory will return | 3040 // SyncManagerInitInvalidStorageTest::GetFactory will return |
3136 // DirectoryBackingStore that ensures that SyncManagerImpl::OpenDirectory fails. | 3041 // DirectoryBackingStore that ensures that SyncManagerImpl::OpenDirectory fails. |
3137 // SyncManagerImpl initialization is done in SyncManagerTest::SetUp. This test's | 3042 // SyncManagerImpl initialization is done in SyncManagerTest::SetUp. This test's |
3138 // task is to ensure that SyncManagerImpl reported initialization failure in | 3043 // task is to ensure that SyncManagerImpl reported initialization failure in |
3139 // OnInitializationComplete callback. | 3044 // OnInitializationComplete callback. |
3140 TEST_F(SyncManagerInitInvalidStorageTest, FailToOpenDatabase) { | 3045 TEST_F(SyncManagerInitInvalidStorageTest, FailToOpenDatabase) { |
3141 EXPECT_FALSE(initialization_succeeded_); | 3046 EXPECT_FALSE(initialization_succeeded_); |
3142 } | 3047 } |
3143 | 3048 |
3144 } // namespace syncer | 3049 } // namespace syncer |
OLD | NEW |