#include "config.h"
#include "IDBDatabase.h"
#if ENABLE(INDEXED_DATABASE)
#include "DOMStringList.h"
#include "EventQueue.h"
#include "ExceptionCode.h"
#include "HistogramSupport.h"
#include "IDBAny.h"
#include "IDBDatabaseCallbacks.h"
#include "IDBDatabaseError.h"
#include "IDBDatabaseException.h"
#include "IDBEventDispatcher.h"
#include "IDBHistograms.h"
#include "IDBIndex.h"
#include "IDBKeyPath.h"
#include "IDBObjectStore.h"
#include "IDBTracing.h"
#include "IDBTransaction.h"
#include "IDBVersionChangeEvent.h"
#include "ScriptCallStack.h"
#include "ScriptExecutionContext.h"
#include <limits>
#include <wtf/Atomics.h>
namespace WebCore {
PassRefPtr<IDBDatabase> IDBDatabase::create(ScriptExecutionContext* context, PassRefPtr<IDBDatabaseBackendInterface> database, PassRefPtr<IDBDatabaseCallbacks> callbacks)
{
RefPtr<IDBDatabase> idbDatabase(adoptRef(new IDBDatabase(context, database, callbacks)));
idbDatabase->suspendIfNeeded();
return idbDatabase.release();
}
IDBDatabase::IDBDatabase(ScriptExecutionContext* context, PassRefPtr<IDBDatabaseBackendInterface> backend, PassRefPtr<IDBDatabaseCallbacks> callbacks)
: ActiveDOMObject(context)
, m_backend(backend)
, m_closePending(false)
, m_contextStopped(false)
, m_databaseCallbacks(callbacks)
{
relaxAdoptionRequirement();
}
IDBDatabase::~IDBDatabase()
{
close();
}
int64_t IDBDatabase::nextTransactionId()
{
AtomicallyInitializedStatic(int, currentTransactionId = 0);
return atomicIncrement(¤tTransactionId);
}
void IDBDatabase::transactionCreated(IDBTransaction* transaction)
{
ASSERT(transaction);
ASSERT(!m_transactions.contains(transaction->id()));
m_transactions.add(transaction->id(), transaction);
if (transaction->isVersionChange()) {
ASSERT(!m_versionChangeTransaction);
m_versionChangeTransaction = transaction;
}
}
void IDBDatabase::transactionFinished(IDBTransaction* transaction)
{
ASSERT(transaction);
ASSERT(m_transactions.contains(transaction->id()));
ASSERT(m_transactions.get(transaction->id()) == transaction);
m_transactions.remove(transaction->id());
if (transaction->isVersionChange()) {
ASSERT(m_versionChangeTransaction == transaction);
m_versionChangeTransaction = 0;
}
if (m_closePending && m_transactions.isEmpty())
closeConnection();
}
void IDBDatabase::onAbort(int64_t transactionId, PassRefPtr<IDBDatabaseError> error)
{
ASSERT(m_transactions.contains(transactionId));
m_transactions.get(transactionId)->onAbort(error);
}
void IDBDatabase::onComplete(int64_t transactionId)
{
ASSERT(m_transactions.contains(transactionId));
m_transactions.get(transactionId)->onComplete();
}
PassRefPtr<DOMStringList> IDBDatabase::objectStoreNames() const
{
RefPtr<DOMStringList> objectStoreNames = DOMStringList::create();
for (IDBDatabaseMetadata::ObjectStoreMap::const_iterator it = m_metadata.objectStores.begin(); it != m_metadata.objectStores.end(); ++it)
objectStoreNames->append(it->value.name);
objectStoreNames->sort();
return objectStoreNames.release();
}
PassRefPtr<IDBAny> IDBDatabase::version() const
{
int64_t intVersion = m_metadata.intVersion;
if (intVersion == IDBDatabaseMetadata::NoIntVersion)
return IDBAny::createString(m_metadata.version);
return IDBAny::create(intVersion);
}
PassRefPtr<IDBObjectStore> IDBDatabase::createObjectStore(const String& name, const Dictionary& options, ExceptionCode& ec)
{
IDBKeyPath keyPath;
bool autoIncrement = false;
if (!options.isUndefinedOrNull()) {
String keyPathString;
Vector<String> keyPathArray;
if (options.get("keyPath", keyPathArray))
keyPath = IDBKeyPath(keyPathArray);
else if (options.getWithUndefinedOrNullCheck("keyPath", keyPathString))
keyPath = IDBKeyPath(keyPathString);
options.get("autoIncrement", autoIncrement);
}
return createObjectStore(name, keyPath, autoIncrement, ec);
}
PassRefPtr<IDBObjectStore> IDBDatabase::createObjectStore(const String& name, const IDBKeyPath& keyPath, bool autoIncrement, ExceptionCode& ec)
{
IDB_TRACE("IDBDatabase::createObjectStore");
HistogramSupport::histogramEnumeration("WebCore.IndexedDB.FrontEndAPICalls", IDBCreateObjectStoreCall, IDBMethodsMax);
if (!m_versionChangeTransaction) {
ec = IDBDatabaseException::InvalidStateError;
return 0;
}
if (!m_versionChangeTransaction->isActive()) {
ec = IDBDatabaseException::TransactionInactiveError;
return 0;
}
if (containsObjectStore(name)) {
ec = IDBDatabaseException::ConstraintError;
return 0;
}
if (!keyPath.isNull() && !keyPath.isValid()) {
ec = IDBDatabaseException::SyntaxError;
return 0;
}
if (autoIncrement && ((keyPath.type() == IDBKeyPath::StringType && keyPath.string().isEmpty()) || keyPath.type() == IDBKeyPath::ArrayType)) {
ec = IDBDatabaseException::InvalidAccessError;
return 0;
}
int64_t objectStoreId = m_metadata.maxObjectStoreId + 1;
m_backend->createObjectStore(m_versionChangeTransaction->id(), objectStoreId, name, keyPath, autoIncrement);
IDBObjectStoreMetadata metadata(name, objectStoreId, keyPath, autoIncrement, IDBDatabaseBackendInterface::MinimumIndexId);
RefPtr<IDBObjectStore> objectStore = IDBObjectStore::create(metadata, m_versionChangeTransaction.get());
m_metadata.objectStores.set(metadata.id, metadata);
++m_metadata.maxObjectStoreId;
m_versionChangeTransaction->objectStoreCreated(name, objectStore);
return objectStore.release();
}
void IDBDatabase::deleteObjectStore(const String& name, ExceptionCode& ec)
{
IDB_TRACE("IDBDatabase::deleteObjectStore");
HistogramSupport::histogramEnumeration("WebCore.IndexedDB.FrontEndAPICalls", IDBDeleteObjectStoreCall, IDBMethodsMax);
if (!m_versionChangeTransaction) {
ec = IDBDatabaseException::InvalidStateError;
return;
}
if (!m_versionChangeTransaction->isActive()) {
ec = IDBDatabaseException::TransactionInactiveError;
return;
}
int64_t objectStoreId = findObjectStoreId(name);
if (objectStoreId == IDBObjectStoreMetadata::InvalidId) {
ec = IDBDatabaseException::NotFoundError;
return;
}
m_backend->deleteObjectStore(m_versionChangeTransaction->id(), objectStoreId);
m_versionChangeTransaction->objectStoreDeleted(name);
m_metadata.objectStores.remove(objectStoreId);
}
PassRefPtr<IDBTransaction> IDBDatabase::transaction(ScriptExecutionContext* context, const Vector<String>& scope, const String& modeString, ExceptionCode& ec)
{
IDB_TRACE("IDBDatabase::transaction");
HistogramSupport::histogramEnumeration("WebCore.IndexedDB.FrontEndAPICalls", IDBTransactionCall, IDBMethodsMax);
if (!scope.size()) {
ec = IDBDatabaseException::InvalidAccessError;
return 0;
}
IndexedDB::TransactionMode mode = IDBTransaction::stringToMode(modeString, ec);
if (ec)
return 0;
if (m_versionChangeTransaction || m_closePending) {
ec = IDBDatabaseException::InvalidStateError;
return 0;
}
Vector<int64_t> objectStoreIds;
for (size_t i = 0; i < scope.size(); ++i) {
int64_t objectStoreId = findObjectStoreId(scope[i]);
if (objectStoreId == IDBObjectStoreMetadata::InvalidId) {
ec = IDBDatabaseException::NotFoundError;
return 0;
}
objectStoreIds.append(objectStoreId);
}
int64_t transactionId = nextTransactionId();
m_backend->createTransaction(transactionId, m_databaseCallbacks, objectStoreIds, mode);
RefPtr<IDBTransaction> transaction = IDBTransaction::create(context, transactionId, scope, mode, this);
return transaction.release();
}
PassRefPtr<IDBTransaction> IDBDatabase::transaction(ScriptExecutionContext* context, const String& storeName, const String& mode, ExceptionCode& ec)
{
RefPtr<DOMStringList> storeNames = DOMStringList::create();
storeNames->append(storeName);
return transaction(context, storeNames, mode, ec);
}
void IDBDatabase::forceClose()
{
for (TransactionMap::const_iterator::Values it = m_transactions.begin().values(), end = m_transactions.end().values(); it != end; ++it)
(*it)->abort(IGNORE_EXCEPTION);
this->close();
}
void IDBDatabase::close()
{
IDB_TRACE("IDBDatabase::close");
if (m_closePending)
return;
m_closePending = true;
if (m_transactions.isEmpty())
closeConnection();
}
void IDBDatabase::closeConnection()
{
ASSERT(m_closePending);
ASSERT(m_transactions.isEmpty());
m_backend->close(m_databaseCallbacks);
if (m_contextStopped || !scriptExecutionContext())
return;
EventQueue* eventQueue = scriptExecutionContext()->eventQueue();
for (size_t i = 0; i < m_enqueuedEvents.size(); ++i) {
bool removed = eventQueue->cancelEvent(m_enqueuedEvents[i].get());
ASSERT_UNUSED(removed, removed);
}
}
void IDBDatabase::onVersionChange(int64_t oldVersion, int64_t newVersion)
{
IDB_TRACE("IDBDatabase::onVersionChange");
if (m_contextStopped || !scriptExecutionContext())
return;
if (m_closePending)
return;
RefPtr<IDBAny> newVersionAny = newVersion == IDBDatabaseMetadata::NoIntVersion ? IDBAny::createNull() : IDBAny::create(newVersion);
enqueueEvent(IDBVersionChangeEvent::create(IDBAny::create(oldVersion), newVersionAny.release(), eventNames().versionchangeEvent));
}
void IDBDatabase::enqueueEvent(PassRefPtr<Event> event)
{
ASSERT(!m_contextStopped);
ASSERT(scriptExecutionContext());
EventQueue* eventQueue = scriptExecutionContext()->eventQueue();
event->setTarget(this);
eventQueue->enqueueEvent(event.get());
m_enqueuedEvents.append(event);
}
bool IDBDatabase::dispatchEvent(PassRefPtr<Event> event)
{
IDB_TRACE("IDBDatabase::dispatchEvent");
ASSERT(event->type() == eventNames().versionchangeEvent);
for (size_t i = 0; i < m_enqueuedEvents.size(); ++i) {
if (m_enqueuedEvents[i].get() == event.get())
m_enqueuedEvents.remove(i);
}
return EventTarget::dispatchEvent(event.get());
}
int64_t IDBDatabase::findObjectStoreId(const String& name) const
{
for (IDBDatabaseMetadata::ObjectStoreMap::const_iterator it = m_metadata.objectStores.begin(); it != m_metadata.objectStores.end(); ++it) {
if (it->value.name == name) {
ASSERT(it->key != IDBObjectStoreMetadata::InvalidId);
return it->key;
}
}
return IDBObjectStoreMetadata::InvalidId;
}
bool IDBDatabase::hasPendingActivity() const
{
return !m_closePending && !m_eventTargetData.eventListenerMap.isEmpty() && !m_contextStopped;
}
void IDBDatabase::stop()
{
close();
m_contextStopped = true;
}
const AtomicString& IDBDatabase::interfaceName() const
{
return eventNames().interfaceForIDBDatabase;
}
ScriptExecutionContext* IDBDatabase::scriptExecutionContext() const
{
return ActiveDOMObject::scriptExecutionContext();
}
EventTargetData* IDBDatabase::eventTargetData()
{
return &m_eventTargetData;
}
EventTargetData* IDBDatabase::ensureEventTargetData()
{
return &m_eventTargetData;
}
}
#endif // ENABLE(INDEXED_DATABASE)