OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 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 | 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 "chrome/browser/sync/engine/syncapi.h" | 5 #include "chrome/browser/sync/engine/syncapi.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <bitset> | 8 #include <bitset> |
9 #include <iomanip> | 9 #include <iomanip> |
10 #include <list> | 10 #include <list> |
(...skipping 1162 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1173 } | 1173 } |
1174 node_value = node_dict; | 1174 node_value = node_dict; |
1175 } else { | 1175 } else { |
1176 ReadNode node(trans); | 1176 ReadNode node(trans); |
1177 if (node.InitByIdLookup(id)) { | 1177 if (node.InitByIdLookup(id)) { |
1178 node_value = node.GetDetailsAsValue(); | 1178 node_value = node.GetDetailsAsValue(); |
1179 } | 1179 } |
1180 } | 1180 } |
1181 if (!node_value) { | 1181 if (!node_value) { |
1182 NOTREACHED(); | 1182 NOTREACHED(); |
1183 node_value = Value::CreateNullValue(); | 1183 node_value = base::NullValue(); |
1184 } | 1184 } |
1185 value->Set("node", node_value); | 1185 value->Set("node", node_value); |
1186 return value; | 1186 return value; |
1187 } | 1187 } |
1188 | 1188 |
1189 SyncManager::ExtraPasswordChangeRecordData::ExtraPasswordChangeRecordData() {} | 1189 SyncManager::ExtraPasswordChangeRecordData::ExtraPasswordChangeRecordData() {} |
1190 | 1190 |
1191 SyncManager::ExtraPasswordChangeRecordData::ExtraPasswordChangeRecordData( | 1191 SyncManager::ExtraPasswordChangeRecordData::ExtraPasswordChangeRecordData( |
1192 const sync_pb::PasswordSpecificsData& data) | 1192 const sync_pb::PasswordSpecificsData& data) |
1193 : unencrypted_(data) { | 1193 : unencrypted_(data) { |
(...skipping 1550 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2744 value->Set(model_type_str, it->second.ToValue()); | 2744 value->Set(model_type_str, it->second.ToValue()); |
2745 } | 2745 } |
2746 | 2746 |
2747 return value; | 2747 return value; |
2748 } | 2748 } |
2749 | 2749 |
2750 JsArgList SyncManager::SyncInternal::GetNotificationState( | 2750 JsArgList SyncManager::SyncInternal::GetNotificationState( |
2751 const JsArgList& args) { | 2751 const JsArgList& args) { |
2752 bool notifications_enabled = allstatus_.status().notifications_enabled; | 2752 bool notifications_enabled = allstatus_.status().notifications_enabled; |
2753 ListValue return_args; | 2753 ListValue return_args; |
2754 return_args.Append(Value::CreateBooleanValue(notifications_enabled)); | 2754 return_args.Append(base::BooleanValue::New(notifications_enabled)); |
2755 return JsArgList(&return_args); | 2755 return JsArgList(&return_args); |
2756 } | 2756 } |
2757 | 2757 |
2758 JsArgList SyncManager::SyncInternal::GetNotificationInfo( | 2758 JsArgList SyncManager::SyncInternal::GetNotificationInfo( |
2759 const JsArgList& args) { | 2759 const JsArgList& args) { |
2760 ListValue return_args; | 2760 ListValue return_args; |
2761 return_args.Append(NotificationInfoToValue(notification_info_map_)); | 2761 return_args.Append(NotificationInfoToValue(notification_info_map_)); |
2762 return JsArgList(&return_args); | 2762 return JsArgList(&return_args); |
2763 } | 2763 } |
2764 | 2764 |
(...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2830 ListValue* child_ids = new ListValue(); | 2830 ListValue* child_ids = new ListValue(); |
2831 return_args.Append(child_ids); | 2831 return_args.Append(child_ids); |
2832 int64 id = GetId(args.Get(), 0); | 2832 int64 id = GetId(args.Get(), 0); |
2833 if (id != kInvalidId) { | 2833 if (id != kInvalidId) { |
2834 ReadTransaction trans(FROM_HERE, GetUserShare()); | 2834 ReadTransaction trans(FROM_HERE, GetUserShare()); |
2835 syncable::Directory::ChildHandles child_handles; | 2835 syncable::Directory::ChildHandles child_handles; |
2836 trans.GetLookup()->GetChildHandlesByHandle(trans.GetWrappedTrans(), | 2836 trans.GetLookup()->GetChildHandlesByHandle(trans.GetWrappedTrans(), |
2837 id, &child_handles); | 2837 id, &child_handles); |
2838 for (syncable::Directory::ChildHandles::const_iterator it = | 2838 for (syncable::Directory::ChildHandles::const_iterator it = |
2839 child_handles.begin(); it != child_handles.end(); ++it) { | 2839 child_handles.begin(); it != child_handles.end(); ++it) { |
2840 child_ids->Append(Value::CreateStringValue( | 2840 child_ids->Append(base::StringValue::New( |
2841 base::Int64ToString(*it))); | 2841 base::Int64ToString(*it))); |
2842 } | 2842 } |
2843 } | 2843 } |
2844 return JsArgList(&return_args); | 2844 return JsArgList(&return_args); |
2845 } | 2845 } |
2846 | 2846 |
2847 JsArgList SyncManager::SyncInternal::FindNodesContainingString( | 2847 JsArgList SyncManager::SyncInternal::FindNodesContainingString( |
2848 const JsArgList& args) { | 2848 const JsArgList& args) { |
2849 std::string query; | 2849 std::string query; |
2850 ListValue return_args; | 2850 ListValue return_args; |
(...skipping 11 matching lines...) Expand all Loading... |
2862 return_args.Append(result); | 2862 return_args.Append(result); |
2863 | 2863 |
2864 ReadTransaction trans(FROM_HERE, GetUserShare()); | 2864 ReadTransaction trans(FROM_HERE, GetUserShare()); |
2865 std::vector<const syncable::EntryKernel*> entry_kernels; | 2865 std::vector<const syncable::EntryKernel*> entry_kernels; |
2866 trans.GetLookup()->GetAllEntryKernels(trans.GetWrappedTrans(), | 2866 trans.GetLookup()->GetAllEntryKernels(trans.GetWrappedTrans(), |
2867 &entry_kernels); | 2867 &entry_kernels); |
2868 | 2868 |
2869 for (std::vector<const syncable::EntryKernel*>::const_iterator it = | 2869 for (std::vector<const syncable::EntryKernel*>::const_iterator it = |
2870 entry_kernels.begin(); it != entry_kernels.end(); ++it) { | 2870 entry_kernels.begin(); it != entry_kernels.end(); ++it) { |
2871 if ((*it)->ContainsString(lowercase_query)) { | 2871 if ((*it)->ContainsString(lowercase_query)) { |
2872 result->Append(new StringValue(base::Int64ToString( | 2872 result->Append(base::StringValue::New(base::Int64ToString( |
2873 (*it)->ref(syncable::META_HANDLE)))); | 2873 (*it)->ref(syncable::META_HANDLE)))); |
2874 } | 2874 } |
2875 } | 2875 } |
2876 | 2876 |
2877 return JsArgList(&return_args); | 2877 return JsArgList(&return_args); |
2878 } | 2878 } |
2879 | 2879 |
2880 void SyncManager::SyncInternal::OnNotificationStateChange( | 2880 void SyncManager::SyncInternal::OnNotificationStateChange( |
2881 bool notifications_enabled) { | 2881 bool notifications_enabled) { |
2882 VLOG(1) << "P2P: Notifications enabled = " | 2882 VLOG(1) << "P2P: Notifications enabled = " |
2883 << (notifications_enabled ? "true" : "false"); | 2883 << (notifications_enabled ? "true" : "false"); |
2884 allstatus_.SetNotificationsEnabled(notifications_enabled); | 2884 allstatus_.SetNotificationsEnabled(notifications_enabled); |
2885 if (scheduler()) { | 2885 if (scheduler()) { |
2886 scheduler()->set_notifications_enabled(notifications_enabled); | 2886 scheduler()->set_notifications_enabled(notifications_enabled); |
2887 } | 2887 } |
2888 if (js_event_handler_.IsInitialized()) { | 2888 if (js_event_handler_.IsInitialized()) { |
2889 DictionaryValue details; | 2889 DictionaryValue details; |
2890 details.Set("enabled", Value::CreateBooleanValue(notifications_enabled)); | 2890 details.Set("enabled", base::BooleanValue::New(notifications_enabled)); |
2891 js_event_handler_.Call(FROM_HERE, | 2891 js_event_handler_.Call(FROM_HERE, |
2892 &JsEventHandler::HandleJsEvent, | 2892 &JsEventHandler::HandleJsEvent, |
2893 "onNotificationStateChange", | 2893 "onNotificationStateChange", |
2894 JsEventDetails(&details)); | 2894 JsEventDetails(&details)); |
2895 } | 2895 } |
2896 } | 2896 } |
2897 | 2897 |
2898 void SyncManager::SyncInternal::UpdateNotificationInfo( | 2898 void SyncManager::SyncInternal::UpdateNotificationInfo( |
2899 const syncable::ModelTypePayloadMap& type_payloads) { | 2899 const syncable::ModelTypePayloadMap& type_payloads) { |
2900 for (syncable::ModelTypePayloadMap::const_iterator it = type_payloads.begin(); | 2900 for (syncable::ModelTypePayloadMap::const_iterator it = type_payloads.begin(); |
(...skipping 21 matching lines...) Expand all Loading... |
2922 | 2922 |
2923 if (js_event_handler_.IsInitialized()) { | 2923 if (js_event_handler_.IsInitialized()) { |
2924 DictionaryValue details; | 2924 DictionaryValue details; |
2925 ListValue* changed_types = new ListValue(); | 2925 ListValue* changed_types = new ListValue(); |
2926 details.Set("changedTypes", changed_types); | 2926 details.Set("changedTypes", changed_types); |
2927 for (syncable::ModelTypePayloadMap::const_iterator | 2927 for (syncable::ModelTypePayloadMap::const_iterator |
2928 it = type_payloads.begin(); | 2928 it = type_payloads.begin(); |
2929 it != type_payloads.end(); ++it) { | 2929 it != type_payloads.end(); ++it) { |
2930 const std::string& model_type_str = | 2930 const std::string& model_type_str = |
2931 syncable::ModelTypeToString(it->first); | 2931 syncable::ModelTypeToString(it->first); |
2932 changed_types->Append(Value::CreateStringValue(model_type_str)); | 2932 changed_types->Append(base::StringValue::New(model_type_str)); |
2933 } | 2933 } |
2934 js_event_handler_.Call(FROM_HERE, | 2934 js_event_handler_.Call(FROM_HERE, |
2935 &JsEventHandler::HandleJsEvent, | 2935 &JsEventHandler::HandleJsEvent, |
2936 "onIncomingNotification", | 2936 "onIncomingNotification", |
2937 JsEventDetails(&details)); | 2937 JsEventDetails(&details)); |
2938 } | 2938 } |
2939 } | 2939 } |
2940 | 2940 |
2941 void SyncManager::SyncInternal::StoreState( | 2941 void SyncManager::SyncInternal::StoreState( |
2942 const std::string& state) { | 2942 const std::string& state) { |
(...skipping 131 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3074 void SyncManager::TriggerOnIncomingNotificationForTest( | 3074 void SyncManager::TriggerOnIncomingNotificationForTest( |
3075 const syncable::ModelTypeBitSet& model_types) { | 3075 const syncable::ModelTypeBitSet& model_types) { |
3076 syncable::ModelTypePayloadMap model_types_with_payloads = | 3076 syncable::ModelTypePayloadMap model_types_with_payloads = |
3077 syncable::ModelTypePayloadMapFromBitSet(model_types, | 3077 syncable::ModelTypePayloadMapFromBitSet(model_types, |
3078 std::string()); | 3078 std::string()); |
3079 | 3079 |
3080 data_->OnIncomingNotification(model_types_with_payloads); | 3080 data_->OnIncomingNotification(model_types_with_payloads); |
3081 } | 3081 } |
3082 | 3082 |
3083 } // namespace sync_api | 3083 } // namespace sync_api |
OLD | NEW |