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

#ifndef IOS_CHROME_BROWSER_DRIVE_MODEL_DRIVE_TAB_HELPER_H_
#define IOS_CHROME_BROWSER_DRIVE_MODEL_DRIVE_TAB_HELPER_H_

#import "base/memory/raw_ptr.h"
#import "base/scoped_observation.h"
#import "ios/chrome/browser/drive/model/upload_task_observer.h"
#import "ios/web/public/download/download_task.h"
#import "ios/web/public/download/download_task_observer.h"
#import "ios/web/public/web_state_observer.h"
#import "ios/web/public/web_state_user_data.h"

class DriveUploadTask;
class DriveTabHelperTest;
@protocol SystemIdentity;
class UploadTask;

namespace enterprise_connectors {
class FilesRequestHandlerBase;
class ContentAnalysisInfo;
}  // namespace enterprise_connectors

// Manages Save to Drive tab-scoped state i.e. if a `DownloadTask` is received
// through AddDownloadToSaveToDrive(...) then this tab helper
// - 1 - memorises the task, what `SystemIdentity` will be used to save the
// downloaded file to Drive, etc.
// - 2 - observes the `DownloadTask` and uploads the downloaded file using the
// Drive service upon completion of the download task.
// - 3 - observes the `UploadTask` and removes the local copy of the downloaded
// file upon completion of the upload task.
class DriveTabHelper : public web::WebStateUserData<DriveTabHelper>,
                       public web::DownloadTaskObserver,
                       public UploadTaskObserver {
 public:
  DriveTabHelper(const DriveTabHelper&) = delete;
  DriveTabHelper& operator=(const DriveTabHelper&) = delete;
  ~DriveTabHelper() override;

  // Adds a DownloadTask to Save to Drive. This download task will be observed
  // and the downloaded file will be uploaded to Drive.
  void AddDownloadToSaveToDrive(web::DownloadTask* task,
                                id<SystemIdentity> identity);
  // Returns the upload task associated with `download_task`, if any.
  UploadTask* GetUploadTaskForDownload(web::DownloadTask* task);

 private:
  friend class DriveTabHelperTest;
  friend class web::WebStateUserData<DriveTabHelper>;
  explicit DriveTabHelper(web::WebState* web_state);

  // web::DownloadTaskObserver overrides:
  void OnDownloadUpdated(web::DownloadTask* task) override;
  void OnDownloadDestroyed(web::DownloadTask* task) override;

  // UploadTaskObserver overrides:
  void OnUploadUpdated(UploadTask* task) override;
  void OnUploadDestroyed(UploadTask* task) override;

  // Resets `download_task_observation_` and `upload_task_`. If `task` and
  // `identity` are non-nil, `task` will be observed and a new upload task will
  // be created with identity.
  void ResetSaveToDriveData(web::DownloadTask* task,
                            id<SystemIdentity> identity);

  // Removes the local copy of the downloaded file if it exists.
  void RemoveIfFileExists(base::FilePath task_path,
                          bool file_exists);

  // Checks if the remove has been completed.
  void RemoveComplete(bool remove_completed);

  // Process the complete download task and upload the download item to Google
  // Drive.
  void ProcessCompleteDownloadTask(web::DownloadTask* task);

  // Upload the download item to google drive if `should_proceed` is true,
  // otherwise cancel the task.
  void MaybeUploadDownloadToDrive(web::DownloadTask* task, bool should_proceed);

  // Associated WebState.
  raw_ptr<web::WebState> web_state_;

  // Scoped observation to observe the `DownloadTask`.
  using ScopedDownloadTaskObservation =
      base::ScopedObservation<web::DownloadTask, web::DownloadTaskObserver>;
  ScopedDownloadTaskObservation download_task_observation_{this};
  // Scoped observation to observe the `UploadTask`.
  using ScopedUploadTaskObservation =
      base::ScopedObservation<UploadTask, UploadTaskObserver>;
  ScopedUploadTaskObservation upload_task_observation_{this};
  // Drive upload task associated with the observed download task. Should be
  // started as soon as the download task is completed.
  std::unique_ptr<DriveUploadTask> upload_task_;

  // Enterprise content scanning metadata.
  std::unique_ptr<enterprise_connectors::ContentAnalysisInfo>
      content_analysis_info_;
  // Request handler for enterprise content scanning.
  std::unique_ptr<enterprise_connectors::FilesRequestHandlerBase>
      files_request_handler_;
  // Tracks whether completion processing has been initiated for the current
  // download task. This prevents duplicate triggers of
  // `ProcessCompleteDownloadTask` when subsequent properties are updated
  // while the task remains in the `kComplete` state.
  // Reset to false in `ResetSaveToDriveData()`.
  bool has_processed_complete_task_ = false;

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

#endif  // IOS_CHROME_BROWSER_DRIVE_MODEL_DRIVE_TAB_HELPER_H_