Home | History | Annotate | Download | only in file_manager 
      1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
      2 // Use of this source code is governed by a BSD-style license that can be
      3 // found in the LICENSE file.
      4 
      5 #ifndef CHROME_BROWSER_CHROMEOS_EXTENSIONS_FILE_MANAGER_EVENT_ROUTER_H_
      6 #define CHROME_BROWSER_CHROMEOS_EXTENSIONS_FILE_MANAGER_EVENT_ROUTER_H_
      7 
      8 #include <map>
      9 #include <string>
     10 
     11 #include "base/files/file_path_watcher.h"
     12 #include "base/memory/scoped_ptr.h"
     13 #include "chrome/browser/chromeos/drive/drive_integration_service.h"
     14 #include "chrome/browser/chromeos/drive/file_system_observer.h"
     15 #include "chrome/browser/chromeos/drive/job_list.h"
     16 #include "chrome/browser/chromeos/extensions/file_manager/file_watcher.h"
     17 #include "chrome/browser/drive/drive_service_interface.h"
     18 #include "chromeos/disks/disk_mount_manager.h"
     19 #include "chromeos/network/network_state_handler_observer.h"
     20 
     21 class PrefChangeRegistrar;
     22 class Profile;
     23 
     24 namespace chromeos {
     25 class NetworkState;
     26 }
     27 
     28 namespace file_manager {
     29 
     30 class DesktopNotifications;
     31 class MountedDiskMonitor;
     32 
     33 // Monitors changes in disk mounts, network connection state and preferences
     34 // affecting File Manager. Dispatches appropriate File Browser events.
     35 class EventRouter
     36     : public chromeos::disks::DiskMountManager::Observer,
     37       public chromeos::NetworkStateHandlerObserver,
     38       public drive::DriveIntegrationServiceObserver,
     39       public drive::FileSystemObserver,
     40       public drive::JobListObserver,
     41       public drive::DriveServiceObserver {
     42  public:
     43   explicit EventRouter(Profile* profile);
     44   virtual ~EventRouter();
     45 
     46   void Shutdown();
     47 
     48   // Starts observing file system change events.
     49   void ObserveFileSystemEvents();
     50 
     51   typedef base::Callback<void(bool success)> BoolCallback;
     52 
     53   // Adds a file watch at |local_path|, associated with |virtual_path|, for
     54   // an extension with |extension_id|.
     55   //
     56   // |callback| will be called with true on success, or false on failure.
     57   // |callback| must not be null.
     58   void AddFileWatch(const base::FilePath& local_path,
     59                     const base::FilePath& virtual_path,
     60                     const std::string& extension_id,
     61                     const BoolCallback& callback);
     62 
     63   // Removes a file watch at |local_path| for an extension with |extension_id|.
     64   void RemoveFileWatch(const base::FilePath& local_path,
     65                        const std::string& extension_id);
     66 
     67   // CrosDisksClient::Observer overrides.
     68   virtual void OnDiskEvent(
     69       chromeos::disks::DiskMountManager::DiskEvent event,
     70       const chromeos::disks::DiskMountManager::Disk* disk) OVERRIDE;
     71   virtual void OnDeviceEvent(
     72       chromeos::disks::DiskMountManager::DeviceEvent event,
     73       const std::string& device_path) OVERRIDE;
     74   virtual void OnMountEvent(
     75       chromeos::disks::DiskMountManager::MountEvent event,
     76       chromeos::MountError error_code,
     77       const chromeos::disks::DiskMountManager::MountPointInfo& mount_info)
     78       OVERRIDE;
     79   virtual void OnFormatEvent(
     80       chromeos::disks::DiskMountManager::FormatEvent event,
     81       chromeos::FormatError error_code,
     82       const std::string& device_path) OVERRIDE;
     83 
     84   // chromeos::NetworkStateHandlerObserver overrides.
     85   virtual void NetworkManagerChanged() OVERRIDE;
     86   virtual void DefaultNetworkChanged(
     87       const chromeos::NetworkState* network) OVERRIDE;
     88 
     89   // drive::JobListObserver overrides.
     90   virtual void OnJobAdded(const drive::JobInfo& job_info) OVERRIDE;
     91   virtual void OnJobUpdated(const drive::JobInfo& job_info) OVERRIDE;
     92   virtual void OnJobDone(const drive::JobInfo& job_info,
     93                          drive::FileError error) OVERRIDE;
     94 
     95   // drive::DriveServiceObserver overrides.
     96   virtual void OnRefreshTokenInvalid() OVERRIDE;
     97 
     98   // drive::FileSystemObserver overrides.
     99   virtual void OnDirectoryChanged(
    100       const base::FilePath& directory_path) OVERRIDE;
    101 
    102   // drive::DriveIntegrationServiceObserver overrides.
    103   virtual void OnFileSystemMounted() OVERRIDE;
    104   virtual void OnFileSystemBeingUnmounted() OVERRIDE;
    105 
    106  private:
    107   typedef std::map<base::FilePath, FileWatcher*> WatcherMap;
    108 
    109   // USB mount event handlers.
    110   void OnDiskAdded(const chromeos::disks::DiskMountManager::Disk* disk);
    111   void OnDiskRemoved(const chromeos::disks::DiskMountManager::Disk* disk);
    112   void OnDiskMounted(const chromeos::disks::DiskMountManager::Disk* disk);
    113   void OnDiskUnmounted(const chromeos::disks::DiskMountManager::Disk* disk);
    114   void OnDeviceAdded(const std::string& device_path);
    115   void OnDeviceRemoved(const std::string& device_path);
    116   void OnDeviceScanned(const std::string& device_path);
    117   void OnFormatStarted(const std::string& device_path, bool success);
    118   void OnFormatCompleted(const std::string& device_path, bool success);
    119 
    120   // Called on change to kExternalStorageDisabled pref.
    121   void OnExternalStorageDisabledChanged();
    122 
    123   // Called when prefs related to file manager change.
    124   void OnFileManagerPrefsChanged();
    125 
    126   // Process file watch notifications.
    127   void HandleFileWatchNotification(const base::FilePath& path,
    128                                    bool got_error);
    129 
    130   // Sends directory change event.
    131   void DispatchDirectoryChangeEvent(
    132       const base::FilePath& path,
    133       bool error,
    134       const std::vector<std::string>& extension_ids);
    135 
    136   void DispatchMountEvent(
    137       chromeos::disks::DiskMountManager::MountEvent event,
    138       chromeos::MountError error_code,
    139       const chromeos::disks::DiskMountManager::MountPointInfo& mount_info);
    140 
    141   // If needed, opens a file manager window for the removable device mounted at
    142   // |mount_path|. Disk.mount_path() is empty, since it is being filled out
    143   // after calling notifying observers by DiskMountManager.
    144   void ShowRemovableDeviceInFileManager(
    145       const chromeos::disks::DiskMountManager::Disk& disk,
    146       const base::FilePath& mount_path);
    147 
    148   // Sends onFileTranferUpdated to extensions if needed. If |always| is true,
    149   // it sends the event always. Otherwise, it sends the event if enough time has
    150   // passed from the previous event so as not to make extension busy.
    151   void SendDriveFileTransferEvent(bool always);
    152 
    153   // Manages the list of currently active Drive file transfer jobs.
    154   struct DriveJobInfoWithStatus {
    155     DriveJobInfoWithStatus();
    156     DriveJobInfoWithStatus(const drive::JobInfo& info,
    157                            const std::string& status);
    158     drive::JobInfo job_info;
    159     std::string status;
    160   };
    161   std::map<drive::JobID, DriveJobInfoWithStatus> drive_jobs_;
    162   base::Time last_file_transfer_event_;
    163 
    164   WatcherMap file_watchers_;
    165   scoped_ptr<DesktopNotifications> notifications_;
    166   scoped_ptr<PrefChangeRegistrar> pref_change_registrar_;
    167   scoped_ptr<MountedDiskMonitor> mounted_disk_monitor_;
    168   Profile* profile_;
    169 
    170   // Note: This should remain the last member so it'll be destroyed and
    171   // invalidate the weak pointers before any other members are destroyed.
    172   base::WeakPtrFactory<EventRouter> weak_factory_;
    173   DISALLOW_COPY_AND_ASSIGN(EventRouter);
    174 };
    175 
    176 }  // namespace file_manager
    177 
    178 #endif  // CHROME_BROWSER_CHROMEOS_EXTENSIONS_FILE_MANAGER_EVENT_ROUTER_H_
    179