Send IndexedDB observations through IDBDatabaseCallbacks.

content/child/indexed_db/indexed_db_database_callbacks_impl.cc

 // 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 "content/child/indexed_db/indexed_db_database_callbacks_impl.h"
 
 #include "content/child/indexed_db/indexed_db_dispatcher.h"
+#include "content/child/indexed_db/indexed_db_key_builders.h"
 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBDatabaseCallbacks.h"
 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBDatabaseError.h"
+#include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBObservation.h"
 
 using blink::WebIDBDatabaseCallbacks;
 
 namespace content {
 
 namespace {
 
 void DeleteDatabaseCallbacks(WebIDBDatabaseCallbacks* callbacks) {
   IndexedDBDispatcher::ThreadSpecificInstance()
       ->UnregisterMojoOwnedDatabaseCallbacks(callbacks);
   delete callbacks;
 }
 
 void BuildErrorAndAbort(WebIDBDatabaseCallbacks* callbacks,
                         int64_t transaction_id,
                         int32_t code,
                         const base::string16& message) {
   callbacks->onAbort(transaction_id, blink::WebIDBDatabaseError(code, message));
 }
 
+void BuildObservationsAndNotify(WebIDBDatabaseCallbacks* callbacks,
+                                indexed_db::mojom::ObserverChangesPtr changes) {
+  std::vector<blink::WebIDBObservation> web_observations;
+  for (const auto& observation : changes->observations) {
+    blink::WebIDBObservation web_observation;
+    web_observation.objectStoreId = observation->object_store_id;
+    web_observation.type = observation->type;
+    web_observation.keyRange =
+        WebIDBKeyRangeBuilder::Build(observation->key_range);
+    // TODO(palakj): Assign value to web_observation.
+    web_observations.push_back(std::move(web_observation));
+  }
+  callbacks->onChanges(changes->observation_index_map, web_observations);
+}
+
 }  // namespace
 
 IndexedDBDatabaseCallbacksImpl::IndexedDBDatabaseCallbacksImpl(
     std::unique_ptr<WebIDBDatabaseCallbacks> callbacks)
     : callback_runner_(base::ThreadTaskRunnerHandle::Get()),
       callbacks_(callbacks.release()) {
   IndexedDBDispatcher::ThreadSpecificInstance()
       ->RegisterMojoOwnedDatabaseCallbacks(callbacks_);
 }
 
@@ skipping 25 matching lines @@
       FROM_HERE, base::Bind(&BuildErrorAndAbort, base::Unretained(callbacks_),
                             transaction_id, code, message));
 }
 
 void IndexedDBDatabaseCallbacksImpl::Complete(int64_t transaction_id) {
   callback_runner_->PostTask(
       FROM_HERE, base::Bind(&WebIDBDatabaseCallbacks::onComplete,
                             base::Unretained(callbacks_), transaction_id));
 }
 
+void IndexedDBDatabaseCallbacksImpl::Changes(
+    indexed_db::mojom::ObserverChangesPtr changes) {
+  callback_runner_->PostTask(FROM_HERE, base::Bind(&BuildObservationsAndNotify,
+                                                   base::Unretained(callbacks_),
+                                                   base::Passed(&changes)));
+}
+
 }  // namespace content