1
    2
    3
    4
    5
    6
    7
    8
    9
   10
   11
   12
   13
   14
   15
   16
   17
   18
   19
   20
   21
   22
   23
   24
   25
   26
   27
   28
   29
   30
   31
   32
   33
   34
   35
   36
   37
   38
   39
   40
   41
   42
   43
   44
   45
   46
   47
   48
   49
   50
   51
   52
   53
   54
   55
   56
   57
   58
   59
   60
   61
   62
   63
   64
   65
   66
   67
   68


content / browser / cache_storage / background_fetch_cache_entry_handler_impl.cc [blame]

// Copyright 2018 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "content/browser/cache_storage/background_fetch_cache_entry_handler_impl.h"

#include "mojo/public/cpp/bindings/remote.h"
#include "third_party/blink/public/common/blob/blob_utils.h"

namespace content {

BackgroundFetchCacheEntryHandlerImpl::BackgroundFetchCacheEntryHandlerImpl(
    scoped_refptr<BlobStorageContextWrapper> blob_storage_context)
    : CacheStorageCacheEntryHandler(std::move(blob_storage_context)) {}

BackgroundFetchCacheEntryHandlerImpl::~BackgroundFetchCacheEntryHandlerImpl() =
    default;

std::unique_ptr<PutContext>
BackgroundFetchCacheEntryHandlerImpl::CreatePutContext(
    blink::mojom::FetchAPIRequestPtr request,
    blink::mojom::FetchAPIResponsePtr response,
    int64_t trace_id) {
  mojo::PendingRemote<blink::mojom::Blob> response_blob;
  uint64_t response_blob_size = blink::BlobUtils::kUnknownSize;
  mojo::PendingRemote<blink::mojom::Blob> request_blob;
  uint64_t request_blob_size = blink::BlobUtils::kUnknownSize;

  if (response->blob) {
    response_blob = std::move(response->blob->blob);
    response_blob_size = response->blob->size;
  }
  if (request->blob) {
    request_blob = std::move(request->blob->blob);
    request_blob_size = request->blob->size;
  }

  return std::make_unique<PutContext>(
      std::move(request), std::move(response), std::move(response_blob),
      response_blob_size, std::move(request_blob), request_blob_size, trace_id);
}

void BackgroundFetchCacheEntryHandlerImpl::PopulateResponseBody(
    scoped_refptr<DiskCacheBlobEntry> blob_entry,
    blink::mojom::FetchAPIResponse* response) {
  response->blob =
      CreateBlob(std::move(blob_entry), CacheStorageCache::INDEX_RESPONSE_BODY);
}

void BackgroundFetchCacheEntryHandlerImpl::PopulateRequestBody(
    scoped_refptr<DiskCacheBlobEntry> blob_entry,
    blink::mojom::FetchAPIRequest* request) {
  if (!blob_entry->disk_cache_entry() ||
      !blob_entry->disk_cache_entry()->GetDataSize(
          CacheStorageCache::INDEX_SIDE_DATA)) {
    return;
  }

  request->blob =
      CreateBlob(std::move(blob_entry), CacheStorageCache::INDEX_SIDE_DATA);
}

base::WeakPtr<CacheStorageCacheEntryHandler>
BackgroundFetchCacheEntryHandlerImpl::GetWeakPtr() {
  return weak_ptr_factory_.GetWeakPtr();
}

}  // namespace content