Home | History | Annotate | Download | only in storage 
      1 /*
      2  * Copyright (C) 2010 Google 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  *
      8  * 1.  Redistributions of source code must retain the above copyright
      9  *     notice, this list of conditions and the following disclaimer.
     10  * 2.  Redistributions in binary form must reproduce the above copyright
     11  *     notice, this list of conditions and the following disclaimer in the
     12  *     documentation and/or other materials provided with the distribution.
     13  *
     14  * THIS SOFTWARE IS PROVIDED BY APPLE AND ITS CONTRIBUTORS "AS IS" AND ANY
     15  * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
     16  * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
     17  * DISCLAIMED. IN NO EVENT SHALL APPLE OR ITS CONTRIBUTORS BE LIABLE FOR ANY
     18  * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
     19  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
     20  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
     21  * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
     22  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
     23  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
     24  */
     25 
     26 #include "config.h"
     27 #include "IDBCursor.h"
     28 
     29 #if ENABLE(INDEXED_DATABASE)
     30 
     31 #include "IDBAny.h"
     32 #include "IDBCallbacks.h"
     33 #include "IDBCursorBackendInterface.h"
     34 #include "IDBKey.h"
     35 #include "IDBRequest.h"
     36 #include "IDBTransaction.h"
     37 #include "ScriptExecutionContext.h"
     38 #include "SerializedScriptValue.h"
     39 
     40 namespace WebCore {
     41 
     42 PassRefPtr<IDBCursor> IDBCursor::create(PassRefPtr<IDBCursorBackendInterface> backend, IDBRequest* request, IDBAny* source, IDBTransaction* transaction)
     43 {
     44     return adoptRef(new IDBCursor(backend, request, source, transaction));
     45 }
     46 
     47 IDBCursor::IDBCursor(PassRefPtr<IDBCursorBackendInterface> backend, IDBRequest* request, IDBAny* source, IDBTransaction* transaction)
     48     : m_backend(backend)
     49     , m_request(request)
     50     , m_source(source)
     51     , m_transaction(transaction)
     52 {
     53     ASSERT(m_backend);
     54     ASSERT(m_request);
     55     ASSERT(m_source->type() == IDBAny::IDBObjectStoreType || m_source->type() == IDBAny::IDBIndexType);
     56     ASSERT(m_transaction);
     57 }
     58 
     59 IDBCursor::~IDBCursor()
     60 {
     61 }
     62 
     63 unsigned short IDBCursor::direction() const
     64 {
     65     return m_backend->direction();
     66 }
     67 
     68 PassRefPtr<IDBKey> IDBCursor::key() const
     69 {
     70     return m_backend->key();
     71 }
     72 
     73 PassRefPtr<IDBKey> IDBCursor::primaryKey() const
     74 {
     75     return m_backend->primaryKey();
     76 }
     77 
     78 PassRefPtr<SerializedScriptValue> IDBCursor::value() const
     79 {
     80     return m_backend->value();
     81 }
     82 
     83 IDBAny* IDBCursor::source() const
     84 {
     85     return m_source.get();
     86 }
     87 
     88 PassRefPtr<IDBRequest> IDBCursor::update(ScriptExecutionContext* context, PassRefPtr<SerializedScriptValue> value, ExceptionCode& ec)
     89 {
     90     RefPtr<IDBRequest> request = IDBRequest::create(context, IDBAny::create(this), m_transaction.get());
     91     m_backend->update(value, request, ec);
     92     if (ec) {
     93         request->markEarlyDeath();
     94         return 0;
     95     }
     96     return request.release();
     97 }
     98 
     99 void IDBCursor::continueFunction(PassRefPtr<IDBKey> key, ExceptionCode& ec)
    100 {
    101     // FIXME: We're not using the context from when continue was called, which means the callback
    102     //        will be on the original context openCursor was called on. Is this right?
    103     if (m_request->resetReadyState(m_transaction.get()))
    104         m_backend->continueFunction(key, m_request, ec);
    105     else
    106         ec = IDBDatabaseException::NOT_ALLOWED_ERR;
    107 }
    108 
    109 PassRefPtr<IDBRequest> IDBCursor::deleteFunction(ScriptExecutionContext* context, ExceptionCode& ec)
    110 {
    111     RefPtr<IDBRequest> request = IDBRequest::create(context, IDBAny::create(this), m_transaction.get());
    112     m_backend->deleteFunction(request, ec);
    113     if (ec) {
    114         request->markEarlyDeath();
    115         return 0;
    116     }
    117     return request.release();
    118 }
    119 
    120 } // namespace WebCore
    121 
    122 #endif // ENABLE(INDEXED_DATABASE)
    123