commit f6b387120252a1b89e7afd04af6a05475d99bd79
author Alex Vakulenko <avakulenko@chromium.org> Wed Sep 03 16:23:38 2014 -0700
committer chrome-internal-fetch <chrome-internal-fetch@google.com> Fri Sep 05 01:17:32 2014 +0000
tree 5f52d30c5cbc5284a2576e9be5ac5dc1ef23ffa3
parent f8f10fa8a436ee9c61138cc577cee8e0d3679088

buffet: Move command state into CommandInstance

The command state is now stored in CommandInstance and not in
DBusCommandProxy. CommandInstance can now notify the proxy of
command state changes via CommandProxyInterface.

Moved command status strings from dbus_constants.h into the
CommandInstance class, as members.

Added a property on DBusCommandProxy to expose the command
parameters to command handlers, so they can get the parameter
values over D-Bus.

BUG=chromium:374864
TEST=FEATURES=test emerge-link buffet

Change-Id: Ief3397ef09644772ffc3b1b01ed972a8b6779df4
Reviewed-on: https://chromium-review.googlesource.com/216296
Tested-by: Alex Vakulenko <avakulenko@chromium.org>
Reviewed-by: Christopher Wiley <wiley@chromium.org>
Commit-Queue: Alex Vakulenko <avakulenko@chromium.org>

buffet/commands/dbus_command_proxy.cc

diff --git a/buffet/commands/dbus_command_proxy.cc b/buffet/commands/dbus_command_proxy.cc
index 56bc706..1003ce7 100644
--- a/buffet/commands/dbus_command_proxy.cc
+++ b/buffet/commands/dbus_command_proxy.cc
@@ -51,18 +51,35 @@
   itf->AddProperty(dbus_constants::kCommandId, &id_);
   itf->AddProperty(dbus_constants::kCommandStatus, &status_);
   itf->AddProperty(dbus_constants::kCommandProgress, &progress_);
+  itf->AddProperty(dbus_constants::kCommandParameters, &parameters_);
 
   // Set the initial property values before registering the DBus object.
   name_.SetValue(command_instance_->GetName());
   category_.SetValue(command_instance_->GetCategory());
   id_.SetValue(command_instance_->GetID());
-  status_.SetValue(dbus_constants::kCommandStatusQueued);
-  progress_.SetValue(0);
+  status_.SetValue(command_instance_->GetStatus());
+  progress_.SetValue(command_instance_->GetProgress());
+  // Convert a string-to-PropValue map into a string-to-Any map which can be
+  // sent over D-Bus.
+  chromeos::dbus_utils::Dictionary params;
+  for (const auto& param_pair : command_instance_->GetParameters()) {
+    params.insert(std::make_pair(param_pair.first,
+                                 param_pair.second->GetValueAsAny()));
+  }
+  parameters_.SetValue(params);
 
   // Register the command DBus object and expose its methods and properties.
   dbus_object_.RegisterAsync(completion_callback);
 }
 
+void DBusCommandProxy::OnStatusChanged(const std::string& status) {
+  status_.SetValue(status);
+}
+
+void DBusCommandProxy::OnProgressChanged(int progress) {
+  progress_.SetValue(progress);
+}
+
 void DBusCommandProxy::HandleSetProgress(chromeos::ErrorPtr* error,
                                          int32_t progress) {
   LOG(INFO) << "Received call to Command<"
@@ -73,28 +90,26 @@
   IntPropType progress_type;
   progress_type.AddMinMaxConstraint(0, 100);
   if (progress_type.ValidateValue(progress, error)) {
-    status_.SetValue(dbus_constants::kCommandStatusInProgress);
-    progress_.SetValue(progress);
+    command_instance_->SetProgress(progress);
   }
 }
 
 void DBusCommandProxy::HandleAbort(chromeos::ErrorPtr* error) {
   LOG(INFO) << "Received call to Command<"
             << command_instance_->GetName() << ">::Abort()";
-  status_.SetValue(dbus_constants::kCommandStatusAborted);
+  command_instance_->Abort();
 }
 
 void DBusCommandProxy::HandleCancel(chromeos::ErrorPtr* error) {
   LOG(INFO) << "Received call to Command<"
             << command_instance_->GetName() << ">::Cancel()";
-  status_.SetValue(dbus_constants::kCommandStatusCanceled);
+  command_instance_->Cancel();
 }
 
 void DBusCommandProxy::HandleDone(chromeos::ErrorPtr* error) {
   LOG(INFO) << "Received call to Command<"
             << command_instance_->GetName() << ">::Done()";
-  status_.SetValue(dbus_constants::kCommandStatusDone);
-  progress_.SetValue(100);
+  command_instance_->Done();
 }