|  | // Copyright 2019 The Chromium Authors | 
|  | // Use of this source code is governed by a BSD-style license that can be | 
|  | // found in the LICENSE file. | 
|  |  | 
|  | #include "storage/browser/test/fake_blob_data_handle.h" | 
|  |  | 
|  | #include "base/compiler_specific.h" | 
|  | #include "base/containers/span.h" | 
|  | #include "base/functional/bind.h" | 
|  | #include "base/numerics/safe_conversions.h" | 
|  | #include "net/base/net_errors.h" | 
|  |  | 
|  | namespace storage { | 
|  |  | 
|  | FakeBlobDataHandle::FakeBlobDataHandle(std::string body_data, | 
|  | std::string side_data) | 
|  | : body_data_(std::move(body_data)), side_data_(std::move(side_data)) {} | 
|  |  | 
|  | uint64_t FakeBlobDataHandle::GetSize() const { | 
|  | return body_data_.size(); | 
|  | } | 
|  |  | 
|  | void FakeBlobDataHandle::Read(mojo::ScopedDataPipeProducerHandle producer, | 
|  | uint64_t src_offset, | 
|  | uint64_t bytes_to_read, | 
|  | base::OnceCallback<void(int)> callback) { | 
|  | if (src_offset >= body_data_.size()) { | 
|  | std::move(callback).Run(net::ERR_FAILED); | 
|  | return; | 
|  | } | 
|  |  | 
|  | base::span<const uint8_t> bytes = base::as_byte_span(body_data_); | 
|  | bytes = bytes.subspan(static_cast<size_t>(src_offset)); | 
|  | bytes = bytes.first(base::checked_cast<size_t>(bytes_to_read)); | 
|  | MojoResult result = producer->WriteAllData(bytes); | 
|  |  | 
|  | // This should all succeed. | 
|  | DCHECK_EQ(MOJO_RESULT_OK, result); | 
|  |  | 
|  | // The callback expects a `net::Error` only and not the number of bytes read. | 
|  | std::move(callback).Run(net::OK); | 
|  | } | 
|  |  | 
|  | uint64_t FakeBlobDataHandle::GetSideDataSize() const { | 
|  | return side_data_.size(); | 
|  | } | 
|  |  | 
|  | void FakeBlobDataHandle::ReadSideData( | 
|  | base::OnceCallback<void(int, mojo_base::BigBuffer)> callback) { | 
|  | if (side_data_.size() == 0) { | 
|  | std::move(callback).Run(side_data_.size(), mojo_base::BigBuffer()); | 
|  | return; | 
|  | } | 
|  |  | 
|  | mojo_base::BigBuffer buffer(side_data_.size()); | 
|  | UNSAFE_TODO(memcpy(buffer.data(), side_data_.data(), side_data_.size())); | 
|  |  | 
|  | std::move(callback).Run(side_data_.size(), std::move(buffer)); | 
|  | } | 
|  |  | 
|  | FakeBlobDataHandle::~FakeBlobDataHandle() = default; | 
|  |  | 
|  | }  // namespace storage |