| OLD | NEW |
| 1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 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 | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "chrome/browser/chromeos/extensions/networking_private_event_router.h" | 5 #include "chrome/browser/chromeos/extensions/networking_private_event_router.h" |
| 6 | 6 |
| 7 #include "base/json/json_writer.h" | 7 #include "base/json/json_writer.h" |
| 8 #include "chrome/browser/browser_process.h" | 8 #include "chrome/browser/browser_process.h" |
| 9 #include "chrome/browser/chromeos/extensions/networking_private_api.h" | 9 #include "chrome/browser/chromeos/extensions/networking_private_api.h" |
| 10 #include "chrome/browser/extensions/event_names.h" | 10 #include "chrome/browser/extensions/event_names.h" |
| 11 #include "chrome/browser/extensions/event_router_forwarder.h" | 11 #include "chrome/browser/extensions/event_router_forwarder.h" |
| 12 #include "chrome/browser/extensions/extension_system.h" | 12 #include "chrome/browser/extensions/extension_system.h" |
| 13 #include "chrome/browser/extensions/extension_system_factory.h" | 13 #include "chrome/browser/extensions/extension_system_factory.h" |
| 14 #include "chrome/browser/profiles/profile.h" | 14 #include "chrome/browser/profiles/profile.h" |
| 15 #include "chrome/browser/profiles/profile_dependency_manager.h" | 15 #include "chrome/browser/profiles/profile_dependency_manager.h" |
| 16 #include "chrome/common/extensions/api/networking_private.h" | 16 #include "chrome/common/extensions/api/networking_private.h" |
| 17 #include "chromeos/network/network_state.h" | 17 #include "chromeos/network/network_state.h" |
| 18 #include "chromeos/network/network_state_handler.h" | 18 #include "chromeos/network/network_state_handler.h" |
| 19 #include "chromeos/network/onc/onc_constants.h" | 19 #include "chromeos/network/onc/onc_constants.h" |
| 20 #include "chromeos/network/onc/onc_signature.h" | 20 #include "chromeos/network/onc/onc_signature.h" |
| 21 #include "chromeos/network/onc/onc_translator.h" | 21 #include "chromeos/network/onc/onc_translator.h" |
| 22 #include "third_party/cros_system_api/dbus/service_constants.h" | 22 #include "third_party/cros_system_api/dbus/service_constants.h" |
| 23 | 23 |
| 24 using extensions::event_names::kOnNetworkListChanged; |
| 25 using extensions::event_names::kOnNetworksChanged; |
| 26 using extensions::EventRouter; |
| 24 using extensions::ExtensionSystem; | 27 using extensions::ExtensionSystem; |
| 25 namespace api = extensions::api::networking_private; | 28 namespace api = extensions::api::networking_private; |
| 26 | 29 |
| 27 namespace chromeos { | 30 namespace chromeos { |
| 28 | 31 |
| 29 namespace { | 32 namespace { |
| 30 | 33 |
| 31 // Translates the current connection state of the network into the ONC | 34 // Translates the current connection state of the network into the ONC |
| 32 // equivalent. | 35 // equivalent. |
| 33 std::string GetConnectionState(const NetworkState* state) { | 36 std::string GetConnectionState(const NetworkState* state) { |
| (...skipping 21 matching lines...) Expand all Loading... |
| 55 } | 58 } |
| 56 | 59 |
| 57 } // namespace | 60 } // namespace |
| 58 | 61 |
| 59 NetworkingPrivateEventRouter::NetworkingPrivateEventRouter(Profile* profile) | 62 NetworkingPrivateEventRouter::NetworkingPrivateEventRouter(Profile* profile) |
| 60 : profile_(profile), listening_(false) { | 63 : profile_(profile), listening_(false) { |
| 61 // Register with the event router so we know when renderers are listening to | 64 // Register with the event router so we know when renderers are listening to |
| 62 // our events. We first check and see if there *is* an event router, because | 65 // our events. We first check and see if there *is* an event router, because |
| 63 // some unit tests try to create all profile services, but don't initialize | 66 // some unit tests try to create all profile services, but don't initialize |
| 64 // the event router first. | 67 // the event router first. |
| 65 extensions::EventRouter* event_router = | 68 EventRouter* event_router = ExtensionSystem::Get(profile_)->event_router(); |
| 66 ExtensionSystem::Get(profile_)->event_router(); | |
| 67 if (event_router) { | 69 if (event_router) { |
| 68 event_router->RegisterObserver( | 70 event_router->RegisterObserver( |
| 69 this, extensions::event_names::kOnNetworkChanged); | 71 this, extensions::event_names::kOnNetworksChanged); |
| 72 event_router->RegisterObserver( |
| 73 this, extensions::event_names::kOnNetworkListChanged); |
| 70 StartOrStopListeningForNetworkChanges(); | 74 StartOrStopListeningForNetworkChanges(); |
| 71 } | 75 } |
| 72 } | 76 } |
| 73 | 77 |
| 74 NetworkingPrivateEventRouter::~NetworkingPrivateEventRouter() { | 78 NetworkingPrivateEventRouter::~NetworkingPrivateEventRouter() { |
| 75 } | 79 } |
| 76 | 80 |
| 77 void NetworkingPrivateEventRouter::Shutdown() { | 81 void NetworkingPrivateEventRouter::Shutdown() { |
| 78 // Unregister with the event router. We first check and see if there *is* an | 82 // Unregister with the event router. We first check and see if there *is* an |
| 79 // event router, because some unit tests try to shutdown all profile services, | 83 // event router, because some unit tests try to shutdown all profile services, |
| 80 // but didn't initialize the event router first. | 84 // but didn't initialize the event router first. |
| 81 extensions::EventRouter* event_router = | 85 EventRouter* event_router = ExtensionSystem::Get(profile_)->event_router(); |
| 82 ExtensionSystem::Get(profile_)->event_router(); | |
| 83 if (event_router) | 86 if (event_router) |
| 84 event_router->UnregisterObserver(this); | 87 event_router->UnregisterObserver(this); |
| 85 | 88 |
| 86 if (listening_) | 89 if (listening_) |
| 87 NetworkStateHandler::Get()->RemoveObserver(this); | 90 NetworkStateHandler::Get()->RemoveObserver(this); |
| 88 listening_ = false; | 91 listening_ = false; |
| 89 } | 92 } |
| 90 | 93 |
| 91 void NetworkingPrivateEventRouter::OnListenerAdded( | 94 void NetworkingPrivateEventRouter::OnListenerAdded( |
| 92 const extensions::EventListenerInfo& details) { | 95 const extensions::EventListenerInfo& details) { |
| 93 // Start listening to events from the network state handler. | 96 // Start listening to events from the network state handler. |
| 94 StartOrStopListeningForNetworkChanges(); | 97 StartOrStopListeningForNetworkChanges(); |
| 95 } | 98 } |
| 96 | 99 |
| 97 void NetworkingPrivateEventRouter::OnListenerRemoved( | 100 void NetworkingPrivateEventRouter::OnListenerRemoved( |
| 98 const extensions::EventListenerInfo& details) { | 101 const extensions::EventListenerInfo& details) { |
| 99 // Stop listening to events from the network state handler if there are no | 102 // Stop listening to events from the network state handler if there are no |
| 100 // more listeners. | 103 // more listeners. |
| 101 StartOrStopListeningForNetworkChanges(); | 104 StartOrStopListeningForNetworkChanges(); |
| 102 } | 105 } |
| 103 | 106 |
| 104 void NetworkingPrivateEventRouter::StartOrStopListeningForNetworkChanges() { | 107 void NetworkingPrivateEventRouter::StartOrStopListeningForNetworkChanges() { |
| 105 bool should_listen = ExtensionSystem::Get(profile_)->event_router()-> | 108 EventRouter* event_router = ExtensionSystem::Get(profile_)->event_router(); |
| 106 HasEventListener(extensions::event_names::kOnNetworkChanged); | 109 bool should_listen = event_router->HasEventListener(kOnNetworksChanged) || |
| 110 event_router->HasEventListener(kOnNetworkListChanged); |
| 107 | 111 |
| 108 if (should_listen) { | 112 if (should_listen) { |
| 109 if (!listening_) | 113 if (!listening_) |
| 110 NetworkStateHandler::Get()->AddObserver(this); | 114 NetworkStateHandler::Get()->AddObserver(this); |
| 111 } else { | 115 } else { |
| 112 if (listening_) | 116 if (listening_) |
| 113 NetworkStateHandler::Get()->RemoveObserver(this); | 117 NetworkStateHandler::Get()->RemoveObserver(this); |
| 114 } | 118 } |
| 115 listening_ = should_listen; | 119 listening_ = should_listen; |
| 116 } | 120 } |
| 117 | 121 |
| 118 void NetworkingPrivateEventRouter::NetworkListChanged() { | 122 void NetworkingPrivateEventRouter::NetworkListChanged() { |
| 123 EventRouter* event_router = ExtensionSystem::Get(profile_)->event_router(); |
| 119 NetworkStateList networks; | 124 NetworkStateList networks; |
| 120 NetworkStateHandler::Get()->GetNetworkList(&networks); | 125 NetworkStateHandler::Get()->GetNetworkList(&networks); |
| 121 std::vector<linked_ptr<api::NetworkProperties> > changes; | 126 if (!event_router->HasEventListener(kOnNetworkListChanged)) |
| 127 return; |
| 128 |
| 129 std::vector<std::string> changes; |
| 122 for (NetworkStateList::const_iterator iter = networks.begin(); | 130 for (NetworkStateList::const_iterator iter = networks.begin(); |
| 123 iter != networks.end(); ++iter) { | 131 iter != networks.end(); ++iter) { |
| 124 api::NetworkProperties* network_properties = new api::NetworkProperties; | 132 // TODO(gspencer): Currently the "GUID" is actually the service path. Fix |
| 125 network_properties->additional_properties.SetString( | 133 // this to be the real GUID once we're using |
| 126 onc::network_config::kName, (*iter)->name()); | 134 // ManagedNetworkConfigurationManager. |
| 127 network_properties->additional_properties.SetString( | 135 changes.push_back((*iter)->path()); |
| 128 onc::network_config::kGUID, (*iter)->path()); | |
| 129 network_properties->additional_properties.SetString( | |
| 130 onc::network_config::kType, | |
| 131 GetConnectionType((*iter)->type())); | |
| 132 network_properties->additional_properties.SetString( | |
| 133 onc::network_config::kConnectionState, | |
| 134 GetConnectionState(*iter)); | |
| 135 changes.push_back(make_linked_ptr(network_properties)); | |
| 136 } | 136 } |
| 137 | 137 |
| 138 scoped_ptr<base::ListValue> args(api::OnNetworkChanged::Create(changes)); | 138 scoped_ptr<base::ListValue> args(api::OnNetworkListChanged::Create(changes)); |
| 139 scoped_ptr<extensions::Event> extension_event(new extensions::Event( | 139 scoped_ptr<extensions::Event> extension_event(new extensions::Event( |
| 140 extensions::event_names::kOnNetworkChanged, args.Pass())); | 140 kOnNetworkListChanged, args.Pass())); |
| 141 ExtensionSystem::Get(profile_)->event_router()->BroadcastEvent( | 141 event_router->BroadcastEvent(extension_event.Pass()); |
| 142 extension_event.Pass()); | 142 } |
| 143 |
| 144 void NetworkingPrivateEventRouter::NetworkPropertiesUpdated( |
| 145 const NetworkState* network) { |
| 146 EventRouter* event_router = ExtensionSystem::Get(profile_)->event_router(); |
| 147 if (!event_router->HasEventListener(kOnNetworksChanged)) |
| 148 return; |
| 149 |
| 150 scoped_ptr<base::ListValue> args(api::OnNetworksChanged::Create( |
| 151 std::vector<std::string>(1, network->path()))); |
| 152 scoped_ptr<extensions::Event> extension_event( |
| 153 new extensions::Event(kOnNetworksChanged, args.Pass())); |
| 154 event_router->BroadcastEvent(extension_event.Pass()); |
| 143 } | 155 } |
| 144 | 156 |
| 145 } // namespace chromeos | 157 } // namespace chromeos |
| OLD | NEW |