#ifndef IDBTransaction_h
#define IDBTransaction_h
#include "bindings/v8/ScriptWrappable.h"
#include "core/dom/ActiveDOMObject.h"
#include "core/dom/DOMError.h"
#include "core/events/Event.h"
#include "core/events/EventListener.h"
#include "core/events/EventTarget.h"
#include "heap/Handle.h"
#include "modules/indexeddb/IDBMetadata.h"
#include "modules/indexeddb/IndexedDB.h"
#include "public/platform/WebIDBDatabase.h"
#include "wtf/HashSet.h"
#include "wtf/RefCounted.h"
namespace WebCore {
class DOMError;
class ExceptionState;
class IDBCursor;
class IDBDatabase;
class IDBObjectStore;
class IDBOpenDBRequest;
struct IDBObjectStoreMetadata;
class IDBTransaction FINAL : public ScriptWrappable, public RefCounted<IDBTransaction>, public EventTargetWithInlineData, public ActiveDOMObject {
REFCOUNTED_EVENT_TARGET(IDBTransaction);
public:
static PassRefPtr<IDBTransaction> create(ExecutionContext*, int64_t, const Vector<String>& objectStoreNames, blink::WebIDBDatabase::TransactionMode, IDBDatabase*);
static PassRefPtr<IDBTransaction> create(ExecutionContext*, int64_t, IDBDatabase*, IDBOpenDBRequest*, const IDBDatabaseMetadata& previousMetadata);
virtual ~IDBTransaction();
static const AtomicString& modeReadOnly();
static const AtomicString& modeReadWrite();
static const AtomicString& modeVersionChange();
static blink::WebIDBDatabase::TransactionMode stringToMode(const String&, ExceptionState&);
static const AtomicString& modeToString(blink::WebIDBDatabase::TransactionMode);
blink::WebIDBDatabase* backendDB() const;
int64_t id() const { return m_id; }
bool isActive() const { return m_state == Active; }
bool isFinished() const { return m_state == Finished; }
bool isReadOnly() const { return m_mode == blink::WebIDBDatabase::TransactionReadOnly; }
bool isVersionChange() const { return m_mode == blink::WebIDBDatabase::TransactionVersionChange; }
const String& mode() const;
IDBDatabase* db() const { return m_database.get(); }
PassRefPtrWillBeRawPtr<DOMError> error() const { return m_error; }
PassRefPtr<IDBObjectStore> objectStore(const String& name, ExceptionState&);
void abort(ExceptionState&);
void registerRequest(IDBRequest*);
void unregisterRequest(IDBRequest*);
void objectStoreCreated(const String&, PassRefPtr<IDBObjectStore>);
void objectStoreDeleted(const String&);
void setActive(bool);
void setError(PassRefPtrWillBeRawPtr<DOMError>);
DEFINE_ATTRIBUTE_EVENT_LISTENER(abort);
DEFINE_ATTRIBUTE_EVENT_LISTENER(complete);
DEFINE_ATTRIBUTE_EVENT_LISTENER(error);
void onAbort(PassRefPtrWillBeRawPtr<DOMError>);
void onComplete();
virtual const AtomicString& interfaceName() const OVERRIDE;
virtual ExecutionContext* executionContext() const OVERRIDE;
using EventTarget::dispatchEvent;
virtual bool dispatchEvent(PassRefPtrWillBeRawPtr<Event>) OVERRIDE;
virtual bool hasPendingActivity() const OVERRIDE;
virtual void stop() OVERRIDE;
private:
IDBTransaction(ExecutionContext*, int64_t, const Vector<String>&, blink::WebIDBDatabase::TransactionMode, IDBDatabase*, IDBOpenDBRequest*, const IDBDatabaseMetadata&);
void enqueueEvent(PassRefPtrWillBeRawPtr<Event>);
enum State {
Inactive,
Active,
Finishing,
Finished,
};
int64_t m_id;
RefPtr<IDBDatabase> m_database;
const Vector<String> m_objectStoreNames;
IDBOpenDBRequest* m_openDBRequest;
const blink::WebIDBDatabase::TransactionMode m_mode;
State m_state;
bool m_hasPendingActivity;
bool m_contextStopped;
RefPtrWillBePersistent<DOMError> m_error;
ListHashSet<RefPtr<IDBRequest> > m_requestList;
typedef HashMap<String, RefPtr<IDBObjectStore> > IDBObjectStoreMap;
IDBObjectStoreMap m_objectStoreMap;
typedef HashSet<RefPtr<IDBObjectStore> > IDBObjectStoreSet;
IDBObjectStoreSet m_deletedObjectStores;
typedef HashMap<RefPtr<IDBObjectStore>, IDBObjectStoreMetadata> IDBObjectStoreMetadataMap;
IDBObjectStoreMetadataMap m_objectStoreCleanupMap;
IDBDatabaseMetadata m_previousMetadata;
};
}
#endif