Merge changes I74e9bee3,Ia1ad6f9c,Ic47363f6,I2bba2b18,I507097db, ...
[transportpce.git] / renderer / src / main / java / org / opendaylight / transportpce / renderer / provisiondevice / tasks / DeviceRenderingTask.java
1 /*
2  * Copyright © 2017 AT&T and others.  All rights reserved.
3  *
4  * This program and the accompanying materials are made available under the
5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6  * and is available at http://www.eclipse.org/legal/epl-v10.html
7  */
8 package org.opendaylight.transportpce.renderer.provisiondevice.tasks;
9
10 import java.util.ArrayList;
11 import java.util.List;
12 import java.util.concurrent.Callable;
13 import org.opendaylight.transportpce.renderer.ServicePathInputData;
14 import org.opendaylight.transportpce.renderer.provisiondevice.DeviceRendererService;
15 import org.opendaylight.transportpce.renderer.provisiondevice.DeviceRenderingResult;
16 import org.opendaylight.transportpce.renderer.provisiondevice.servicepath.ServicePathDirection;
17 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.device.renderer.rev210618.ServicePathOutput;
18 import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev210618.optical.renderer.nodes.Nodes;
19 import org.slf4j.Logger;
20 import org.slf4j.LoggerFactory;
21
22 public class DeviceRenderingTask implements Callable<DeviceRenderingResult> {
23
24     private static final Logger LOG = LoggerFactory.getLogger(DeviceRenderingTask.class);
25
26     private final DeviceRendererService deviceRenderer;
27     private final ServicePathInputData servicePathInputData;
28     private final ServicePathDirection direction;
29
30     public DeviceRenderingTask(DeviceRendererService deviceRenderer, ServicePathInputData servicePathInputData,
31             ServicePathDirection direction) {
32         this.deviceRenderer = deviceRenderer;
33         this.servicePathInputData = servicePathInputData;
34         this.direction = direction;
35     }
36
37     @Override
38     public DeviceRenderingResult call() throws Exception {
39         ServicePathOutput output;
40         String operation;
41         List<Nodes> olmList = null;
42         switch (this.servicePathInputData.getServicePathInput().getOperation()) {
43             case Create:
44                 operation = "setup";
45                 output = this.deviceRenderer.setupServicePath(this.servicePathInputData.getServicePathInput(),
46                     this.direction);
47                 olmList = this.servicePathInputData.getNodeLists().getOlmNodeList();
48                 break;
49             case Delete:
50                 operation = "delete";
51                 output = this.deviceRenderer.deleteServicePath(this.servicePathInputData.getServicePathInput());
52                 break;
53             default:
54                 return DeviceRenderingResult.failed("Device rendering failed - unknown operation");
55         }
56         if (!output.getSuccess()) {
57             LOG.error("Device rendering {} service path failed.", operation);
58             return DeviceRenderingResult.failed("Operation Failed");
59         }
60         LOG.info("Device rendering {} service path finished successfully.", operation);
61         return DeviceRenderingResult.ok(olmList, new ArrayList<>(output.nonnullNodeInterface().values()),
62             new ArrayList<>(output.nonnullLinkTp()));
63
64     }
65
66 }