15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Copyright (c) 2012 The Chromium Authors. All rights reserved. 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// found in the LICENSE file. 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 55821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "sync/internal_api/js_mutation_event_observer.h" 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <string> 85821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 95821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/location.h" 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/logging.h" 11868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)#include "base/strings/string_number_conversions.h" 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/values.h" 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "sync/js/js_event_details.h" 145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "sync/js/js_event_handler.h" 155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace syncer { 175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)JsMutationEventObserver::JsMutationEventObserver() 19c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) : weak_ptr_factory_(this) {} 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)JsMutationEventObserver::~JsMutationEventObserver() { 225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)base::WeakPtr<JsMutationEventObserver> JsMutationEventObserver::AsWeakPtr() { 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return weak_ptr_factory_.GetWeakPtr(); 275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void JsMutationEventObserver::InvalidateWeakPtrs() { 305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) weak_ptr_factory_.InvalidateWeakPtrs(); 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void JsMutationEventObserver::SetJsEventHandler( 345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const WeakHandle<JsEventHandler>& event_handler) { 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) event_handler_ = event_handler; 365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace { 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Max number of changes we attempt to convert to values (to avoid 415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// running out of memory). 425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)const size_t kChangeLimit = 100; 435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace 455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void JsMutationEventObserver::OnChangesApplied( 475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ModelType model_type, 485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int64 write_transaction_id, 495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const ImmutableChangeRecordList& changes) { 505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!event_handler_.IsInitialized()) { 515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return; 525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 532a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::DictionaryValue details; 545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) details.SetString("modelType", ModelTypeToString(model_type)); 555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) details.SetString("writeTransactionId", 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Int64ToString(write_transaction_id)); 575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Value* changes_value = NULL; 585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const size_t changes_size = changes.Get().size(); 595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (changes_size <= kChangeLimit) { 602a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::ListValue* changes_list = new base::ListValue(); 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for (ChangeRecordList::const_iterator it = 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) changes.Get().begin(); it != changes.Get().end(); ++it) { 635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) changes_list->Append(it->ToValue()); 645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) changes_value = changes_list; 665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) changes_value = 682a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) new base::StringValue( 69116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch base::SizeTToString(changes_size) + " changes"); 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) details.Set("changes", changes_value); 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HandleJsEvent(FROM_HERE, "onChangesApplied", JsEventDetails(&details)); 735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void JsMutationEventObserver::OnChangesComplete(ModelType model_type) { 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!event_handler_.IsInitialized()) { 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return; 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 792a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::DictionaryValue details; 805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) details.SetString("modelType", ModelTypeToString(model_type)); 815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HandleJsEvent(FROM_HERE, "onChangesComplete", JsEventDetails(&details)); 825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void JsMutationEventObserver::OnTransactionWrite( 855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const syncable::ImmutableWriteTransactionInfo& write_transaction_info, 865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ModelTypeSet models_with_changes) { 875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!event_handler_.IsInitialized()) { 895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return; 905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 912a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::DictionaryValue details; 925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) details.Set("writeTransactionInfo", 935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) write_transaction_info.Get().ToValue(kChangeLimit)); 945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) details.Set("modelsWithChanges", 955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ModelTypeSetToValue(models_with_changes)); 965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HandleJsEvent(FROM_HERE, "onTransactionWrite", JsEventDetails(&details)); 975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void JsMutationEventObserver::HandleJsEvent( 1005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const tracked_objects::Location& from_here, 1015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& name, const JsEventDetails& details) { 1025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!event_handler_.IsInitialized()) { 1035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 1045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return; 1055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) event_handler_.Call(from_here, 1075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) &JsEventHandler::HandleJsEvent, name, details); 1085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace syncer 111