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 | |
Johan Euphrosine | 3fb474e | 2015-10-29 15:23:53 -0700 | [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[] = { |
Johan Euphrosine | 3fb474e | 2015-10-29 15:23:53 -0700 | [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() |
Johan Euphrosine | 3fb474e | 2015-10-29 15:23:53 -0700 | [diff] [blame] | 25 | : EnumToStringMap(lockstate::kLockMapMethod) {} |
| 26 | } // namespace weave |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 27 | |
Alex Vakulenko | d6db049 | 2015-12-07 16:55:19 -0800 | [diff] [blame] | 28 | namespace { |
| 29 | |
| 30 | const char kTraits[] = R"({ |
| 31 | "lock": { |
| 32 | "commands": { |
| 33 | "setConfig": { |
| 34 | "minimalRole": "user", |
| 35 | "parameters": { |
| 36 | "lockedState": { |
| 37 | "type": "string", |
| 38 | "enum": [ "locked", "unlocked" ] |
| 39 | } |
Alex Vakulenko | 8d0cfef | 2015-12-15 18:40:05 -0800 | [diff] [blame] | 40 | }, |
| 41 | "errors": ["batteryTooLow", "jammed", "lockingNotSupported"] |
Alex Vakulenko | d6db049 | 2015-12-07 16:55:19 -0800 | [diff] [blame] | 42 | } |
| 43 | }, |
| 44 | "state": { |
| 45 | "lockedState": { |
| 46 | "type": "string", |
Alex Vakulenko | 8d0cfef | 2015-12-15 18:40:05 -0800 | [diff] [blame] | 47 | "enum": [ "locked", "unlocked", "partiallyLocked" ], |
| 48 | "isRequired": true |
Alex Vakulenko | d6db049 | 2015-12-07 16:55:19 -0800 | [diff] [blame] | 49 | }, |
Alex Vakulenko | 8d0cfef | 2015-12-15 18:40:05 -0800 | [diff] [blame] | 50 | "isLockingSupported": { |
| 51 | "type": "boolean", |
| 52 | "isRequired": true |
| 53 | } |
Alex Vakulenko | d6db049 | 2015-12-07 16:55:19 -0800 | [diff] [blame] | 54 | } |
| 55 | } |
| 56 | })"; |
| 57 | |
| 58 | const char kDefaultState[] = R"({ |
| 59 | "lock":{"isLockingSupported": true} |
| 60 | })"; |
| 61 | |
| 62 | const char kComponent[] = "lock"; |
| 63 | |
| 64 | } // anonymous namespace |
| 65 | |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 66 | // LockHandler is a command handler example that shows |
| 67 | // how to handle commands for a Weave lock. |
| 68 | class LockHandler { |
| 69 | public: |
| 70 | LockHandler() = default; |
Johan Euphrosine | 3fb474e | 2015-10-29 15:23:53 -0700 | [diff] [blame] | 71 | void Register(weave::Device* device) { |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 72 | device_ = device; |
| 73 | |
Alex Vakulenko | d6db049 | 2015-12-07 16:55:19 -0800 | [diff] [blame] | 74 | device->AddTraitDefinitionsFromJson(kTraits); |
| 75 | CHECK(device->AddComponent(kComponent, {"lock"}, nullptr)); |
Vitaly Buka | 34668e7 | 2015-12-15 14:46:47 -0800 | [diff] [blame] | 76 | CHECK( |
| 77 | device->SetStatePropertiesFromJson(kComponent, kDefaultState, nullptr)); |
Alex Vakulenko | d6db049 | 2015-12-07 16:55:19 -0800 | [diff] [blame] | 78 | UpdateLockState(); |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 79 | |
Alex Vakulenko | d6db049 | 2015-12-07 16:55:19 -0800 | [diff] [blame] | 80 | device->AddCommandHandler(kComponent, "lock.setConfig", |
Johan Euphrosine | 3fb474e | 2015-10-29 15:23:53 -0700 | [diff] [blame] | 81 | base::Bind(&LockHandler::OnLockSetConfig, |
| 82 | weak_ptr_factory_.GetWeakPtr())); |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 83 | } |
| 84 | |
| 85 | private: |
Johan Euphrosine | 3fb474e | 2015-10-29 15:23:53 -0700 | [diff] [blame] | 86 | void OnLockSetConfig(const std::weak_ptr<weave::Command>& command) { |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 87 | auto cmd = command.lock(); |
| 88 | if (!cmd) |
| 89 | return; |
| 90 | LOG(INFO) << "received command: " << cmd->GetName(); |
Vitaly Buka | c430560 | 2015-11-24 23:33:09 -0800 | [diff] [blame] | 91 | const auto& params = cmd->GetParameters(); |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 92 | std::string requested_state; |
Vitaly Buka | c430560 | 2015-11-24 23:33:09 -0800 | [diff] [blame] | 93 | if (params.GetString("lockedState", &requested_state)) { |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 94 | LOG(INFO) << cmd->GetName() << " state: " << requested_state; |
| 95 | |
Johan Euphrosine | 3fb474e | 2015-10-29 15:23:53 -0700 | [diff] [blame] | 96 | weave::lockstate::LockState new_lock_status; |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 97 | |
| 98 | if (!weave::StringToEnum(requested_state, &new_lock_status)) { |
| 99 | // Invalid lock state was specified. |
Johan Euphrosine | 3fb474e | 2015-10-29 15:23:53 -0700 | [diff] [blame] | 100 | weave::ErrorPtr error; |
| 101 | weave::Error::AddTo(&error, FROM_HERE, "example", |
| 102 | "invalid_parameter_value", "Invalid parameters"); |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 103 | cmd->Abort(error.get(), nullptr); |
| 104 | return; |
| 105 | } |
| 106 | |
| 107 | if (new_lock_status != lock_state_) { |
| 108 | lock_state_ = new_lock_status; |
| 109 | |
| 110 | LOG(INFO) << "Lock is now: " << requested_state; |
| 111 | UpdateLockState(); |
| 112 | } |
| 113 | cmd->Complete({}, nullptr); |
| 114 | return; |
| 115 | } |
Johan Euphrosine | 3fb474e | 2015-10-29 15:23:53 -0700 | [diff] [blame] | 116 | weave::ErrorPtr error; |
| 117 | weave::Error::AddTo(&error, FROM_HERE, "example", "invalid_parameter_value", |
| 118 | "Invalid parameters"); |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 119 | cmd->Abort(error.get(), nullptr); |
| 120 | } |
| 121 | |
Johan Euphrosine | 3fb474e | 2015-10-29 15:23:53 -0700 | [diff] [blame] | 122 | void UpdateLockState() { |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 123 | std::string updated_state = weave::EnumToString(lock_state_); |
Alex Vakulenko | d6db049 | 2015-12-07 16:55:19 -0800 | [diff] [blame] | 124 | device_->SetStateProperty(kComponent, "lock.lockedState", |
| 125 | base::StringValue{updated_state}, nullptr); |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 126 | } |
| 127 | |
Johan Euphrosine | 3fb474e | 2015-10-29 15:23:53 -0700 | [diff] [blame] | 128 | weave::Device* device_{nullptr}; |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 129 | |
| 130 | // Simulate the state of the light. |
Johan Euphrosine | 3fb474e | 2015-10-29 15:23:53 -0700 | [diff] [blame] | 131 | weave::lockstate::LockState lock_state_{weave::lockstate::LockState::kLocked}; |
Paul Westbrook | c18c7cf | 2015-10-27 06:38:59 -0700 | [diff] [blame] | 132 | base::WeakPtrFactory<LockHandler> weak_ptr_factory_{this}; |
| 133 | }; |
| 134 | |
Johan Euphrosine | 3fb474e | 2015-10-29 15:23:53 -0700 | [diff] [blame] | 135 | int main(int argc, char** argv) { |
| 136 | Daemon::Options opts; |
Paul Westbrook | 04e628f | 2015-12-08 18:33:21 -0800 | [diff] [blame] | 137 | opts.model_id_ = "AOAAA"; |
Johan Euphrosine | 3fb474e | 2015-10-29 15:23:53 -0700 | [diff] [blame] | 138 | if (!opts.Parse(argc, argv)) { |
| 139 | Daemon::Options::ShowUsage(argv[0]); |
| 140 | return 1; |
| 141 | } |
| 142 | Daemon daemon{opts}; |
| 143 | LockHandler handler; |
| 144 | handler.Register(daemon.GetDevice()); |
| 145 | daemon.Run(); |
| 146 | return 0; |
| 147 | } |