#include "config.h"
#include "IDBCursor.h"
#if ENABLE(INDEXED_DATABASE)
#include "IDBAny.h"
#include "IDBCallbacks.h"
#include "IDBCursorBackendInterface.h"
#include "IDBKey.h"
#include "IDBRequest.h"
#include "IDBTracing.h"
#include "IDBTransaction.h"
#include "ScriptExecutionContext.h"
#include "SerializedScriptValue.h"
namespace WebCore {
PassRefPtr<IDBCursor> IDBCursor::create(PassRefPtr<IDBCursorBackendInterface> backend, IDBRequest* request, IDBAny* source, IDBTransaction* transaction)
{
return adoptRef(new IDBCursor(backend, request, source, transaction));
}
IDBCursor::IDBCursor(PassRefPtr<IDBCursorBackendInterface> backend, IDBRequest* request, IDBAny* source, IDBTransaction* transaction)
: m_backend(backend)
, m_request(request)
, m_source(source)
, m_transaction(transaction)
, m_transactionNotifier(transaction, this)
, m_gotValue(false)
{
ASSERT(m_backend);
ASSERT(m_request);
ASSERT(m_source->type() == IDBAny::IDBObjectStoreType || m_source->type() == IDBAny::IDBIndexType);
ASSERT(m_transaction);
}
IDBCursor::~IDBCursor()
{
}
unsigned short IDBCursor::direction() const
{
IDB_TRACE("IDBCursor::direction");
return m_backend->direction();
}
PassRefPtr<IDBKey> IDBCursor::key() const
{
IDB_TRACE("IDBCursor::key");
return m_currentKey;
}
PassRefPtr<IDBKey> IDBCursor::primaryKey() const
{
IDB_TRACE("IDBCursor::primaryKey");
return m_currentPrimaryKey;
}
PassRefPtr<IDBAny> IDBCursor::value() const
{
IDB_TRACE("IDBCursor::value");
return m_currentValue;
}
IDBAny* IDBCursor::source() const
{
return m_source.get();
}
PassRefPtr<IDBRequest> IDBCursor::update(ScriptExecutionContext* context, PassRefPtr<SerializedScriptValue> prpValue, ExceptionCode& ec)
{
IDB_TRACE("IDBCursor::update");
if (!m_gotValue) {
ec = INVALID_STATE_ERR;
return 0;
}
RefPtr<SerializedScriptValue> value = prpValue;
if (value->blobURLs().size() > 0) {
ec = DATA_CLONE_ERR;
return 0;
}
RefPtr<IDBRequest> request = IDBRequest::create(context, IDBAny::create(this), m_transaction.get());
m_backend->update(value, request, ec);
if (ec) {
request->markEarlyDeath();
return 0;
}
return request.release();
}
void IDBCursor::advance(unsigned long count, ExceptionCode& ec)
{
IDB_TRACE("IDBCursor::advance");
if (!m_gotValue) {
ec = INVALID_STATE_ERR;
return;
}
if (!m_request) {
ec = IDBDatabaseException::TRANSACTION_INACTIVE_ERR;
return;
}
if (!count) {
ec = TYPE_MISMATCH_ERR;
return;
}
if (!m_request->resetReadyState(m_transaction.get())) {
ec = IDBDatabaseException::NOT_ALLOWED_ERR;
return;
}
m_request->setCursor(this);
m_gotValue = false;
m_backend->advance(count, m_request, ec);
}
void IDBCursor::continueFunction(PassRefPtr<IDBKey> key, ExceptionCode& ec)
{
IDB_TRACE("IDBCursor::continue");
if (key && (key->type() == IDBKey::InvalidType)) {
ec = IDBDatabaseException::DATA_ERR;
return;
}
if (!m_request) {
ec = IDBDatabaseException::TRANSACTION_INACTIVE_ERR;
return;
}
if (!m_gotValue) {
ec = INVALID_STATE_ERR;
return;
}
if (m_request->resetReadyState(m_transaction.get())) {
m_request->setCursor(this);
m_gotValue = false;
m_backend->continueFunction(key, m_request, ec);
} else
ec = IDBDatabaseException::NOT_ALLOWED_ERR;
}
PassRefPtr<IDBRequest> IDBCursor::deleteFunction(ScriptExecutionContext* context, ExceptionCode& ec)
{
IDB_TRACE("IDBCursor::delete");
if (!m_gotValue) {
ec = INVALID_STATE_ERR;
return 0;
}
RefPtr<IDBRequest> request = IDBRequest::create(context, IDBAny::create(this), m_transaction.get());
m_backend->deleteFunction(request, ec);
if (ec) {
request->markEarlyDeath();
return 0;
}
return request.release();
}
void IDBCursor::postSuccessHandlerCallback()
{
m_backend->postSuccessHandlerCallback();
}
void IDBCursor::close()
{
ASSERT(m_request);
m_request->finishCursor();
m_request.clear();
}
void IDBCursor::setValueReady()
{
m_currentKey = m_backend->key();
m_currentPrimaryKey = m_backend->primaryKey();
m_currentValue = IDBAny::create(m_backend->value());
m_gotValue = true;
}
}
#endif // ENABLE(INDEXED_DATABASE)