opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/utils/DataTreeModificationOutput.java

   1 /*
   2  * Copyright (c) 2016 Brocade Communications Systems, Inc. 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.controller.cluster.datastore.utils;
   9
  10 import com.google.common.base.Throwables;
  11 import java.io.DataOutputStream;
  12 import java.io.File;
  13 import java.io.FileOutputStream;
  14 import java.io.IOException;
  15 import javax.xml.stream.XMLStreamException;
  16 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.PathArgument;
  17 import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
  18 import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeModification;
  19 import org.slf4j.Logger;
  20 import org.slf4j.LoggerFactory;
  21
  22 /**
  23  * Utility class to output DataTreeModifications in readable format.
  24  *
  25  * @author Thomas Pantelis
  26  */
  27 public final class DataTreeModificationOutput {
  28     private static final Logger LOG = LoggerFactory.getLogger(DataTreeModificationOutput.class);
  29
  30     private DataTreeModificationOutput() {
  31     }
  32
  33     public static void toFile(File file, DataTreeModification modification) {
  34         try(FileOutputStream outStream = new FileOutputStream(file)) {
  35             modification.applyToCursor(new DataTreeModificationOutputCursor(new DataOutputStream(outStream)));
  36         } catch(Exception e) {
  37             LOG.error("Error writing DataTreeModification to file {}", file, e);
  38         }
  39     }
  40
  41     private static class DataTreeModificationOutputCursor extends AbstractDataTreeModificationCursor {
  42         private final DataOutputStream output;
  43
  44         DataTreeModificationOutputCursor(DataOutputStream output) {
  45             this.output = output;
  46         }
  47
  48         @Override
  49         public void delete(PathArgument child) {
  50             try {
  51                 output.write("\nDELETE -> ".getBytes());
  52                 output.write(next(child).toString().getBytes());
  53                 output.writeByte('\n');
  54             } catch(IOException e) {
  55                 Throwables.propagate(e);
  56             }
  57         }
  58
  59         @Override
  60         public void merge(PathArgument child, NormalizedNode<?, ?> data) {
  61             outputPathAndNode("MERGE", child, data);
  62         }
  63
  64         @Override
  65         public void write(PathArgument child, NormalizedNode<?, ?> data) {
  66             outputPathAndNode("WRITE", child, data);
  67         }
  68
  69         private void outputPathAndNode(String name, PathArgument child, NormalizedNode<?, ?> data) {
  70             try {
  71                 output.writeByte('\n');
  72                 output.write(name.getBytes());
  73                 output.write(" -> ".getBytes());
  74                 output.write(next(child).toString().getBytes());
  75                 output.write(": \n".getBytes());
  76                 NormalizedNodeXMLOutput.toStream(output, data);
  77                 output.writeByte('\n');
  78             } catch(IOException | XMLStreamException e) {
  79                 Throwables.propagate(e);
  80             }
  81         }
  82     }
  83 }