Use delete journal to remove bookmarks that are already deleted in sync model

sync/internal_api/base_transaction.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "sync/internal_api/public/base_transaction.h"
 
 #include "sync/syncable/directory.h"
+#include "sync/syncable/entry_kernel.h"
 #include "sync/syncable/nigori_handler.h"
 #include "sync/util/cryptographer.h"
 
 namespace syncer {
 
 //////////////////////////////////////////////////////////////////////////
 // BaseTransaction member definitions
 BaseTransaction::BaseTransaction(UserShare* share)
     : user_share_(share) {
   DCHECK(share && share->directory.get());
 }
 
 BaseTransaction::~BaseTransaction() {
 }
 
 Cryptographer* BaseTransaction::GetCryptographer() const {
   return GetDirectory()->GetCryptographer(this->GetWrappedTrans());
 }
 
 ModelTypeSet BaseTransaction::GetEncryptedTypes() const {
   return GetDirectory()->GetNigoriHandler()->GetEncryptedTypes(
       this->GetWrappedTrans());
 }
 
+void BaseTransaction::GetDeletedSyncData(
+    ModelType type, SyncDataList *deleted) const {
+  syncer::syncable::EntryKernelSet deleted_entries;
+  GetDirectory()->GetDeleteJournals(GetWrappedTrans(), type, &deleted_entries);
+  std::set<int64> undecryptable_journal;
+  for (syncer::syncable::EntryKernelSet::const_iterator i =
+      deleted_entries.begin(); i != deleted_entries.end(); ++i) {
+    int64 id = (*i)->ref(syncer::syncable::META_HANDLE);
+    const sync_pb::EntitySpecifics& specifics =
+        (*i)->ref(syncer::syncable::SPECIFICS);
+    bool is_folder = (*i)->ref(syncer::syncable::IS_DIR);
+    if (!specifics.has_encrypted()) {
+      deleted->push_back(syncer::SyncData::CreateRemoteData(id, specifics,
+                                                            is_folder));
+    } else {
+      const sync_pb::EncryptedData& encrypted = specifics.encrypted();
+      std::string plaintext_data =
+          GetCryptographer()->DecryptToString(encrypted);
+      sync_pb::EntitySpecifics unencrypted_data;
+      if (plaintext_data.length() == 0 ||
+          !unencrypted_data.ParseFromString(plaintext_data)) {
+        // Fail to decrypt, purge this delete journal.
+        undecryptable_journal.insert(id);
+      } else {
+        deleted->push_back(syncer::SyncData::CreateRemoteData(id,
+                                                              unencrypted_data,
+                                                              is_folder));
+      }
+    }
+  }
+
+  if (!undecryptable_journal.empty()) {
+    GetDirectory()->PurgeDeleteJournals(GetWrappedTrans(),
+                                        undecryptable_journal);
+  }
+}
+
+void BaseTransaction::PurgeDeletedSyncData(const std::set<int64>& ids) {
+  GetDirectory()->PurgeDeleteJournals(GetWrappedTrans(), ids);
+}
+
 }  // namespace syncer