itm/itm-impl/src/main/java/org/opendaylight/genius/itm/cli/TepDeleteDatastore.java

   1 /*
   2  * Copyright (c) 2016, 2017 Ericsson India Global Services Pvt Ltd. 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.genius.itm.cli;
   9
  10 import com.google.common.util.concurrent.Futures;
  11 import com.google.common.util.concurrent.MoreExecutors;
  12 import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
  13 import java.util.ArrayList;
  14 import java.util.List;
  15 import org.apache.karaf.shell.commands.Command;
  16 import org.apache.karaf.shell.console.OsgiCommandSupport;
  17 import org.opendaylight.genius.infra.Datastore;
  18 import org.opendaylight.genius.infra.ManagedNewTransactionRunner;
  19 import org.opendaylight.genius.infra.ManagedNewTransactionRunnerImpl;
  20 import org.opendaylight.genius.itm.api.IITMProvider;
  21 import org.opendaylight.genius.itm.impl.ItmUtils;
  22 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.Interfaces;
  23 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.InterfacesState;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.TransportZones;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
  26 import org.opendaylight.yangtools.yang.binding.DataObject;
  27 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  28
  29 @Command(scope = "tep", name = "deleteDatastore", description = "deleting all tep data from datastore")
  30 public class TepDeleteDatastore<T extends DataObject>  extends OsgiCommandSupport {
  31     private IITMProvider itmProvider;
  32
  33     public void setItmProvider(IITMProvider itmProvider) {
  34         this.itmProvider = itmProvider;
  35     }
  36
  37     @Override
  38     @SuppressFBWarnings("UWF_FIELD_NOT_INITIALIZED_IN_CONSTRUCTOR")
  39     protected Object doExecute() {
  40         InstanceIdentifier<TransportZones> itmConfigPath =
  41                 InstanceIdentifier.builder(TransportZones.class).build();
  42         InstanceIdentifier<Interfaces> interfacesConfigPath =
  43                 InstanceIdentifier.builder(Interfaces.class).build();
  44         final InstanceIdentifier<InterfacesState> ifStateOpPath =
  45                 InstanceIdentifier.builder(InterfacesState.class).build();
  46         InstanceIdentifier<Nodes> frmConfigPath =
  47                 InstanceIdentifier.builder(Nodes.class).build();
  48         List<InstanceIdentifier<T>> allConfigPaths = new ArrayList<>();
  49         allConfigPaths.add((InstanceIdentifier<T>) itmConfigPath);
  50         allConfigPaths.add((InstanceIdentifier<T>) interfacesConfigPath);
  51         allConfigPaths.add((InstanceIdentifier<T>) frmConfigPath);
  52         //allConfigPaths.add((InstanceIdentifier<T>) tunnelsConfigPath);
  53         final ManagedNewTransactionRunner txrunner = new ManagedNewTransactionRunnerImpl(itmProvider.getDataBroker());
  54         Futures.addCallback(txrunner.callWithNewWriteOnlyTransactionAndSubmit(Datastore.CONFIGURATION,
  55             tx -> allConfigPaths.forEach(tx::delete)), ItmUtils.DEFAULT_WRITE_CALLBACK, MoreExecutors.directExecutor());
  56         List<InstanceIdentifier<T>> allOperationalPaths = new ArrayList<>();
  57         // allOperationalPaths.add((InstanceIdentifier<T>) tnStateOpPath);
  58         allOperationalPaths.add((InstanceIdentifier<T>) ifStateOpPath);
  59         Futures.addCallback(txrunner.callWithNewWriteOnlyTransactionAndSubmit(Datastore.OPERATIONAL,
  60             tx -> allOperationalPaths.forEach(tx::delete)), ItmUtils.DEFAULT_WRITE_CALLBACK,
  61                 MoreExecutors.directExecutor());
  62         return null;
  63     }
  64 }