| 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 |