[ew] Add basic classes.

content/public/test/test_file_system_backend.cc

 // Copyright 2013 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.
 
 #include "content/public/test/test_file_system_backend.h"
 
 #include <set>
 #include <string>
 #include <vector>
 
 #include "base/file_util.h"
+#include "base/files/file.h"
+#include "base/memory/weak_ptr.h"
+#include "base/observer_list.h"
 #include "base/sequenced_task_runner.h"
 #include "webkit/browser/blob/file_stream_reader.h"
 #include "webkit/browser/fileapi/copy_or_move_file_validator.h"
 #include "webkit/browser/fileapi/file_observers.h"
 #include "webkit/browser/fileapi/file_system_operation.h"
 #include "webkit/browser/fileapi/file_system_operation_context.h"
 #include "webkit/browser/fileapi/file_system_quota_util.h"
 #include "webkit/browser/fileapi/local_file_util.h"
 #include "webkit/browser/fileapi/native_file_util.h"
 #include "webkit/browser/fileapi/quota/quota_reservation.h"
 #include "webkit/browser/fileapi/sandbox_file_stream_writer.h"
+#include "webkit/browser/fileapi/watcher_manager.h"
 #include "webkit/browser/quota/quota_manager.h"
 #include "webkit/common/fileapi/file_system_util.h"
 
 using fileapi::FileSystemContext;
 using fileapi::FileSystemOperation;
 using fileapi::FileSystemOperationContext;
 using fileapi::FileSystemURL;
 
 namespace content {
 
 namespace {
 
+// Stub implementation of fileapi::LocalFileUtil.
 class TestFileUtil : public fileapi::LocalFileUtil {
  public:
   explicit TestFileUtil(const base::FilePath& base_path)
       : base_path_(base_path) {}
   virtual ~TestFileUtil() {}
 
   // LocalFileUtil overrides.
   virtual base::File::Error GetLocalFilePath(
       FileSystemOperationContext* context,
       const FileSystemURL& file_system_url,
       base::FilePath* local_file_path) OVERRIDE {
     *local_file_path = base_path_.Append(file_system_url.path());
     return base::File::FILE_OK;
   }
 
  private:
   base::FilePath base_path_;
 };
 
+// Stub implementation of fileapi::WatcherManager. Emits a fake notification
+// after a directory watcher is set successfully.
+class TestWatcherManager : public fileapi::WatcherManager {
+ public:
+  TestWatcherManager() : weak_ptr_factory_(this) {}
+  virtual ~TestWatcherManager() {}
+
+  // fileapi::WatcherManager overrides.
+  virtual void AddObserver(Observer* observer) OVERRIDE {
+    observers_.AddObserver(observer);
+  }
+
+  virtual void RemoveObserver(Observer* observer) OVERRIDE {
+    observers_.RemoveObserver(observer);
+  }
+
+  virtual bool HasObserver(Observer* observer) const OVERRIDE {
+    return observers_.HasObserver(observer);
+  }
+
+  virtual void WatchDirectory(const fileapi::FileSystemURL& url,
+                              bool recursive,
+                              const StatusCallback& callback) OVERRIDE {
+    if (recursive) {
+      base::MessageLoopProxy::current()->PostTask(
+          FROM_HERE,
+          base::Bind(callback, base::File::FILE_ERROR_INVALID_OPERATION));
+      return;
+    }
+
+    const GURL gurl = url.ToGURL();
+    if (watched_urls_.find(gurl) != watched_urls_.end()) {
+      base::MessageLoopProxy::current()->PostTask(
+          FROM_HERE, base::Bind(callback, base::File::FILE_ERROR_EXISTS));
+      return;
+    }
+
+    watched_urls_.insert(gurl);
+    base::MessageLoopProxy::current()->PostTask(
+        FROM_HERE, base::Bind(callback, base::File::FILE_OK));
+
+    // Send a fake changed notification.
+    base::MessageLoopProxy::current()->PostTask(
+        FROM_HERE,
+        base::Bind(&TestWatcherManager::SendFakeChangeNotification,
+                   weak_ptr_factory_.GetWeakPtr(),
+                   url));
+
+    // Send a fake removed notification.
+    base::MessageLoopProxy::current()->PostTask(
+        FROM_HERE,
+        base::Bind(&TestWatcherManager::SendFakeRemoveNotification,
+                   weak_ptr_factory_.GetWeakPtr(),
+                   url));
+  }
+
+  virtual void UnwatchEntry(const fileapi::FileSystemURL& url,
+                            const StatusCallback& callback) OVERRIDE {
+    const GURL gurl = url.ToGURL();
+    if (watched_urls_.find(gurl) == watched_urls_.end()) {
+      base::MessageLoopProxy::current()->PostTask(
+          FROM_HERE, base::Bind(callback, base::File::FILE_ERROR_NOT_FOUND));
+      return;
+    }
+
+    watched_urls_.erase(gurl);
+    base::MessageLoopProxy::current()->PostTask(
+        FROM_HERE, base::Bind(callback, base::File::FILE_OK));
+  }
+
+ private:
+  // Sends a fake notification to each observer about a changed entry
+  // represented by |url|, as long as it is still being watched.
+  void SendFakeChangeNotification(const fileapi::FileSystemURL& url) {
+    if (watched_urls_.find(url.ToGURL()) == watched_urls_.end())
+      return;
+
+    FOR_EACH_OBSERVER(Observer, observers_, OnEntryChanged(url));
+  }
+
+  // Sends a fake notification to each observer about a removed entry
+  // represented by |url|, as long as it is still being watched.
+  void SendFakeRemoveNotification(const fileapi::FileSystemURL& url) {
+    if (watched_urls_.find(url.ToGURL()) == watched_urls_.end())
+      return;
+
+    FOR_EACH_OBSERVER(Observer, observers_, OnEntryRemoved(url));
+  }
+
+  ObserverList<Observer> observers_;
+  std::set<GURL> watched_urls_;
+
+  base::WeakPtrFactory<TestWatcherManager> weak_ptr_factory_;
+};
+
 }  // namespace
 
 // This only supports single origin.
 class TestFileSystemBackend::QuotaUtil
     : public fileapi::FileSystemQuotaUtil,
       public fileapi::FileUpdateObserver {
  public:
   explicit QuotaUtil(base::SequencedTaskRunner* task_runner)
       : usage_(0),
         task_runner_(task_runner) {
@@ skipping 92 matching lines @@
   fileapi::UpdateObserverList update_observers_;
   fileapi::ChangeObserverList change_observers_;
 };
 
 TestFileSystemBackend::TestFileSystemBackend(
     base::SequencedTaskRunner* task_runner,
     const base::FilePath& base_path)
     : base_path_(base_path),
       file_util_(
           new fileapi::AsyncFileUtilAdapter(new TestFileUtil(base_path))),
+      watcher_manager_(new TestWatcherManager()),
       quota_util_(new QuotaUtil(task_runner)),
       require_copy_or_move_validator_(false) {
 }
 
 TestFileSystemBackend::~TestFileSystemBackend() {
 }
 
 bool TestFileSystemBackend::CanHandleType(fileapi::FileSystemType type) const {
   return (type == fileapi::kFileSystemTypeTest);
 }
 
 void TestFileSystemBackend::Initialize(FileSystemContext* context) {
 }
 
 void TestFileSystemBackend::ResolveURL(const FileSystemURL& url,
                                        fileapi::OpenFileSystemMode mode,
                                        const OpenFileSystemCallback& callback) {
   callback.Run(GetFileSystemRootURI(url.origin(), url.type()),
                GetFileSystemName(url.origin(), url.type()),
                base::File::FILE_OK);
 }
 
 fileapi::AsyncFileUtil* TestFileSystemBackend::GetAsyncFileUtil(
     fileapi::FileSystemType type) {
   return file_util_.get();
 }
 
+fileapi::WatcherManager* TestFileSystemBackend::GetWatcherManager(
+    fileapi::FileSystemType type) {
+  return watcher_manager_.get();
+}
+
 fileapi::CopyOrMoveFileValidatorFactory*
 TestFileSystemBackend::GetCopyOrMoveFileValidatorFactory(
     fileapi::FileSystemType type,
     base::File::Error* error_code) {
   DCHECK(error_code);
   *error_code = base::File::FILE_OK;
   if (require_copy_or_move_validator_) {
     if (!copy_or_move_file_validator_factory_)
       *error_code = base::File::FILE_ERROR_SECURITY;
     return copy_or_move_file_validator_factory_.get();
@@ skipping 54 matching lines @@
   return quota_util_->GetUpdateObservers(type);
 }
 
 void TestFileSystemBackend::AddFileChangeObserver(
     fileapi::FileChangeObserver* observer) {
   quota_util_->AddFileChangeObserver(
       fileapi::kFileSystemTypeTest, observer, quota_util_->task_runner());
 }
 
 }  // namespace content