Implement SyncFileSystemService::GetFileSyncStatus method

chrome/browser/sync_file_system/sync_file_system_service.cc

 // Copyright (c) 2012 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 "chrome/browser/sync_file_system/sync_file_system_service.h"
 
 #include "base/bind.h"
 #include "base/logging.h"
 #include "base/memory/ref_counted.h"
 #include "base/stl_util.h"
@@ skipping 203 matching lines @@
                  base::Owned(local_metadata),
                  base::Owned(remote_metadata));
   scoped_refptr<SharedCallbackRunner> callback_runner(
       new SharedCallbackRunner(completion_callback));
   local_file_service_->GetLocalFileMetadata(
       url, callback_runner->CreateAssignAndRunCallback(local_metadata));
   remote_file_service_->GetRemoteFileMetadata(
       url, callback_runner->CreateAssignAndRunCallback(remote_metadata));
 }
 
+void SyncFileSystemService::GetFileSyncStatus(
+    const fileapi::FileSystemURL& url,
+    const fileapi::SyncFileStatusCallback& callback) {
+  DCHECK(local_file_service_);
+  DCHECK(remote_file_service_);
+
+  if (!ContainsKey(initialized_app_origins_, url.origin())) {
+    base::MessageLoopProxy::current()->PostTask(
+        FROM_HERE,
+        base::Bind(callback,
+                   fileapi::SYNC_STATUS_NOT_INITIALIZED,
+                   fileapi::SYNC_FILE_STATUS_UNKNOWN));
+    return;
+  }
+
+  if (remote_file_service_->IsConflicting(url)) {
+    base::MessageLoopProxy::current()->PostTask(
+        FROM_HERE,
+        base::Bind(callback,
+                   fileapi::SYNC_STATUS_OK,
+                   fileapi::SYNC_FILE_STATUS_CONFLICTING));
+    return;
+  }
+
+  local_file_service_->HasPendingLocalChanges(
+      url,
+      base::Bind(&SyncFileSystemService::DidGetLocalChangeStatus,
+                 AsWeakPtr(), callback));
+}
+
 void SyncFileSystemService::AddSyncEventObserver(SyncEventObserver* observer) {
   observers_.AddObserver(observer);
 }
 
 void SyncFileSystemService::RemoveSyncEventObserver(
     SyncEventObserver* observer) {
   observers_.RemoveObserver(observer);
 }
 
 SyncFileSystemService::SyncFileSystemService(Profile* profile)
@@ skipping 144 matching lines @@
     pending_local_changes_ = 0;
     return;
   } else if (status == fileapi::SYNC_STATUS_HAS_CONFLICT) {
     // TODO(kinuko,tzik): Handle conflict!
   }
   base::MessageLoopProxy::current()->PostTask(
       FROM_HERE, base::Bind(&SyncFileSystemService::MaybeStartSync,
                             AsWeakPtr()));
 }
 
+void SyncFileSystemService::DidGetLocalChangeStatus(
+    const fileapi::SyncFileStatusCallback& callback,
+    bool has_pending_local_changes) {
+  callback.Run(
+      fileapi::SYNC_STATUS_OK,
+      has_pending_local_changes ? fileapi::SYNC_FILE_STATUS_HAS_PENDING_CHANGES
+                                : fileapi::SYNC_FILE_STATUS_SYNCED);
+}
+
 void SyncFileSystemService::OnSyncEnabledForRemoteSync() {
   is_waiting_remote_sync_enabled_ = false;
   MaybeStartRemoteSync();
 }
 
 void SyncFileSystemService::OnLocalChangeAvailable(int64 pending_changes) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   DCHECK_GE(pending_changes, 0);
   DVLOG(1) << "OnLocalChangeAvailable: " << pending_changes;
   pending_local_changes_ = pending_changes;
@@ skipping 74 matching lines @@
     remote_file_service = mock_remote_file_service_.Pass();
   else
     remote_file_service.reset(new DriveFileSyncService(profile));
 
   service->Initialize(local_file_service.Pass(),
                       remote_file_service.Pass());
   return service;
 }
 
 }  // namespace sync_file_system