[IndexedDB] Adding transaction and value support to observers

third_party/WebKit/Source/modules/indexeddb/IDBObserverChanges.cpp

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "modules/indexeddb/IDBObserverChanges.h"
 
 #include "bindings/core/v8/ExceptionState.h"
 #include "bindings/core/v8/ScriptState.h"
 #include "bindings/core/v8/V8Binding.h"
 #include "bindings/modules/v8/ToV8ForModules.h"
@@ skipping 13 matching lines @@
         v8String(isolate, m_database->getObjectStoreName(it.key));
     v8::Local<v8::Value> value = ToV8(it.value, context->Global(), isolate);
     map->Set(context, key, value).ToLocalChecked();
   }
   return ScriptValue::from(scriptState, map);
 }
 
 IDBObserverChanges* IDBObserverChanges::create(
     IDBDatabase* database,
     const WebVector<WebIDBObservation>& observations,
-    const WebVector<int32_t>& observationIndex) {
-  return new IDBObserverChanges(database, observations, observationIndex);
+    const WebVector<int32_t>& observationIndices) {
+  return new IDBObserverChanges(database, nullptr, observations,
+                                observationIndices);
+}
+
+IDBObserverChanges* IDBObserverChanges::create(
+    IDBDatabase* database,
+    IDBTransaction* transaction,
+    const WebVector<WebIDBObservation>& observations,
+    const WebVector<int32_t>& observationIndices) {
+  return new IDBObserverChanges(database, transaction, observations,
+                                observationIndices);
 }
 
 IDBObserverChanges::IDBObserverChanges(
     IDBDatabase* database,
+    IDBTransaction* transaction,
     const WebVector<WebIDBObservation>& observations,
-    const WebVector<int32_t>& observationIndex)
-    : m_database(database) {
-  extractChanges(observations, observationIndex);
+    const WebVector<int32_t>& observationIndices)
+    : m_database(database), m_transaction(transaction) {
+  extractChanges(observations, observationIndices);
 }
 
 void IDBObserverChanges::extractChanges(
     const WebVector<WebIDBObservation>& observations,
-    const WebVector<int32_t>& observationIndex) {
+    const WebVector<int32_t>& observationIndices) {
   // TODO(dmurph): Avoid getting and setting repeated times.
-  for (const auto& idx : observationIndex)
+  for (const auto& idx : observationIndices) {
     m_records
         .add(observations[idx].objectStoreId,
              HeapVector<Member<IDBObservation>>())
         .storedValue->value.push_back(
             IDBObservation::create(observations[idx]));
+  }
 }
 
 DEFINE_TRACE(IDBObserverChanges) {
   visitor->trace(m_database);
   visitor->trace(m_transaction);
   visitor->trace(m_records);
 }
 
 }  // namespace blink