Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 1 | // Copyright 2015 The Weave Authors. All rights reserved. |
| 2 | // Use of this source code is governed by a BSD-style license that can be |
| 3 | // found in the LICENSE file. |
| 4 | |
Vitaly Buka | ca54c12 | 2015-11-05 23:06:09 -0800 | [diff] [blame^] | 5 | #include "examples/daemon/common/daemon.h" |
| 6 | |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 7 | #include <weave/device.h> |
| 8 | #include <weave/enum_to_string.h> |
| 9 | |
| 10 | #include <base/bind.h> |
| 11 | #include <base/memory/weak_ptr.h> |
| 12 | |
| 13 | namespace weave { |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 14 | namespace lockstate { |
| 15 | enum class LockState { kUnlocked, kLocked, kPartiallyLocked }; |
| 16 | |
| 17 | const weave::EnumToStringMap<LockState>::Map kLockMapMethod[] = { |
Vitaly Buka | ca54c12 | 2015-11-05 23:06:09 -0800 | [diff] [blame^] | 18 | {LockState::kLocked, "locked"}, |
| 19 | {LockState::kUnlocked, "unlocked"}, |
| 20 | {LockState::kPartiallyLocked, "partiallyLocked"}}; |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 21 | } // namespace lockstate |
| 22 | |
| 23 | template <> |
| 24 | EnumToStringMap<lockstate::LockState>::EnumToStringMap() |
Vitaly Buka | ca54c12 | 2015-11-05 23:06:09 -0800 | [diff] [blame^] | 25 | : EnumToStringMap(lockstate::kLockMapMethod) {} |
| 26 | } // namespace weave |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 27 | |
| 28 | // LockHandler is a command handler example that shows |
| 29 | // how to handle commands for a Weave lock. |
| 30 | class LockHandler { |
| 31 | public: |
| 32 | LockHandler() = default; |
Vitaly Buka | ca54c12 | 2015-11-05 23:06:09 -0800 | [diff] [blame^] | 33 | void Register(weave::Device* device) { |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 34 | device_ = device; |
| 35 | |
| 36 | device->AddStateDefinitionsFromJson(R"({ |
Paul Westbrook | 1bc421c | 2015-11-01 14:59:35 -0800 | [diff] [blame] | 37 | "lock": {"lockedState": ["locked", "unlocked", "partiallyLocked"]} |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 38 | })"); |
| 39 | |
| 40 | device->SetStatePropertiesFromJson(R"({ |
Paul Westbrook | 1bc421c | 2015-11-01 14:59:35 -0800 | [diff] [blame] | 41 | "lock":{"lockedState": "locked"} |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 42 | })", |
| 43 | nullptr); |
| 44 | |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 45 | device->AddCommandDefinitionsFromJson(R"({ |
Paul Westbrook | 1bc421c | 2015-11-01 14:59:35 -0800 | [diff] [blame] | 46 | "lock": { |
| 47 | "setConfig":{ |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 48 | "parameters": { |
Paul Westbrook | 1bc421c | 2015-11-01 14:59:35 -0800 | [diff] [blame] | 49 | "lockedState": ["locked", "unlocked"] |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 50 | } |
| 51 | } |
| 52 | } |
| 53 | })"); |
Vitaly Buka | ca54c12 | 2015-11-05 23:06:09 -0800 | [diff] [blame^] | 54 | device->AddCommandHandler("lock.setConfig", |
| 55 | base::Bind(&LockHandler::OnLockSetConfig, |
| 56 | weak_ptr_factory_.GetWeakPtr())); |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 57 | } |
| 58 | |
| 59 | private: |
Vitaly Buka | ca54c12 | 2015-11-05 23:06:09 -0800 | [diff] [blame^] | 60 | void OnLockSetConfig(const std::weak_ptr<weave::Command>& command) { |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 61 | auto cmd = command.lock(); |
| 62 | if (!cmd) |
| 63 | return; |
| 64 | LOG(INFO) << "received command: " << cmd->GetName(); |
| 65 | std::string requested_state; |
Paul Westbrook | 1bc421c | 2015-11-01 14:59:35 -0800 | [diff] [blame] | 66 | if (cmd->GetParameters()->GetString("lockedState", &requested_state)) { |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 67 | LOG(INFO) << cmd->GetName() << " state: " << requested_state; |
| 68 | |
Vitaly Buka | ca54c12 | 2015-11-05 23:06:09 -0800 | [diff] [blame^] | 69 | weave::lockstate::LockState new_lock_status; |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 70 | |
| 71 | if (!weave::StringToEnum(requested_state, &new_lock_status)) { |
| 72 | // Invalid lock state was specified. |
Vitaly Buka | ca54c12 | 2015-11-05 23:06:09 -0800 | [diff] [blame^] | 73 | weave::ErrorPtr error; |
| 74 | weave::Error::AddTo(&error, FROM_HERE, "example", |
| 75 | "invalid_parameter_value", "Invalid parameters"); |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 76 | cmd->Abort(error.get(), nullptr); |
| 77 | return; |
| 78 | } |
| 79 | |
| 80 | if (new_lock_status != lock_state_) { |
| 81 | lock_state_ = new_lock_status; |
| 82 | |
| 83 | LOG(INFO) << "Lock is now: " << requested_state; |
| 84 | UpdateLockState(); |
| 85 | } |
| 86 | cmd->Complete({}, nullptr); |
| 87 | return; |
| 88 | } |
Vitaly Buka | ca54c12 | 2015-11-05 23:06:09 -0800 | [diff] [blame^] | 89 | weave::ErrorPtr error; |
| 90 | weave::Error::AddTo(&error, FROM_HERE, "example", "invalid_parameter_value", |
| 91 | "Invalid parameters"); |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 92 | cmd->Abort(error.get(), nullptr); |
| 93 | } |
| 94 | |
Vitaly Buka | ca54c12 | 2015-11-05 23:06:09 -0800 | [diff] [blame^] | 95 | void UpdateLockState() { |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 96 | base::DictionaryValue state; |
| 97 | std::string updated_state = weave::EnumToString(lock_state_); |
| 98 | state.SetString("lock.lockedState", updated_state); |
| 99 | device_->SetStateProperties(state, nullptr); |
| 100 | } |
| 101 | |
Vitaly Buka | ca54c12 | 2015-11-05 23:06:09 -0800 | [diff] [blame^] | 102 | weave::Device* device_{nullptr}; |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 103 | |
| 104 | // Simulate the state of the light. |
Vitaly Buka | ca54c12 | 2015-11-05 23:06:09 -0800 | [diff] [blame^] | 105 | weave::lockstate::LockState lock_state_{weave::lockstate::LockState::kLocked}; |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 106 | base::WeakPtrFactory<LockHandler> weak_ptr_factory_{this}; |
| 107 | }; |
| 108 | |
Vitaly Buka | ca54c12 | 2015-11-05 23:06:09 -0800 | [diff] [blame^] | 109 | int main(int argc, char** argv) { |
| 110 | Daemon::Options opts; |
| 111 | if (!opts.Parse(argc, argv)) { |
| 112 | Daemon::Options::ShowUsage(argv[0]); |
| 113 | return 1; |
| 114 | } |
| 115 | Daemon daemon{opts}; |
| 116 | LockHandler handler; |
| 117 | handler.Register(daemon.GetDevice()); |
| 118 | daemon.Run(); |
| 119 | return 0; |
| 120 | } |