[IndexedDB] Adding transaction and value support to observers

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

 /*
  * Copyright (C) 2010 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  *
  * 1.  Redistributions of source code must retain the above copyright
  *     notice, this list of conditions and the following disclaimer.
  * 2.  Redistributions in binary form must reproduce the above copyright
@@ skipping 29 matching lines @@
 #include "modules/indexeddb/IDBKeyPath.h"
 #include "modules/indexeddb/IDBObserver.h"
 #include "modules/indexeddb/IDBObserverChanges.h"
 #include "modules/indexeddb/IDBTracing.h"
 #include "modules/indexeddb/IDBVersionChangeEvent.h"
 #include "modules/indexeddb/WebIDBDatabaseCallbacksImpl.h"
 #include "platform/Histogram.h"
 #include "public/platform/modules/indexeddb/WebIDBKeyPath.h"
 #include "public/platform/modules/indexeddb/WebIDBTypes.h"
 #include "wtf/Atomics.h"
+
 #include <limits>
 #include <memory>
 
 using blink::WebIDBDatabase;
 
 namespace blink {
 
+const char IDBDatabase::cannotObserveVersionChangeTransaction[] =
+    "An observer cannot target a version change transaction.";
 const char IDBDatabase::indexDeletedErrorMessage[] =
     "The index or its object store has been deleted.";
 const char IDBDatabase::indexNameTakenErrorMessage[] =
     "An index with the specified name already exists.";
 const char IDBDatabase::isKeyCursorErrorMessage[] =
     "The cursor is a key cursor.";
 const char IDBDatabase::noKeyOrKeyRangeErrorMessage[] =
     "No key or key range specified.";
 const char IDBDatabase::noSuchIndexErrorMessage[] =
     "The specified index was not found.";
@@ skipping 104 matching lines @@
 }
 
 void IDBDatabase::onComplete(int64_t transactionId) {
   DCHECK(m_transactions.contains(transactionId));
   m_transactions.get(transactionId)->onComplete();
 }
 
 void IDBDatabase::onChanges(
     const std::unordered_map<int32_t, std::vector<int32_t>>&
         observation_index_map,
-    const WebVector<WebIDBObservation>& observations) {
+    const WebVector<WebIDBObservation>& observations,
+    const std::unordered_map<int32_t, std::pair<int64_t, std::vector<int64_t>>>&
+        transactions) {
   for (const auto& map_entry : observation_index_map) {
     auto it = m_observers.find(map_entry.first);
     if (it != m_observers.end()) {
       IDBObserver* observer = it->value;
+
+      IDBTransaction* transaction = nullptr;
+      auto it = transactions.find(map_entry.first);
+      if (it != transactions.end()) {
+        const std::pair<int64_t, std::vector<int64_t>>& obs_txn = it->second;
+        HashSet<String> stores;
+        for (int64_t store_id : obs_txn.second) {
+          stores.add(m_metadata.objectStores.get(store_id)->name);
+        }
+
+        transaction = IDBTransaction::createObserver(
+            getExecutionContext(), obs_txn.first, stores, this);
+      }
+
       observer->callback()->call(
-          observer,
-          IDBObserverChanges::create(this, observations, map_entry.second));
+          observer, IDBObserverChanges::create(this, transaction, observations,
+                                               map_entry.second));
+      if (transaction)
+        transaction->setActive(false);
     }
   }
 }
 
 DOMStringList* IDBDatabase::objectStoreNames() const {
   DOMStringList* objectStoreNames =
       DOMStringList::create(DOMStringList::IndexedDB);
   for (const auto& it : m_metadata.objectStores)
     objectStoreNames->append(it.value->name);
   objectStoreNames->sort();
@@ skipping 381 matching lines @@
 
 void IDBDatabase::recordApiCallsHistogram(IndexedDatabaseMethods method) {
   DEFINE_THREAD_SAFE_STATIC_LOCAL(
       EnumerationHistogram, apiCallsHistogram,
       new EnumerationHistogram("WebCore.IndexedDB.FrontEndAPICalls",
                                IDBMethodsMax));
   apiCallsHistogram.count(method);
 }
 
 }  // namespace blink