Index: sync/internal_api/public/base/invalidation.cc |
diff --git a/sync/internal_api/public/base/invalidation.cc b/sync/internal_api/public/base/invalidation.cc |
deleted file mode 100644 |
index 4e1135c32e3b6fd5b40c2378ca71617dfbe1f183..0000000000000000000000000000000000000000 |
--- a/sync/internal_api/public/base/invalidation.cc |
+++ /dev/null |
@@ -1,178 +0,0 @@ |
-// Copyright 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/invalidation.h" |
- |
-#include <cstddef> |
- |
-#include "base/json/json_string_value_serializer.h" |
-#include "base/rand_util.h" |
-#include "base/strings/string_number_conversions.h" |
-#include "base/values.h" |
-#include "sync/internal_api/public/base/ack_handler.h" |
-#include "sync/internal_api/public/base/invalidation_util.h" |
- |
-namespace syncer { |
- |
-namespace { |
-const char kObjectIdKey[] = "objectId"; |
-const char kIsUnknownVersionKey[] = "isUnknownVersion"; |
-const char kVersionKey[] = "version"; |
-const char kPayloadKey[] = "payload"; |
-const int64 kInvalidVersion = -1; |
-} |
- |
-Invalidation Invalidation::Init( |
- const invalidation::ObjectId& id, |
- int64 version, |
- const std::string& payload) { |
- return Invalidation(id, false, version, payload, AckHandle::CreateUnique()); |
-} |
- |
-Invalidation Invalidation::InitUnknownVersion( |
- const invalidation::ObjectId& id) { |
- return Invalidation(id, true, kInvalidVersion, |
- std::string(), AckHandle::CreateUnique()); |
-} |
- |
-Invalidation Invalidation::InitFromDroppedInvalidation( |
- const Invalidation& dropped) { |
- return Invalidation(dropped.id_, true, kInvalidVersion, |
- std::string(), dropped.ack_handle_); |
-} |
- |
-scoped_ptr<Invalidation> Invalidation::InitFromValue( |
- const base::DictionaryValue& value) { |
- invalidation::ObjectId id; |
- |
- const base::DictionaryValue* object_id_dict; |
- if (!value.GetDictionary(kObjectIdKey, &object_id_dict) |
- || !ObjectIdFromValue(*object_id_dict, &id)) { |
- DLOG(WARNING) << "Failed to parse id"; |
- return scoped_ptr<Invalidation>(); |
- } |
- bool is_unknown_version; |
- if (!value.GetBoolean(kIsUnknownVersionKey, &is_unknown_version)) { |
- DLOG(WARNING) << "Failed to parse is_unknown_version flag"; |
- return scoped_ptr<Invalidation>(); |
- } |
- if (is_unknown_version) { |
- return scoped_ptr<Invalidation>(new Invalidation( |
- id, |
- true, |
- kInvalidVersion, |
- std::string(), |
- AckHandle::CreateUnique())); |
- } |
- int64 version = 0; |
- std::string version_as_string; |
- if (!value.GetString(kVersionKey, &version_as_string) |
- || !base::StringToInt64(version_as_string, &version)) { |
- DLOG(WARNING) << "Failed to parse version"; |
- return scoped_ptr<Invalidation>(); |
- } |
- std::string payload; |
- if (!value.GetString(kPayloadKey, &payload)) { |
- DLOG(WARNING) << "Failed to parse payload"; |
- return scoped_ptr<Invalidation>(); |
- } |
- return scoped_ptr<Invalidation>(new Invalidation( |
- id, |
- false, |
- version, |
- payload, |
- AckHandle::CreateUnique())); |
-} |
- |
-Invalidation::~Invalidation() {} |
- |
-invalidation::ObjectId Invalidation::object_id() const { |
- return id_; |
-} |
- |
-bool Invalidation::is_unknown_version() const { |
- return is_unknown_version_; |
-} |
- |
-int64 Invalidation::version() const { |
- DCHECK(!is_unknown_version_); |
- return version_; |
-} |
- |
-const std::string& Invalidation::payload() const { |
- DCHECK(!is_unknown_version_); |
- return payload_; |
-} |
- |
-const AckHandle& Invalidation::ack_handle() const { |
- return ack_handle_; |
-} |
- |
-void Invalidation::set_ack_handler(syncer::WeakHandle<AckHandler> handler) { |
- ack_handler_ = handler; |
-} |
- |
-bool Invalidation::SupportsAcknowledgement() const { |
- return ack_handler_.IsInitialized(); |
-} |
- |
-void Invalidation::Acknowledge() const { |
- if (SupportsAcknowledgement()) { |
- ack_handler_.Call(FROM_HERE, |
- &AckHandler::Acknowledge, |
- id_, |
- ack_handle_); |
- } |
-} |
- |
-void Invalidation::Drop() { |
- if (SupportsAcknowledgement()) { |
- ack_handler_.Call(FROM_HERE, |
- &AckHandler::Drop, |
- id_, |
- ack_handle_); |
- } |
-} |
- |
-bool Invalidation::Equals(const Invalidation& other) const { |
- return id_ == other.id_ |
- && is_unknown_version_ == other.is_unknown_version_ |
- && version_ == other.version_ |
- && payload_ == other.payload_; |
-} |
- |
-scoped_ptr<base::DictionaryValue> Invalidation::ToValue() const { |
- scoped_ptr<base::DictionaryValue> value(new base::DictionaryValue()); |
- value->Set(kObjectIdKey, ObjectIdToValue(id_).release()); |
- if (is_unknown_version_) { |
- value->SetBoolean(kIsUnknownVersionKey, true); |
- } else { |
- value->SetBoolean(kIsUnknownVersionKey, false); |
- value->SetString(kVersionKey, base::Int64ToString(version_)); |
- value->SetString(kPayloadKey, payload_); |
- } |
- return value.Pass(); |
-} |
- |
-std::string Invalidation::ToString() const { |
- std::string output; |
- JSONStringValueSerializer serializer(&output); |
- serializer.set_pretty_print(true); |
- serializer.Serialize(*ToValue().get()); |
- return output; |
-} |
- |
-Invalidation::Invalidation( |
- const invalidation::ObjectId& id, |
- bool is_unknown_version, |
- int64 version, |
- const std::string& payload, |
- AckHandle ack_handle) |
- : id_(id), |
- is_unknown_version_(is_unknown_version), |
- version_(version), |
- payload_(payload), |
- ack_handle_(ack_handle) {} |
- |
-} // namespace syncer |