blob: f68f57d9db02ee95cdc0253b3f75e9d7754322b1 [file] [log] [blame]
Thomas Vachuska329af532015-03-10 02:08:33 -07001/*
Brian O'Connora09fe5b2017-08-03 21:12:30 -07002 * Copyright 2015-present Open Networking Foundation
Thomas Vachuska329af532015-03-10 02:08:33 -07003 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16package org.onosproject.ui.impl;
17
18import com.fasterxml.jackson.databind.JsonNode;
Thomas Vachuska329af532015-03-10 02:08:33 -070019import com.fasterxml.jackson.databind.node.ArrayNode;
20import com.fasterxml.jackson.databind.node.ObjectNode;
Simon Hunt879ce452017-08-10 23:32:00 -070021import com.google.common.collect.ImmutableSet;
Thomas Vachuska329af532015-03-10 02:08:33 -070022import org.onlab.osgi.ServiceDirectory;
23import org.onlab.packet.IpAddress;
Simon Hunta58d8942017-08-11 12:51:14 -070024import org.onlab.packet.VlanId;
Simon Hunt95d56fd2015-11-12 11:06:44 -080025import org.onlab.util.DefaultHashMap;
Thomas Vachuska329af532015-03-10 02:08:33 -070026import org.onosproject.cluster.ClusterEvent;
Thomas Vachuska329af532015-03-10 02:08:33 -070027import org.onosproject.cluster.ControllerNode;
28import org.onosproject.cluster.NodeId;
29import org.onosproject.core.CoreService;
cheng fan35dc0f22015-06-10 06:02:47 +080030import org.onosproject.incubator.net.tunnel.OpticalTunnelEndPoint;
31import org.onosproject.incubator.net.tunnel.Tunnel;
Thomas Vachuska329af532015-03-10 02:08:33 -070032import org.onosproject.net.AnnotationKeys;
33import org.onosproject.net.Annotations;
34import org.onosproject.net.ConnectPoint;
35import org.onosproject.net.DefaultEdgeLink;
36import org.onosproject.net.Device;
37import org.onosproject.net.DeviceId;
38import org.onosproject.net.EdgeLink;
Simon Huntf4fd2a22016-08-10 15:41:09 -070039import org.onosproject.net.ElementId;
Thomas Vachuska329af532015-03-10 02:08:33 -070040import org.onosproject.net.Host;
41import org.onosproject.net.HostId;
42import org.onosproject.net.HostLocation;
43import org.onosproject.net.Link;
Thomas Vachuska4c47a382018-05-07 13:48:38 -070044import org.onosproject.net.config.NetworkConfigService;
45import org.onosproject.net.config.basics.BasicDeviceConfig;
46import org.onosproject.net.config.basics.BasicElementConfig;
47import org.onosproject.net.config.basics.BasicHostConfig;
Thomas Vachuska329af532015-03-10 02:08:33 -070048import org.onosproject.net.device.DeviceEvent;
Thomas Vachuska164ecf62018-05-08 17:29:55 -070049import org.onosproject.net.driver.Driver;
Thomas Vachuska329af532015-03-10 02:08:33 -070050import org.onosproject.net.host.HostEvent;
Thomas Vachuska329af532015-03-10 02:08:33 -070051import org.onosproject.net.link.LinkEvent;
Thomas Vachuska329af532015-03-10 02:08:33 -070052import org.onosproject.net.provider.ProviderId;
Thomas Vachuska329af532015-03-10 02:08:33 -070053import org.onosproject.net.topology.Topology;
Simon Huntd2747a02015-04-30 22:41:16 -070054import org.onosproject.ui.JsonUtils;
Thomas Vachuska329af532015-03-10 02:08:33 -070055import org.onosproject.ui.UiConnection;
Simon Hunta0ddb022015-05-01 09:53:01 -070056import org.onosproject.ui.UiMessageHandler;
Simon Hunted804d52016-03-30 09:51:40 -070057import org.onosproject.ui.impl.topo.util.ServicesBundle;
Simon Hunt879ce452017-08-10 23:32:00 -070058import org.onosproject.ui.lion.LionBundle;
Simon Hunt0af1ec32015-07-24 12:17:55 -070059import org.onosproject.ui.topo.PropertyPanel;
Thomas Vachuska329af532015-03-10 02:08:33 -070060import org.slf4j.Logger;
61import org.slf4j.LoggerFactory;
62
Thomas Vachuska329af532015-03-10 02:08:33 -070063import java.util.Collection;
64import java.util.Collections;
Thomas Vachuska329af532015-03-10 02:08:33 -070065import java.util.Iterator;
Thomas Vachuska329af532015-03-10 02:08:33 -070066import java.util.Map;
Thomas Vachuskac616e172018-04-17 16:57:12 -070067import java.util.Objects;
chengfanc553c952016-07-22 15:48:23 +080068import java.util.Optional;
Simon Huntf4fd2a22016-08-10 15:41:09 -070069import java.util.Set;
Thomas Vachuska329af532015-03-10 02:08:33 -070070import java.util.concurrent.ConcurrentHashMap;
71
Thomas Vachuska329af532015-03-10 02:08:33 -070072import static com.google.common.base.Strings.isNullOrEmpty;
Thomas Vachuska164ecf62018-05-08 17:29:55 -070073import static org.onosproject.net.AnnotationKeys.DRIVER;
Thomas Vachuska329af532015-03-10 02:08:33 -070074import static org.onosproject.net.PortNumber.portNumber;
Thomas Vachuskac616e172018-04-17 16:57:12 -070075import static org.onosproject.net.config.basics.BasicElementConfig.LOC_TYPE_GEO;
76import static org.onosproject.net.config.basics.BasicElementConfig.LOC_TYPE_GRID;
Simon Hunt3a0598f2015-08-04 19:59:04 -070077import static org.onosproject.ui.topo.TopoConstants.CoreButtons;
Thomas Vachuska4c47a382018-05-07 13:48:38 -070078import static org.onosproject.ui.topo.TopoConstants.Properties.*;
Simon Huntd3ceffa2015-08-25 12:44:35 -070079import static org.onosproject.ui.topo.TopoUtils.compactLinkString;
Thomas Vachuska329af532015-03-10 02:08:33 -070080
81/**
82 * Facility for creating messages bound for the topology viewer.
83 */
Simon Hunta0ddb022015-05-01 09:53:01 -070084public abstract class TopologyViewMessageHandlerBase extends UiMessageHandler {
Thomas Vachuska329af532015-03-10 02:08:33 -070085
Simon Huntf4fd2a22016-08-10 15:41:09 -070086 private static final String NO_GEO_VALUE = "0.0";
Simon Hunt10618f62017-06-15 19:30:52 -070087 private static final String DASH = "-";
Simon Hunta58d8942017-08-11 12:51:14 -070088 private static final String SLASH = " / ";
Simon Hunt10618f62017-06-15 19:30:52 -070089
90 // nav paths are the view names for hot-link navigation from topo view...
91 private static final String DEVICE_NAV_PATH = "device";
92 private static final String HOST_NAV_PATH = "host";
Simon Huntf4fd2a22016-08-10 15:41:09 -070093
Simon Hunta58d8942017-08-11 12:51:14 -070094 // link panel label keys
95 private static final String LPL_FRIENDLY = "lp_label_friendly";
96 private static final String LPL_A_TYPE = "lp_label_a_type";
97 private static final String LPL_A_ID = "lp_label_a_id";
98 private static final String LPL_A_FRIENDLY = "lp_label_a_friendly";
99 private static final String LPL_A_PORT = "lp_label_a_port";
100 private static final String LPL_B_TYPE = "lp_label_b_type";
101 private static final String LPL_B_ID = "lp_label_b_id";
102 private static final String LPL_B_FRIENDLY = "lp_label_b_friendly";
103 private static final String LPL_B_PORT = "lp_label_b_port";
104 private static final String LPL_A2B = "lp_label_a2b";
105 private static final String LPL_B2A = "lp_label_b2a";
106 private static final String LPV_NO_LINK = "lp_value_no_link";
107
108 // other Lion keys
109 private static final String HOST = "host";
110 private static final String DEVICE = "device";
111 private static final String EXPECTED = "expected";
112 private static final String NOT_EXPECTED = "not_expected";
113
Simon Hunt95d56fd2015-11-12 11:06:44 -0800114 // default to an "add" event...
115 private static final DefaultHashMap<ClusterEvent.Type, String> CLUSTER_EVENT =
116 new DefaultHashMap<>("addInstance");
117
118 // default to an "update" event...
119 private static final DefaultHashMap<DeviceEvent.Type, String> DEVICE_EVENT =
120 new DefaultHashMap<>("updateDevice");
121 private static final DefaultHashMap<LinkEvent.Type, String> LINK_EVENT =
122 new DefaultHashMap<>("updateLink");
123 private static final DefaultHashMap<HostEvent.Type, String> HOST_EVENT =
124 new DefaultHashMap<>("updateHost");
125
126 // but call out specific events that we care to differentiate...
127 static {
128 CLUSTER_EVENT.put(ClusterEvent.Type.INSTANCE_REMOVED, "removeInstance");
129
130 DEVICE_EVENT.put(DeviceEvent.Type.DEVICE_ADDED, "addDevice");
131 DEVICE_EVENT.put(DeviceEvent.Type.DEVICE_REMOVED, "removeDevice");
132
133 LINK_EVENT.put(LinkEvent.Type.LINK_ADDED, "addLink");
134 LINK_EVENT.put(LinkEvent.Type.LINK_REMOVED, "removeLink");
135
136 HOST_EVENT.put(HostEvent.Type.HOST_ADDED, "addHost");
137 HOST_EVENT.put(HostEvent.Type.HOST_REMOVED, "removeHost");
138 HOST_EVENT.put(HostEvent.Type.HOST_MOVED, "moveHost");
139 }
140
Simon Hunta58d8942017-08-11 12:51:14 -0700141 private static final DefaultHashMap<Device.Type, String> DEVICE_GLYPHS =
142 new DefaultHashMap<>("m_unknown");
143
144 static {
145 DEVICE_GLYPHS.put(Device.Type.SWITCH, "m_switch");
146 DEVICE_GLYPHS.put(Device.Type.ROUTER, "m_router");
147 DEVICE_GLYPHS.put(Device.Type.ROADM, "m_roadm");
148 DEVICE_GLYPHS.put(Device.Type.OTN, "m_otn");
149 DEVICE_GLYPHS.put(Device.Type.ROADM_OTN, "m_roadm_otn");
150 DEVICE_GLYPHS.put(Device.Type.BALANCER, "m_balancer");
151 DEVICE_GLYPHS.put(Device.Type.IPS, "m_ips");
152 DEVICE_GLYPHS.put(Device.Type.IDS, "m_ids");
153 DEVICE_GLYPHS.put(Device.Type.CONTROLLER, "m_controller");
154 DEVICE_GLYPHS.put(Device.Type.VIRTUAL, "m_virtual");
155 DEVICE_GLYPHS.put(Device.Type.FIBER_SWITCH, "m_fiberSwitch");
156 DEVICE_GLYPHS.put(Device.Type.MICROWAVE, "m_microwave");
157 DEVICE_GLYPHS.put(Device.Type.OLT, "m_olt");
158 DEVICE_GLYPHS.put(Device.Type.ONU, "m_onu");
159 DEVICE_GLYPHS.put(Device.Type.OPTICAL_AMPLIFIER, "unknown"); // TODO glyph needed
160 DEVICE_GLYPHS.put(Device.Type.OTHER, "m_other");
161 }
162
163 private static final String DEFAULT_HOST_GLYPH = "m_endstation";
164 private static final String LINK_GLYPH = "m_ports";
165
166
Ray Milkey9c9cde42018-01-12 14:22:06 -0800167 static final Logger log =
Simon Huntd2747a02015-04-30 22:41:16 -0700168 LoggerFactory.getLogger(TopologyViewMessageHandlerBase.class);
Thomas Vachuska329af532015-03-10 02:08:33 -0700169
Simon Huntd2747a02015-04-30 22:41:16 -0700170 private static final ProviderId PID =
171 new ProviderId("core", "org.onosproject.core", true);
Thomas Vachuska329af532015-03-10 02:08:33 -0700172
Thomas Vachuska329af532015-03-10 02:08:33 -0700173 // TODO: extract into an external & durable state; good enough for now and demo
174 private static Map<String, ObjectNode> metaUi = new ConcurrentHashMap<>();
175
176 /**
Thomas Vachuska329af532015-03-10 02:08:33 -0700177 * Returns read-only view of the meta-ui information.
178 *
179 * @return map of id to meta-ui mementos
180 */
181 static Map<String, ObjectNode> getMetaUi() {
182 return Collections.unmodifiableMap(metaUi);
183 }
184
Thomas Vachuskac616e172018-04-17 16:57:12 -0700185 /**
186 * Clears any meta-ui information.
187 */
188 public static void clearMetaUi() {
189 metaUi.clear();
190 }
191
Simon Hunt879ce452017-08-10 23:32:00 -0700192 private static final String LION_TOPO = "core.view.Topo";
193
194 private static final Set<String> REQ_LION_BUNDLES = ImmutableSet.of(
195 LION_TOPO
196 );
Simon Hunt1911fe42017-05-02 18:25:58 -0700197
198 protected ServicesBundle services;
199
200 private String version;
201
202
Thomas Vachuska329af532015-03-10 02:08:33 -0700203 @Override
204 public void init(UiConnection connection, ServiceDirectory directory) {
205 super.init(connection, directory);
Simon Hunt1911fe42017-05-02 18:25:58 -0700206 services = new ServicesBundle(directory);
207 setVersionString(directory);
208 }
Thomas Vachuska329af532015-03-10 02:08:33 -0700209
Simon Hunt1911fe42017-05-02 18:25:58 -0700210 // Creates a palatable version string to display on the summary panel
211 private void setVersionString(ServiceDirectory directory) {
Thomas Vachuska329af532015-03-10 02:08:33 -0700212 String ver = directory.get(CoreService.class).version().toString();
213 version = ver.replace(".SNAPSHOT", "*").replaceFirst("~.*$", "");
214 }
215
Simon Hunt879ce452017-08-10 23:32:00 -0700216 @Override
217 public Set<String> requiredLionBundles() {
218 return REQ_LION_BUNDLES;
219 }
220
Simon Hunt10618f62017-06-15 19:30:52 -0700221 // Returns the first of the given set of IP addresses as a string.
Thomas Vachuska329af532015-03-10 02:08:33 -0700222 private String ip(Set<IpAddress> ipAddresses) {
223 Iterator<IpAddress> it = ipAddresses.iterator();
224 return it.hasNext() ? it.next().toString() : "unknown";
225 }
226
227 // Produces JSON structure from annotations.
228 private JsonNode props(Annotations annotations) {
Simon Huntda580882015-05-12 20:58:18 -0700229 ObjectNode props = objectNode();
Thomas Vachuska329af532015-03-10 02:08:33 -0700230 if (annotations != null) {
231 for (String key : annotations.keys()) {
232 props.put(key, annotations.value(key));
233 }
234 }
235 return props;
236 }
237
238 // Produces an informational log message event bound to the client.
Simon Hunt36740d02017-06-07 11:25:51 -0700239 protected ObjectNode info(String message) {
240 return message("info", message);
Thomas Vachuska329af532015-03-10 02:08:33 -0700241 }
242
243 // Produces a warning log message event bound to the client.
Simon Hunt36740d02017-06-07 11:25:51 -0700244 protected ObjectNode warning(String message) {
245 return message("warning", message);
Thomas Vachuska329af532015-03-10 02:08:33 -0700246 }
247
248 // Produces an error log message event bound to the client.
Simon Hunt36740d02017-06-07 11:25:51 -0700249 protected ObjectNode error(String message) {
250 return message("error", message);
Thomas Vachuska329af532015-03-10 02:08:33 -0700251 }
252
253 // Produces a log message event bound to the client.
Simon Hunt36740d02017-06-07 11:25:51 -0700254 private ObjectNode message(String severity, String message) {
Simon Huntda580882015-05-12 20:58:18 -0700255 ObjectNode payload = objectNode()
Simon Huntd2747a02015-04-30 22:41:16 -0700256 .put("severity", severity)
257 .put("message", message);
Thomas Vachuska329af532015-03-10 02:08:33 -0700258
Simon Hunt36740d02017-06-07 11:25:51 -0700259 return JsonUtils.envelope("message", payload);
Thomas Vachuska329af532015-03-10 02:08:33 -0700260 }
261
Thomas Vachuska329af532015-03-10 02:08:33 -0700262 // Produces a cluster instance message to the client.
Simon Hunt95d56fd2015-11-12 11:06:44 -0800263 protected ObjectNode instanceMessage(ClusterEvent event, String msgType) {
Thomas Vachuska329af532015-03-10 02:08:33 -0700264 ControllerNode node = event.subject();
Simon Hunt1911fe42017-05-02 18:25:58 -0700265 int switchCount = services.mastership().getDevicesOf(node.id()).size();
Simon Huntda580882015-05-12 20:58:18 -0700266 ObjectNode payload = objectNode()
Thomas Vachuska329af532015-03-10 02:08:33 -0700267 .put("id", node.id().toString())
268 .put("ip", node.ip().toString())
Simon Hunt1911fe42017-05-02 18:25:58 -0700269 .put("online", services.cluster().getState(node.id()).isActive())
270 .put("ready", services.cluster().getState(node.id()).isReady())
271 .put("uiAttached", node.equals(services.cluster().getLocalNode()))
Thomas Vachuska329af532015-03-10 02:08:33 -0700272 .put("switches", switchCount);
273
Simon Huntda580882015-05-12 20:58:18 -0700274 ArrayNode labels = arrayNode();
Thomas Vachuska329af532015-03-10 02:08:33 -0700275 labels.add(node.id().toString());
276 labels.add(node.ip().toString());
277
278 // Add labels, props and stuff the payload into envelope.
279 payload.set("labels", labels);
280 addMetaUi(node.id().toString(), payload);
281
Simon Hunt95d56fd2015-11-12 11:06:44 -0800282 String type = msgType != null ? msgType : CLUSTER_EVENT.get(event.type());
Simon Hunt36740d02017-06-07 11:25:51 -0700283 return JsonUtils.envelope(type, payload);
Thomas Vachuska329af532015-03-10 02:08:33 -0700284 }
285
286 // Produces a device event message to the client.
287 protected ObjectNode deviceMessage(DeviceEvent event) {
288 Device device = event.subject();
Simon Hunt1e20dae2016-10-28 11:26:26 -0700289 String uiType = device.annotations().value(AnnotationKeys.UI_TYPE);
Thomas Vachuska164ecf62018-05-08 17:29:55 -0700290 String driverName = device.annotations().value(DRIVER);
291 Driver driver = driverName == null ? null : services.driver().getDriver(driverName);
Simon Hunt1e20dae2016-10-28 11:26:26 -0700292 String devType = uiType != null ? uiType :
Thomas Vachuska164ecf62018-05-08 17:29:55 -0700293 (driver != null ? driver.getProperty(AnnotationKeys.UI_TYPE) : null);
Laszlo Pappe1579fa2018-03-08 09:18:48 +0000294 if (devType == null) {
295 devType = device.type().toString().toLowerCase();
296 }
Simon Hunt10618f62017-06-15 19:30:52 -0700297 String name = device.annotations().value(AnnotationKeys.NAME);
298 name = isNullOrEmpty(name) ? device.id().toString() : name;
Simon Hunt1e20dae2016-10-28 11:26:26 -0700299
Simon Huntda580882015-05-12 20:58:18 -0700300 ObjectNode payload = objectNode()
Thomas Vachuska329af532015-03-10 02:08:33 -0700301 .put("id", device.id().toString())
Simon Hunt1e20dae2016-10-28 11:26:26 -0700302 .put("type", devType)
Simon Hunt1911fe42017-05-02 18:25:58 -0700303 .put("online", services.device().isAvailable(device.id()))
Thomas Vachuska329af532015-03-10 02:08:33 -0700304 .put("master", master(device.id()));
305
Simon Hunt10618f62017-06-15 19:30:52 -0700306 payload.set("labels", labels("", name, device.id().toString()));
Thomas Vachuska329af532015-03-10 02:08:33 -0700307 payload.set("props", props(device.annotations()));
Thomas Vachuskac616e172018-04-17 16:57:12 -0700308
Thomas Vachuska4c47a382018-05-07 13:48:38 -0700309 BasicDeviceConfig cfg = get(NetworkConfigService.class)
310 .getConfig(device.id(), BasicDeviceConfig.class);
311 if (!addLocation(cfg, payload)) {
Thomas Vachuskac616e172018-04-17 16:57:12 -0700312 addMetaUi(device.id().toString(), payload);
313 }
Thomas Vachuska329af532015-03-10 02:08:33 -0700314
Simon Hunt95d56fd2015-11-12 11:06:44 -0800315 String type = DEVICE_EVENT.get(event.type());
Simon Hunt36740d02017-06-07 11:25:51 -0700316 return JsonUtils.envelope(type, payload);
Thomas Vachuska329af532015-03-10 02:08:33 -0700317 }
318
319 // Produces a link event message to the client.
320 protected ObjectNode linkMessage(LinkEvent event) {
321 Link link = event.subject();
Simon Huntda580882015-05-12 20:58:18 -0700322 ObjectNode payload = objectNode()
Thomas Vachuska329af532015-03-10 02:08:33 -0700323 .put("id", compactLinkString(link))
324 .put("type", link.type().toString().toLowerCase())
Ray Milkeyb7f0f642016-01-22 16:08:14 -0800325 .put("expected", link.isExpected())
Thomas Vachuska329af532015-03-10 02:08:33 -0700326 .put("online", link.state() == Link.State.ACTIVE)
327 .put("linkWidth", 1.2)
328 .put("src", link.src().deviceId().toString())
329 .put("srcPort", link.src().port().toString())
330 .put("dst", link.dst().deviceId().toString())
331 .put("dstPort", link.dst().port().toString());
Simon Hunt95d56fd2015-11-12 11:06:44 -0800332 String type = LINK_EVENT.get(event.type());
Simon Hunt36740d02017-06-07 11:25:51 -0700333 return JsonUtils.envelope(type, payload);
Thomas Vachuska329af532015-03-10 02:08:33 -0700334 }
335
336 // Produces a host event message to the client.
337 protected ObjectNode hostMessage(HostEvent event) {
338 Host host = event.subject();
Charles Chan33f28a92015-11-13 13:12:38 -0800339 Host prevHost = event.prevSubject();
Simon Hunt1e20dae2016-10-28 11:26:26 -0700340 String hostType = host.annotations().value(AnnotationKeys.UI_TYPE);
Simon Hunt10618f62017-06-15 19:30:52 -0700341 String ip = ip(host.ipAddresses());
Simon Hunt95d56fd2015-11-12 11:06:44 -0800342
Simon Huntda580882015-05-12 20:58:18 -0700343 ObjectNode payload = objectNode()
Thomas Vachuska329af532015-03-10 02:08:33 -0700344 .put("id", host.id().toString())
Simon Hunt12c79ed2017-09-12 11:58:44 -0700345 .put("type", isNullOrEmpty(hostType) ? "endstation" : hostType);
Simon Hunt10618f62017-06-15 19:30:52 -0700346
Simon Hunt12c79ed2017-09-12 11:58:44 -0700347 // set most recent connect point (and previous if we know it)
Simon Huntda580882015-05-12 20:58:18 -0700348 payload.set("cp", hostConnect(host.location()));
Charles Chan33f28a92015-11-13 13:12:38 -0800349 if (prevHost != null && prevHost.location() != null) {
350 payload.set("prevCp", hostConnect(prevHost.location()));
Simon Hunt95d56fd2015-11-12 11:06:44 -0800351 }
Simon Hunt12c79ed2017-09-12 11:58:44 -0700352
353 // set ALL connect points
354 addAllCps(host.locations(), payload);
355
Thomas Vachuska528ea952017-10-09 18:25:35 +0200356 payload.set("labels", labels(nameForHost(host), ip, host.mac().toString(), ""));
Thomas Vachuska329af532015-03-10 02:08:33 -0700357 payload.set("props", props(host.annotations()));
Thomas Vachuskac616e172018-04-17 16:57:12 -0700358
Thomas Vachuska4c47a382018-05-07 13:48:38 -0700359 BasicHostConfig cfg = get(NetworkConfigService.class)
360 .getConfig(host.id(), BasicHostConfig.class);
361 if (!addLocation(cfg, payload)) {
Thomas Vachuskac616e172018-04-17 16:57:12 -0700362 addMetaUi(host.id().toString(), payload);
363 }
Thomas Vachuska329af532015-03-10 02:08:33 -0700364
Simon Hunt95d56fd2015-11-12 11:06:44 -0800365 String type = HOST_EVENT.get(event.type());
Simon Hunt36740d02017-06-07 11:25:51 -0700366 return JsonUtils.envelope(type, payload);
Thomas Vachuska329af532015-03-10 02:08:33 -0700367 }
368
Simon Hunt12c79ed2017-09-12 11:58:44 -0700369 private void addAllCps(Set<HostLocation> locations, ObjectNode payload) {
370 ArrayNode cps = arrayNode();
371 locations.forEach(loc -> cps.add(hostConnect(loc)));
372 payload.set("allCps", cps);
373 }
374
Thomas Vachuska329af532015-03-10 02:08:33 -0700375 // Encodes the specified host location into a JSON object.
Simon Huntda580882015-05-12 20:58:18 -0700376 private ObjectNode hostConnect(HostLocation location) {
377 return objectNode()
Thomas Vachuska329af532015-03-10 02:08:33 -0700378 .put("device", location.deviceId().toString())
379 .put("port", location.port().toLong());
380 }
381
382 // Encodes the specified list of labels a JSON array.
Simon Huntda580882015-05-12 20:58:18 -0700383 private ArrayNode labels(String... labels) {
384 ArrayNode json = arrayNode();
Thomas Vachuska329af532015-03-10 02:08:33 -0700385 for (String label : labels) {
386 json.add(label);
387 }
388 return json;
389 }
390
391 // Returns the name of the master node for the specified device id.
392 private String master(DeviceId deviceId) {
Simon Hunt1911fe42017-05-02 18:25:58 -0700393 NodeId master = services.mastership().getMasterFor(deviceId);
Thomas Vachuska329af532015-03-10 02:08:33 -0700394 return master != null ? master.toString() : "";
395 }
396
397 // Generates an edge link from the specified host location.
398 private EdgeLink edgeLink(Host host, boolean ingress) {
399 return new DefaultEdgeLink(PID, new ConnectPoint(host.id(), portNumber(0)),
400 host.location(), ingress);
401 }
402
403 // Adds meta UI information for the specified object.
404 private void addMetaUi(String id, ObjectNode payload) {
405 ObjectNode meta = metaUi.get(id);
406 if (meta != null) {
407 payload.set("metaUi", meta);
408 }
409 }
410
Thomas Vachuska4c47a382018-05-07 13:48:38 -0700411 private boolean addLocation(BasicElementConfig cfg, ObjectNode payload) {
412 if (cfg != null) {
413 String locType = cfg.locType();
414 boolean isGeo = Objects.equals(locType, LOC_TYPE_GEO);
415 boolean isGrid = Objects.equals(locType, LOC_TYPE_GRID);
416 if (isGeo || isGrid) {
Thomas Vachuskac616e172018-04-17 16:57:12 -0700417 try {
Thomas Vachuskac616e172018-04-17 16:57:12 -0700418 ObjectNode loc = objectNode()
Thomas Vachuska4c47a382018-05-07 13:48:38 -0700419 .put("locType", locType)
420 .put("latOrY", isGeo ? cfg.latitude() : cfg.gridY())
421 .put("longOrX", isGeo ? cfg.longitude() : cfg.gridX());
Thomas Vachuskac616e172018-04-17 16:57:12 -0700422 payload.set("location", loc);
423 return true;
424 } catch (NumberFormatException e) {
Thomas Vachuska4c47a382018-05-07 13:48:38 -0700425 log.warn("Invalid location data: {}", cfg);
Thomas Vachuskac616e172018-04-17 16:57:12 -0700426 }
Thomas Vachuskac67a9912018-03-06 14:37:45 -0800427 }
428 }
Thomas Vachuskac616e172018-04-17 16:57:12 -0700429 return false;
Thomas Vachuskac67a9912018-03-06 14:37:45 -0800430 }
431
Thomas Vachuska329af532015-03-10 02:08:33 -0700432 // Updates meta UI information for the specified object.
Simon Huntd2747a02015-04-30 22:41:16 -0700433 protected void updateMetaUi(ObjectNode payload) {
434 metaUi.put(JsonUtils.string(payload, "id"),
435 JsonUtils.node(payload, "memento"));
Thomas Vachuska329af532015-03-10 02:08:33 -0700436 }
437
Simon Hunta17fa672015-08-19 18:42:22 -0700438
Simon Huntb745ca62015-07-28 15:37:11 -0700439 // -----------------------------------------------------------------------
440 // Create models of the data to return, that overlays can adjust / augment
441
Simon Hunta58d8942017-08-11 12:51:14 -0700442 private String lookupGlyph(Device device) {
443 return DEVICE_GLYPHS.get(device.type());
444 }
445
446
Simon Huntb745ca62015-07-28 15:37:11 -0700447 // Returns property panel model for summary response.
Simon Hunt8a0429a2017-01-06 16:52:47 -0800448 protected PropertyPanel summmaryMessage() {
Simon Hunta58d8942017-08-11 12:51:14 -0700449 // chose NOT to add debug messages, since this is called every few seconds
Simon Hunt1911fe42017-05-02 18:25:58 -0700450 Topology topology = services.topology().currentTopology();
Simon Hunt879ce452017-08-10 23:32:00 -0700451 LionBundle lion = getLionBundle(LION_TOPO);
452 String panelTitle = lion.getSafe("title_panel_summary");
Simon Hunt0af1ec32015-07-24 12:17:55 -0700453
Simon Hunta58d8942017-08-11 12:51:14 -0700454 return new PropertyPanel(panelTitle, "bird")
Simon Hunt879ce452017-08-10 23:32:00 -0700455 .addProp(VERSION, lion.getSafe(VERSION), version)
Simon Hunt1911fe42017-05-02 18:25:58 -0700456 .addSeparator()
Simon Hunt879ce452017-08-10 23:32:00 -0700457 .addProp(DEVICES, lion.getSafe(DEVICES), services.device().getDeviceCount())
458 .addProp(LINKS, lion.getSafe(LINKS), topology.linkCount())
459 .addProp(HOSTS, lion.getSafe(HOSTS), services.host().getHostCount())
460 .addProp(TOPOLOGY_SSCS, lion.getSafe(TOPOLOGY_SSCS), topology.clusterCount())
Simon Hunt1911fe42017-05-02 18:25:58 -0700461 .addSeparator()
Simon Hunt879ce452017-08-10 23:32:00 -0700462 .addProp(INTENTS, lion.getSafe(INTENTS), services.intent().getIntentCount())
463 .addProp(TUNNELS, lion.getSafe(TUNNELS), services.tunnel().tunnelCount())
464 .addProp(FLOWS, lion.getSafe(FLOWS), services.flow().getFlowRuleCount());
Thomas Vachuska329af532015-03-10 02:08:33 -0700465 }
466
Simon Hunta58d8942017-08-11 12:51:14 -0700467
468 private String friendlyDevice(DeviceId deviceId) {
Simon Hunt1911fe42017-05-02 18:25:58 -0700469 Device device = services.device().getDevice(deviceId);
Thomas Vachuska329af532015-03-10 02:08:33 -0700470 Annotations annot = device.annotations();
471 String name = annot.value(AnnotationKeys.NAME);
Simon Hunta58d8942017-08-11 12:51:14 -0700472 return isNullOrEmpty(name) ? deviceId.toString() : name;
473 }
474
475 // Generates a property panel model for device details response
476 protected PropertyPanel deviceDetails(DeviceId deviceId) {
477 log.debug("generate prop panel data for device {}", deviceId);
478 Device device = services.device().getDevice(deviceId);
479 Annotations annot = device.annotations();
480 String proto = annot.value(AnnotationKeys.PROTOCOL);
481 String title = friendlyDevice(deviceId);
482 LionBundle lion = getLionBundle(LION_TOPO);
483
484 PropertyPanel pp = new PropertyPanel(title, lookupGlyph(device))
485 .navPath(DEVICE_NAV_PATH)
486 .id(deviceId.toString());
487 addDeviceBasicProps(pp, deviceId, device, proto, lion);
488 addLocationProps(pp, annot, lion);
489 addDeviceCountStats(pp, deviceId, lion);
490 addDeviceCoreButtons(pp);
491 return pp;
492 }
493
494 private void addDeviceBasicProps(PropertyPanel pp, DeviceId deviceId,
495 Device device, String proto, LionBundle lion) {
496 pp.addProp(URI, lion.getSafe(URI), deviceId.toString())
497 .addProp(VENDOR, lion.getSafe(VENDOR), device.manufacturer())
498 .addProp(HW_VERSION, lion.getSafe(HW_VERSION), device.hwVersion())
499 .addProp(SW_VERSION, lion.getSafe(SW_VERSION), device.swVersion())
500 .addProp(SERIAL_NUMBER, lion.getSafe(SERIAL_NUMBER), device.serialNumber())
501 .addProp(PROTOCOL, lion.getSafe(PROTOCOL), proto)
502 .addSeparator();
503 }
504
505 // only add location properties if we have them
506 private void addLocationProps(PropertyPanel pp, Annotations annot,
507 LionBundle lion) {
508 String slat = annot.value(AnnotationKeys.LATITUDE);
509 String slng = annot.value(AnnotationKeys.LONGITUDE);
510 String sgrY = annot.value(AnnotationKeys.GRID_Y);
511 String sgrX = annot.value(AnnotationKeys.GRID_X);
512
513 boolean validLat = slat != null && !slat.equals(NO_GEO_VALUE);
514 boolean validLng = slng != null && !slng.equals(NO_GEO_VALUE);
515 if (validLat && validLng) {
516 pp.addProp(LATITUDE, lion.getSafe(LATITUDE), slat)
517 .addProp(LONGITUDE, lion.getSafe(LONGITUDE), slng)
518 .addSeparator();
519
520 } else if (sgrY != null && sgrX != null) {
521 pp.addProp(GRID_Y, lion.getSafe(GRID_Y), sgrY)
522 .addProp(GRID_X, lion.getSafe(GRID_X), sgrX)
523 .addSeparator();
524 }
525 // else, no location
526 }
527
528 private void addDeviceCountStats(PropertyPanel pp, DeviceId deviceId, LionBundle lion) {
Simon Hunt1911fe42017-05-02 18:25:58 -0700529 int portCount = services.device().getPorts(deviceId).size();
Thomas Vachuska329af532015-03-10 02:08:33 -0700530 int flowCount = getFlowCount(deviceId);
cheng fan35dc0f22015-06-10 06:02:47 +0800531 int tunnelCount = getTunnelCount(deviceId);
Simon Huntb745ca62015-07-28 15:37:11 -0700532
Simon Hunta58d8942017-08-11 12:51:14 -0700533 pp.addProp(PORTS, lion.getSafe(PORTS), portCount)
534 .addProp(FLOWS, lion.getSafe(FLOWS), flowCount)
535 .addProp(TUNNELS, lion.getSafe(TUNNELS), tunnelCount);
536 }
Simon Huntb745ca62015-07-28 15:37:11 -0700537
Simon Hunta58d8942017-08-11 12:51:14 -0700538 private void addDeviceCoreButtons(PropertyPanel pp) {
539 pp.addButton(CoreButtons.SHOW_DEVICE_VIEW)
Simon Hunt1911fe42017-05-02 18:25:58 -0700540 .addButton(CoreButtons.SHOW_FLOW_VIEW)
541 .addButton(CoreButtons.SHOW_PORT_VIEW)
542 .addButton(CoreButtons.SHOW_GROUP_VIEW)
543 .addButton(CoreButtons.SHOW_METER_VIEW);
Thomas Vachuska329af532015-03-10 02:08:33 -0700544 }
545
546 protected int getFlowCount(DeviceId deviceId) {
Thomas Vachuskaa8e74772018-02-26 11:33:35 -0800547 return services.flow().getFlowRuleCount(deviceId);
Thomas Vachuska329af532015-03-10 02:08:33 -0700548 }
549
cheng fan35dc0f22015-06-10 06:02:47 +0800550 protected int getTunnelCount(DeviceId deviceId) {
551 int count = 0;
Simon Hunt1911fe42017-05-02 18:25:58 -0700552 Collection<Tunnel> tunnels = services.tunnel().queryAllTunnels();
cheng fan35dc0f22015-06-10 06:02:47 +0800553 for (Tunnel tunnel : tunnels) {
chengfanc553c952016-07-22 15:48:23 +0800554 //Only OpticalTunnelEndPoint has a device
555 if (!(tunnel.src() instanceof OpticalTunnelEndPoint) ||
556 !(tunnel.dst() instanceof OpticalTunnelEndPoint)) {
557 continue;
558 }
559
560 Optional<ElementId> srcElementId = ((OpticalTunnelEndPoint) tunnel.src()).elementId();
561 Optional<ElementId> dstElementId = ((OpticalTunnelEndPoint) tunnel.dst()).elementId();
562 if (!srcElementId.isPresent() || !dstElementId.isPresent()) {
563 continue;
564 }
565 DeviceId srcDeviceId = (DeviceId) srcElementId.get();
566 DeviceId dstDeviceId = (DeviceId) dstElementId.get();
567 if (srcDeviceId.equals(deviceId) || dstDeviceId.equals(deviceId)) {
cheng fan35dc0f22015-06-10 06:02:47 +0800568 count++;
569 }
570 }
571 return count;
572 }
573
Simon Hunt10618f62017-06-15 19:30:52 -0700574 private boolean useDefaultName(String annotName) {
575 return isNullOrEmpty(annotName) || DASH.equals(annotName);
576 }
577
578 private String nameForHost(Host host) {
579 String name = host.annotations().value(AnnotationKeys.NAME);
580 return useDefaultName(name) ? ip(host.ipAddresses()) : name;
581 }
582
Simon Hunta58d8942017-08-11 12:51:14 -0700583 private String glyphForHost(Annotations annot) {
584 String uiType = annot.value(AnnotationKeys.UI_TYPE);
585 return isNullOrEmpty(uiType) ? DEFAULT_HOST_GLYPH : uiType;
Thomas Vachuska329af532015-03-10 02:08:33 -0700586 }
587
Simon Hunta58d8942017-08-11 12:51:14 -0700588 // Generates a property panel model for a host details response
589 protected PropertyPanel hostDetails(HostId hostId) {
590 log.debug("generate prop panel data for host {}", hostId);
591 Host host = services.host().getHost(hostId);
592 Annotations annot = host.annotations();
593 String glyphId = glyphForHost(annot);
594 LionBundle lion = getLionBundle(LION_TOPO);
595
596 PropertyPanel pp = new PropertyPanel(nameForHost(host), glyphId)
597 .navPath(HOST_NAV_PATH)
598 .id(hostId.toString());
599 addHostBasicProps(pp, host, lion);
600 addLocationProps(pp, annot, lion);
601 return pp;
602 }
603
604 private void addHostBasicProps(PropertyPanel pp, Host host, LionBundle lion) {
605 pp.addProp(LPL_FRIENDLY, lion.getSafe(LPL_FRIENDLY), nameForHost(host))
606 .addProp(MAC, lion.getSafe(MAC), host.mac())
607 .addProp(IP, lion.getSafe(IP), host.ipAddresses(), "[\\[\\]]")
608 .addProp(VLAN, lion.getSafe(VLAN), displayVlan(host.vlan(), lion))
609 .addSeparator();
610 }
611
612 private String displayVlan(VlanId vlan, LionBundle lion) {
613 return VlanId.NONE.equals(vlan) ? lion.getSafe(VLAN_NONE) : vlan.toString();
614 }
615
616 // Generates a property panel model for a link details response (edge-link)
617 protected PropertyPanel edgeLinkDetails(HostId hid, ConnectPoint cp) {
618 log.debug("generate prop panel data for edgelink {} {}", hid, cp);
619 LionBundle lion = getLionBundle(LION_TOPO);
620 String title = lion.getSafe("title_edge_link");
621
622 PropertyPanel pp = new PropertyPanel(title, LINK_GLYPH);
623 addLinkHostProps(pp, hid, lion);
624 addLinkCpBProps(pp, cp, lion);
625 return pp;
626 }
627
628 // Generates a property panel model for a link details response (infra-link)
629 protected PropertyPanel infraLinkDetails(ConnectPoint cpA, ConnectPoint cpB) {
630 log.debug("generate prop panel data for infralink {} {}", cpA, cpB);
631 LionBundle lion = getLionBundle(LION_TOPO);
632 String title = lion.getSafe("title_infra_link");
633
634 PropertyPanel pp = new PropertyPanel(title, LINK_GLYPH);
635 addLinkCpAProps(pp, cpA, lion);
636 addLinkCpBProps(pp, cpB, lion);
637 addLinkBackingProps(pp, cpA, cpB, lion);
638 return pp;
639 }
640
641 private void addLinkHostProps(PropertyPanel pp, HostId hostId, LionBundle lion) {
642 Host host = services.host().getHost(hostId);
643
644 pp.addProp(LPL_A_TYPE, lion.getSafe(LPL_A_TYPE), lion.getSafe(HOST))
645 .addProp(LPL_A_ID, lion.getSafe(LPL_A_ID), hostId.toString())
646 .addProp(LPL_A_FRIENDLY, lion.getSafe(LPL_A_FRIENDLY), nameForHost(host))
647 .addSeparator();
648 }
649
650 private void addLinkCpAProps(PropertyPanel pp, ConnectPoint cp, LionBundle lion) {
651 DeviceId did = cp.deviceId();
652
653 pp.addProp(LPL_A_TYPE, lion.getSafe(LPL_A_TYPE), lion.getSafe(DEVICE))
654 .addProp(LPL_A_ID, lion.getSafe(LPL_A_ID), did.toString())
655 .addProp(LPL_A_FRIENDLY, lion.getSafe(LPL_A_FRIENDLY), friendlyDevice(did))
656 .addProp(LPL_A_PORT, lion.getSafe(LPL_A_PORT), cp.port().toLong())
657 .addSeparator();
658 }
659
660 private void addLinkCpBProps(PropertyPanel pp, ConnectPoint cp, LionBundle lion) {
661 DeviceId did = cp.deviceId();
662
663 pp.addProp(LPL_B_TYPE, lion.getSafe(LPL_B_TYPE), lion.getSafe(DEVICE))
664 .addProp(LPL_B_ID, lion.getSafe(LPL_B_ID), did.toString())
665 .addProp(LPL_B_FRIENDLY, lion.getSafe(LPL_B_FRIENDLY), friendlyDevice(did))
666 .addProp(LPL_B_PORT, lion.getSafe(LPL_B_PORT), cp.port().toLong())
667 .addSeparator();
668 }
669
670 private void addLinkBackingProps(PropertyPanel pp, ConnectPoint cpA,
671 ConnectPoint cpB, LionBundle lion) {
672 Link a2b = services.link().getLink(cpA, cpB);
673 Link b2a = services.link().getLink(cpB, cpA);
674
675 pp.addProp(LPL_A2B, lion.getSafe(LPL_A2B), linkPropString(a2b, lion))
676 .addProp(LPL_B2A, lion.getSafe(LPL_B2A), linkPropString(b2a, lion));
677 }
678
679 private String linkPropString(Link link, LionBundle lion) {
680 if (link == null) {
681 return lion.getSafe(LPV_NO_LINK);
682 }
683 return lion.getSafe(link.type()) + SLASH +
684 lion.getSafe(link.state()) + SLASH +
685 lion.getSafe(link.isExpected() ? EXPECTED : NOT_EXPECTED);
686 }
Thomas Vachuska329af532015-03-10 02:08:33 -0700687}