Home | History | Annotate | Download | only in indexeddb 
      1 /*
      2  * Copyright (C) 2012 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 "modules/indexeddb/IDBOpenDBRequest.h"
     28 
     29 #include "core/dom/ExceptionCode.h"
     30 #include "core/dom/ExecutionContext.h"
     31 #include "modules/indexeddb/IDBDatabase.h"
     32 #include "modules/indexeddb/IDBDatabaseCallbacks.h"
     33 #include "modules/indexeddb/IDBPendingTransactionMonitor.h"
     34 #include "modules/indexeddb/IDBTracing.h"
     35 #include "modules/indexeddb/IDBVersionChangeEvent.h"
     36 
     37 using blink::WebIDBDatabase;
     38 
     39 namespace WebCore {
     40 
     41 PassRefPtr<IDBOpenDBRequest> IDBOpenDBRequest::create(ExecutionContext* context, PassRefPtr<IDBDatabaseCallbacks> callbacks, int64_t transactionId, int64_t version)
     42 {
     43     RefPtr<IDBOpenDBRequest> request(adoptRef(new IDBOpenDBRequest(context, callbacks, transactionId, version)));
     44     request->suspendIfNeeded();
     45     return request.release();
     46 }
     47 
     48 IDBOpenDBRequest::IDBOpenDBRequest(ExecutionContext* context, PassRefPtr<IDBDatabaseCallbacks> callbacks, int64_t transactionId, int64_t version)
     49     : IDBRequest(context, IDBAny::createNull(), 0)
     50     , m_databaseCallbacks(callbacks)
     51     , m_transactionId(transactionId)
     52     , m_version(version)
     53 {
     54     ASSERT(!resultAsAny());
     55     ScriptWrappable::init(this);
     56 }
     57 
     58 IDBOpenDBRequest::~IDBOpenDBRequest()
     59 {
     60 }
     61 
     62 const AtomicString& IDBOpenDBRequest::interfaceName() const
     63 {
     64     return EventTargetNames::IDBOpenDBRequest;
     65 }
     66 
     67 void IDBOpenDBRequest::onBlocked(int64_t oldVersion)
     68 {
     69     IDB_TRACE("IDBOpenDBRequest::onBlocked()");
     70     if (!shouldEnqueueEvent())
     71         return;
     72     RefPtr<IDBAny> newVersionAny = (m_version == IDBDatabaseMetadata::DefaultIntVersion) ? IDBAny::createNull() : IDBAny::create(m_version);
     73     enqueueEvent(IDBVersionChangeEvent::create(IDBAny::create(oldVersion), newVersionAny.release(), EventTypeNames::blocked));
     74 }
     75 
     76 void IDBOpenDBRequest::onUpgradeNeeded(int64_t oldVersion, PassOwnPtr<WebIDBDatabase> backend, const IDBDatabaseMetadata& metadata, blink::WebIDBDataLoss dataLoss, String dataLossMessage)
     77 {
     78     IDB_TRACE("IDBOpenDBRequest::onUpgradeNeeded()");
     79     if (m_contextStopped || !executionContext()) {
     80         OwnPtr<WebIDBDatabase> db = backend;
     81         db->abort(m_transactionId);
     82         db->close();
     83         return;
     84     }
     85     if (!shouldEnqueueEvent())
     86         return;
     87 
     88     ASSERT(m_databaseCallbacks);
     89 
     90     RefPtr<IDBDatabase> idbDatabase = IDBDatabase::create(executionContext(), backend, m_databaseCallbacks.release());
     91     idbDatabase->setMetadata(metadata);
     92 
     93     if (oldVersion == IDBDatabaseMetadata::NoIntVersion) {
     94         // This database hasn't had an integer version before.
     95         oldVersion = IDBDatabaseMetadata::DefaultIntVersion;
     96     }
     97     IDBDatabaseMetadata oldMetadata(metadata);
     98     oldMetadata.intVersion = oldVersion;
     99 
    100     m_transaction = IDBTransaction::create(executionContext(), m_transactionId, idbDatabase.get(), this, oldMetadata);
    101     setResult(IDBAny::create(idbDatabase.release()));
    102 
    103     if (m_version == IDBDatabaseMetadata::NoIntVersion)
    104         m_version = 1;
    105     enqueueEvent(IDBVersionChangeEvent::create(IDBAny::create(oldVersion), IDBAny::create(m_version), EventTypeNames::upgradeneeded, dataLoss, dataLossMessage));
    106 }
    107 
    108 void IDBOpenDBRequest::onSuccess(PassOwnPtr<WebIDBDatabase> backend, const IDBDatabaseMetadata& metadata)
    109 {
    110     IDB_TRACE("IDBOpenDBRequest::onSuccess()");
    111     if (m_contextStopped || !executionContext()) {
    112         OwnPtr<WebIDBDatabase> db = backend;
    113         if (db)
    114             db->close();
    115         return;
    116     }
    117     if (!shouldEnqueueEvent())
    118         return;
    119 
    120     RefPtr<IDBDatabase> idbDatabase;
    121     if (resultAsAny()) {
    122         // Previous onUpgradeNeeded call delivered the backend.
    123         ASSERT(!backend.get());
    124         idbDatabase = resultAsAny()->idbDatabase();
    125         ASSERT(idbDatabase);
    126         ASSERT(!m_databaseCallbacks);
    127     } else {
    128         ASSERT(backend.get());
    129         ASSERT(m_databaseCallbacks);
    130         idbDatabase = IDBDatabase::create(executionContext(), backend, m_databaseCallbacks.release());
    131         setResult(IDBAny::create(idbDatabase.get()));
    132     }
    133     idbDatabase->setMetadata(metadata);
    134     enqueueEvent(Event::create(EventTypeNames::success));
    135 }
    136 
    137 bool IDBOpenDBRequest::shouldEnqueueEvent() const
    138 {
    139     if (m_contextStopped || !executionContext())
    140         return false;
    141     ASSERT(m_readyState == PENDING || m_readyState == DONE);
    142     if (m_requestAborted)
    143         return false;
    144     return true;
    145 }
    146 
    147 bool IDBOpenDBRequest::dispatchEvent(PassRefPtr<Event> event)
    148 {
    149     // If the connection closed between onUpgradeNeeded and the delivery of the "success" event,
    150     // an "error" event should be fired instead.
    151     if (event->type() == EventTypeNames::success && resultAsAny()->type() == IDBAny::IDBDatabaseType && resultAsAny()->idbDatabase()->isClosePending()) {
    152         dequeueEvent(event.get());
    153         setResult(0);
    154         onError(DOMError::create(AbortError, "The connection was closed."));
    155         return false;
    156     }
    157 
    158     return IDBRequest::dispatchEvent(event);
    159 }
    160 
    161 } // namespace WebCore
    162