Chromium Code Reviews| OLD | NEW |
|---|---|
| (Empty) | |
| 1 // Copyright (c) 2013 The Chromium 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 "chrome/browser/chromeos/extensions/networking_private_event_router.h" | |
| 6 | |
| 7 #include "base/json/json_writer.h" | |
| 8 #include "chrome/browser/browser_process.h" | |
| 9 #include "chrome/browser/chromeos/extensions/networking_private_api.h" | |
| 10 #include "chrome/browser/extensions/event_names.h" | |
| 11 #include "chrome/browser/extensions/event_router_forwarder.h" | |
| 12 #include "chrome/browser/extensions/extension_system.h" | |
| 13 #include "chrome/browser/extensions/extension_system_factory.h" | |
| 14 #include "chrome/browser/profiles/profile.h" | |
| 15 #include "chrome/browser/profiles/profile_dependency_manager.h" | |
| 16 #include "chrome/common/extensions/api/networking_private.h" | |
| 17 #include "chromeos/network/network_state.h" | |
| 18 #include "chromeos/network/network_state_handler.h" | |
| 19 #include "chromeos/network/onc/onc_constants.h" | |
| 20 #include "chromeos/network/onc/onc_signature.h" | |
| 21 #include "chromeos/network/onc/onc_translator.h" | |
| 22 #include "third_party/cros_system_api/dbus/service_constants.h" | |
| 23 | |
| 24 using extensions::ExtensionSystem; | |
| 25 namespace api = extensions::api::networking_private; | |
| 26 | |
| 27 namespace chromeos { | |
| 28 | |
| 29 namespace { | |
| 30 | |
| 31 // Translates the current connection state of the network into the ONC | |
| 32 // equivalent. | |
| 33 std::string GetConnectionState(const NetworkState* state) { | |
| 34 if (state->IsConnectedState()) | |
| 35 return onc::connection_state::kConnected; | |
| 36 else if (state->IsConnectingState()) | |
| 37 return onc::connection_state::kConnecting; | |
| 38 else | |
| 39 return onc::connection_state::kNotConnected; | |
| 40 } | |
| 41 | |
| 42 // Translate from the Shill network type to the ONC network type. | |
| 43 std::string GetConnectionType(const std::string& shill_type) { | |
| 44 base::DictionaryValue shill_type_dict; | |
| 45 shill_type_dict.SetStringWithoutPathExpansion(flimflam::kTypeProperty, | |
| 46 shill_type); | |
| 47 scoped_ptr<base::DictionaryValue> onc_type_dict = | |
| 48 onc::TranslateShillServiceToONCPart( | |
| 49 shill_type_dict, | |
| 50 &onc::kNetworkConfigurationSignature); | |
| 51 std::string onc_type; | |
| 52 if (onc_type_dict->GetString(onc::network_config::kType, &onc_type)) | |
| 53 return onc_type; | |
| 54 return std::string(); | |
| 55 } | |
| 56 | |
| 57 } // namespace | |
| 58 | |
| 59 NetworkingPrivateEventRouter::NetworkingPrivateEventRouter(Profile* profile) | |
| 60 : profile_(profile), listening_(false) { | |
| 61 // Register with the event router so we know when renderers are listening | |
| 62 // to our events. | |
| 63 ExtensionSystem::Get(profile_)->event_router()->RegisterObserver( | |
| 64 this, extensions::event_names::kOnNetworkChanged); | |
| 65 StartOrStopListeningForNetworkChanges(); | |
| 66 } | |
| 67 | |
| 68 NetworkingPrivateEventRouter::~NetworkingPrivateEventRouter() { | |
| 69 } | |
| 70 | |
| 71 void NetworkingPrivateEventRouter::Shutdown() { | |
| 72 ExtensionSystem::Get(profile_)->event_router()->UnregisterObserver(this); | |
| 73 if (listening_) | |
| 74 NetworkStateHandler::Get()->RemoveObserver(this); | |
| 75 listening_ = false; | |
| 76 } | |
| 77 | |
| 78 void NetworkingPrivateEventRouter::OnListenerAdded( | |
| 79 const extensions::EventListenerInfo& details) { | |
| 80 // Start listening to events from the network state handler. | |
| 81 StartOrStopListeningForNetworkChanges(); | |
| 82 } | |
| 83 | |
| 84 void NetworkingPrivateEventRouter::OnListenerRemoved( | |
| 85 const extensions::EventListenerInfo& details) { | |
| 86 // Stop listening to events from the network state handler if there are no | |
| 87 // more listeners. | |
| 88 StartOrStopListeningForNetworkChanges(); | |
| 89 } | |
| 90 | |
| 91 // If there are any listeners for our event, then we want to register for | |
|
pneubeck (no reviews)
2013/02/05 23:08:30
move/combine this comment to the header?
Greg Spencer (Chromium)
2013/02/05 23:17:35
Done.
| |
| 92 // change notification from the network state handler. Otherwise, we want to | |
| 93 // stop listening. | |
| 94 void NetworkingPrivateEventRouter::StartOrStopListeningForNetworkChanges() { | |
| 95 extensions::EventRouter* event_router = | |
| 96 ExtensionSystem::Get(profile_)->event_router(); | |
| 97 CHECK(event_router); | |
|
pneubeck (no reviews)
2013/02/05 23:08:30
nit: not necessary, the calls below would fail imm
Greg Spencer (Chromium)
2013/02/05 23:17:35
Done.
| |
| 98 | |
| 99 bool should_listen = event_router->HasEventListener( | |
| 100 extensions::event_names::kOnNetworkChanged); | |
| 101 | |
| 102 if (should_listen) { | |
| 103 if (!listening_) | |
| 104 NetworkStateHandler::Get()->AddObserver(this); | |
| 105 listening_ = true; | |
| 106 } else { | |
| 107 if (listening_) | |
|
pneubeck (no reviews)
2013/02/05 23:08:30
else if (...
outside of clause
listening_ = shou
Greg Spencer (Chromium)
2013/02/05 23:17:35
Done.
| |
| 108 NetworkStateHandler::Get()->RemoveObserver(this); | |
| 109 listening_ = false; | |
| 110 } | |
| 111 } | |
| 112 | |
| 113 void NetworkingPrivateEventRouter::NetworkListChanged( | |
| 114 const NetworkStateList& networks) { | |
| 115 extensions::EventRouter* event_router = | |
|
pneubeck (no reviews)
2013/02/05 23:08:30
might move that to its usage below
nit: again, ch
Greg Spencer (Chromium)
2013/02/05 23:17:35
Done.
| |
| 116 ExtensionSystem::Get(profile_)->event_router(); | |
| 117 CHECK(event_router); | |
| 118 | |
| 119 std::vector<linked_ptr<api::NetworkProperties> > changes; | |
| 120 for (NetworkStateList::const_iterator iter = networks.begin(); | |
| 121 iter != networks.end(); ++iter) { | |
| 122 api::NetworkProperties* network_properties = new api::NetworkProperties; | |
| 123 network_properties->additional_properties.SetString( | |
| 124 onc::network_config::kName, (*iter)->name()); | |
| 125 network_properties->additional_properties.SetString( | |
| 126 onc::network_config::kGUID, (*iter)->path()); | |
| 127 network_properties->additional_properties.SetString( | |
| 128 onc::network_config::kType, | |
| 129 GetConnectionType((*iter)->type())); | |
| 130 network_properties->additional_properties.SetString( | |
| 131 onc::network_config::kConnectionState, | |
| 132 GetConnectionState(*iter)); | |
| 133 changes.push_back(make_linked_ptr(network_properties)); | |
| 134 } | |
| 135 | |
| 136 scoped_ptr<base::ListValue> args(api::OnNetworkChanged::Create(changes)); | |
| 137 scoped_ptr<extensions::Event> extension_event(new extensions::Event( | |
| 138 extensions::event_names::kOnNetworkChanged, args.Pass())); | |
| 139 event_router->BroadcastEvent(extension_event.Pass()); | |
| 140 } | |
| 141 | |
| 142 } // namespace chromeos | |
| OLD | NEW |