[USS] Implement ApplySyncChanges and OnURLVisited/Modified/Deleted.

components/history/core/browser/typed_url_sync_metadata_database.cc

 // Copyright 2017 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 "components/history/core/browser/typed_url_sync_metadata_database.h"
 
 #include "base/big_endian.h"
 #include "base/logging.h"
-#include "components/history/core/browser/url_row.h"
 #include "sql/statement.h"
 
 namespace history {
 
 namespace {
 
 // Key in sql::MetaTable, the value will be Serialization of sync
 // ModelTypeState, which is for tracking sync state of typed url datatype.
 const char kTypedURLModelTypeStateKey[] = "typed_url_model_type_state";
 
@@ skipping 28 matching lines @@
   return true;
 }
 
 bool TypedURLSyncMetadataDatabase::UpdateSyncMetadata(
     syncer::ModelType model_type,
     const std::string& storage_key,
     const sync_pb::EntityMetadata& metadata) {
   DCHECK_EQ(model_type, syncer::TYPED_URLS)
       << "Only the TYPED_URLS model type is supported";
 
-  int64_t storage_key_int = 0;
-  DCHECK_EQ(storage_key.size(), sizeof(storage_key_int));
-  base::ReadBigEndian(storage_key.data(), &storage_key_int);
-  // Make sure storage_key_int is set.
-  DCHECK_NE(storage_key_int, 0);
-
   sql::Statement s(GetDB().GetUniqueStatement(
       "INSERT OR REPLACE INTO typed_url_sync_metadata "
       "(storage_key, value) VALUES(?, ?)"));
-  s.BindInt64(0, storage_key_int);
+  s.BindInt64(0, StorageKeyToURLID(storage_key));
   s.BindString(1, metadata.SerializeAsString());
 
   return s.Run();
 }
 
 bool TypedURLSyncMetadataDatabase::ClearSyncMetadata(
     syncer::ModelType model_type,
     const std::string& storage_key) {
   DCHECK_EQ(model_type, syncer::TYPED_URLS)
       << "Only the TYPED_URLS model type is supported";
 
-  int64_t storage_key_int = 0;
-  DCHECK_EQ(storage_key.size(), sizeof(storage_key_int));
-  base::ReadBigEndian(storage_key.data(), &storage_key_int);
-  // Make sure storage_key_int is set.
-  DCHECK_NE(storage_key_int, 0);
-
   sql::Statement s(GetDB().GetUniqueStatement(
       "DELETE FROM typed_url_sync_metadata WHERE storage_key=?"));
-  s.BindInt64(0, storage_key_int);
+  s.BindInt64(0, StorageKeyToURLID(storage_key));
 
   return s.Run();
 }
 
 bool TypedURLSyncMetadataDatabase::UpdateModelTypeState(
     syncer::ModelType model_type,
     const sync_pb::ModelTypeState& model_type_state) {
   DCHECK_EQ(model_type, syncer::TYPED_URLS)
       << "Only the TYPED_URLS model type is supported";
   DCHECK_GT(GetMetaTable().GetVersionNumber(), 0);
 
   std::string serialized_state = model_type_state.SerializeAsString();
   return GetMetaTable().SetValue(kTypedURLModelTypeStateKey, serialized_state);
 }
 
 bool TypedURLSyncMetadataDatabase::ClearModelTypeState(
     syncer::ModelType model_type) {
   DCHECK_EQ(model_type, syncer::TYPED_URLS)
       << "Only the TYPED_URLS model type is supported";
   DCHECK_GT(GetMetaTable().GetVersionNumber(), 0);
   return GetMetaTable().DeleteKey(kTypedURLModelTypeStateKey);
 }
 
+URLID TypedURLSyncMetadataDatabase::StorageKeyToURLID(
+    const std::string& storage_key) {
+  URLID storage_key_int = 0;
+  DCHECK_EQ(storage_key.size(), sizeof(storage_key_int));
+  base::ReadBigEndian(storage_key.data(), &storage_key_int);
+  // Make sure storage_key_int is set.
+  DCHECK_NE(storage_key_int, 0);
+  return storage_key_int;
+}
+
 bool TypedURLSyncMetadataDatabase::InitSyncTable() {
   if (!GetDB().DoesTableExist("typed_url_sync_metadata")) {
     if (!GetDB().Execute("CREATE TABLE typed_url_sync_metadata ("
                          "storage_key INTEGER PRIMARY KEY NOT NULL,"
                          "value BLOB)")) {
       NOTREACHED();
       return false;
     }
   }
   return true;
@@ skipping 26 matching lines @@
   DCHECK_GT(GetMetaTable().GetVersionNumber(), 0);
   std::string serialized_state;
   if (!GetMetaTable().GetValue(kTypedURLModelTypeStateKey, &serialized_state)) {
     return true;
   }
 
   return state->ParseFromString(serialized_state);
 }
 
 }  // namespace history