| // Copyright 2015 The Weave 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 "examples/daemon/common/daemon.h" | |
| #include <weave/device.h> | |
| #include <weave/enum_to_string.h> | |
| #include <base/bind.h> | |
| #include <base/memory/weak_ptr.h> | |
| namespace weave { | |
| namespace lockstate { | |
| enum class LockState { kUnlocked, kLocked, kPartiallyLocked }; | |
| const weave::EnumToStringMap<LockState>::Map kLockMapMethod[] = { | |
| {LockState::kLocked, "locked"}, | |
| {LockState::kUnlocked, "unlocked"}, | |
| {LockState::kPartiallyLocked, "partiallyLocked"}}; | |
| } // namespace lockstate | |
| template <> | |
| EnumToStringMap<lockstate::LockState>::EnumToStringMap() | |
| : EnumToStringMap(lockstate::kLockMapMethod) {} | |
| } // namespace weave | |
| namespace { | |
| const char kTraits[] = R"({ | |
| "lock": { | |
| "commands": { | |
| "setConfig": { | |
| "minimalRole": "user", | |
| "parameters": { | |
| "lockedState": { | |
| "type": "string", | |
| "enum": [ "locked", "unlocked" ] | |
| } | |
| }, | |
| "errors": ["batteryTooLow", "jammed", "lockingNotSupported"] | |
| } | |
| }, | |
| "state": { | |
| "lockedState": { | |
| "type": "string", | |
| "enum": [ "locked", "unlocked", "partiallyLocked" ], | |
| "isRequired": true | |
| }, | |
| "isLockingSupported": { | |
| "type": "boolean", | |
| "isRequired": true | |
| } | |
| } | |
| } | |
| })"; | |
| const char kDefaultState[] = R"({ | |
| "lock":{"isLockingSupported": true} | |
| })"; | |
| const char kComponent[] = "lock"; | |
| } // anonymous namespace | |
| // LockHandler is a command handler example that shows | |
| // how to handle commands for a Weave lock. | |
| class LockHandler { | |
| public: | |
| LockHandler() = default; | |
| void Register(weave::Device* device) { | |
| device_ = device; | |
| device->AddTraitDefinitionsFromJson(kTraits); | |
| CHECK(device->AddComponent(kComponent, {"lock"}, nullptr)); | |
| CHECK( | |
| device->SetStatePropertiesFromJson(kComponent, kDefaultState, nullptr)); | |
| UpdateLockState(); | |
| device->AddCommandHandler(kComponent, "lock.setConfig", | |
| base::Bind(&LockHandler::OnLockSetConfig, | |
| weak_ptr_factory_.GetWeakPtr())); | |
| } | |
| private: | |
| void OnLockSetConfig(const std::weak_ptr<weave::Command>& command) { | |
| auto cmd = command.lock(); | |
| if (!cmd) | |
| return; | |
| LOG(INFO) << "received command: " << cmd->GetName(); | |
| const auto& params = cmd->GetParameters(); | |
| std::string requested_state; | |
| if (params.GetString("lockedState", &requested_state)) { | |
| LOG(INFO) << cmd->GetName() << " state: " << requested_state; | |
| weave::lockstate::LockState new_lock_status; | |
| if (!weave::StringToEnum(requested_state, &new_lock_status)) { | |
| // Invalid lock state was specified. | |
| weave::ErrorPtr error; | |
| weave::Error::AddTo(&error, FROM_HERE, "example", | |
| "invalid_parameter_value", "Invalid parameters"); | |
| cmd->Abort(error.get(), nullptr); | |
| return; | |
| } | |
| if (new_lock_status != lock_state_) { | |
| lock_state_ = new_lock_status; | |
| LOG(INFO) << "Lock is now: " << requested_state; | |
| UpdateLockState(); | |
| } | |
| cmd->Complete({}, nullptr); | |
| return; | |
| } | |
| weave::ErrorPtr error; | |
| weave::Error::AddTo(&error, FROM_HERE, "example", "invalid_parameter_value", | |
| "Invalid parameters"); | |
| cmd->Abort(error.get(), nullptr); | |
| } | |
| void UpdateLockState() { | |
| std::string updated_state = weave::EnumToString(lock_state_); | |
| device_->SetStateProperty(kComponent, "lock.lockedState", | |
| base::StringValue{updated_state}, nullptr); | |
| } | |
| weave::Device* device_{nullptr}; | |
| // Simulate the state of the light. | |
| weave::lockstate::LockState lock_state_{weave::lockstate::LockState::kLocked}; | |
| base::WeakPtrFactory<LockHandler> weak_ptr_factory_{this}; | |
| }; | |
| int main(int argc, char** argv) { | |
| Daemon::Options opts; | |
| opts.model_id_ = "AOAAA"; | |
| if (!opts.Parse(argc, argv)) { | |
| Daemon::Options::ShowUsage(argv[0]); | |
| return 1; | |
| } | |
| Daemon daemon{opts}; | |
| LockHandler handler; | |
| handler.Register(daemon.GetDevice()); | |
| daemon.Run(); | |
| return 0; | |
| } |