blob: 59d774b5c8e39b0a0bdb2073357f6b46819249ae [file] [log] [blame]
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef CONTENT_RENDERER_INDEXED_DB_DISPATCHER_H_
#define CONTENT_RENDERER_INDEXED_DB_DISPATCHER_H_
#pragma once
#include "base/id_map.h"
#include "base/nullable_string16.h"
#include "ipc/ipc_channel.h"
#include "third_party/WebKit/Source/WebKit/chromium/public/WebExceptionCode.h"
#include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBCallbacks.h"
#include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBDatabase.h"
#include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBObjectStore.h"
#include "third_party/WebKit/Source/WebKit/chromium/public/WebIDBTransactionCallbacks.h"
class IndexedDBKey;
class SerializedScriptValue;
namespace WebKit {
class WebFrame;
class WebIDBKeyRange;
class WebIDBTransaction;
}
// Handle the indexed db related communication for this entire renderer.
class IndexedDBDispatcher : public IPC::Channel::Listener {
public:
IndexedDBDispatcher();
virtual ~IndexedDBDispatcher();
// IPC::Channel::Listener implementation.
virtual bool OnMessageReceived(const IPC::Message& msg);
void RequestIDBFactoryOpen(
const string16& name,
WebKit::WebIDBCallbacks* callbacks,
const string16& origin,
WebKit::WebFrame* web_frame,
uint64 maximum_size);
void RequestIDBFactoryDeleteDatabase(
const string16& name,
WebKit::WebIDBCallbacks* callbacks,
const string16& origin,
WebKit::WebFrame* web_frame);
void RequestIDBCursorUpdate(
const SerializedScriptValue& value,
WebKit::WebIDBCallbacks* callbacks_ptr,
int32 idb_cursor_id,
WebKit::WebExceptionCode* ec);
void RequestIDBCursorContinue(
const IndexedDBKey& key,
WebKit::WebIDBCallbacks* callbacks_ptr,
int32 idb_cursor_id,
WebKit::WebExceptionCode* ec);
void RequestIDBCursorDelete(
WebKit::WebIDBCallbacks* callbacks_ptr,
int32 idb_cursor_id,
WebKit::WebExceptionCode* ec);
void RequestIDBDatabaseClose(
int32 idb_database_id);
void RequestIDBDatabaseOpen(
WebKit::WebIDBDatabaseCallbacks* callbacks_ptr,
int32 idb_database_id);
void RequestIDBDatabaseSetVersion(
const string16& version,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_database_id,
WebKit::WebExceptionCode* ec);
void RequestIDBIndexOpenObjectCursor(
const WebKit::WebIDBKeyRange& idb_key_range,
unsigned short direction,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_index_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RequestIDBIndexOpenKeyCursor(
const WebKit::WebIDBKeyRange& idb_key_range,
unsigned short direction,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_index_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RequestIDBIndexGetObject(const IndexedDBKey& key,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_index_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RequestIDBIndexGetKey(const IndexedDBKey& key,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_index_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RequestIDBObjectStoreGet(const IndexedDBKey& key,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_object_store_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RequestIDBObjectStorePut(const SerializedScriptValue& value,
const IndexedDBKey& key,
WebKit::WebIDBObjectStore::PutMode putMode,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_object_store_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RequestIDBObjectStoreDelete(
const IndexedDBKey& key,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_object_store_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RequestIDBObjectStoreClear(
WebKit::WebIDBCallbacks* callbacks,
int32 idb_object_store_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RequestIDBObjectStoreOpenCursor(
const WebKit::WebIDBKeyRange& idb_key_range,
unsigned short direction,
WebKit::WebIDBCallbacks* callbacks,
int32 idb_object_store_id,
const WebKit::WebIDBTransaction& transaction,
WebKit::WebExceptionCode* ec);
void RegisterWebIDBTransactionCallbacks(
WebKit::WebIDBTransactionCallbacks* callbacks,
int32 id);
static int32 TransactionId(const WebKit::WebIDBTransaction& transaction);
private:
// IDBCallback message handlers.
void OnSuccessNull(int32 response_id);
void OnSuccessIDBDatabase(int32 response_id, int32 object_id);
void OnSuccessIndexedDBKey(int32 response_id, const IndexedDBKey& key);
void OnSuccessIDBTransaction(int32 response_id, int32 object_id);
void OnSuccessOpenCursor(int32 response_id, int32 object_id);
void OnSuccessSerializedScriptValue(int32 response_id,
const SerializedScriptValue& value);
void OnError(int32 response_id, int code, const string16& message);
void OnBlocked(int32 response_id);
void OnAbort(int32 transaction_id);
void OnComplete(int32 transaction_id);
void OnVersionChange(int32 database_id, const string16& newVersion);
// Careful! WebIDBCallbacks wraps non-threadsafe data types. It must be
// destroyed and used on the same thread it was created on.
IDMap<WebKit::WebIDBCallbacks, IDMapOwnPointer> pending_callbacks_;
IDMap<WebKit::WebIDBTransactionCallbacks, IDMapOwnPointer>
pending_transaction_callbacks_;
IDMap<WebKit::WebIDBDatabaseCallbacks, IDMapOwnPointer>
pending_database_callbacks_;
DISALLOW_COPY_AND_ASSIGN(IndexedDBDispatcher);
};
#endif // CONTENT_RENDERER_INDEXED_DB_DISPATCHER_H_