Source/WebKit2/WebProcess/KeyValueStorage/WebKeyValueStorageManager.cpp

   1 /*
   2  * Copyright (C) 2011 Apple Inc. All rights reserved.
   3  *
   4  * Redistribution and use in source and binary forms, with or without
   5  * modification, are permitted provided that the following conditions
   6  * are met:
   7  * 1. Redistributions of source code must retain the above copyright
   8  *    notice, this list of conditions and the following disclaimer.
   9  * 2. Redistributions in binary form must reproduce the above copyright
  10  *    notice, this list of conditions and the following disclaimer in the
  11  *    documentation and/or other materials provided with the distribution.
  12  *
  13  * THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS''
  14  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
  15  * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
  16  * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS
  17  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
  18  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
  19  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  20  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
  21  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  22  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
  23  * THE POSSIBILITY OF SUCH DAMAGE.
  24  */
  25
  26 #include "config.h"
  27 #include "WebKeyValueStorageManager.h"
  28
  29 #include "MessageID.h"
  30 #include "SecurityOriginData.h"
  31 #include "WebKeyValueStorageManagerProxyMessages.h"
  32 #include "WebProcess.h"
  33
  34 #include <WebCore/SecurityOrigin.h>
  35 #include <WebCore/SecurityOriginHash.h>
  36 #include <WebCore/StorageTracker.h>
  37
  38 using namespace WebCore;
  39
  40 namespace WebKit {
  41
  42 WebKeyValueStorageManager& WebKeyValueStorageManager::shared()
  43 {
  44     static WebKeyValueStorageManager& shared = *new WebKeyValueStorageManager;
  45     return shared;
  46 }
  47
  48 WebKeyValueStorageManager::WebKeyValueStorageManager()
  49 {
  50 }
  51
  52 void WebKeyValueStorageManager::didReceiveMessage(CoreIPC::Connection* connection, CoreIPC::MessageID messageID, CoreIPC::ArgumentDecoder* arguments)
  53 {
  54     didReceiveWebKeyValueStorageManagerMessage(connection, messageID, arguments);
  55 }
  56
  57 #if ENABLE(TIZEN_WEB_STORAGE)
  58 void WebKeyValueStorageManager::didReceiveSyncMessage(CoreIPC::Connection* connection, CoreIPC::MessageID messageID, CoreIPC::ArgumentDecoder* arguments, OwnPtr<CoreIPC::ArgumentEncoder>& reply)
  59 {
  60     didReceiveSyncWebKeyValueStorageManagerMessage(connection, messageID, arguments, reply);
  61 }
  62 #endif
  63
  64 static void keyValueStorageOriginIdentifiers(Vector<SecurityOriginData>& identifiers)
  65 {
  66     ASSERT(identifiers.isEmpty());
  67
  68     Vector<RefPtr<SecurityOrigin> > coreOrigins;
  69
  70     StorageTracker::tracker().origins(coreOrigins);
  71
  72     size_t size = coreOrigins.size();
  73     identifiers.reserveCapacity(size);
  74
  75     for (size_t i = 0; i < size; ++i) {
  76         SecurityOriginData originData;
  77
  78         originData.protocol = coreOrigins[i]->protocol();
  79         originData.host = coreOrigins[i]->host();
  80         originData.port = coreOrigins[i]->port();
  81
  82         identifiers.uncheckedAppend(originData);
  83     }
  84 }
  85
  86 static void dispatchDidGetKeyValueStorageOrigins(const Vector<SecurityOriginData>& identifiers, uint64_t callbackID)
  87 {
  88     WebProcess::shared().connection()->send(Messages::WebKeyValueStorageManagerProxy::DidGetKeyValueStorageOrigins(identifiers, callbackID), 0);
  89 }
  90
  91 void WebKeyValueStorageManager::getKeyValueStorageOrigins(uint64_t callbackID)
  92 {
  93     WebProcess::LocalTerminationDisabler terminationDisabler(WebProcess::shared());
  94
  95     if (!StorageTracker::tracker().originsLoaded()) {
  96         m_originsRequestCallbackIDs.append(callbackID);
  97         return;
  98     }
  99
 100     Vector<SecurityOriginData> identifiers;
 101     keyValueStorageOriginIdentifiers(identifiers);
 102     dispatchDidGetKeyValueStorageOrigins(identifiers, callbackID);
 103 }
 104
 105 void WebKeyValueStorageManager::didFinishLoadingOrigins()
 106 {
 107     if (m_originsRequestCallbackIDs.isEmpty())
 108         return;
 109
 110     Vector<SecurityOriginData> identifiers;
 111     keyValueStorageOriginIdentifiers(identifiers);
 112
 113     for (size_t i = 0; i < m_originsRequestCallbackIDs.size(); ++i)
 114         dispatchDidGetKeyValueStorageOrigins(identifiers, m_originsRequestCallbackIDs[i]);
 115
 116     m_originsRequestCallbackIDs.clear();
 117 }
 118
 119 void WebKeyValueStorageManager::dispatchDidModifyOrigin(const String&)
 120 {
 121 }
 122
 123 void WebKeyValueStorageManager::deleteEntriesForOrigin(const SecurityOriginData& originData)
 124 {
 125     WebProcess::LocalTerminationDisabler terminationDisabler(WebProcess::shared());
 126
 127     RefPtr<SecurityOrigin> origin = SecurityOrigin::create(originData.protocol, originData.host, originData.port);
 128     if (!origin)
 129         return;
 130
 131     StorageTracker::tracker().deleteOrigin(origin.get());
 132 }
 133
 134 void WebKeyValueStorageManager::deleteAllEntries()
 135 {
 136     WebProcess::LocalTerminationDisabler terminationDisabler(WebProcess::shared());
 137     StorageTracker::tracker().deleteAllOrigins();
 138 }
 139
 140 #if ENABLE(TIZEN_WEB_STORAGE)
 141 void WebKeyValueStorageManager::getKeyValueStoragePath(uint64_t callbackID)
 142 {
 143     WebProcess::LocalTerminationDisabler terminationDisabler(WebProcess::shared());
 144     WebProcess::shared().connection()->send(Messages::WebKeyValueStorageManagerProxy::DidGetKeyValueStoragePath(StorageTracker::tracker().databaseDirectoryPath(), callbackID), 0);
 145 }
 146
 147 void WebKeyValueStorageManager::getKeyValueStorageUsageForOrigin(uint64_t callbackID, const SecurityOriginData& originData)
 148 {
 149     WebProcess::LocalTerminationDisabler terminationDisabler(WebProcess::shared());
 150
 151     RefPtr<SecurityOrigin> origin = SecurityOrigin::create(originData.protocol, originData.host, originData.port);
 152     if (!origin)
 153         return;
 154 #if ENABLE(TIZEN_WEBKIT2_NUMBER_TYPE_SUPPORT)
 155     WebProcess::shared().connection()->send(Messages::WebKeyValueStorageManagerProxy::DidGetKeyValueStorageUsageForOrigin(StorageTracker::tracker().diskUsageForOrigin(origin.get()), callbackID), 0);
 156 #endif
 157 }
 158
 159 void WebKeyValueStorageManager::syncLocalStorage()
 160 {
 161     StorageTracker::tracker().syncLocalStorage();
 162 }
 163 #endif
 164
 165 } // namespace WebKit