Renderer and OLM update

[transportpce.git] / renderer / src / main / java / org / opendaylight / transportpce / renderer / provisiondevice / tasks / DeviceRenderingRollbackTask.java

diff --git a/renderer/src/main/java/org/opendaylight/transportpce/renderer/provisiondevice/tasks/DeviceRenderingRollbackTask.java b/renderer/src/main/java/org/opendaylight/transportpce/renderer/provisiondevice/tasks/DeviceRenderingRollbackTask.java
new file mode 100644 (file)
index 0000000..01bf58c
--- /dev/null
+++ b/renderer/src/main/java/org/opendaylight/transportpce/renderer/provisiondevice/tasks/DeviceRenderingRollbackTask.java
@@ -0,0 +1,65 @@
+/*
+ * Copyright © 2017 AT&T and others.  All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+package org.opendaylight.transportpce.renderer.provisiondevice.tasks;
+
+import java.util.ArrayList;
+import java.util.List;
+import org.opendaylight.transportpce.renderer.provisiondevice.DeviceRendererService;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.node.interfaces.NodeInterface;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.renderer.rev170228.RendererRollbackInput;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.renderer.rev170228.RendererRollbackInputBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.renderer.rev170228.RendererRollbackOutput;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.renderer.rev170228.renderer.rollback.output.FailedToRollback;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class DeviceRenderingRollbackTask extends RollbackTask {
+
+    private static final Logger LOG = LoggerFactory.getLogger(DeviceRenderingRollbackTask.class);
+    private final boolean isRollbackNecessary;
+    private final DeviceRendererService rendererService;
+    private final List<NodeInterface> renderedInterfaces;
+
+    public DeviceRenderingRollbackTask(String id, boolean isRollbackNecessary, List<NodeInterface> renderedInterfaces,
+            DeviceRendererService rendererService) {
+        super(id);
+        this.isRollbackNecessary = isRollbackNecessary;
+        this.rendererService = rendererService;
+        this.renderedInterfaces = renderedInterfaces;
+    }
+
+    @Override
+    public boolean isRollbackNecessary() {
+        return isRollbackNecessary;
+    }
+
+    @Override
+    public Void call() throws Exception {
+        RendererRollbackInput rollbackInput = new RendererRollbackInputBuilder()
+                .setNodeInterface(this.renderedInterfaces)
+                .build();
+        RendererRollbackOutput rollbackOutput = this.rendererService.rendererRollback(rollbackInput);
+        if (! rollbackOutput.isSuccess()) {
+            LOG.warn("Device rendering rollback of {} was not successful! Failed rollback on {}.", this.getId(),
+                    createErrorMessage(rollbackOutput.getFailedToRollback()));
+        } else {
+            LOG.info("Device rollback of {} successful.", this.getId());
+        }
+        return null;
+    }
+
+    private String createErrorMessage(List<FailedToRollback> failedRollbacks) {
+        List<String> failedRollbackNodes = new ArrayList<>();
+        failedRollbacks.forEach(failedRollback -> {
+            String nodeId = failedRollback.getNodeId();
+            failedRollbackNodes.add(nodeId + ": " + String.join(", ", failedRollback.getInterface()));
+        });
+        return String.join(System.lineSeparator(), failedRollbackNodes);
+    }
+
+}