Implementation of IDBFactory::getDatabaseNames

content/browser/in_process_webkit/indexed_db_dispatcher_host.cc

 // 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/browser/in_process_webkit/indexed_db_dispatcher_host.h"
 
 #include "base/command_line.h"
 #include "base/utf_string_conversions.h"
 #include "content/browser/browser_thread.h"
 #include "content/browser/in_process_webkit/indexed_db_callbacks.h"
@@ skipping 107 matching lines @@
       database_dispatcher_host_->OnMessageReceived(message, message_was_ok) ||
       index_dispatcher_host_->OnMessageReceived(message, message_was_ok) ||
       object_store_dispatcher_host_->OnMessageReceived(
           message, message_was_ok) ||
       cursor_dispatcher_host_->OnMessageReceived(message, message_was_ok) ||
       transaction_dispatcher_host_->OnMessageReceived(message, message_was_ok);
 
   if (!handled) {
     handled = true;
     IPC_BEGIN_MESSAGE_MAP_EX(IndexedDBDispatcherHost, message, *message_was_ok)
+      IPC_MESSAGE_HANDLER(IndexedDBHostMsg_FactoryDatabaseNames,
+                          OnIDBFactoryDatabaseNames)
       IPC_MESSAGE_HANDLER(IndexedDBHostMsg_FactoryOpen, OnIDBFactoryOpen)
       IPC_MESSAGE_HANDLER(IndexedDBHostMsg_FactoryDeleteDatabase,
                           OnIDBFactoryDeleteDatabase)
       IPC_MESSAGE_UNHANDLED(handled = false)
     IPC_END_MESSAGE_MAP()
   }
 
   return handled;
 }
 
@@ skipping 42 matching lines @@
   if (!transaction_dispatcher_host_.get()) {
     delete idb_transaction;
     return 0;
   }
   int32 id = transaction_dispatcher_host_->map_.Add(idb_transaction);
   idb_transaction->setCallbacks(new IndexedDBTransactionCallbacks(this, id));
   transaction_dispatcher_host_->transaction_url_map_[id] = url;
   return id;
 }
 
+void IndexedDBDispatcherHost::OnIDBFactoryDatabaseNames(
+    const IndexedDBHostMsg_FactoryDatabaseNames_Params& params,
+    std::vector<string16>* database_names) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT));
+
+  FilePath base_path = webkit_context_->data_path();
+  FilePath indexed_db_path;
+  if (!base_path.empty()) {
+    indexed_db_path = base_path.Append(
+        IndexedDBContext::kIndexedDBDirectory);
+  }
+
+  // TODO(jorlow): This doesn't support file:/// urls properly. We probably need
+  //               to add some toString method to WebSecurityOrigin that doesn't
+  //               return null for them.  Look at
+  //               DatabaseUtil::GetOriginFromIdentifier.
+  WebSecurityOrigin origin(
+      WebSecurityOrigin::createFromDatabaseIdentifier(params.origin));
+  GURL origin_url(origin.toString());
+
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT));
+
+  WebKit::WebIDBFactory::BackingStoreType backingStoreType =
+      WebKit::WebIDBFactory::LevelDBBackingStore;
+
+  if (CommandLine::ForCurrentProcess()->HasSwitch(
+      switches::kSQLiteIndexedDatabase)) {
+    backingStoreType = WebKit::WebIDBFactory::SQLiteBackingStore;
+  }
+
+  // TODO(dgrogan): Delete this magic constant once we've removed sqlite.
+  static const uint64 kIncognitoSqliteBackendQuota = 50 * 1024 * 1024;

[dgrogan, 2011/09/14 01:25:20]

Get rid of this quota stuff, as elsewhere.

+
+  // TODO(dgrogan): Don't let a non-existing database be opened (and therefore

[dgrogan, 2011/09/14 01:25:20]

And this comment.

+  // created) if this origin is already over quota.
+  WebDOMStringList web_db_names = Context()->GetIDBFactory()->databaseNames(
+      origin, NULL, webkit_glue::FilePathToWebString(indexed_db_path),
+      kIncognitoSqliteBackendQuota, backingStoreType);
+
+  database_names->reserve(web_db_names.length());
+  for (unsigned i = 0; i < web_db_names.length(); ++i)
+    database_names->push_back(web_db_names.item(i));
+}
+
 void IndexedDBDispatcherHost::OnIDBFactoryOpen(
     const IndexedDBHostMsg_FactoryOpen_Params& params) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT));
   FilePath base_path = webkit_context_->data_path();
   FilePath indexed_db_path;
   if (!base_path.empty()) {
     indexed_db_path = base_path.Append(
         IndexedDBContext::kIndexedDBDirectory);
   }
 
@@ skipping 853 matching lines @@
   }
   idb_transaction->didCompleteTaskEvents();
 }
 
 void IndexedDBDispatcherHost::TransactionDispatcherHost::OnDestroyed(
     int32 object_id) {
   transaction_size_map_.erase(object_id);
   transaction_url_map_.erase(object_id);
   parent_->DestroyObject(&map_, object_id);
 }