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