diff options
Diffstat (limited to 'buffet/dbus_command_proxy_unittest.cc')
| -rw-r--r-- | buffet/dbus_command_proxy_unittest.cc | 189 |
1 files changed, 0 insertions, 189 deletions
diff --git a/buffet/dbus_command_proxy_unittest.cc b/buffet/dbus_command_proxy_unittest.cc deleted file mode 100644 index 5225f11..0000000 --- a/buffet/dbus_command_proxy_unittest.cc +++ /dev/null @@ -1,189 +0,0 @@ -// Copyright 2015 The Android Open Source Project -// -// Licensed under the Apache License, Version 2.0 (the "License"); -// you may not use this file except in compliance with the License. -// You may obtain a copy of the License at -// -// http://www.apache.org/licenses/LICENSE-2.0 -// -// Unless required by applicable law or agreed to in writing, software -// distributed under the License is distributed on an "AS IS" BASIS, -// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -// See the License for the specific language governing permissions and -// limitations under the License. - -#include "buffet/dbus_command_proxy.h" - -#include <functional> -#include <memory> -#include <vector> - -#include <dbus/mock_bus.h> -#include <dbus/mock_exported_object.h> -#include <dbus/property.h> -#include <brillo/dbus/dbus_object.h> -#include <brillo/dbus/dbus_object_test_helpers.h> -#include <gtest/gtest.h> -#include <weave/command.h> -#include <weave/enum_to_string.h> -#include <weave/test/mock_command.h> -#include <weave/test/unittest_utils.h> - -#include "buffet/dbus_constants.h" - -namespace buffet { - -using ::testing::_; -using ::testing::AnyNumber; -using ::testing::Return; -using ::testing::ReturnRef; -using ::testing::ReturnRefOfCopy; -using ::testing::StrictMock; - -using brillo::VariantDictionary; -using brillo::dbus_utils::AsyncEventSequencer; -using weave::test::CreateDictionaryValue; -using weave::test::IsEqualValue; - -namespace { - -const char kTestCommandId[] = "cmd_1"; - -MATCHER_P(EqualToJson, json, "") { - auto json_value = CreateDictionaryValue(json); - return IsEqualValue(*json_value, arg); -} - -MATCHER_P2(ExpectError, code, message, "") { - return arg->GetCode() == code && arg->GetMessage() == message; -} - -} // namespace - -class DBusCommandProxyTest : public ::testing::Test { - public: - void SetUp() override { - command_ = std::make_shared<StrictMock<weave::test::MockCommand>>(); - // Set up a mock DBus bus object. - dbus::Bus::Options options; - options.bus_type = dbus::Bus::SYSTEM; - bus_ = new dbus::MockBus(options); - // By default, don't worry about threading assertions. - EXPECT_CALL(*bus_, AssertOnOriginThread()).Times(AnyNumber()); - EXPECT_CALL(*bus_, AssertOnDBusThread()).Times(AnyNumber()); - - expected_result_dict_.SetInteger("height", 53); - expected_result_dict_.SetString("_jumpType", "_withKick"); - EXPECT_CALL(*command_, GetID()) - .WillOnce(ReturnRefOfCopy<std::string>(kTestCommandId)); - // Use WillRepeatedly because GetName is used for logging. - EXPECT_CALL(*command_, GetName()) - .WillRepeatedly(ReturnRefOfCopy<std::string>("robot.jump")); - EXPECT_CALL(*command_, GetComponent()) - .WillRepeatedly(ReturnRefOfCopy<std::string>("myComponent")); - EXPECT_CALL(*command_, GetState()) - .WillRepeatedly(Return(weave::Command::State::kQueued)); - EXPECT_CALL(*command_, GetOrigin()) - .WillOnce(Return(weave::Command::Origin::kLocal)); - EXPECT_CALL(*command_, GetParameters()) - .WillOnce(ReturnRef(expected_result_dict_)); - EXPECT_CALL(*command_, GetProgress()) - .WillRepeatedly(ReturnRef(empty_dict_)); - EXPECT_CALL(*command_, GetResults()) - .WillRepeatedly(ReturnRef(empty_dict_)); - - // Set up a mock ExportedObject to be used with the DBus command proxy. - std::string cmd_path = buffet::dbus_constants::kCommandServicePathPrefix; - cmd_path += kTestCommandId; - const dbus::ObjectPath kCmdObjPath(cmd_path); - // Use a mock exported object for the exported object manager. - mock_exported_object_command_ = - new dbus::MockExportedObject(bus_.get(), kCmdObjPath); - EXPECT_CALL(*bus_, GetExportedObject(kCmdObjPath)) - .Times(AnyNumber()) - .WillRepeatedly(Return(mock_exported_object_command_.get())); - EXPECT_CALL(*mock_exported_object_command_, ExportMethod(_, _, _, _)) - .Times(AnyNumber()); - - proxy_.reset(new DBusCommandProxy{ - nullptr, bus_, std::weak_ptr<weave::Command>{command_}, cmd_path}); - GetCommandProxy()->RegisterAsync( - AsyncEventSequencer::GetDefaultCompletionAction()); - } - - void TearDown() override { - EXPECT_CALL(*mock_exported_object_command_, Unregister()).Times(1); - bus_ = nullptr; - } - - DBusCommandProxy* GetCommandProxy() const { return proxy_.get(); } - - com::android::Weave::CommandAdaptor* GetCommandAdaptor() const { - return &GetCommandProxy()->dbus_adaptor_; - } - - com::android::Weave::CommandInterface* GetCommandInterface() const { - // DBusCommandProxy also implements CommandInterface. - return GetCommandProxy(); - } - - weave::Command::State GetCommandState() const { - weave::Command::State state; - EXPECT_TRUE(StringToEnum(GetCommandAdaptor()->GetState(), &state)); - return state; - } - - scoped_refptr<dbus::MockExportedObject> mock_exported_object_command_; - scoped_refptr<dbus::MockBus> bus_; - base::DictionaryValue empty_dict_; - base::DictionaryValue expected_result_dict_; - - std::shared_ptr<StrictMock<weave::test::MockCommand>> command_; - std::unique_ptr<DBusCommandProxy> proxy_; -}; - -TEST_F(DBusCommandProxyTest, Init) { - VariantDictionary params = { - {"height", int32_t{53}}, {"_jumpType", std::string{"_withKick"}}, - }; - EXPECT_EQ(weave::Command::State::kQueued, GetCommandState()); - EXPECT_EQ(params, GetCommandAdaptor()->GetParameters()); - EXPECT_EQ(VariantDictionary{}, GetCommandAdaptor()->GetProgress()); - EXPECT_EQ(VariantDictionary{}, GetCommandAdaptor()->GetResults()); - EXPECT_EQ("robot.jump", GetCommandAdaptor()->GetName()); - EXPECT_EQ("myComponent", GetCommandAdaptor()->GetComponent()); - EXPECT_EQ(kTestCommandId, GetCommandAdaptor()->GetId()); -} - -TEST_F(DBusCommandProxyTest, SetProgress) { - EXPECT_CALL(*command_, SetProgress(EqualToJson("{'progress': 10}"), _)) - .WillOnce(Return(true)); - EXPECT_TRUE( - GetCommandInterface()->SetProgress(nullptr, {{"progress", int32_t{10}}})); -} - -TEST_F(DBusCommandProxyTest, Complete) { - EXPECT_CALL( - *command_, - Complete( - EqualToJson("{'foo': 42, 'bar': 'foobar', 'resultList': [1, 2, 3]}"), - _)) - .WillOnce(Return(true)); - EXPECT_TRUE(GetCommandInterface()->Complete( - nullptr, VariantDictionary{{"foo", int32_t{42}}, - {"bar", std::string{"foobar"}}, - {"resultList", std::vector<int>{1, 2, 3}}})); -} - -TEST_F(DBusCommandProxyTest, Abort) { - EXPECT_CALL(*command_, Abort(ExpectError("foo", "bar"), _)) - .WillOnce(Return(true)); - EXPECT_TRUE(GetCommandInterface()->Abort(nullptr, "foo", "bar")); -} - -TEST_F(DBusCommandProxyTest, Cancel) { - EXPECT_CALL(*command_, Cancel(_)).WillOnce(Return(true)); - EXPECT_TRUE(GetCommandInterface()->Cancel(nullptr)); -} - -} // namespace buffet |