Replacing Indexed DB Chromium IPC with Mojo

content/browser/indexed_db/indexed_db_pending_connection.h

 // Copyright 2014 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.
 
 #ifndef CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_PENDING_CONNECTION_H_
 #define CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_PENDING_CONNECTION_H_
 
 #include <stdint.h>
 
 #include "base/memory/ref_counted.h"
-#include "content/browser/indexed_db/indexed_db_callbacks.h"
 #include "content/browser/indexed_db/indexed_db_database_callbacks.h"
 #include "content/common/content_export.h"
+#include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBTypes.h"
 
 namespace content {
 
 class IndexedDBCallbacks;
+class IndexedDBConnection;
 class IndexedDBDatabaseCallbacks;
+struct IndexedDBDatabaseMetadata;
+class IndexedDBOpenRequestObserver;
 
-struct CONTENT_EXPORT IndexedDBPendingConnection {
+typedef base::Callback<void(std::unique_ptr<IndexedDBConnection> connection,
+                            const content::IndexedDBDatabaseMetadata& metadata,
+                            const content::IndexedDBDatabaseError&)>
+    OpenResultCallback;
+
+class CONTENT_EXPORT IndexedDBPendingConnection {
+ public:
   IndexedDBPendingConnection(
-      scoped_refptr<IndexedDBCallbacks> callbacks_in,
-      scoped_refptr<IndexedDBDatabaseCallbacks> database_callbacks_in,
-      int child_process_id_in,
-      int64_t transaction_id_in,
-      int64_t version_in);
+      const OpenResultCallback& open_callback,
+      scoped_refptr<IndexedDBDatabaseCallbacks> database_callbacks,
+      scoped_refptr<IndexedDBOpenRequestObserver> open_observer,
+      int child_process_id,
+      int64_t transaction_id,
+      int64_t version);
   IndexedDBPendingConnection(const IndexedDBPendingConnection& other);
   ~IndexedDBPendingConnection();
-  scoped_refptr<IndexedDBCallbacks> callbacks;
-  scoped_refptr<IndexedDBDatabaseCallbacks> database_callbacks;
-  int child_process_id;
-  int64_t transaction_id;
-  int64_t version;
+  void OnError(const IndexedDBDatabaseError& error) const;
+  void OnDataLoss(blink::WebIDBDataLoss data_loss,
+                  std::string data_loss_message) const;
+  void OnSuccess(std::unique_ptr<IndexedDBConnection> connection,
+                 const IndexedDBDatabaseMetadata& metadata) const;
+  void OnBlocked(int64_t old_version);
+  blink::WebIDBDataLoss data_loss() const;
+  int child_process_id() const { return child_process_id_; }
+  int64_t transaction_id() const { return transaction_id_; }
+  int64_t version() const { return version_; }
+  void SetVersion(int64_t version) { version_ = version; }
+  const scoped_refptr<IndexedDBDatabaseCallbacks>& database_callbacks() const {
+    return database_callbacks_;
+  }
+  const scoped_refptr<IndexedDBOpenRequestObserver>& open_observer() const {
+    return open_observer_;
+  }
+
+ private:
+  OpenResultCallback open_callback_;
+  scoped_refptr<IndexedDBDatabaseCallbacks> database_callbacks_;
+  scoped_refptr<IndexedDBOpenRequestObserver> open_observer_;
+  int child_process_id_;
+  int64_t transaction_id_;
+  int64_t version_;
 };
 
 }  // namespace content
 
 #endif  // CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_PENDING_CONNECTION_H_