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 |