Files.app: Add JobEventRouter class that handles Job related events of Files.app.

chrome/browser/chromeos/extensions/file_manager/job_event_router.h

Index: chrome/browser/chromeos/extensions/file_manager/job_event_router.h
diff --git a/chrome/browser/chromeos/extensions/file_manager/job_event_router.h b/chrome/browser/chromeos/extensions/file_manager/job_event_router.h
new file mode 100644
index 0000000000000000000000000000000000000000..e3c8672d579f8dd25f06e9f67721beb2a4d4f638
--- /dev/null
+++ b/chrome/browser/chromeos/extensions/file_manager/job_event_router.h
@@ -0,0 +1,89 @@
+// Copyright 2015 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+#ifndef CHROME_BROWSER_CHROMEOS_EXTENSIONS_FILE_MANAGER_JOB_EVENT_ROUTER_H_
+#define CHROME_BROWSER_CHROMEOS_EXTENSIONS_FILE_MANAGER_JOB_EVENT_ROUTER_H_
+
+#include <map>
+#include <string>
+
+#include "base/memory/scoped_ptr.h"
+#include "base/memory/weak_ptr.h"
+#include "base/threading/thread_checker.h"
+#include "base/time/time.h"
+#include "base/values.h"
+#include "chrome/browser/chromeos/drive/job_list.h"
+#include "chrome/common/extensions/api/file_manager_private.h"
+#include "url/gurl.h"
+
+namespace file_manager {
+
+// Files.app's event router handling job related events.
+class JobEventRouter : public drive::JobListObserver {
+ public:
+  explicit JobEventRouter(const base::TimeDelta& event_delay);
+  ~JobEventRouter() override;
+
+  // drive::JobListObserver overrides.
+  void OnJobAdded(const drive::JobInfo& job_info) override;
+  void OnJobUpdated(const drive::JobInfo& job_info) override;
+  void OnJobDone(const drive::JobInfo& job_info,
+                 drive::FileError error) override;
+
+ protected:
+  // Helper method to convert drive path to file system URL.
+  virtual GURL ConvertDrivePathToFileSystemUrl(const base::FilePath& path,
+                                               const std::string& id) const = 0;
+
+  // Helper method to dispatch events.
+  virtual void BroadcastEvent(const std::string& event_name,
+                              scoped_ptr<base::ListValue> event_args) = 0;
+
+ private:
+  // Request sending transfer event with |job_info| and |state|.
+  // If |immediate| is true, the event will be dispatched synchronously.
+  // Otherwise, the event is throttled, or may be skipped.
+  void ScheduleDriveFileTransferEvent(
+      const drive::JobInfo& job_info,
+      extensions::api::file_manager_private::TransferState state,
+      bool immediate);
+
+  // Send transfer event requested by ScheduleDriveFileTransferEvent at last.
+  void SendDriveFileTransferEvent();
+
+  // Update |num_completed_bytes_| and |num_total_bytes_| depends on |job|.
+  void UpdateBytes(const drive::JobInfo& job_info);
+
+  // Delay time before sending progress events.
+  base::TimeDelta event_delay_;
+
+  // Set of job that are in the job schedular.
+  std::map<drive::JobID, linked_ptr<drive::JobInfo>> drive_jobs_;
+
+  // Pending transfer event. |ScheduleDriveFileTransferEvent| registers timeout
+  // callback to dispatch this.
+  scoped_ptr<extensions::api::file_manager_private::FileTransferStatus>
+      pending_event_;
+
+  // Computed bytes of tasks that have been processed. Once it completes all
+  // tasks, it clears the variable.
+  int64 num_completed_bytes_;
+
+  // Total bytes of tasks that have been processed. Once it completes all tasks,
+  // it clears the variable.
+  int64 num_total_bytes_;
+
+  // Thread checker.
+  base::ThreadChecker thread_checker_;
+
+  // Note: This should remain the last member so it'll be destroyed and
+  // invalidate the weak pointers before any other members are destroyed.
+  base::WeakPtrFactory<JobEventRouter> weak_factory_;
+
+  DISALLOW_COPY_AND_ASSIGN(JobEventRouter);
+};
+
+}  // namespace file_manager
+
+#endif  // CHROME_BROWSER_CHROMEOS_EXTENSIONS_FILE_MANAGER_JOB_EVENT_ROUTER_H_