chrome/browser/ash/file_system_provider/request_dispatcher_impl.h

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

#ifndef CHROME_BROWSER_ASH_FILE_SYSTEM_PROVIDER_REQUEST_DISPATCHER_IMPL_H_
#define CHROME_BROWSER_ASH_FILE_SYSTEM_PROVIDER_REQUEST_DISPATCHER_IMPL_H_

#include <memory>

#include "base/files/file.h"
#include "base/functional/callback.h"
#include "base/memory/weak_ptr.h"
#include "chrome/browser/ash/file_system_provider/request_dispatcher.h"
#include "chromeos/crosapi/mojom/file_system_provider.mojom-forward.h"
#include "extensions/common/extension_id.h"

namespace extensions {
class EventRouter;

namespace file_system_provider {
class ServiceWorkerLifetimeManager;
}  // namespace file_system_provider

}  // namespace extensions

namespace ash::file_system_provider {

// Routes fileSystemProvider events to an extension locally or in Lacros.
class RequestDispatcherImpl : public RequestDispatcher {
 public:
  // This callback is an indirection to reject requests in |RequestManager|: the
  // dispatcher cannot depend on request manager directly as it needs to outlive
  // the request manager the request manager accesses the dispatcher in the
  // destructor when it aborts outstanding operations.
  using ForwardResultCallback =
      base::RepeatingCallback<void(int, base::File::Error)>;
  RequestDispatcherImpl(
      const extensions::ExtensionId& extension_id,
      extensions::EventRouter* event_router,
      ForwardResultCallback forward_result_callback,
      extensions::file_system_provider::ServiceWorkerLifetimeManager*
          sw_lifetime_manager);
  ~RequestDispatcherImpl() override;

  RequestDispatcherImpl(const RequestDispatcherImpl&) = delete;
  RequestDispatcherImpl& operator=(const RequestDispatcherImpl&) = delete;

  bool DispatchRequest(int request_id,
                       absl::optional<std::string> file_system_id,
                       std::unique_ptr<extensions::Event> event) override;
  void CancelRequest(int request_id,
                     absl::optional<std::string> file_system_id) override;

 private:
  // This method is only used when Lacros is enabled. It's a callback from
  // Lacros indicating whether the operation was successfully forwarded. If the
  // operation could not be forwarded then the file system request manager must
  // be informed.
  void OperationForwarded(int request_id,
                          crosapi::mojom::FSPForwardResult result);
  // Same as |OperationForwarded|, but called with a result of call to an older
  // crosapi returning a boolean.
  void OperationForwardedDeprecated(int request_id, bool delivery_failure);

  const extensions::ExtensionId extension_id_;
  const raw_ptr<extensions::EventRouter> event_router_;
  const ForwardResultCallback forward_result_callback_;
  const raw_ptr<extensions::file_system_provider::ServiceWorkerLifetimeManager>
      sw_lifetime_manager_;

  base::WeakPtrFactory<RequestDispatcherImpl> weak_ptr_factory_{this};
};

}  // namespace ash::file_system_provider

#endif  // CHROME_BROWSER_ASH_FILE_SYSTEM_PROVIDER_REQUEST_DISPATCHER_IMPL_H_