Port IndexedDB open() and database callbacks to Mojo.

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

 /*
  * Copyright (C) 2013 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:
  *
  *     * Redistributions of source code must retain the above copyright
  * notice, this list of conditions and the following disclaimer.
  *     * Redistributions in binary form must reproduce the above
@@ skipping 17 matching lines @@
  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  */
 
 #include "modules/indexeddb/IDBTransaction.h"
 
 #include "bindings/core/v8/V8BindingForTesting.h"
 #include "core/dom/DOMException.h"
 #include "core/dom/Document.h"
 #include "core/dom/ExceptionCode.h"
 #include "modules/indexeddb/IDBDatabase.h"
-#include "modules/indexeddb/IDBDatabaseCallbacks.h"
 #include "modules/indexeddb/MockWebIDBDatabase.h"
 #include "platform/SharedBuffer.h"
 #include "testing/gtest/include/gtest/gtest.h"
 #include <memory>
 #include <v8.h>
 
 namespace blink {
 namespace {
 
 void deactivateNewTransactions(v8::Isolate* isolate)
 {
     V8PerIsolateData::from(isolate)->runEndOfScopeTasks();
 }
 
-class FakeIDBDatabaseCallbacks final : public IDBDatabaseCallbacks {
-public:
-    static FakeIDBDatabaseCallbacks* create() { return new FakeIDBDatabaseCallbacks(); }
-    void onVersionChange(int64_t oldVersion, int64_t newVersion) override { }
-    void onForcedClose() override { }
-    void onAbort(int64_t transactionId, DOMException* error) override { }
-    void onComplete(int64_t transactionId) override { }
-private:
-    FakeIDBDatabaseCallbacks() { }
-};
-
 TEST(IDBTransactionTest, EnsureLifetime)
 {
     V8TestingScope scope;
     std::unique_ptr<MockWebIDBDatabase> backend = MockWebIDBDatabase::create();
     EXPECT_CALL(*backend, close())
         .Times(1);
-    Persistent<IDBDatabase> db = IDBDatabase::create(scope.getExecutionContext(), std::move(backend), FakeIDBDatabaseCallbacks::create());
+    Persistent<IDBDatabase> db = IDBDatabase::create(scope.getExecutionContext(), std::move(backend), nullptr);
 
     const int64_t transactionId = 1234;
     const HashSet<String> transactionScope = HashSet<String>();
     Persistent<IDBTransaction> transaction = IDBTransaction::create(scope.getScriptState(), transactionId, transactionScope, WebIDBTransactionModeReadOnly, db.get());
     PersistentHeapHashSet<WeakMember<IDBTransaction>> set;
     set.add(transaction);
 
     ThreadState::current()-> collectAllGarbage();
     EXPECT_EQ(1u, set.size());
 
@@ skipping 16 matching lines @@
 TEST(IDBTransactionTest, TransactionFinish)
 {
     V8TestingScope scope;
     const int64_t transactionId = 1234;
 
     std::unique_ptr<MockWebIDBDatabase> backend = MockWebIDBDatabase::create();
     EXPECT_CALL(*backend, commit(transactionId))
         .Times(1);
     EXPECT_CALL(*backend, close())
         .Times(1);
-    Persistent<IDBDatabase> db = IDBDatabase::create(scope.getExecutionContext(), std::move(backend), FakeIDBDatabaseCallbacks::create());
+    Persistent<IDBDatabase> db = IDBDatabase::create(scope.getExecutionContext(), std::move(backend), nullptr);
 
     const HashSet<String> transactionScope = HashSet<String>();
     Persistent<IDBTransaction> transaction = IDBTransaction::create(scope.getScriptState(), transactionId, transactionScope, WebIDBTransactionModeReadOnly, db.get());
     PersistentHeapHashSet<WeakMember<IDBTransaction>> set;
     set.add(transaction);
 
     ThreadState::current()-> collectAllGarbage();
     EXPECT_EQ(1u, set.size());
 
     deactivateNewTransactions(scope.isolate());
 
     ThreadState::current()-> collectAllGarbage();
     EXPECT_EQ(1u, set.size());
 
     transaction.clear();
 
     ThreadState::current()-> collectAllGarbage();
     EXPECT_EQ(1u, set.size());
 
     // Stop the context, so events don't get queued (which would keep the transaction alive).
     scope.getExecutionContext()->stopActiveDOMObjects();
 
     // Fire an abort to make sure this doesn't free the transaction during use. The test
     // will not fail if it is, but ASAN would notice the error.
-    db->onAbort(transactionId, DOMException::create(AbortError, "Aborted"));
+    auto errorInfo = indexed_db::mojom::blink::ErrorInfo::New();
+    errorInfo->code = AbortError;
+    errorInfo->message = "Aborted";
+    db->OnTransactionAborted(transactionId, std::move(errorInfo));
 
     // onAbort() should have cleared the transaction's reference to the database.
     ThreadState::current()-> collectAllGarbage();
     EXPECT_EQ(0u, set.size());
 }
 
 } // namespace
 } // namespace blink