/* * Copyright © 2020 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.concurrent.Callable; import org.opendaylight.transportpce.renderer.provisiondevice.OtnDeviceRendererService; import org.opendaylight.transportpce.renderer.provisiondevice.OtnDeviceRenderingResult; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.device.renderer.rev211004.OtnServicePathInput; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.device.renderer.rev211004.OtnServicePathOutput; import org.slf4j.Logger; import org.slf4j.LoggerFactory; public class OtnDeviceRenderingTask implements Callable { private static final Logger LOG = LoggerFactory.getLogger(OtnDeviceRenderingTask.class); private final OtnDeviceRendererService otnDeviceRenderer; private final OtnServicePathInput otnServicePathInput; private final String serviceType; public OtnDeviceRenderingTask(OtnDeviceRendererService otnDeviceRendererService, OtnServicePathInput otnServicePathInput, String serviceType) { this.otnDeviceRenderer = otnDeviceRendererService; this.otnServicePathInput = otnServicePathInput; this.serviceType = serviceType; } @Override public OtnDeviceRenderingResult call() throws Exception { OtnServicePathOutput output; String operation; switch (this.otnServicePathInput.getOperation()) { case Create: operation = "setup"; output = this.otnDeviceRenderer.setupOtnServicePath(this.otnServicePathInput, this.serviceType); break; case Delete: operation = "delete"; output = this.otnDeviceRenderer.deleteOtnServicePath(this.otnServicePathInput, this.serviceType); break; default: return OtnDeviceRenderingResult.failed("Device rendering failed - unknown operation"); } if (!output.getSuccess()) { LOG.error("Device rendering {} otn service path failed.", operation); return OtnDeviceRenderingResult.failed("Operation Failed"); } LOG.info("Device rendering {} otn service path finished successfully.", operation); return OtnDeviceRenderingResult.ok(new ArrayList<>(output.nonnullNodeInterface().values()), new ArrayList<>(output.nonnullLinkTp())); } }