| // Copyright 2019 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 THIRD_PARTY_BLINK_RENDERER_MODULES_INDEXEDDB_WEB_IDB_TRANSACTION_IMPL_H_ |
| #define THIRD_PARTY_BLINK_RENDERER_MODULES_INDEXEDDB_WEB_IDB_TRANSACTION_IMPL_H_ |
| |
| #include <stdint.h> |
| #include <memory> |
| |
| #include "base/single_thread_task_runner.h" |
| #include "mojo/public/cpp/bindings/associated_remote.h" |
| #include "mojo/public/cpp/bindings/pending_associated_receiver.h" |
| #include "third_party/blink/public/common/indexeddb/web_idb_types.h" |
| #include "third_party/blink/public/mojom/indexeddb/indexeddb.mojom-blink-forward.h" |
| #include "third_party/blink/renderer/modules/indexeddb/web_idb_transaction.h" |
| #include "third_party/blink/renderer/modules/modules_export.h" |
| |
| namespace blink { |
| |
| class MODULES_EXPORT WebIDBTransactionImpl : public WebIDBTransaction { |
| public: |
| WebIDBTransactionImpl(scoped_refptr<base::SequencedTaskRunner> task_runner, |
| int64_t transaction_id); |
| ~WebIDBTransactionImpl() override; |
| |
| // WebIDBTransaction |
| void CreateObjectStore(int64_t objectstore_id, |
| const String& name, |
| const IDBKeyPath&, |
| bool auto_increment) override; |
| void DeleteObjectStore(int64_t object_store_id) override; |
| void Put(int64_t object_store_id, |
| std::unique_ptr<IDBValue> value, |
| std::unique_ptr<IDBKey> primary_key, |
| mojom::IDBPutMode, |
| std::unique_ptr<WebIDBCallbacks> callbacks, |
| Vector<IDBIndexKeys>) override; |
| void PutAll(int64_t object_store_id, |
| Vector<mojom::blink::IDBPutParamsPtr> puts, |
| std::unique_ptr<WebIDBCallbacks> callbacks) override; |
| void PutCallback(std::unique_ptr<WebIDBCallbacks> callbacks, |
| mojom::blink::IDBTransactionPutResultPtr result); |
| void PutAllCallback(std::unique_ptr<WebIDBCallbacks> callbacks, |
| mojom::blink::IDBTransactionPutAllResultPtr result); |
| void Commit(int64_t num_errors_handled) override; |
| |
| mojo::PendingAssociatedReceiver<mojom::blink::IDBTransaction> CreateReceiver() |
| override; |
| |
| private: |
| FRIEND_TEST_ALL_PREFIXES(WebIDBTransactionImplTest, ValueSizeTest); |
| FRIEND_TEST_ALL_PREFIXES(WebIDBTransactionImplTest, KeyAndValueSizeTest); |
| |
| // Maximum size (in bytes) of value/key pair allowed for put requests. Any |
| // requests larger than this size will be rejected. |
| // Used by unit tests to exercise behavior without allocating huge chunks |
| // of memory. |
| size_t max_put_value_size_ = |
| mojom::blink::kIDBMaxMessageSize - mojom::blink::kIDBMaxMessageOverhead; |
| |
| mojo::AssociatedRemote<mojom::blink::IDBTransaction> transaction_; |
| scoped_refptr<base::SequencedTaskRunner> task_runner_; |
| int64_t transaction_id_; |
| }; |
| |
| } // namespace blink |
| |
| #endif // THIRD_PARTY_BLINK_RENDERER_MODULES_INDEXEDDB_WEB_IDB_TRANSACTION_IMPL_H_ |