| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 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 #include "sync/api/sync_data.h" | 5 #include "sync/api/sync_data.h" |
| 6 | 6 |
| 7 #include <ostream> | 7 #include <ostream> |
| 8 | 8 |
| 9 #include "base/json/json_writer.h" | 9 #include "base/json/json_writer.h" |
| 10 #include "base/memory/scoped_ptr.h" | 10 #include "base/memory/scoped_ptr.h" |
| (...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 56 sync_pb::SyncEntity* SyncData::ImmutableSyncEntityTraits::UnwrapMutable( | 56 sync_pb::SyncEntity* SyncData::ImmutableSyncEntityTraits::UnwrapMutable( |
| 57 Wrapper* wrapper) { | 57 Wrapper* wrapper) { |
| 58 return *wrapper; | 58 return *wrapper; |
| 59 } | 59 } |
| 60 | 60 |
| 61 void SyncData::ImmutableSyncEntityTraits::Swap(sync_pb::SyncEntity* t1, | 61 void SyncData::ImmutableSyncEntityTraits::Swap(sync_pb::SyncEntity* t1, |
| 62 sync_pb::SyncEntity* t2) { | 62 sync_pb::SyncEntity* t2) { |
| 63 t1->Swap(t2); | 63 t1->Swap(t2); |
| 64 } | 64 } |
| 65 | 65 |
| 66 SyncData::SyncData() : is_valid_(false), id_(kInvalidId) {} | 66 SyncData::SyncData() |
| 67 : local_(NULL), remote_(NULL), is_valid_(false), id_(kInvalidId) {} |
| 67 | 68 |
| 68 SyncData::SyncData( | 69 SyncData::SyncData(int64 id, |
| 69 int64 id, | 70 sync_pb::SyncEntity* entity, |
| 70 sync_pb::SyncEntity* entity, | 71 AttachmentList* attachments, |
| 71 AttachmentList* attachments, | 72 const base::Time& remote_modification_time, |
| 72 const base::Time& remote_modification_time, | 73 const syncer::AttachmentServiceProxy& attachment_service) |
| 73 const syncer::AttachmentServiceProxy& attachment_service) | 74 : local_(this), |
| 74 : is_valid_(true), | 75 remote_(this), |
| 76 is_valid_(true), |
| 75 id_(id), | 77 id_(id), |
| 76 remote_modification_time_(remote_modification_time), | 78 remote_modification_time_(remote_modification_time), |
| 77 immutable_entity_(entity), | 79 immutable_entity_(entity), |
| 78 attachments_(attachments), | 80 attachments_(attachments), |
| 79 attachment_service_(attachment_service) {} | 81 attachment_service_(attachment_service) { |
| 82 if (IsLocal()) { |
| 83 remote_ = Remote(NULL); |
| 84 } else { |
| 85 local_ = Local(NULL); |
| 86 } |
| 87 } |
| 80 | 88 |
| 81 SyncData::~SyncData() {} | 89 SyncData::~SyncData() {} |
| 82 | 90 |
| 83 // Static. | 91 // Static. |
| 84 SyncData SyncData::CreateLocalDelete(const std::string& sync_tag, | 92 SyncData SyncData::CreateLocalDelete(const std::string& sync_tag, |
| 85 ModelType datatype) { | 93 ModelType datatype) { |
| 86 sync_pb::EntitySpecifics specifics; | 94 sync_pb::EntitySpecifics specifics; |
| 87 AddDefaultFieldValue(datatype, &specifics); | 95 AddDefaultFieldValue(datatype, &specifics); |
| 88 return CreateLocalData(sync_tag, std::string(), specifics); | 96 return CreateLocalData(sync_tag, std::string(), specifics); |
| 89 } | 97 } |
| (...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 158 bool SyncData::IsValid() const { return is_valid_; } | 166 bool SyncData::IsValid() const { return is_valid_; } |
| 159 | 167 |
| 160 const sync_pb::EntitySpecifics& SyncData::GetSpecifics() const { | 168 const sync_pb::EntitySpecifics& SyncData::GetSpecifics() const { |
| 161 return immutable_entity_.Get().specifics(); | 169 return immutable_entity_.Get().specifics(); |
| 162 } | 170 } |
| 163 | 171 |
| 164 ModelType SyncData::GetDataType() const { | 172 ModelType SyncData::GetDataType() const { |
| 165 return GetModelTypeFromSpecifics(GetSpecifics()); | 173 return GetModelTypeFromSpecifics(GetSpecifics()); |
| 166 } | 174 } |
| 167 | 175 |
| 168 const std::string& SyncData::GetTag() const { | |
| 169 DCHECK(IsLocal()); | |
| 170 return immutable_entity_.Get().client_defined_unique_tag(); | |
| 171 } | |
| 172 | |
| 173 const std::string& SyncData::GetTitle() const { | 176 const std::string& SyncData::GetTitle() const { |
| 174 // TODO(zea): set this for data coming from the syncer too. | 177 // TODO(zea): set this for data coming from the syncer too. |
| 175 DCHECK(immutable_entity_.Get().has_non_unique_name()); | 178 DCHECK(immutable_entity_.Get().has_non_unique_name()); |
| 176 return immutable_entity_.Get().non_unique_name(); | 179 return immutable_entity_.Get().non_unique_name(); |
| 177 } | 180 } |
| 178 | 181 |
| 179 const base::Time& SyncData::GetRemoteModifiedTime() const { | |
| 180 DCHECK(!IsLocal()); | |
| 181 return remote_modification_time_; | |
| 182 } | |
| 183 | |
| 184 int64 SyncData::GetRemoteId() const { | |
| 185 DCHECK(!IsLocal()); | |
| 186 return id_; | |
| 187 } | |
| 188 | |
| 189 bool SyncData::IsLocal() const { return id_ == kInvalidId; } | 182 bool SyncData::IsLocal() const { return id_ == kInvalidId; } |
| 190 | 183 |
| 191 std::string SyncData::ToString() const { | 184 std::string SyncData::ToString() const { |
| 192 if (!IsValid()) | 185 if (!IsValid()) |
| 193 return "<Invalid SyncData>"; | 186 return "<Invalid SyncData>"; |
| 194 | 187 |
| 195 std::string type = ModelTypeToString(GetDataType()); | 188 std::string type = ModelTypeToString(GetDataType()); |
| 196 std::string specifics; | 189 std::string specifics; |
| 197 scoped_ptr<base::DictionaryValue> value( | 190 scoped_ptr<base::DictionaryValue> value( |
| 198 EntitySpecificsToValue(GetSpecifics())); | 191 EntitySpecificsToValue(GetSpecifics())); |
| 199 base::JSONWriter::WriteWithOptions( | 192 base::JSONWriter::WriteWithOptions( |
| 200 value.get(), base::JSONWriter::OPTIONS_PRETTY_PRINT, &specifics); | 193 value.get(), base::JSONWriter::OPTIONS_PRETTY_PRINT, &specifics); |
| 201 | 194 |
| 202 if (IsLocal()) { | 195 if (IsLocal()) { |
| 203 return "{ isLocal: true, type: " + type + ", tag: " + GetTag() + | 196 return "{ isLocal: true, type: " + type + ", tag: " + local().GetTag() + |
| 204 ", title: " + GetTitle() + ", specifics: " + specifics + "}"; | 197 ", title: " + GetTitle() + ", specifics: " + specifics + "}"; |
| 205 } | 198 } |
| 206 | 199 |
| 207 std::string id = base::Int64ToString(GetRemoteId()); | 200 std::string id = base::Int64ToString(remote().GetRemoteId()); |
| 208 return "{ isLocal: false, type: " + type + ", specifics: " + specifics + | 201 return "{ isLocal: false, type: " + type + ", specifics: " + specifics + |
| 209 ", id: " + id + "}"; | 202 ", id: " + id + "}"; |
| 210 } | 203 } |
| 211 | 204 |
| 212 void PrintTo(const SyncData& sync_data, std::ostream* os) { | 205 void PrintTo(const SyncData& sync_data, std::ostream* os) { |
| 213 *os << sync_data.ToString(); | 206 *os << sync_data.ToString(); |
| 214 } | 207 } |
| 215 | 208 |
| 216 AttachmentIdList SyncData::GetAttachmentIds() const { | 209 AttachmentIdList SyncData::GetAttachmentIds() const { |
| 217 AttachmentIdList result; | 210 AttachmentIdList result; |
| 218 const sync_pb::SyncEntity& entity = immutable_entity_.Get(); | 211 const sync_pb::SyncEntity& entity = immutable_entity_.Get(); |
| 219 std::transform(entity.attachment_id().begin(), | 212 std::transform(entity.attachment_id().begin(), |
| 220 entity.attachment_id().end(), | 213 entity.attachment_id().end(), |
| 221 std::back_inserter(result), | 214 std::back_inserter(result), |
| 222 ProtoToId); | 215 ProtoToId); |
| 223 return result; | 216 return result; |
| 224 } | 217 } |
| 225 | 218 |
| 226 const AttachmentList& SyncData::GetLocalAttachmentsForUpload() const { | 219 const AttachmentList& SyncData::Local::GetLocalAttachmentsForUpload() const { |
| 227 DCHECK(IsLocal()); | 220 return sync_data_->attachments_.Get(); |
| 228 return attachments_.Get(); | |
| 229 } | 221 } |
| 230 | 222 |
| 231 void SyncData::GetOrDownloadAttachments( | 223 const std::string& SyncData::Local::GetTag() const { |
| 224 return sync_data_->immutable_entity_.Get().client_defined_unique_tag(); |
| 225 } |
| 226 |
| 227 const SyncData::Local& SyncData::local() const { |
| 228 DCHECK(IsLocal()); |
| 229 return local_; |
| 230 } |
| 231 |
| 232 const base::Time& SyncData::Remote::GetRemoteModifiedTime() const { |
| 233 return sync_data_->remote_modification_time_; |
| 234 } |
| 235 |
| 236 int64 SyncData::Remote::GetRemoteId() const { |
| 237 return sync_data_->id_; |
| 238 } |
| 239 |
| 240 void SyncData::Remote::GetOrDownloadAttachments( |
| 232 const AttachmentIdList& attachment_ids, | 241 const AttachmentIdList& attachment_ids, |
| 233 const AttachmentService::GetOrDownloadCallback& callback) { | 242 const AttachmentService::GetOrDownloadCallback& callback) { |
| 234 DCHECK(!IsLocal()); | 243 sync_data_->attachment_service_.GetOrDownloadAttachments(attachment_ids, |
| 235 attachment_service_.GetOrDownloadAttachments(attachment_ids, callback); | 244 callback); |
| 236 } | 245 } |
| 237 | 246 |
| 238 void SyncData::DropAttachments( | 247 void SyncData::Remote::DropAttachments( |
| 239 const AttachmentIdList& attachment_ids, | 248 const AttachmentIdList& attachment_ids, |
| 240 const AttachmentService::DropCallback& callback) { | 249 const AttachmentService::DropCallback& callback) { |
| 250 sync_data_->attachment_service_.DropAttachments(attachment_ids, callback); |
| 251 } |
| 252 |
| 253 SyncData::Remote& SyncData::remote() { |
| 241 DCHECK(!IsLocal()); | 254 DCHECK(!IsLocal()); |
| 242 attachment_service_.DropAttachments(attachment_ids, callback); | 255 return remote_; |
| 256 } |
| 257 |
| 258 const SyncData::Remote& SyncData::remote() const { |
| 259 DCHECK(!IsLocal()); |
| 260 return remote_; |
| 243 } | 261 } |
| 244 | 262 |
| 245 } // namespace syncer | 263 } // namespace syncer |
| OLD | NEW |