// 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 "third_party/blink/renderer/modules/cache_storage/cache_utils.h"

#include <utility>

#include "third_party/blink/renderer/core/fetch/fetch_response_data.h"
#include "third_party/blink/renderer/core/fetch/response.h"
#include "third_party/blink/renderer/modules/cache_storage/cache_storage_blob_client_list.h"
#include "third_party/blink/renderer/platform/loader/fetch/data_pipe_bytes_consumer.h"

namespace blink {

Response* CreateEagerResponse(ScriptState* script_state,
                              mojom::blink::EagerResponsePtr eager_response,
                              CacheStorageBlobClientList* client_list) {
  auto& response = eager_response->response;
  DCHECK(!response->blob);

  ExecutionContext* context = ExecutionContext::From(script_state);

  FetchResponseData* fetch_data =
      Response::CreateUnfilteredFetchResponseDataWithoutBody(script_state,
                                                             *response);

  DataPipeBytesConsumer::CompletionNotifier* completion_notifier = nullptr;
  fetch_data->ReplaceBodyStreamBuffer(BodyStreamBuffer::Create(
      script_state,
      MakeGarbageCollected<DataPipeBytesConsumer>(
          context->GetTaskRunner(TaskType::kNetworking),
          std::move(eager_response->pipe), &completion_notifier),
      nullptr /* AbortSignal */, /*cached_metadata_handler=*/nullptr,
      std::move(response->side_data_blob)));

  // Create a BlobReaderClient in the provided list.  This will track the
  // completion of the eagerly read blob and propagate it to the given
  // DataPipeBytesConsumer::CompletionNotifier.  The list will also hold
  // the client alive.
  client_list->AddClient(context, std::move(eager_response->client_receiver),
                         std::move(completion_notifier));

  fetch_data = Response::FilterResponseData(
      response->response_type, fetch_data, response->cors_exposed_header_names);

  return Response::Create(context, fetch_data);
}

}  // namespace blink