Christopher Wiley | 4b5f04c | 2014-03-27 14:45:37 -0700 | [diff] [blame] | 1 | // Copyright 2014 The Chromium OS 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 | |
| 5 | #include "buffet/manager.h" |
| 6 | |
Alex Vakulenko | 7c3226e | 2014-05-07 17:35:24 -0700 | [diff] [blame] | 7 | #include <map> |
Alex Vakulenko | ec41a0c | 2015-04-17 15:35:34 -0700 | [diff] [blame] | 8 | #include <set> |
Alex Vakulenko | 7c3226e | 2014-05-07 17:35:24 -0700 | [diff] [blame] | 9 | #include <string> |
| 10 | |
Christopher Wiley | 4b5f04c | 2014-03-27 14:45:37 -0700 | [diff] [blame] | 11 | #include <base/bind.h> |
| 12 | #include <base/bind_helpers.h> |
Alex Vakulenko | 4f7778e | 2014-09-11 16:57:24 -0700 | [diff] [blame] | 13 | #include <base/json/json_reader.h> |
Christopher Wiley | 2ffa004 | 2014-05-05 16:09:16 -0700 | [diff] [blame] | 14 | #include <base/json/json_writer.h> |
Alex Vakulenko | f775454 | 2015-06-26 12:59:50 -0700 | [diff] [blame] | 15 | #include <base/message_loop/message_loop.h> |
Christopher Wiley | 8994e01 | 2015-02-06 17:51:43 -0800 | [diff] [blame] | 16 | #include <base/time/time.h> |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 17 | #include <chromeos/bind_lambda.h> |
Alex Vakulenko | 24e5f5d | 2014-08-27 11:00:57 -0700 | [diff] [blame] | 18 | #include <chromeos/dbus/async_event_sequencer.h> |
| 19 | #include <chromeos/dbus/exported_object_manager.h> |
| 20 | #include <chromeos/errors/error.h> |
Garret Kelly | 89ba036 | 2015-05-29 15:56:52 -0400 | [diff] [blame] | 21 | #include <chromeos/http/http_transport.h> |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 22 | #include <chromeos/http/http_utils.h> |
Anton Muhin | 53e882a | 2014-11-22 05:59:14 +0400 | [diff] [blame] | 23 | #include <chromeos/key_value_store.h> |
Vitaly Buka | e74c872 | 2015-08-13 00:33:00 -0700 | [diff] [blame] | 24 | #include <chromeos/message_loops/message_loop.h> |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 25 | #include <chromeos/mime_utils.h> |
Christopher Wiley | 2ffa004 | 2014-05-05 16:09:16 -0700 | [diff] [blame] | 26 | #include <dbus/bus.h> |
Christopher Wiley | 54028f9 | 2014-04-01 17:33:29 -0700 | [diff] [blame] | 27 | #include <dbus/object_path.h> |
Alex Vakulenko | f3d77e5 | 2014-04-15 11:36:32 -0700 | [diff] [blame] | 28 | #include <dbus/values_util.h> |
Vitaly Buka | e2713ac | 2015-08-03 13:50:01 -0700 | [diff] [blame] | 29 | #include <weave/enum_to_string.h> |
Christopher Wiley | 4b5f04c | 2014-03-27 14:45:37 -0700 | [diff] [blame] | 30 | |
Robert Ginda | f86123d | 2015-09-11 16:10:43 -0700 | [diff] [blame] | 31 | #include "buffet/bluetooth_client.h" |
Vitaly Buka | 1175a9b | 2015-08-15 10:42:17 -0700 | [diff] [blame] | 32 | #include "buffet/buffet_config.h" |
Vitaly Buka | a0305d3 | 2015-07-27 16:08:51 -0700 | [diff] [blame] | 33 | #include "buffet/dbus_command_dispatcher.h" |
| 34 | #include "buffet/dbus_conversion.h" |
Vitaly Buka | 00882b7 | 2015-08-06 00:32:11 -0700 | [diff] [blame] | 35 | #include "buffet/http_transport_client.h" |
Alex Vakulenko | f0f5534 | 2015-08-18 15:51:40 -0700 | [diff] [blame] | 36 | #include "buffet/mdns_client.h" |
Peter Qiu | 786a906 | 2015-10-02 11:45:01 -0700 | [diff] [blame] | 37 | #include "buffet/shill_client.h" |
Vitaly Buka | 4f77153 | 2015-08-14 14:58:39 -0700 | [diff] [blame] | 38 | #include "buffet/weave_error_conversion.h" |
Alex Vakulenko | 1642bec | 2015-08-19 09:34:58 -0700 | [diff] [blame] | 39 | #include "buffet/webserv_client.h" |
Vitaly Buka | 03319c2 | 2015-07-17 14:48:30 -0700 | [diff] [blame] | 40 | |
Christopher Wiley | 68c07cc | 2014-07-29 14:07:10 -0700 | [diff] [blame] | 41 | using chromeos::dbus_utils::AsyncEventSequencer; |
Christopher Wiley | 1aa980e | 2014-08-11 10:51:20 -0700 | [diff] [blame] | 42 | using chromeos::dbus_utils::ExportedObjectManager; |
Christopher Wiley | 4b5f04c | 2014-03-27 14:45:37 -0700 | [diff] [blame] | 43 | |
| 44 | namespace buffet { |
| 45 | |
Alex Vakulenko | ecf961a | 2014-10-28 13:50:16 -0700 | [diff] [blame] | 46 | namespace { |
Vitaly Buka | 7b3ba79 | 2015-06-09 17:01:54 -0700 | [diff] [blame] | 47 | |
Vitaly Buka | 7b3ba79 | 2015-06-09 17:01:54 -0700 | [diff] [blame] | 48 | const char kPairingSessionIdKey[] = "sessionId"; |
| 49 | const char kPairingModeKey[] = "mode"; |
| 50 | const char kPairingCodeKey[] = "code"; |
| 51 | |
Vitaly Buka | 0c6dcd2 | 2015-07-10 00:12:25 -0700 | [diff] [blame] | 52 | const char kErrorDomain[] = "buffet"; |
Vitaly Buka | 0c6dcd2 | 2015-07-10 00:12:25 -0700 | [diff] [blame] | 53 | |
Alex Vakulenko | ecf961a | 2014-10-28 13:50:16 -0700 | [diff] [blame] | 54 | } // anonymous namespace |
| 55 | |
Alex Vakulenko | e32375b | 2015-09-28 08:55:40 -0700 | [diff] [blame] | 56 | class Manager::TaskRunner : public weave::provider::TaskRunner { |
Vitaly Buka | e74c872 | 2015-08-13 00:33:00 -0700 | [diff] [blame] | 57 | public: |
| 58 | void PostDelayedTask(const tracked_objects::Location& from_here, |
| 59 | const base::Closure& task, |
| 60 | base::TimeDelta delay) override { |
| 61 | chromeos::MessageLoop::current()->PostDelayedTask(from_here, task, delay); |
| 62 | } |
| 63 | }; |
| 64 | |
Alex Vakulenko | b635153 | 2014-08-15 11:49:35 -0700 | [diff] [blame] | 65 | Manager::Manager(const base::WeakPtr<ExportedObjectManager>& object_manager) |
| 66 | : dbus_object_(object_manager.get(), |
| 67 | object_manager->GetBus(), |
Alex Vakulenko | 63bdf08 | 2015-08-21 09:27:12 -0700 | [diff] [blame] | 68 | com::android::Weave::ManagerAdaptor::GetObjectPath()) { |
Vitaly Buka | 91cc715 | 2015-03-20 09:46:57 -0700 | [diff] [blame] | 69 | } |
Christopher Wiley | 4b5f04c | 2014-03-27 14:45:37 -0700 | [diff] [blame] | 70 | |
Vitaly Buka | 91cc715 | 2015-03-20 09:46:57 -0700 | [diff] [blame] | 71 | Manager::~Manager() { |
| 72 | } |
Alex Vakulenko | ecf961a | 2014-10-28 13:50:16 -0700 | [diff] [blame] | 73 | |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 74 | void Manager::Start(const Options& options, |
| 75 | const BuffetConfig::Options& paths, |
Vitaly Buka | 58a288b | 2015-07-31 00:33:31 -0700 | [diff] [blame] | 76 | const std::set<std::string>& device_whitelist, |
Vitaly Buka | 0c6dcd2 | 2015-07-10 00:12:25 -0700 | [diff] [blame] | 77 | AsyncEventSequencer* sequencer) { |
Vitaly Buka | e74c872 | 2015-08-13 00:33:00 -0700 | [diff] [blame] | 78 | task_runner_.reset(new TaskRunner{}); |
Vitaly Buka | 00882b7 | 2015-08-06 00:32:11 -0700 | [diff] [blame] | 79 | http_client_.reset(new HttpTransportClient); |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 80 | shill_client_.reset(new ShillClient{dbus_object_.GetBus(), device_whitelist, |
| 81 | !options.xmpp_enabled}); |
| 82 | weave::provider::HttpServer* http_server{nullptr}; |
Christopher Wiley | e925bb3 | 2015-08-03 20:09:18 -0700 | [diff] [blame] | 83 | #ifdef BUFFET_USE_WIFI_BOOTSTRAPPING |
Alex Vakulenko | f0f5534 | 2015-08-18 15:51:40 -0700 | [diff] [blame] | 84 | if (!options.disable_privet) { |
Robert Ginda | cf92c66 | 2015-08-20 09:30:11 -0700 | [diff] [blame] | 85 | mdns_client_ = MdnsClient::CreateInstance(dbus_object_.GetBus()); |
Alex Vakulenko | 1642bec | 2015-08-19 09:34:58 -0700 | [diff] [blame] | 86 | web_serv_client_.reset(new WebServClient{dbus_object_.GetBus(), sequencer}); |
Robert Ginda | f86123d | 2015-09-11 16:10:43 -0700 | [diff] [blame] | 87 | bluetooth_client_ = BluetoothClient::CreateInstance(); |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 88 | http_server = web_serv_client_.get(); |
| 89 | |
| 90 | if (options.enable_ping) { |
| 91 | http_server->AddRequestHandler( |
| 92 | "/privet/ping", |
| 93 | base::Bind( |
| 94 | [](const weave::provider::HttpServer::Request& request, |
| 95 | const weave::provider::HttpServer::OnReplyCallback& callback) { |
| 96 | callback.Run(chromeos::http::status_code::Ok, "Hello, world!", |
| 97 | chromeos::mime::text::kPlain); |
| 98 | })); |
| 99 | } |
Alex Vakulenko | f0f5534 | 2015-08-18 15:51:40 -0700 | [diff] [blame] | 100 | } |
Christopher Wiley | e925bb3 | 2015-08-03 20:09:18 -0700 | [diff] [blame] | 101 | #endif // BUFFET_USE_WIFI_BOOTSTRAPPING |
Vitaly Buka | 7042c58 | 2015-07-30 17:02:14 -0700 | [diff] [blame] | 102 | |
Vitaly Buka | becd461 | 2015-08-16 23:31:55 -0700 | [diff] [blame] | 103 | config_.reset(new BuffetConfig{paths}); |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 104 | device_ = weave::Device::Create(config_.get(), task_runner_.get(), |
| 105 | http_client_.get(), shill_client_.get(), |
| 106 | mdns_client_.get(), web_serv_client_.get(), |
| 107 | shill_client_.get(), bluetooth_client_.get()); |
Vitaly Buka | 1175a9b | 2015-08-15 10:42:17 -0700 | [diff] [blame] | 108 | |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 109 | device_->AddSettingsChangedCallback( |
| 110 | base::Bind(&Manager::OnConfigChanged, weak_ptr_factory_.GetWeakPtr())); |
Vitaly Buka | 0c6dcd2 | 2015-07-10 00:12:25 -0700 | [diff] [blame] | 111 | |
Vitaly Buka | a0305d3 | 2015-07-27 16:08:51 -0700 | [diff] [blame] | 112 | command_dispatcher_.reset(new DBusCommandDispacher{ |
Vitaly Buka | e8c3bab | 2015-07-29 16:39:34 -0700 | [diff] [blame] | 113 | dbus_object_.GetObjectManager(), device_->GetCommands()}); |
| 114 | |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 115 | device_->AddStateChangedCallback( |
Vitaly Buka | 2b30e7a | 2015-05-27 09:27:08 -0700 | [diff] [blame] | 116 | base::Bind(&Manager::OnStateChanged, weak_ptr_factory_.GetWeakPtr())); |
Vitaly Buka | bf4ba65 | 2015-05-14 16:57:23 -0700 | [diff] [blame] | 117 | |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 118 | device_->AddGcdStateChangedCallback( |
| 119 | base::Bind(&Manager::OnGcdStateChanged, weak_ptr_factory_.GetWeakPtr())); |
Vitaly Buka | e74fe3c | 2015-05-13 13:48:59 -0700 | [diff] [blame] | 120 | |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 121 | if (!options.disable_privet) { |
| 122 | device_->AddPairingChangedCallbacks( |
Vitaly Buka | 1d63c9c | 2015-07-17 14:34:35 -0700 | [diff] [blame] | 123 | base::Bind(&Manager::OnPairingStart, weak_ptr_factory_.GetWeakPtr()), |
| 124 | base::Bind(&Manager::OnPairingEnd, weak_ptr_factory_.GetWeakPtr())); |
Vitaly Buka | 1d63c9c | 2015-07-17 14:34:35 -0700 | [diff] [blame] | 125 | } |
Vitaly Buka | 84fd6dd | 2015-06-09 17:22:18 -0700 | [diff] [blame] | 126 | |
Alex Vakulenko | 12e2c1a | 2014-11-21 08:57:57 -0800 | [diff] [blame] | 127 | dbus_adaptor_.RegisterWithDBusObject(&dbus_object_); |
Vitaly Buka | 84fd6dd | 2015-06-09 17:22:18 -0700 | [diff] [blame] | 128 | dbus_object_.RegisterAsync( |
| 129 | sequencer->GetHandler("Manager.RegisterAsync() failed.", true)); |
Vitaly Buka | 84fd6dd | 2015-06-09 17:22:18 -0700 | [diff] [blame] | 130 | } |
| 131 | |
| 132 | void Manager::Stop() { |
Vitaly Buka | 0c6dcd2 | 2015-07-10 00:12:25 -0700 | [diff] [blame] | 133 | device_.reset(); |
Christopher Wiley | 4b5f04c | 2014-03-27 14:45:37 -0700 | [diff] [blame] | 134 | } |
| 135 | |
Alex Vakulenko | 6c37526 | 2015-06-19 11:01:42 -0700 | [diff] [blame] | 136 | void Manager::RegisterDevice(DBusMethodResponsePtr<std::string> response, |
Vitaly Buka | cbadabe | 2015-05-14 23:33:32 -0700 | [diff] [blame] | 137 | const std::string& ticket_id) { |
Anton Muhin | 9cc03fd | 2014-10-16 18:59:57 +0400 | [diff] [blame] | 138 | LOG(INFO) << "Received call to Manager.RegisterDevice()"; |
Alex Vakulenko | f3d77e5 | 2014-04-15 11:36:32 -0700 | [diff] [blame] | 139 | |
Vitaly Buka | 4f77153 | 2015-08-14 14:58:39 -0700 | [diff] [blame] | 140 | weave::ErrorPtr error; |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 141 | std::string device_id = device_->Register(ticket_id, &error); |
David Zeuthen | 2101c08 | 2015-02-12 15:24:21 -0500 | [diff] [blame] | 142 | if (!device_id.empty()) { |
Alex Vakulenko | b91dcfe | 2014-10-30 16:28:38 -0700 | [diff] [blame] | 143 | response->Return(device_id); |
David Zeuthen | 2101c08 | 2015-02-12 15:24:21 -0500 | [diff] [blame] | 144 | return; |
| 145 | } |
Vitaly Buka | 4f77153 | 2015-08-14 14:58:39 -0700 | [diff] [blame] | 146 | chromeos::ErrorPtr chromeos_error; |
| 147 | ConvertError(*error, &chromeos_error); |
| 148 | response->ReplyWithError(chromeos_error.get()); |
Christopher Wiley | 4b5f04c | 2014-03-27 14:45:37 -0700 | [diff] [blame] | 149 | } |
| 150 | |
Alex Vakulenko | 6c37526 | 2015-06-19 11:01:42 -0700 | [diff] [blame] | 151 | void Manager::UpdateState(DBusMethodResponsePtr<> response, |
Alex Vakulenko | 12e2c1a | 2014-11-21 08:57:57 -0800 | [diff] [blame] | 152 | const chromeos::VariantDictionary& property_set) { |
Vitaly Buka | 4f77153 | 2015-08-14 14:58:39 -0700 | [diff] [blame] | 153 | chromeos::ErrorPtr chromeos_error; |
| 154 | auto properties = |
| 155 | DictionaryFromDBusVariantDictionary(property_set, &chromeos_error); |
Vitaly Buka | fb2584b | 2015-07-28 21:39:45 -0700 | [diff] [blame] | 156 | if (!properties) |
Alex Vakulenko | e32375b | 2015-09-28 08:55:40 -0700 | [diff] [blame] | 157 | return response->ReplyWithError(chromeos_error.get()); |
Vitaly Buka | fb2584b | 2015-07-28 21:39:45 -0700 | [diff] [blame] | 158 | |
Vitaly Buka | 4f77153 | 2015-08-14 14:58:39 -0700 | [diff] [blame] | 159 | weave::ErrorPtr error; |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 160 | if (!device_->SetStateProperties(*properties, &error)) { |
Vitaly Buka | 4f77153 | 2015-08-14 14:58:39 -0700 | [diff] [blame] | 161 | ConvertError(*error, &chromeos_error); |
Alex Vakulenko | e32375b | 2015-09-28 08:55:40 -0700 | [diff] [blame] | 162 | return response->ReplyWithError(chromeos_error.get()); |
Vitaly Buka | 4f77153 | 2015-08-14 14:58:39 -0700 | [diff] [blame] | 163 | } |
| 164 | response->Return(); |
Christopher Wiley | 4b5f04c | 2014-03-27 14:45:37 -0700 | [diff] [blame] | 165 | } |
| 166 | |
Alex Vakulenko | ceab177 | 2015-01-20 10:50:04 -0800 | [diff] [blame] | 167 | bool Manager::GetState(chromeos::ErrorPtr* error, std::string* state) { |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 168 | auto json = device_->GetState(); |
Vitaly Buka | cd5e556 | 2015-07-28 15:33:55 -0700 | [diff] [blame] | 169 | CHECK(json); |
Nathan Bullock | f5b91bf | 2015-04-01 15:32:58 -0400 | [diff] [blame] | 170 | base::JSONWriter::WriteWithOptions( |
Alex Vakulenko | ab4e4ff | 2015-06-15 12:53:22 -0700 | [diff] [blame] | 171 | *json, base::JSONWriter::OPTIONS_PRETTY_PRINT, state); |
Alex Vakulenko | ceab177 | 2015-01-20 10:50:04 -0800 | [diff] [blame] | 172 | return true; |
| 173 | } |
| 174 | |
Alex Vakulenko | 6c37526 | 2015-06-19 11:01:42 -0700 | [diff] [blame] | 175 | void Manager::AddCommand(DBusMethodResponsePtr<std::string> response, |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 176 | const std::string& json_command) { |
Alex Vakulenko | 4f7778e | 2014-09-11 16:57:24 -0700 | [diff] [blame] | 177 | std::string error_message; |
Alex Vakulenko | ab4e4ff | 2015-06-15 12:53:22 -0700 | [diff] [blame] | 178 | std::unique_ptr<base::Value> value( |
| 179 | base::JSONReader::ReadAndReturnError(json_command, base::JSON_PARSE_RFC, |
| 180 | nullptr, &error_message) |
| 181 | .release()); |
Vitaly Buka | a4e8d7f | 2015-06-09 09:46:53 -0700 | [diff] [blame] | 182 | const base::DictionaryValue* command{nullptr}; |
| 183 | if (!value || !value->GetAsDictionary(&command)) { |
| 184 | return response->ReplyWithError(FROM_HERE, chromeos::errors::json::kDomain, |
| 185 | chromeos::errors::json::kParseError, |
| 186 | error_message); |
Alex Vakulenko | 4f7778e | 2014-09-11 16:57:24 -0700 | [diff] [blame] | 187 | } |
Vitaly Buka | a4e8d7f | 2015-06-09 09:46:53 -0700 | [diff] [blame] | 188 | |
Vitaly Buka | a4e8d7f | 2015-06-09 09:46:53 -0700 | [diff] [blame] | 189 | std::string id; |
Vitaly Buka | 4f77153 | 2015-08-14 14:58:39 -0700 | [diff] [blame] | 190 | weave::ErrorPtr error; |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 191 | if (!device_->GetCommands()->AddCommand(*command, &id, &error)) { |
| 192 | chromeos::ErrorPtr chromeos_error; |
Vitaly Buka | 4f77153 | 2015-08-14 14:58:39 -0700 | [diff] [blame] | 193 | ConvertError(*error, &chromeos_error); |
| 194 | return response->ReplyWithError(chromeos_error.get()); |
| 195 | } |
Vitaly Buka | c03ec2b | 2015-05-31 23:32:46 -0700 | [diff] [blame] | 196 | |
Vitaly Buka | 59af7ac | 2015-03-24 12:42:24 -0700 | [diff] [blame] | 197 | response->Return(id); |
Alex Vakulenko | 4f7778e | 2014-09-11 16:57:24 -0700 | [diff] [blame] | 198 | } |
| 199 | |
Alex Vakulenko | 6c37526 | 2015-06-19 11:01:42 -0700 | [diff] [blame] | 200 | void Manager::GetCommand(DBusMethodResponsePtr<std::string> response, |
Vitaly Buka | 5515de0 | 2015-03-24 11:39:40 -0700 | [diff] [blame] | 201 | const std::string& id) { |
Vitaly Buka | ba46373 | 2015-07-14 19:19:39 -0700 | [diff] [blame] | 202 | const weave::Command* command = device_->GetCommands()->FindCommand(id); |
Vitaly Buka | 5515de0 | 2015-03-24 11:39:40 -0700 | [diff] [blame] | 203 | if (!command) { |
Vitaly Buka | 0c6dcd2 | 2015-07-10 00:12:25 -0700 | [diff] [blame] | 204 | response->ReplyWithError(FROM_HERE, kErrorDomain, "unknown_command", |
Vitaly Buka | 5515de0 | 2015-03-24 11:39:40 -0700 | [diff] [blame] | 205 | "Can't find command with id: " + id); |
| 206 | return; |
| 207 | } |
| 208 | std::string command_str; |
Alex Vakulenko | ab4e4ff | 2015-06-15 12:53:22 -0700 | [diff] [blame] | 209 | base::JSONWriter::WriteWithOptions( |
| 210 | *command->ToJson(), base::JSONWriter::OPTIONS_PRETTY_PRINT, &command_str); |
Vitaly Buka | 5515de0 | 2015-03-24 11:39:40 -0700 | [diff] [blame] | 211 | response->Return(command_str); |
| 212 | } |
| 213 | |
Alex Vakulenko | 12e2c1a | 2014-11-21 08:57:57 -0800 | [diff] [blame] | 214 | std::string Manager::TestMethod(const std::string& message) { |
Alex Vakulenko | 35e3bab | 2014-08-15 11:45:46 -0700 | [diff] [blame] | 215 | LOG(INFO) << "Received call to test method: " << message; |
| 216 | return message; |
Christopher Wiley | 2ffa004 | 2014-05-05 16:09:16 -0700 | [diff] [blame] | 217 | } |
| 218 | |
Vitaly Buka | 2b30e7a | 2015-05-27 09:27:08 -0700 | [diff] [blame] | 219 | void Manager::OnStateChanged() { |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 220 | auto state = device_->GetState(); |
Vitaly Buka | 2b30e7a | 2015-05-27 09:27:08 -0700 | [diff] [blame] | 221 | CHECK(state); |
| 222 | std::string json; |
| 223 | base::JSONWriter::WriteWithOptions( |
Alex Vakulenko | ab4e4ff | 2015-06-15 12:53:22 -0700 | [diff] [blame] | 224 | *state, base::JSONWriter::OPTIONS_PRETTY_PRINT, &json); |
Vitaly Buka | 2b30e7a | 2015-05-27 09:27:08 -0700 | [diff] [blame] | 225 | dbus_adaptor_.SetState(json); |
| 226 | } |
| 227 | |
Alex Vakulenko | 0022b75 | 2015-10-02 11:09:59 -0700 | [diff] [blame^] | 228 | void Manager::OnGcdStateChanged(weave::GcdState state) { |
| 229 | dbus_adaptor_.SetStatus(weave::EnumToString(state)); |
Vitaly Buka | bf4ba65 | 2015-05-14 16:57:23 -0700 | [diff] [blame] | 230 | } |
| 231 | |
Vitaly Buka | 00b8349 | 2015-07-20 00:37:48 -0700 | [diff] [blame] | 232 | void Manager::OnConfigChanged(const weave::Settings& settings) { |
Alex Vakulenko | e4ef261 | 2015-09-29 09:53:39 -0700 | [diff] [blame] | 233 | dbus_adaptor_.SetDeviceId(settings.cloud_id); |
Vitaly Buka | 00b8349 | 2015-07-20 00:37:48 -0700 | [diff] [blame] | 234 | dbus_adaptor_.SetOemName(settings.oem_name); |
| 235 | dbus_adaptor_.SetModelName(settings.model_name); |
| 236 | dbus_adaptor_.SetModelId(settings.model_id); |
| 237 | dbus_adaptor_.SetName(settings.name); |
| 238 | dbus_adaptor_.SetDescription(settings.description); |
| 239 | dbus_adaptor_.SetLocation(settings.location); |
Vitaly Buka | 7b3ba79 | 2015-06-09 17:01:54 -0700 | [diff] [blame] | 240 | } |
| 241 | |
| 242 | void Manager::OnPairingStart(const std::string& session_id, |
Vitaly Buka | 0c6dcd2 | 2015-07-10 00:12:25 -0700 | [diff] [blame] | 243 | weave::PairingType pairing_type, |
Vitaly Buka | 7b3ba79 | 2015-06-09 17:01:54 -0700 | [diff] [blame] | 244 | const std::vector<uint8_t>& code) { |
| 245 | // For now, just overwrite the exposed PairInfo with |
| 246 | // the most recent pairing attempt. |
| 247 | dbus_adaptor_.SetPairingInfo(chromeos::VariantDictionary{ |
| 248 | {kPairingSessionIdKey, session_id}, |
Vitaly Buka | 03319c2 | 2015-07-17 14:48:30 -0700 | [diff] [blame] | 249 | {kPairingModeKey, weave::EnumToString(pairing_type)}, |
Vitaly Buka | 7b3ba79 | 2015-06-09 17:01:54 -0700 | [diff] [blame] | 250 | {kPairingCodeKey, code}, |
| 251 | }); |
| 252 | } |
| 253 | |
| 254 | void Manager::OnPairingEnd(const std::string& session_id) { |
| 255 | auto exposed_pairing_attempt = dbus_adaptor_.GetPairingInfo(); |
| 256 | auto it = exposed_pairing_attempt.find(kPairingSessionIdKey); |
| 257 | if (it == exposed_pairing_attempt.end()) { |
| 258 | return; |
| 259 | } |
| 260 | std::string exposed_session{it->second.TryGet<std::string>()}; |
| 261 | if (exposed_session == session_id) { |
| 262 | dbus_adaptor_.SetPairingInfo(chromeos::VariantDictionary{}); |
| 263 | } |
| 264 | } |
| 265 | |
Christopher Wiley | 4b5f04c | 2014-03-27 14:45:37 -0700 | [diff] [blame] | 266 | } // namespace buffet |