Send IndexedDB observations through IDBDatabaseCallbacks.

content/common/indexed_db/indexed_db.mojom

 // 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.
 
 // TODO: This will move to //third_party/WebKit when //content/child/indexed_db
 // is deleted but for now this will depend on //content/common types and so
 // so belongs here.
 
 module indexed_db.mojom;
 
@@ skipping 46 matching lines @@
   KeyPathData? data;
 };
 
 struct KeyRange {
   Key lower;
   Key upper;
   bool lower_open;
   bool upper_open;
 };
 
+enum OperationType {
+  Add,
+  Put,
+  Delete,
+  Clear,
+};
+
 enum PutMode {
   AddOrUpdate,
   AddOnly,
   CursorUpdate,
 };
 
 enum TaskType {
   Normal,
   Preemptive,
 };
@@ skipping 51 matching lines @@
   string bits;
   array<BlobInfo> blob_or_file_info;
 };
 
 struct ReturnValue {
   Value value;
   Key primary_key;
   KeyPath key_path;
 };
 
+struct Observation {
+  int64 object_store_id;
+  OperationType type;
+  KeyRange key_range;
+};
+
+struct ObserverChanges {
+  map<int32, array<int32>> observation_index_map;

[jsbell, 2016/11/21 19:45:22]

Can we document what this is a map from/to?

IIRC this maps observer id to the associated observations (below) by index.

+  array<Observation> observations;
+};
+
 // The Callbacks interface is used to return results for individual requests.
 // Some requests may return multiple results before completion, such as
 // UpgradeNeeded before SuccessDatabase.
 //
 // TODO(https://crbug.com/627484): Many of these could be replaced with
 // replies associated with particular messages.
 interface Callbacks {
   Error(int32 code, mojo.common.mojom.String16 message);
 
   // Factory::GetDatabaseNames
@@ skipping 41 matching lines @@
 
 // The DatabaseCallbacks interface is used to notification of events out of
 // band to individual requests. A single instance is used for the lifetime of
 // a database connection.
 interface DatabaseCallbacks {
   ForcedClose();
   VersionChange(int64 old_version, int64 new_version);
   Abort(int64 transaction_id, int32 code,
         mojo.common.mojom.String16 message);
   Complete(int64 transaction_id);
+  Changes(ObserverChanges changes);
 };
 
 interface Cursor {
   Advance(uint32 count, associated Callbacks callbacks);
   Continue(Key key, Key primary_key, associated Callbacks callbacks);
   Prefetch(int32 count, associated Callbacks callbacks);
   PrefetchReset(int32 used_prefetches, int32 unused_prefetches,
                 array<string> unused_blob_uuids);
 };
 
@@ skipping 81 matching lines @@
               int64 object_store_id,
               int64 index_id,
               mojo.common.mojom.String16 new_name);
   Abort(int64 transaction_id);
   Commit(int64 transaction_id);
   AckReceivedBlobs(array<string> uuids);
 };
 
 interface Factory {
   GetDatabaseNames(associated Callbacks callbacks, url.mojom.Origin origin);
-  Open(int32 worker_thread, associated Callbacks callbacks,
+  Open(associated Callbacks callbacks,
        associated DatabaseCallbacks database_callbacks, url.mojom.Origin origin,
        mojo.common.mojom.String16 name, int64 version, int64 transaction_id);
   DeleteDatabase(associated Callbacks callbacks, url.mojom.Origin origin,
                  mojo.common.mojom.String16 name);
 };