1 files changed, 136 insertions, 0 deletions
diff --git a/content/renderer/indexed_db/renderer_webidbdatabase_impl.cc b/content/renderer/indexed_db/renderer_webidbdatabase_impl.cc
new file mode 100644
index 0000000..6a07cc0
--- /dev/null
+++ b/content/renderer/indexed_db/renderer_webidbdatabase_impl.cc
@@ -0,0 +1,136 @@
+// Copyright (c) 2011 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.
+
+#include "content/renderer/indexed_db/renderer_webidbdatabase_impl.h"
+
+#include "content/common/indexed_db/indexed_db_messages.h"
+#include "content/renderer/indexed_db/indexed_db_dispatcher.h"
+#include "content/renderer/indexed_db/renderer_webidbobjectstore_impl.h"
+#include "content/renderer/indexed_db/renderer_webidbtransaction_impl.h"
+#include "content/renderer/render_thread_impl.h"
+#include "third_party/WebKit/Source/WebKit/chromium/public/platform/WebString.h"
+#include "third_party/WebKit/Source/WebKit/chromium/public/platform/WebVector.h"
+#include "webkit/glue/worker_task_runner.h"
+
+using WebKit::WebDOMStringList;
+using WebKit::WebExceptionCode;
+using WebKit::WebFrame;
+using WebKit::WebIDBCallbacks;
+using WebKit::WebIDBDatabaseCallbacks;
+using WebKit::WebIDBTransaction;
+using WebKit::WebString;
+using WebKit::WebVector;
+using webkit_glue::WorkerTaskRunner;
+
+RendererWebIDBDatabaseImpl::RendererWebIDBDatabaseImpl(int32 idb_database_id)
+    : idb_database_id_(idb_database_id) {
+}
+
+RendererWebIDBDatabaseImpl::~RendererWebIDBDatabaseImpl() {
+  // It's not possible for there to be pending callbacks that address this
+  // object since inside WebKit, they hold a reference to the object which owns
+  // this object. But, if that ever changed, then we'd need to invalidate
+  // any such pointers.
+  ChildThread::current()->Send(new IndexedDBHostMsg_DatabaseDestroyed(
+      idb_database_id_));
+}
+
+WebString RendererWebIDBDatabaseImpl::name() const {
+  string16 result;
+  ChildThread::current()->Send(
+      new IndexedDBHostMsg_DatabaseName(idb_database_id_, &result));
+  return result;
+}
+
+WebString RendererWebIDBDatabaseImpl::version() const {
+  string16 result;
+  ChildThread::current()->Send(
+      new IndexedDBHostMsg_DatabaseVersion(idb_database_id_, &result));
+  return result;
+}
+
+WebDOMStringList RendererWebIDBDatabaseImpl::objectStoreNames() const {
+  std::vector<string16> result;
+  ChildThread::current()->Send(
+      new IndexedDBHostMsg_DatabaseObjectStoreNames(idb_database_id_, &result));
+  WebDOMStringList webResult;
+  for (std::vector<string16>::const_iterator it = result.begin();
+       it != result.end(); ++it) {
+    webResult.append(*it);
+  }
+  return webResult;
+}
+
+WebKit::WebIDBObjectStore* RendererWebIDBDatabaseImpl::createObjectStore(
+    const WebKit::WebString& name,
+    const WebKit::WebString& key_path,
+    bool auto_increment,
+    const WebKit::WebIDBTransaction& transaction,
+    WebExceptionCode& ec) {
+  IndexedDBHostMsg_DatabaseCreateObjectStore_Params params;
+  params.name = name;
+  params.key_path = key_path;
+  params.auto_increment = auto_increment;
+  params.transaction_id = IndexedDBDispatcher::TransactionId(transaction);
+  params.idb_database_id = idb_database_id_;
+
+  int object_store;
+  ChildThread::current()->Send(
+      new IndexedDBHostMsg_DatabaseCreateObjectStore(
+          params, &object_store, &ec));
+  if (!object_store)
+    return NULL;
+  return new RendererWebIDBObjectStoreImpl(object_store);
+}
+
+void RendererWebIDBDatabaseImpl::deleteObjectStore(
+    const WebString& name,
+    const WebIDBTransaction& transaction,
+    WebExceptionCode& ec) {
+  ChildThread::current()->Send(
+      new IndexedDBHostMsg_DatabaseDeleteObjectStore(
+          idb_database_id_, name,
+          IndexedDBDispatcher::TransactionId(transaction), &ec));
+}
+
+void RendererWebIDBDatabaseImpl::setVersion(
+    const WebString& version,
+    WebIDBCallbacks* callbacks,
+    WebExceptionCode& ec) {
+  IndexedDBDispatcher* dispatcher =
+      IndexedDBDispatcher::ThreadSpecificInstance();
+  dispatcher->RequestIDBDatabaseSetVersion(
+      version, callbacks, idb_database_id_, &ec);
+}
+
+WebKit::WebIDBTransaction* RendererWebIDBDatabaseImpl::transaction(
+    const WebDOMStringList& names,
+    unsigned short mode,
+    WebExceptionCode& ec) {
+  std::vector<string16> object_stores;
+  object_stores.reserve(names.length());
+  for (unsigned int i = 0; i < names.length(); ++i)
+    object_stores.push_back(names.item(i));
+
+  int transaction_id;
+  ChildThread::current()->Send(new IndexedDBHostMsg_DatabaseTransaction(
+      WorkerTaskRunner::Instance()->CurrentWorkerId(),
+      idb_database_id_, object_stores, mode, &transaction_id, &ec));
+  if (!transaction_id)
+    return NULL;
+  return new RendererWebIDBTransactionImpl(transaction_id);
+}
+
+void RendererWebIDBDatabaseImpl::close() {
+  IndexedDBDispatcher* dispatcher =
+      IndexedDBDispatcher::ThreadSpecificInstance();
+  dispatcher->RequestIDBDatabaseClose(idb_database_id_);
+}
+
+void RendererWebIDBDatabaseImpl::open(WebIDBDatabaseCallbacks* callbacks) {
+  IndexedDBDispatcher* dispatcher =
+      IndexedDBDispatcher::ThreadSpecificInstance();
+  DCHECK(dispatcher);
+  dispatcher->RequestIDBDatabaseOpen(callbacks, idb_database_id_);
+}