blob: f26139d69860b40480763afd84c4d5c274e0de43 [file] [log] [blame]
// Copyright 2016 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include <fuchsia/ledger/cloud/cpp/fidl.h>
#include <lib/fidl/cpp/array.h>
#include <lib/fit/function.h>
#include <lib/fxl/memory/weak_ptr.h>
#include "peridot/bin/ledger/encryption/public/encryption_service.h"
#include "peridot/bin/ledger/fidl/include/types.h"
#include "peridot/bin/ledger/storage/public/page_storage.h"
#include "peridot/lib/commit_pack/commit_pack.h"
namespace cloud_sync {
// Adds a batch of remote commits to storage.
// Given a list of commit metadata, this class makes a request to add them to
// storage, and waits until storage confirms that the operation completed before
// calling |on_done|.
// The operation is not retryable, and errors reported through |on_error| are
// not recoverable.
class BatchDownload {
BatchDownload(storage::PageStorage* storage,
encryption::EncryptionService* encryption_service,
std::vector<cloud_provider::CommitPackEntry> entries,
std::unique_ptr<cloud_provider::Token> position_token,
fit::closure on_done, fit::closure on_error);
// Can be called only once.
void Start();
void UpdateTimestampAndQuit();
storage::PageStorage* const storage_;
encryption::EncryptionService* const encryption_service_;
std::vector<cloud_provider::CommitPackEntry> entries_;
std::unique_ptr<cloud_provider::Token> position_token_;
fit::closure on_done_;
fit::closure on_error_;
bool started_ = false;
// Must be the last member.
fxl::WeakPtrFactory<BatchDownload> weak_ptr_factory_;
} // namespace cloud_sync