Replacing Indexed DB Chromium IPC with Mojo

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

 /*
  * Copyright (C) 2010 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:
  *
  * 1.  Redistributions of source code must retain the above copyright
  *     notice, this list of conditions and the following disclaimer.
  * 2.  Redistributions in binary form must reproduce the above copyright
@@ skipping 16 matching lines @@
 
 #include "bindings/core/v8/ExceptionState.h"
 #include "bindings/core/v8/ExceptionStatePlaceholder.h"
 #include "bindings/core/v8/V8PerIsolateData.h"
 #include "core/dom/DOMException.h"
 #include "core/dom/ExceptionCode.h"
 #include "core/dom/ExecutionContext.h"
 #include "core/events/EventQueue.h"
 #include "modules/IndexedDBNames.h"
 #include "modules/indexeddb/IDBDatabase.h"
+#include "modules/indexeddb/IDBDatabaseProxy.h"
 #include "modules/indexeddb/IDBEventDispatcher.h"
 #include "modules/indexeddb/IDBIndex.h"
 #include "modules/indexeddb/IDBObjectStore.h"
 #include "modules/indexeddb/IDBOpenDBRequest.h"
 #include "modules/indexeddb/IDBTracing.h"
 #include "wtf/PtrUtil.h"
 #include <memory>
 
-using blink::WebIDBDatabase;
+using indexed_db::mojom::blink::TransactionMode;
 
 namespace blink {
 
-IDBTransaction* IDBTransaction::create(ScriptState* scriptState, int64_t id, const HashSet<String>& objectStoreNames, WebIDBTransactionMode mode, IDBDatabase* db)
+IDBTransaction* IDBTransaction::create(ScriptState* scriptState, int64_t id, const HashSet<String>& objectStoreNames, TransactionMode mode, IDBDatabase* db)
 {
     IDBOpenDBRequest* openDBRequest = nullptr;
     IDBTransaction* transaction = new IDBTransaction(scriptState, id, objectStoreNames, mode, db, openDBRequest, IDBDatabaseMetadata());
     transaction->suspendIfNeeded();
     return transaction;
 }
 
 IDBTransaction* IDBTransaction::create(ScriptState* scriptState, int64_t id, IDBDatabase* db, IDBOpenDBRequest* openDBRequest, const IDBDatabaseMetadata& previousMetadata)
 {
-    IDBTransaction* transaction = new IDBTransaction(scriptState, id, HashSet<String>(), WebIDBTransactionModeVersionChange, db, openDBRequest, previousMetadata);
+    IDBTransaction* transaction = new IDBTransaction(scriptState, id, HashSet<String>(), TransactionMode::VersionChange, db, openDBRequest, previousMetadata);
     transaction->suspendIfNeeded();
     return transaction;
 }
 
 namespace {
 
 class DeactivateTransactionTask : public V8PerIsolateData::EndOfScopeTask {
 public:
     static std::unique_ptr<DeactivateTransactionTask> create(IDBTransaction* transaction)
     {
         return wrapUnique(new DeactivateTransactionTask(transaction));
     }
 
     void run() override
     {
         m_transaction->setActive(false);
         m_transaction.clear();
     }
 
 private:
     explicit DeactivateTransactionTask(IDBTransaction* transaction)
         : m_transaction(transaction) { }
 
     Persistent<IDBTransaction> m_transaction;
 };
 
 } // namespace
 
-IDBTransaction::IDBTransaction(ScriptState* scriptState, int64_t id, const HashSet<String>& objectStoreNames, WebIDBTransactionMode mode, IDBDatabase* db, IDBOpenDBRequest* openDBRequest, const IDBDatabaseMetadata& previousMetadata)
+IDBTransaction::IDBTransaction(ScriptState* scriptState, int64_t id, const HashSet<String>& objectStoreNames, TransactionMode mode, IDBDatabase* db, IDBOpenDBRequest* openDBRequest, const IDBDatabaseMetadata& previousMetadata)
     : ActiveScriptWrappable(this)
     , ActiveDOMObject(scriptState->getExecutionContext())
     , m_id(id)
     , m_database(db)
     , m_objectStoreNames(objectStoreNames)
     , m_openDBRequest(openDBRequest)
     , m_mode(mode)
     , m_previousMetadata(previousMetadata)
 {
-    if (mode == WebIDBTransactionModeVersionChange) {
+    if (mode == TransactionMode::VersionChange) {
         // Not active until the callback.
         m_state = Inactive;
     }
 
     if (m_state == Active)
         V8PerIsolateData::from(scriptState->isolate())->addEndOfScopeTask(DeactivateTransactionTask::create(this));
     m_database->transactionCreated(this);
 }
 
 IDBTransaction::~IDBTransaction()
@@ skipping 83 matching lines @@
 }
 
 void IDBTransaction::setActive(bool active)
 {
     DCHECK_NE(m_state, Finished) << "A finished transaction tried to setActive(" << (active ? "true" : "false") << ")";
     if (m_state == Finishing)
         return;
     ASSERT(active != (m_state == Active));
     m_state = active ? Active : Inactive;
 
-    if (!active && m_requestList.isEmpty() && backendDB())
-        backendDB()->commit(m_id);
+    if (!active && m_requestList.isEmpty() && backendDB()) {
+        backendDB()->Commit(m_id);
+    }
 }
 
 void IDBTransaction::abort(ExceptionState& exceptionState)
 {
     if (m_state == Finishing || m_state == Finished) {
         exceptionState.throwDOMException(InvalidStateError, IDBDatabase::transactionFinishedErrorMessage);
         return;
     }
 
     m_state = Finishing;
 
     if (m_contextStopped)
         return;
 
     for (IDBRequest* request : m_requestList)
         request->abort();
     m_requestList.clear();
 
     for (IDBObjectStore* store : m_createdObjectStores) {
         store->abort();
         store->markDeleted();
     }
 
     if (backendDB())
-        backendDB()->abort(m_id);
+        backendDB()->Abort(m_id);
 }
 
 void IDBTransaction::registerRequest(IDBRequest* request)
 {
     ASSERT(request);
     ASSERT(m_state == Active);
     m_requestList.add(request);
 }
 
 void IDBTransaction::unregisterRequest(IDBRequest* request)
@@ skipping 66 matching lines @@
 }
 
 bool IDBTransaction::hasPendingActivity() const
 {
     // FIXME: In an ideal world, we should return true as long as anyone has a or can
     //        get a handle to us or any child request object and any of those have
     //        event listeners. This is  in order to handle user generated events properly.
     return m_hasPendingActivity && !m_contextStopped;
 }
 
-WebIDBTransactionMode IDBTransaction::stringToMode(const String& modeString)
+TransactionMode IDBTransaction::stringToMode(const String& modeString)
 {
     if (modeString == IndexedDBNames::readonly)
-        return WebIDBTransactionModeReadOnly;
+        return TransactionMode::ReadOnly;
     if (modeString == IndexedDBNames::readwrite)
-        return WebIDBTransactionModeReadWrite;
+        return TransactionMode::ReadWrite;
     if (modeString == IndexedDBNames::versionchange)
-        return WebIDBTransactionModeVersionChange;
+        return TransactionMode::VersionChange;
     ASSERT_NOT_REACHED();
-    return WebIDBTransactionModeReadOnly;
+    return TransactionMode::ReadOnly;
 }
 
 const String& IDBTransaction::mode() const
 {
     switch (m_mode) {
-    case WebIDBTransactionModeReadOnly:
+    case TransactionMode::ReadOnly:
         return IndexedDBNames::readonly;
 
-    case WebIDBTransactionModeReadWrite:
+    case TransactionMode::ReadWrite:
         return IndexedDBNames::readwrite;
 
-    case WebIDBTransactionModeVersionChange:
+    case TransactionMode::VersionChange:
         return IndexedDBNames::versionchange;
     }
 
     ASSERT_NOT_REACHED();
     return IndexedDBNames::readonly;
 }
 
 DOMStringList* IDBTransaction::objectStoreNames() const
 {
-    if (m_mode == WebIDBTransactionModeVersionChange)
+    if (m_mode == TransactionMode::VersionChange)
         return m_database->objectStoreNames();
 
     DOMStringList* objectStoreNames = DOMStringList::create(DOMStringList::IndexedDB);
     for (const String& name : m_objectStoreNames)
         objectStoreNames->append(name);
     objectStoreNames->sort();
     return objectStoreNames;
 }
 
 const AtomicString& IDBTransaction::interfaceName() const
@@ skipping 60 matching lines @@
 {
     DCHECK_NE(m_state, Finished) << "A finished transaction tried to enqueue an event of type " << event->type() << ".";
     if (m_contextStopped || !getExecutionContext())
         return;
 
     EventQueue* eventQueue = getExecutionContext()->getEventQueue();
     event->setTarget(this);
     eventQueue->enqueueEvent(event);
 }
 
-WebIDBDatabase* IDBTransaction::backendDB() const
+IDBDatabaseProxy* IDBTransaction::backendDB() const
 {
     return m_database->backend();
 }
 
 } // namespace blink