| // Copyright 2017 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 "peridot/bin/ledger/testing/get_ledger.h" |
| |
| #include <fcntl.h> |
| #include <utility> |
| |
| #include <fuchsia/ledger/internal/cpp/fidl.h> |
| #include <fuchsia/sys/cpp/fidl.h> |
| #include <lib/async/cpp/task.h> |
| #include <lib/callback/capture.h> |
| #include <lib/fidl/cpp/interface_request.h> |
| #include <lib/fit/function.h> |
| #include <lib/fsl/io/fd.h> |
| #include <lib/fxl/files/unique_fd.h> |
| #include <lib/fxl/logging.h> |
| #include <lib/svc/cpp/services.h> |
| |
| #include "peridot/bin/ledger/fidl/include/types.h" |
| #include "peridot/bin/ledger/filesystem/detached_path.h" |
| #include "peridot/lib/convert/convert.h" |
| |
| namespace ledger { |
| void GetLedger(component::StartupContext* context, |
| fidl::InterfaceRequest<fuchsia::sys::ComponentController> |
| controller_request, |
| cloud_provider::CloudProviderPtr cloud_provider, |
| std::string ledger_name, |
| const DetachedPath& ledger_repository_path, |
| fit::function<void()> error_handler, |
| fit::function<void(Status, LedgerPtr)> callback) { |
| auto repository_factory = |
| std::make_unique<ledger_internal::LedgerRepositoryFactoryPtr>(); |
| component::Services child_services; |
| fuchsia::sys::LaunchInfo launch_info; |
| launch_info.url = "ledger"; |
| launch_info.directory_request = child_services.NewRequest(); |
| launch_info.arguments.push_back("--disable_reporting"); |
| |
| context->launcher()->CreateComponent(std::move(launch_info), |
| std::move(controller_request)); |
| child_services.ConnectToService(repository_factory->NewRequest()); |
| |
| auto repository_factory_ptr = repository_factory->get(); |
| auto repository = std::make_unique<ledger_internal::LedgerRepositoryPtr>(); |
| auto request = repository->NewRequest(); |
| |
| fxl::UniqueFD dir(openat(ledger_repository_path.root_fd(), |
| ledger_repository_path.path().c_str(), O_PATH)); |
| if (!dir.is_valid()) { |
| FXL_LOG(ERROR) << "Unable to open directory at " |
| << ledger_repository_path.path() << ". errno: " << errno; |
| callback(Status::IO_ERROR, nullptr); |
| return; |
| } |
| |
| repository_factory_ptr->GetRepository( |
| fsl::CloneChannelFromFileDescriptor(dir.get()), std::move(cloud_provider), |
| std::move(request), |
| [repository_factory = std::move(repository_factory), |
| repository = std::move(repository), ledger_name = std::move(ledger_name), |
| ledger_repository_path, error_handler = std::move(error_handler), |
| callback = std::move(callback)](Status status) mutable { |
| if (status != Status::OK) { |
| FXL_LOG(ERROR) << "Failure while getting repository."; |
| callback(status, nullptr); |
| return; |
| } |
| |
| auto repository_ptr = repository->get(); |
| auto ledger = std::make_unique<LedgerPtr>(); |
| auto request = ledger->NewRequest(); |
| repository_ptr->GetLedger( |
| convert::ToArray(ledger_name), std::move(request), |
| [repository = std::move(repository), ledger = std::move(ledger), |
| error_handler = std::move(error_handler), |
| callback = std::move(callback)](Status status) mutable { |
| if (status != Status::OK) { |
| FXL_LOG(ERROR) << "Failure while getting ledger."; |
| callback(status, nullptr); |
| return; |
| } |
| ledger->set_error_handler([error_handler = |
| std::move(error_handler)] { |
| FXL_LOG(ERROR) << "The ledger connection was closed, quitting."; |
| error_handler(); |
| }); |
| callback(Status::OK, std::move(*ledger)); |
| }); |
| }); |
| } |
| |
| void KillLedgerProcess(fuchsia::sys::ComponentControllerPtr* controller) { |
| (*controller)->Kill(); |
| auto channel = controller->Unbind().TakeChannel(); |
| zx_signals_t observed; |
| channel.wait_one(ZX_CHANNEL_PEER_CLOSED, zx::deadline_after(zx::sec(5)), |
| &observed); |
| } |
| |
| } // namespace ledger |