chrome/browser/sync/js/js_mutation_event_observer.cc - Issue 9699057: [Sync] Move 'sync' target to sync/

Side by Side Diff: chrome/browser/sync/js/js_mutation_event_observer.cc

Issue 9699057: [Sync] Move 'sync' target to sync/ (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src

Patch Set: Address Tim's comments Created 8 years, 9 months ago

Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.

Jump to:

View unified diff | Download patch | Annotate | Revision Log

OLD	NEW
	(Empty)
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved.

2 // Use of this source code is governed by a BSD-style license that can be

3 // found in the LICENSE file.

4

5 #include "chrome/browser/sync/js/js_mutation_event_observer.h"

6

7 #include <string>

8

9 #include "base/location.h"

10 #include "base/logging.h"

11 #include "base/string_number_conversions.h"

12 #include "base/values.h"

13 #include "chrome/browser/sync/js/js_event_details.h"

14 #include "chrome/browser/sync/js/js_event_handler.h"

15

16 namespace browser_sync {

17

18 JsMutationEventObserver::JsMutationEventObserver()

19 : weak_ptr_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)) {}

20

21 JsMutationEventObserver::~JsMutationEventObserver() {

22 DCHECK(non_thread_safe_.CalledOnValidThread());

23 }

24

25 base::WeakPtr<JsMutationEventObserver> JsMutationEventObserver::AsWeakPtr() {

26 return weak_ptr_factory_.GetWeakPtr();

27 }

28

29 void JsMutationEventObserver::InvalidateWeakPtrs() {

30 weak_ptr_factory_.InvalidateWeakPtrs();

31 }

32

33 void JsMutationEventObserver::SetJsEventHandler(

34 const WeakHandle<JsEventHandler>& event_handler) {

35 event_handler_ = event_handler;

36 }

37

38 namespace {

39

40 // Max number of changes we attempt to convert to values (to avoid

41 // running out of memory).

42 const size_t kChangeLimit = 100;

43

44 } // namespace

45

46 void JsMutationEventObserver::OnChangesApplied(

47 syncable::ModelType model_type,

48 int64 write_transaction_id,

49 const sync_api::ImmutableChangeRecordList& changes) {

50 if (!event_handler_.IsInitialized()) {

51 return;

52 }

53 DictionaryValue details;

54 details.SetString("modelType", syncable::ModelTypeToString(model_type));

55 details.SetString("writeTransactionId",

56 base::Int64ToString(write_transaction_id));

57 base::Value* changes_value = NULL;

58 const size_t changes_size = changes.Get().size();

59 if (changes_size <= kChangeLimit) {

60 ListValue* changes_list = new ListValue();

61 for (sync_api::ChangeRecordList::const_iterator it =

62 changes.Get().begin(); it != changes.Get().end(); ++it) {

63 changes_list->Append(it->ToValue());

64 }

65 changes_value = changes_list;

66 } else {

67 changes_value =

68 Value::CreateStringValue(

69 base::Uint64ToString(static_cast<uint64>(changes_size)) +

70 " changes");

71 }

72 details.Set("changes", changes_value);

73 HandleJsEvent(FROM_HERE, "onChangesApplied", JsEventDetails(&details));

74 }

75

76 void JsMutationEventObserver::OnChangesComplete(

77 syncable::ModelType model_type) {

78 if (!event_handler_.IsInitialized()) {

79 return;

80 }

81 DictionaryValue details;

82 details.SetString("modelType", syncable::ModelTypeToString(model_type));

83 HandleJsEvent(FROM_HERE, "onChangesComplete", JsEventDetails(&details));

84 }

85

86 void JsMutationEventObserver::OnTransactionWrite(

87 const syncable::ImmutableWriteTransactionInfo& write_transaction_info,

88 syncable::ModelTypeSet models_with_changes) {

89 DCHECK(non_thread_safe_.CalledOnValidThread());

90 if (!event_handler_.IsInitialized()) {

91 return;

92 }

93 DictionaryValue details;

94 details.Set("writeTransactionInfo",

95 write_transaction_info.Get().ToValue(kChangeLimit));

96 details.Set("modelsWithChanges",

97 syncable::ModelTypeSetToValue(models_with_changes));

98 HandleJsEvent(FROM_HERE, "onTransactionWrite", JsEventDetails(&details));

99 }

100

101 void JsMutationEventObserver::HandleJsEvent(

102 const tracked_objects::Location& from_here,

103 const std::string& name, const JsEventDetails& details) {

104 if (!event_handler_.IsInitialized()) {

105 NOTREACHED();

106 return;

107 }

108 event_handler_.Call(from_here,

109 &JsEventHandler::HandleJsEvent, name, details);

110 }

111

112 } // namespace browser_sync

OLD	NEW