Source/WebCore/Modules/indexeddb/IDBIndex.cpp - WebKit - Git at Google

 /*
  * Copyright (C) 2015 Apple 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
  *    notice, this list of conditions and the following disclaimer in the
  *    documentation and/or other materials provided with the distribution.
  *
  * THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS''
  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
  * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
  * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS
  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
  * THE POSSIBILITY OF SUCH DAMAGE.
  */

 #include "config.h"
 #include "IDBIndex.h"

 #if ENABLE(INDEXED_DATABASE)

 #include "IDBBindingUtilities.h"
 #include "IDBCursor.h"
 #include "IDBDatabase.h"
 #include "IDBKeyRangeData.h"
 #include "IDBObjectStore.h"
 #include "IDBRequest.h"
 #include "IDBTransaction.h"
 #include "Logging.h"
 #include <JavaScriptCore/HeapInlines.h>

 namespace WebCore {
 using namespace JSC;

 IDBIndex::IDBIndex(ScriptExecutionContext& context, const IDBIndexInfo& info, IDBObjectStore& objectStore)
     : ActiveDOMObject(&context)
     , m_info(info)
     , m_originalInfo(info)
     , m_objectStore(objectStore)
 {
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

     suspendIfNeeded();
 }

 IDBIndex::~IDBIndex()
 {
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());
 }

 const char* IDBIndex::activeDOMObjectName() const
 {
     return "IDBIndex";
 }

 bool IDBIndex::hasPendingActivity() const
 {
     return m_objectStore.hasPendingActivity();
 }

 const String& IDBIndex::name() const
 {
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());
     return m_info.name();
 }

 ExceptionOr<void> IDBIndex::setName(const String& name)
 {
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

     if (m_deleted)
         return Exception { InvalidStateError, "Failed set property 'name' on 'IDBIndex': The index has been deleted."_s };

     if (m_objectStore.isDeleted())
         return Exception { InvalidStateError, "Failed set property 'name' on 'IDBIndex': The index's object store has been deleted."_s };

     if (!m_objectStore.transaction().isVersionChange())
         return Exception { InvalidStateError, "Failed set property 'name' on 'IDBIndex': The index's transaction is not a version change transaction."_s };

     if (!m_objectStore.transaction().isActive())
         return Exception { TransactionInactiveError, "Failed set property 'name' on 'IDBIndex': The index's transaction is not active."_s };

     if (m_info.name() == name)
         return { };

     if (m_objectStore.info().hasIndex(name))
         return Exception { ConstraintError, makeString("Failed set property 'name' on 'IDBIndex': The owning object store already has an index named '", name, "'.") };

     m_objectStore.transaction().database().renameIndex(*this, name);
     m_info.rename(name);

     return { };
 }

 IDBObjectStore& IDBIndex::objectStore()
 {
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());
     return m_objectStore;
 }

 const IDBKeyPath& IDBIndex::keyPath() const
 {
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());
     return m_info.keyPath();
 }

 bool IDBIndex::unique() const
 {
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());
     return m_info.unique();
 }

 bool IDBIndex::multiEntry() const
 {
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());
     return m_info.multiEntry();
 }

 void IDBIndex::rollbackInfoForVersionChangeAbort()
 {
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

     // Only rollback to the original info if this index still exists in the rolled-back database info.
     auto* objectStoreInfo = m_objectStore.transaction().database().info().infoForExistingObjectStore(m_objectStore.info().identifier());
     if (!objectStoreInfo)
         return;

     if (!objectStoreInfo->hasIndex(m_info.identifier())) {
         m_deleted = true;
         return;
     }

     m_info = m_originalInfo;
     m_deleted = false;
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::doOpenCursor(JSGlobalObject& execState, IDBCursorDirection direction, WTF::Function<ExceptionOr<RefPtr<IDBKeyRange>>()>&& function)
 {
     LOG(IndexedDB, "IDBIndex::openCursor");
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

     if (m_deleted || m_objectStore.isDeleted())
         return Exception { InvalidStateError, "Failed to execute 'openCursor' on 'IDBIndex': The index or its object store has been deleted."_s };

     if (!m_objectStore.transaction().isActive())
         return Exception { TransactionInactiveError, "Failed to execute 'openCursor' on 'IDBIndex': The transaction is inactive or finished."_s };

     auto keyRange = function();
     if (keyRange.hasException())
         return keyRange.releaseException();

     IDBKeyRangeData rangeData = keyRange.returnValue() ? keyRange.releaseReturnValue().get() : nullptr;
     if (rangeData.lowerKey.isNull())
         rangeData.lowerKey = IDBKeyData::minimum();
     if (rangeData.upperKey.isNull())
         rangeData.upperKey = IDBKeyData::maximum();

     auto info = IDBCursorInfo::indexCursor(m_objectStore.transaction(), m_objectStore.info().identifier(), m_info.identifier(), rangeData, direction, IndexedDB::CursorType::KeyAndValue);
     return m_objectStore.transaction().requestOpenCursor(execState, *this, info);
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::openCursor(JSGlobalObject& execState, RefPtr<IDBKeyRange>&& range, IDBCursorDirection direction)
 {
     return doOpenCursor(execState, direction, [range=WTFMove(range)]() {
         return range;
     });
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::openCursor(JSGlobalObject& execState, JSValue key, IDBCursorDirection direction)
 {
     return doOpenCursor(execState, direction, [state=&execState, key]() {
         auto onlyResult = IDBKeyRange::only(*state, key);
         if (onlyResult.hasException())
             return ExceptionOr<RefPtr<IDBKeyRange>>{ Exception(DataError, "Failed to execute 'openCursor' on 'IDBIndex': The parameter is not a valid key."_s) };

         return ExceptionOr<RefPtr<IDBKeyRange>> { onlyResult.releaseReturnValue() };
     });
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::doOpenKeyCursor(JSGlobalObject& execState, IDBCursorDirection direction, WTF::Function<ExceptionOr<RefPtr<IDBKeyRange>>()>&& function)
 {
     LOG(IndexedDB, "IDBIndex::openKeyCursor");
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

     if (m_deleted || m_objectStore.isDeleted())
         return Exception { InvalidStateError, "Failed to execute 'openKeyCursor' on 'IDBIndex': The index or its object store has been deleted."_s };

     if (!m_objectStore.transaction().isActive())
         return Exception { TransactionInactiveError, "Failed to execute 'openKeyCursor' on 'IDBIndex': The transaction is inactive or finished."_s };

     auto keyRange = function();
     if (keyRange.hasException())
         return keyRange.releaseException();

     auto* keyRangePointer = keyRange.returnValue() ? keyRange.releaseReturnValue().get() : nullptr;
     auto info = IDBCursorInfo::indexCursor(m_objectStore.transaction(), m_objectStore.info().identifier(), m_info.identifier(), keyRangePointer, direction, IndexedDB::CursorType::KeyOnly);
     return m_objectStore.transaction().requestOpenCursor(execState, *this, info);
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::openKeyCursor(JSGlobalObject& execState, RefPtr<IDBKeyRange>&& range, IDBCursorDirection direction)
 {
     return doOpenKeyCursor(execState, direction, [range=WTFMove(range)]() {
         return range;
     });
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::openKeyCursor(JSGlobalObject& execState, JSValue key, IDBCursorDirection direction)
 {
     return doOpenKeyCursor(execState, direction, [state=&execState, key]() {
         auto onlyResult = IDBKeyRange::only(*state, key);
         if (onlyResult.hasException())
             return ExceptionOr<RefPtr<IDBKeyRange>>{ Exception(DataError, "Failed to execute 'openKeyCursor' on 'IDBIndex': The parameter is not a valid key."_s) };

         return ExceptionOr<RefPtr<IDBKeyRange>> { onlyResult.releaseReturnValue() };
     });
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::count(JSGlobalObject& execState, IDBKeyRange* range)
 {
     LOG(IndexedDB, "IDBIndex::count");

     return doCount(execState, range ? IDBKeyRangeData(range) : IDBKeyRangeData::allKeys());
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::count(JSGlobalObject& execState, JSValue key)
 {
     LOG(IndexedDB, "IDBIndex::count");

     auto idbKey = scriptValueToIDBKey(execState, key);
     auto* idbKeyPointer = idbKey->isValid() ? idbKey.ptr() : nullptr;

     return doCount(execState, IDBKeyRangeData(idbKeyPointer));
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::doCount(JSGlobalObject& execState, const IDBKeyRangeData& range)
 {
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

     if (m_deleted || m_objectStore.isDeleted())
         return Exception { InvalidStateError, "Failed to execute 'count' on 'IDBIndex': The index or its object store has been deleted."_s };

     auto& transaction = m_objectStore.transaction();
     if (!transaction.isActive())
         return Exception { TransactionInactiveError, "Failed to execute 'count' on 'IDBIndex': The transaction is inactive or finished."_s };

     if (!range.isValid())
         return Exception { DataError, "Failed to execute 'count' on 'IDBIndex': The parameter is not a valid key."_s };

     return transaction.requestCount(execState, *this, range);
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::get(JSGlobalObject& execState, IDBKeyRange* range)
 {
     LOG(IndexedDB, "IDBIndex::get");

     return doGet(execState, IDBKeyRangeData(range));
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::get(JSGlobalObject& execState, JSValue key)
 {
     LOG(IndexedDB, "IDBIndex::get");

     auto idbKey = scriptValueToIDBKey(execState, key);
     if (!idbKey->isValid())
         return doGet(execState, Exception(DataError, "Failed to execute 'get' on 'IDBIndex': The parameter is not a valid key."_s));

     return doGet(execState, IDBKeyRangeData(idbKey.ptr()));
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::doGet(JSGlobalObject& execState, ExceptionOr<IDBKeyRangeData> range)
 {
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

     if (m_deleted || m_objectStore.isDeleted())
         return Exception { InvalidStateError, "Failed to execute 'get' on 'IDBIndex': The index or its object store has been deleted."_s };

     auto& transaction = m_objectStore.transaction();
     if (!transaction.isActive())
         return Exception { TransactionInactiveError, "Failed to execute 'get' on 'IDBIndex': The transaction is inactive or finished."_s };

     if (range.hasException())
         return range.releaseException();
     auto keyRange = range.releaseReturnValue();

     if (keyRange.isNull)
         return Exception { DataError };

     return transaction.requestGetValue(execState, *this, keyRange);
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::getKey(JSGlobalObject& execState, IDBKeyRange* range)
 {
     LOG(IndexedDB, "IDBIndex::getKey");

     return doGetKey(execState, IDBKeyRangeData(range));
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::getKey(JSGlobalObject& execState, JSValue key)
 {
     LOG(IndexedDB, "IDBIndex::getKey");

     auto idbKey = scriptValueToIDBKey(execState, key);
     if (!idbKey->isValid())
         return doGetKey(execState, Exception(DataError, "Failed to execute 'getKey' on 'IDBIndex': The parameter is not a valid key."_s));

     return doGetKey(execState, IDBKeyRangeData(idbKey.ptr()));
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::doGetKey(JSGlobalObject& execState, ExceptionOr<IDBKeyRangeData> range)
 {
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

     if (m_deleted || m_objectStore.isDeleted())
         return Exception { InvalidStateError, "Failed to execute 'getKey' on 'IDBIndex': The index or its object store has been deleted."_s };

     auto& transaction = m_objectStore.transaction();
     if (!transaction.isActive())
         return Exception { TransactionInactiveError, "Failed to execute 'getKey' on 'IDBIndex': The transaction is inactive or finished."_s };

     if (range.hasException())
         return range.releaseException();
     auto keyRange = range.releaseReturnValue();

     if (keyRange.isNull)
         return Exception { DataError };

     return transaction.requestGetKey(execState, *this, keyRange);
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::doGetAll(JSGlobalObject& execState, Optional<uint32_t> count, WTF::Function<ExceptionOr<RefPtr<IDBKeyRange>>()>&& function)
 {
     LOG(IndexedDB, "IDBIndex::getAll");
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

     if (m_deleted || m_objectStore.isDeleted())
         return Exception { InvalidStateError, "Failed to execute 'getAll' on 'IDBIndex': The index or its object store has been deleted."_s };

     if (!m_objectStore.transaction().isActive())
         return Exception { TransactionInactiveError, "Failed to execute 'getAll' on 'IDBIndex': The transaction is inactive or finished."_s };

     auto keyRange = function();
     if (keyRange.hasException())
         return keyRange.releaseException();

     auto* keyRangePointer = keyRange.returnValue() ? keyRange.releaseReturnValue().get() : nullptr;
     return m_objectStore.transaction().requestGetAllIndexRecords(execState, *this, keyRangePointer, IndexedDB::GetAllType::Values, count);
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::getAll(JSGlobalObject& execState, RefPtr<IDBKeyRange>&& range, Optional<uint32_t> count)
 {
     return doGetAll(execState, count, [range = WTFMove(range)]() {
         return range;
     });
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::getAll(JSGlobalObject& execState, JSValue key, Optional<uint32_t> count)
 {
     return doGetAll(execState, count, [state=&execState, key]() {
         auto onlyResult = IDBKeyRange::only(*state, key);
         if (onlyResult.hasException())
             return ExceptionOr<RefPtr<IDBKeyRange>>{ Exception(DataError, "Failed to execute 'getAll' on 'IDBIndex': The parameter is not a valid key."_s) };

         return ExceptionOr<RefPtr<IDBKeyRange>> { onlyResult.releaseReturnValue() };
     });
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::doGetAllKeys(JSGlobalObject& execState, Optional<uint32_t> count, WTF::Function<ExceptionOr<RefPtr<IDBKeyRange>>()>&& function)
 {
     LOG(IndexedDB, "IDBIndex::getAllKeys");
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

     if (m_deleted || m_objectStore.isDeleted())
         return Exception { InvalidStateError, "Failed to execute 'getAllKeys' on 'IDBIndex': The index or its object store has been deleted."_s };

     if (!m_objectStore.transaction().isActive())
         return Exception { TransactionInactiveError, "Failed to execute 'getAllKeys' on 'IDBIndex': The transaction is inactive or finished."_s };

     auto keyRange = function();
     if (keyRange.hasException())
         return keyRange.releaseException();

     auto* keyRangePointer = keyRange.returnValue() ? keyRange.releaseReturnValue().get() : nullptr;
     return m_objectStore.transaction().requestGetAllIndexRecords(execState, *this, keyRangePointer, IndexedDB::GetAllType::Keys, count);
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::getAllKeys(JSGlobalObject& execState, RefPtr<IDBKeyRange>&& range, Optional<uint32_t> count)
 {
     return doGetAllKeys(execState, count, [range = WTFMove(range)]() {
         return range;
     });
 }

 ExceptionOr<Ref<IDBRequest>> IDBIndex::getAllKeys(JSGlobalObject& execState, JSValue key, Optional<uint32_t> count)
 {
     return doGetAllKeys(execState, count, [state=&execState, key]() {
         auto onlyResult = IDBKeyRange::only(*state, key);
         if (onlyResult.hasException())
             return ExceptionOr<RefPtr<IDBKeyRange>>{ Exception(DataError, "Failed to execute 'getAllKeys' on 'IDBIndex': The parameter is not a valid key."_s) };

         return ExceptionOr<RefPtr<IDBKeyRange>> { onlyResult.releaseReturnValue() };
     });
 }

 void IDBIndex::markAsDeleted()
 {
     ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

     ASSERT(!m_deleted);
     m_deleted = true;
 }

 void IDBIndex::ref()
 {
     m_objectStore.ref();
 }

 void IDBIndex::deref()
 {
     m_objectStore.deref();
 }

 } // namespace WebCore

 #endif // ENABLE(INDEXED_DATABASE)
	/*
	* Copyright (C) 2015 Apple 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
	* notice, this list of conditions and the following disclaimer in the
	* documentation and/or other materials provided with the distribution.
	*
	* THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS''
	* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
	* THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
	* PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS
	* BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
	* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
	* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
	* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
	* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
	* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
	* THE POSSIBILITY OF SUCH DAMAGE.
	*/

	#include "config.h"
	#include "IDBIndex.h"

	#if ENABLE(INDEXED_DATABASE)

	#include "IDBBindingUtilities.h"
	#include "IDBCursor.h"
	#include "IDBDatabase.h"
	#include "IDBKeyRangeData.h"
	#include "IDBObjectStore.h"
	#include "IDBRequest.h"
	#include "IDBTransaction.h"
	#include "Logging.h"
	#include <JavaScriptCore/HeapInlines.h>

	namespace WebCore {
	using namespace JSC;

	IDBIndex::IDBIndex(ScriptExecutionContext& context, const IDBIndexInfo& info, IDBObjectStore& objectStore)
	: ActiveDOMObject(&context)
	, m_info(info)
	, m_originalInfo(info)
	, m_objectStore(objectStore)
	{
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

	suspendIfNeeded();
	}

	IDBIndex::~IDBIndex()
	{
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());
	}

	const char* IDBIndex::activeDOMObjectName() const
	{
	return "IDBIndex";
	}

	bool IDBIndex::hasPendingActivity() const
	{
	return m_objectStore.hasPendingActivity();
	}

	const String& IDBIndex::name() const
	{
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());
	return m_info.name();
	}

	ExceptionOr<void> IDBIndex::setName(const String& name)
	{
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

	if (m_deleted)
	return Exception { InvalidStateError, "Failed set property 'name' on 'IDBIndex': The index has been deleted."_s };

	if (m_objectStore.isDeleted())
	return Exception { InvalidStateError, "Failed set property 'name' on 'IDBIndex': The index's object store has been deleted."_s };

	if (!m_objectStore.transaction().isVersionChange())
	return Exception { InvalidStateError, "Failed set property 'name' on 'IDBIndex': The index's transaction is not a version change transaction."_s };

	if (!m_objectStore.transaction().isActive())
	return Exception { TransactionInactiveError, "Failed set property 'name' on 'IDBIndex': The index's transaction is not active."_s };

	if (m_info.name() == name)
	return { };

	if (m_objectStore.info().hasIndex(name))
	return Exception { ConstraintError, makeString("Failed set property 'name' on 'IDBIndex': The owning object store already has an index named '", name, "'.") };

	m_objectStore.transaction().database().renameIndex(*this, name);
	m_info.rename(name);

	return { };
	}

	IDBObjectStore& IDBIndex::objectStore()
	{
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());
	return m_objectStore;
	}

	const IDBKeyPath& IDBIndex::keyPath() const
	{
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());
	return m_info.keyPath();
	}

	bool IDBIndex::unique() const
	{
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());
	return m_info.unique();
	}

	bool IDBIndex::multiEntry() const
	{
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());
	return m_info.multiEntry();
	}

	void IDBIndex::rollbackInfoForVersionChangeAbort()
	{
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

	// Only rollback to the original info if this index still exists in the rolled-back database info.
	auto* objectStoreInfo = m_objectStore.transaction().database().info().infoForExistingObjectStore(m_objectStore.info().identifier());
	if (!objectStoreInfo)
	return;

	if (!objectStoreInfo->hasIndex(m_info.identifier())) {
	m_deleted = true;
	return;
	}

	m_info = m_originalInfo;
	m_deleted = false;
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::doOpenCursor(JSGlobalObject& execState, IDBCursorDirection direction, WTF::Function<ExceptionOr<RefPtr<IDBKeyRange>>()>&& function)
	{
	LOG(IndexedDB, "IDBIndex::openCursor");
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

	if (m_deleted \|\| m_objectStore.isDeleted())
	return Exception { InvalidStateError, "Failed to execute 'openCursor' on 'IDBIndex': The index or its object store has been deleted."_s };

	if (!m_objectStore.transaction().isActive())
	return Exception { TransactionInactiveError, "Failed to execute 'openCursor' on 'IDBIndex': The transaction is inactive or finished."_s };

	auto keyRange = function();
	if (keyRange.hasException())
	return keyRange.releaseException();

	IDBKeyRangeData rangeData = keyRange.returnValue() ? keyRange.releaseReturnValue().get() : nullptr;
	if (rangeData.lowerKey.isNull())
	rangeData.lowerKey = IDBKeyData::minimum();
	if (rangeData.upperKey.isNull())
	rangeData.upperKey = IDBKeyData::maximum();

	auto info = IDBCursorInfo::indexCursor(m_objectStore.transaction(), m_objectStore.info().identifier(), m_info.identifier(), rangeData, direction, IndexedDB::CursorType::KeyAndValue);
	return m_objectStore.transaction().requestOpenCursor(execState, *this, info);
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::openCursor(JSGlobalObject& execState, RefPtr<IDBKeyRange>&& range, IDBCursorDirection direction)
	{
	return doOpenCursor(execState, direction, [range=WTFMove(range)]() {
	return range;
	});
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::openCursor(JSGlobalObject& execState, JSValue key, IDBCursorDirection direction)
	{
	return doOpenCursor(execState, direction, [state=&execState, key]() {
	auto onlyResult = IDBKeyRange::only(*state, key);
	if (onlyResult.hasException())
	return ExceptionOr<RefPtr<IDBKeyRange>>{ Exception(DataError, "Failed to execute 'openCursor' on 'IDBIndex': The parameter is not a valid key."_s) };

	return ExceptionOr<RefPtr<IDBKeyRange>> { onlyResult.releaseReturnValue() };
	});
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::doOpenKeyCursor(JSGlobalObject& execState, IDBCursorDirection direction, WTF::Function<ExceptionOr<RefPtr<IDBKeyRange>>()>&& function)
	{
	LOG(IndexedDB, "IDBIndex::openKeyCursor");
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

	if (m_deleted \|\| m_objectStore.isDeleted())
	return Exception { InvalidStateError, "Failed to execute 'openKeyCursor' on 'IDBIndex': The index or its object store has been deleted."_s };

	if (!m_objectStore.transaction().isActive())
	return Exception { TransactionInactiveError, "Failed to execute 'openKeyCursor' on 'IDBIndex': The transaction is inactive or finished."_s };

	auto keyRange = function();
	if (keyRange.hasException())
	return keyRange.releaseException();

	auto* keyRangePointer = keyRange.returnValue() ? keyRange.releaseReturnValue().get() : nullptr;
	auto info = IDBCursorInfo::indexCursor(m_objectStore.transaction(), m_objectStore.info().identifier(), m_info.identifier(), keyRangePointer, direction, IndexedDB::CursorType::KeyOnly);
	return m_objectStore.transaction().requestOpenCursor(execState, *this, info);
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::openKeyCursor(JSGlobalObject& execState, RefPtr<IDBKeyRange>&& range, IDBCursorDirection direction)
	{
	return doOpenKeyCursor(execState, direction, [range=WTFMove(range)]() {
	return range;
	});
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::openKeyCursor(JSGlobalObject& execState, JSValue key, IDBCursorDirection direction)
	{
	return doOpenKeyCursor(execState, direction, [state=&execState, key]() {
	auto onlyResult = IDBKeyRange::only(*state, key);
	if (onlyResult.hasException())
	return ExceptionOr<RefPtr<IDBKeyRange>>{ Exception(DataError, "Failed to execute 'openKeyCursor' on 'IDBIndex': The parameter is not a valid key."_s) };

	return ExceptionOr<RefPtr<IDBKeyRange>> { onlyResult.releaseReturnValue() };
	});
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::count(JSGlobalObject& execState, IDBKeyRange* range)
	{
	LOG(IndexedDB, "IDBIndex::count");

	return doCount(execState, range ? IDBKeyRangeData(range) : IDBKeyRangeData::allKeys());
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::count(JSGlobalObject& execState, JSValue key)
	{
	LOG(IndexedDB, "IDBIndex::count");

	auto idbKey = scriptValueToIDBKey(execState, key);
	auto* idbKeyPointer = idbKey->isValid() ? idbKey.ptr() : nullptr;

	return doCount(execState, IDBKeyRangeData(idbKeyPointer));
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::doCount(JSGlobalObject& execState, const IDBKeyRangeData& range)
	{
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

	if (m_deleted \|\| m_objectStore.isDeleted())
	return Exception { InvalidStateError, "Failed to execute 'count' on 'IDBIndex': The index or its object store has been deleted."_s };

	auto& transaction = m_objectStore.transaction();
	if (!transaction.isActive())
	return Exception { TransactionInactiveError, "Failed to execute 'count' on 'IDBIndex': The transaction is inactive or finished."_s };

	if (!range.isValid())
	return Exception { DataError, "Failed to execute 'count' on 'IDBIndex': The parameter is not a valid key."_s };

	return transaction.requestCount(execState, *this, range);
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::get(JSGlobalObject& execState, IDBKeyRange* range)
	{
	LOG(IndexedDB, "IDBIndex::get");

	return doGet(execState, IDBKeyRangeData(range));
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::get(JSGlobalObject& execState, JSValue key)
	{
	LOG(IndexedDB, "IDBIndex::get");

	auto idbKey = scriptValueToIDBKey(execState, key);
	if (!idbKey->isValid())
	return doGet(execState, Exception(DataError, "Failed to execute 'get' on 'IDBIndex': The parameter is not a valid key."_s));

	return doGet(execState, IDBKeyRangeData(idbKey.ptr()));
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::doGet(JSGlobalObject& execState, ExceptionOr<IDBKeyRangeData> range)
	{
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

	if (m_deleted \|\| m_objectStore.isDeleted())
	return Exception { InvalidStateError, "Failed to execute 'get' on 'IDBIndex': The index or its object store has been deleted."_s };

	auto& transaction = m_objectStore.transaction();
	if (!transaction.isActive())
	return Exception { TransactionInactiveError, "Failed to execute 'get' on 'IDBIndex': The transaction is inactive or finished."_s };

	if (range.hasException())
	return range.releaseException();
	auto keyRange = range.releaseReturnValue();

	if (keyRange.isNull)
	return Exception { DataError };

	return transaction.requestGetValue(execState, *this, keyRange);
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::getKey(JSGlobalObject& execState, IDBKeyRange* range)
	{
	LOG(IndexedDB, "IDBIndex::getKey");

	return doGetKey(execState, IDBKeyRangeData(range));
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::getKey(JSGlobalObject& execState, JSValue key)
	{
	LOG(IndexedDB, "IDBIndex::getKey");

	auto idbKey = scriptValueToIDBKey(execState, key);
	if (!idbKey->isValid())
	return doGetKey(execState, Exception(DataError, "Failed to execute 'getKey' on 'IDBIndex': The parameter is not a valid key."_s));

	return doGetKey(execState, IDBKeyRangeData(idbKey.ptr()));
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::doGetKey(JSGlobalObject& execState, ExceptionOr<IDBKeyRangeData> range)
	{
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

	if (m_deleted \|\| m_objectStore.isDeleted())
	return Exception { InvalidStateError, "Failed to execute 'getKey' on 'IDBIndex': The index or its object store has been deleted."_s };

	auto& transaction = m_objectStore.transaction();
	if (!transaction.isActive())
	return Exception { TransactionInactiveError, "Failed to execute 'getKey' on 'IDBIndex': The transaction is inactive or finished."_s };

	if (range.hasException())
	return range.releaseException();
	auto keyRange = range.releaseReturnValue();

	if (keyRange.isNull)
	return Exception { DataError };

	return transaction.requestGetKey(execState, *this, keyRange);
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::doGetAll(JSGlobalObject& execState, Optional<uint32_t> count, WTF::Function<ExceptionOr<RefPtr<IDBKeyRange>>()>&& function)
	{
	LOG(IndexedDB, "IDBIndex::getAll");
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

	if (m_deleted \|\| m_objectStore.isDeleted())
	return Exception { InvalidStateError, "Failed to execute 'getAll' on 'IDBIndex': The index or its object store has been deleted."_s };

	if (!m_objectStore.transaction().isActive())
	return Exception { TransactionInactiveError, "Failed to execute 'getAll' on 'IDBIndex': The transaction is inactive or finished."_s };

	auto keyRange = function();
	if (keyRange.hasException())
	return keyRange.releaseException();

	auto* keyRangePointer = keyRange.returnValue() ? keyRange.releaseReturnValue().get() : nullptr;
	return m_objectStore.transaction().requestGetAllIndexRecords(execState, *this, keyRangePointer, IndexedDB::GetAllType::Values, count);
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::getAll(JSGlobalObject& execState, RefPtr<IDBKeyRange>&& range, Optional<uint32_t> count)
	{
	return doGetAll(execState, count, [range = WTFMove(range)]() {
	return range;
	});
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::getAll(JSGlobalObject& execState, JSValue key, Optional<uint32_t> count)
	{
	return doGetAll(execState, count, [state=&execState, key]() {
	auto onlyResult = IDBKeyRange::only(*state, key);
	if (onlyResult.hasException())
	return ExceptionOr<RefPtr<IDBKeyRange>>{ Exception(DataError, "Failed to execute 'getAll' on 'IDBIndex': The parameter is not a valid key."_s) };

	return ExceptionOr<RefPtr<IDBKeyRange>> { onlyResult.releaseReturnValue() };
	});
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::doGetAllKeys(JSGlobalObject& execState, Optional<uint32_t> count, WTF::Function<ExceptionOr<RefPtr<IDBKeyRange>>()>&& function)
	{
	LOG(IndexedDB, "IDBIndex::getAllKeys");
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

	if (m_deleted \|\| m_objectStore.isDeleted())
	return Exception { InvalidStateError, "Failed to execute 'getAllKeys' on 'IDBIndex': The index or its object store has been deleted."_s };

	if (!m_objectStore.transaction().isActive())
	return Exception { TransactionInactiveError, "Failed to execute 'getAllKeys' on 'IDBIndex': The transaction is inactive or finished."_s };

	auto keyRange = function();
	if (keyRange.hasException())
	return keyRange.releaseException();

	auto* keyRangePointer = keyRange.returnValue() ? keyRange.releaseReturnValue().get() : nullptr;
	return m_objectStore.transaction().requestGetAllIndexRecords(execState, *this, keyRangePointer, IndexedDB::GetAllType::Keys, count);
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::getAllKeys(JSGlobalObject& execState, RefPtr<IDBKeyRange>&& range, Optional<uint32_t> count)
	{
	return doGetAllKeys(execState, count, [range = WTFMove(range)]() {
	return range;
	});
	}

	ExceptionOr<Ref<IDBRequest>> IDBIndex::getAllKeys(JSGlobalObject& execState, JSValue key, Optional<uint32_t> count)
	{
	return doGetAllKeys(execState, count, [state=&execState, key]() {
	auto onlyResult = IDBKeyRange::only(*state, key);
	if (onlyResult.hasException())
	return ExceptionOr<RefPtr<IDBKeyRange>>{ Exception(DataError, "Failed to execute 'getAllKeys' on 'IDBIndex': The parameter is not a valid key."_s) };

	return ExceptionOr<RefPtr<IDBKeyRange>> { onlyResult.releaseReturnValue() };
	});
	}

	void IDBIndex::markAsDeleted()
	{
	ASSERT(&m_objectStore.transaction().database().originThread() == &Thread::current());

	ASSERT(!m_deleted);
	m_deleted = true;
	}

	void IDBIndex::ref()
	{
	m_objectStore.ref();
	}

	void IDBIndex::deref()
	{
	m_objectStore.deref();
	}

	} // namespace WebCore

	#endif // ENABLE(INDEXED_DATABASE)