Home | History | Annotate | Download | only in buffet 
      1 // Copyright 2015 The Android Open Source Project
      2 //
      3 // Licensed under the Apache License, Version 2.0 (the "License");
      4 // you may not use this file except in compliance with the License.
      5 // You may obtain a copy of the License at
      6 //
      7 //      http://www.apache.org/licenses/LICENSE-2.0
      8 //
      9 // Unless required by applicable law or agreed to in writing, software
     10 // distributed under the License is distributed on an "AS IS" BASIS,
     11 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     12 // See the License for the specific language governing permissions and
     13 // limitations under the License.
     14 
     15 #include "buffet/ap_manager_client.h"
     16 
     17 namespace buffet {
     18 
     19 using org::chromium::apmanager::ConfigProxyInterface;
     20 using org::chromium::apmanager::ManagerProxyInterface;
     21 using org::chromium::apmanager::ServiceProxyInterface;
     22 
     23 ApManagerClient::ApManagerClient(const scoped_refptr<dbus::Bus>& bus)
     24     : bus_(bus) {}
     25 
     26 ApManagerClient::~ApManagerClient() {
     27   Stop();
     28 }
     29 
     30 void ApManagerClient::Start(const std::string& ssid) {
     31   if (service_path_.IsValid()) {
     32     return;
     33   }
     34 
     35   ssid_ = ssid;
     36 
     37   object_manager_proxy_.reset(
     38       new org::chromium::apmanager::ObjectManagerProxy{bus_});
     39   object_manager_proxy_->SetManagerAddedCallback(base::Bind(
     40       &ApManagerClient::OnManagerAdded, weak_ptr_factory_.GetWeakPtr()));
     41   object_manager_proxy_->SetServiceAddedCallback(base::Bind(
     42       &ApManagerClient::OnServiceAdded, weak_ptr_factory_.GetWeakPtr()));
     43 
     44   object_manager_proxy_->SetServiceRemovedCallback(base::Bind(
     45       &ApManagerClient::OnServiceRemoved, weak_ptr_factory_.GetWeakPtr()));
     46   object_manager_proxy_->SetManagerRemovedCallback(base::Bind(
     47       &ApManagerClient::OnManagerRemoved, weak_ptr_factory_.GetWeakPtr()));
     48 }
     49 
     50 void ApManagerClient::Stop() {
     51   if (manager_proxy_ && service_path_.IsValid()) {
     52     RemoveService(service_path_);
     53   }
     54   service_path_ = dbus::ObjectPath();
     55   service_proxy_ = nullptr;
     56   manager_proxy_ = nullptr;
     57   object_manager_proxy_.reset();
     58   ssid_.clear();
     59 }
     60 
     61 void ApManagerClient::RemoveService(const dbus::ObjectPath& object_path) {
     62   CHECK(object_path.IsValid());
     63   brillo::ErrorPtr error;
     64   if (!manager_proxy_->RemoveService(object_path, &error)) {
     65     LOG(ERROR) << "RemoveService failed: " << error->GetMessage();
     66   }
     67 }
     68 
     69 void ApManagerClient::OnManagerAdded(ManagerProxyInterface* manager_proxy) {
     70   VLOG(1) << "manager added: " << manager_proxy->GetObjectPath().value();
     71   manager_proxy_ = manager_proxy;
     72 
     73   if (service_path_.IsValid())
     74     return;
     75 
     76   brillo::ErrorPtr error;
     77   if (!manager_proxy_->CreateService(&service_path_, &error)) {
     78     LOG(ERROR) << "CreateService failed: " << error->GetMessage();
     79   }
     80 }
     81 
     82 void ApManagerClient::OnServiceAdded(ServiceProxyInterface* service_proxy) {
     83   VLOG(1) << "service added: " << service_proxy->GetObjectPath().value();
     84   if (service_proxy->GetObjectPath() != service_path_) {
     85     RemoveService(service_proxy->GetObjectPath());
     86     return;
     87   }
     88   service_proxy_ = service_proxy;
     89 
     90   ConfigProxyInterface* config_proxy =
     91       object_manager_proxy_->GetConfigProxy(service_proxy->config());
     92   config_proxy->set_ssid(ssid_, base::Bind(&ApManagerClient::OnSsidSet,
     93                                            weak_ptr_factory_.GetWeakPtr()));
     94 }
     95 
     96 void ApManagerClient::OnSsidSet(bool success) {
     97   if (!success || !service_proxy_) {
     98     LOG(ERROR) << "Failed to set ssid.";
     99     return;
    100   }
    101   VLOG(1) << "SSID is set: " << ssid_;
    102 
    103   brillo::ErrorPtr error;
    104   if (!service_proxy_->Start(&error)) {
    105     LOG(ERROR) << "Service start failed: " << error->GetMessage();
    106   }
    107 }
    108 
    109 void ApManagerClient::OnServiceRemoved(const dbus::ObjectPath& object_path) {
    110   VLOG(1) << "service removed: " << object_path.value();
    111   if (object_path != service_path_)
    112     return;
    113   service_path_ = dbus::ObjectPath();
    114   service_proxy_ = nullptr;
    115 }
    116 
    117 void ApManagerClient::OnManagerRemoved(const dbus::ObjectPath& object_path) {
    118   VLOG(1) << "manager removed: " << object_path.value();
    119   manager_proxy_ = nullptr;
    120   Stop();
    121 }
    122 
    123 }  // namespace buffet
    124