[IndexedDB] Propogating changes to observers : Renderer

content/common/indexed_db/indexed_db_messages.h

 // Copyright (c) 2012 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.
 
 // Message definition file, included multiple times, hence no include guard.
 
 #include <stdint.h>
 
 #include <string>
 #include <utility>
 #include <vector>
 
+#include "base/memory/ptr_util.h"
 #include "content/common/indexed_db/indexed_db_key.h"
 #include "content/common/indexed_db/indexed_db_key_path.h"
 #include "content/common/indexed_db/indexed_db_key_range.h"
+#include "content/common/indexed_db/indexed_db_observation.h"
 #include "content/common/indexed_db/indexed_db_param_traits.h"
 #include "ipc/ipc_message_macros.h"
+#include "ipc/ipc_message_utils.h"
 #include "ipc/ipc_param_traits.h"
 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBTypes.h"
 #include "url/origin.h"
 
 // Singly-included section for typedefs in multiply-included file.
 #ifndef CONTENT_COMMON_INDEXED_DB_INDEXED_DB_MESSAGES_H_
 #define CONTENT_COMMON_INDEXED_DB_INDEXED_DB_MESSAGES_H_
 
 // An index id, and corresponding set of keys to insert.
 typedef std::pair<int64_t, std::vector<content::IndexedDBKey>> IndexKeys;
 
 #endif  // CONTENT_COMMON_INDEXED_DB_INDEXED_DB_MESSAGES_H_
 
 #undef IPC_MESSAGE_EXPORT
 #define IPC_MESSAGE_EXPORT CONTENT_EXPORT
 #define IPC_MESSAGE_START IndexedDBMsgStart
 
 // Argument structures used in messages
 
 IPC_ENUM_TRAITS_MAX_VALUE(blink::WebIDBCursorDirection,
                           blink::WebIDBCursorDirectionLast)
 IPC_ENUM_TRAITS_MAX_VALUE(blink::WebIDBPutMode, blink::WebIDBPutModeLast)
 IPC_ENUM_TRAITS_MAX_VALUE(blink::WebIDBTaskType, blink::WebIDBTaskTypeLast)
 IPC_ENUM_TRAITS_MAX_VALUE(blink::WebIDBTransactionMode,
                           blink::WebIDBTransactionModeLast)
 
 IPC_ENUM_TRAITS_MAX_VALUE(blink::WebIDBDataLoss, blink::WebIDBDataLossTotal)
+IPC_ENUM_TRAITS_MAX_VALUE(content::IndexedDBObservation::OperationType,
+                          content::IndexedDBObservation::CLEAR)
 
 // Used to enumerate indexed databases.
 IPC_STRUCT_BEGIN(IndexedDBHostMsg_FactoryGetDatabaseNames_Params)
   // The response should have these ids.
   IPC_STRUCT_MEMBER(int32_t, ipc_thread_id)
   IPC_STRUCT_MEMBER(int32_t, ipc_callbacks_id)
   // The origin doing the initiating.
   IPC_STRUCT_MEMBER(url::Origin, origin)
 IPC_STRUCT_END()
 
@@ skipping 296 matching lines @@
   IPC_STRUCT_MEMBER(int32_t, ipc_thread_id)
   IPC_STRUCT_MEMBER(int32_t, ipc_callbacks_id)
   IPC_STRUCT_MEMBER(int32_t, ipc_database_callbacks_id)
   IPC_STRUCT_MEMBER(int32_t, ipc_database_id)
   IPC_STRUCT_MEMBER(int64_t, old_version)
   IPC_STRUCT_MEMBER(blink::WebIDBDataLoss, data_loss)
   IPC_STRUCT_MEMBER(std::string, data_loss_message)
   IPC_STRUCT_MEMBER(IndexedDBDatabaseMetadata, idb_metadata)
 IPC_STRUCT_END()
 
+IPC_STRUCT_BEGIN(IndexedDBObservation)
+  IPC_STRUCT_MEMBER(content::IndexedDBObservation::OperationType, type)
+  IPC_STRUCT_MEMBER(content::IndexedDBKeyRange, key_range)
+IPC_STRUCT_END()
+
+// IPC_MESSAGE macros fail on the std::map, when expanding. We need to define
+// a type to avoid that.
+// map observer_id to corresponding set of indices in observations.
+using ObservationMap = std::map<int32_t, std::vector<int32_t>>;
+
+IPC_STRUCT_BEGIN(IndexedDBObserverChanges)
+  IPC_STRUCT_MEMBER(ObservationMap, observation_index)
+  IPC_STRUCT_MEMBER(std::vector<IndexedDBObservation>, observations)
+IPC_STRUCT_END()
+
 // Indexed DB messages sent from the browser to the renderer.
 
 // The thread_id needs to be the first parameter in these messages.  In the IO
 // thread on the renderer/client process, an IDB message filter assumes the
 // thread_id is the first int.
 
 // IDBCallback message handlers.
 IPC_MESSAGE_CONTROL1(IndexedDBMsg_CallbacksSuccessIDBCursor,
                      IndexedDBMsg_CallbacksSuccessIDBCursor_Params)
 
@@ skipping 61 matching lines @@
 IPC_MESSAGE_CONTROL5(IndexedDBMsg_DatabaseCallbacksAbort,
                      int32_t,        /* ipc_thread_id */
                      int32_t,        /* ipc_database_callbacks_id */
                      int64_t,        /* transaction_id */
                      int,            /* code */
                      base::string16) /* message */
 IPC_MESSAGE_CONTROL3(IndexedDBMsg_DatabaseCallbacksComplete,
                      int32_t, /* ipc_thread_id */
                      int32_t, /* ipc_database_callbacks_id */
                      int64_t) /* transaction_id */
-
-// Indexed DB messages sent from the renderer to the browser.
+IPC_MESSAGE_CONTROL3(IndexedDBMsg_DatabaseCallbacksChanges,
+                     int32_t, /* ipc_thread_id */
+                     int32_t, /* ipc_database_callbacks_id */
+                     IndexedDBObserverChanges)
 
 // WebIDBCursor::advance() message.
 IPC_MESSAGE_CONTROL4(IndexedDBHostMsg_CursorAdvance,
                      int32_t,  /* ipc_cursor_id */
                      int32_t,  /* ipc_thread_id */
                      int32_t,  /* ipc_callbacks_id */
                      uint32_t) /* count */
 
 // WebIDBCursor::continue() message.
 IPC_MESSAGE_CONTROL5(IndexedDBHostMsg_CursorContinue,
@@ skipping 128 matching lines @@
                      int64_t) /* transaction_id */
 
 // WebIDBDatabase::commit() message.
 IPC_MESSAGE_CONTROL2(IndexedDBHostMsg_DatabaseCommit,
                      int32_t, /* ipc_database_id */
                      int64_t) /* transaction_id */
 
 // WebIDBDatabase::~WebIDBCursor() message.
 IPC_MESSAGE_CONTROL1(IndexedDBHostMsg_CursorDestroyed,
                      int32_t /* ipc_cursor_id */)