gerrit.onap Code Review - appc.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * APPC
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * Copyright (C) 2017 Amdocs
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *      http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END=========================================================
  20  * ECOMP is a trademark and service mark of AT&T Intellectual Property.
  21  */
  22
  23 package org.openecomp.appc.adapter.netconf.internal;
  24
  25 import org.slf4j.Logger;
  26 import org.slf4j.LoggerFactory;
  27
  28 import java.io.*;
  29
  30 /**
  31  * Provides basic methods for exchanging netconf messages.
  32  */
  33 public class NetconfAdapter2 {
  34
  35     private static final Logger LOG = LoggerFactory.getLogger(NetconfAdapter2.class);
  36
  37     // device input pipe
  38     private final PipedOutputStream pipedOutIn = new PipedOutputStream();
  39     private PipedInputStream in;
  40     // device output pipe
  41     private final PipedInputStream pipedInOut = new PipedInputStream();
  42     private PipedOutputStream out;
  43
  44     /**
  45      * Constructor.
  46      *
  47      * @throws IOException
  48      */
  49     public NetconfAdapter2() throws IOException {
  50         in = new PipedInputStream(pipedOutIn);
  51         out = new PipedOutputStream(pipedInOut);
  52     }
  53
  54     /**
  55      * @return InputStream this instance will read netconf messages from.
  56      */
  57     public InputStream getIn() {
  58         return in;
  59     }
  60
  61     /**
  62      * @return OutputStream this instance will write netconf messages to.
  63      */
  64     public OutputStream getOut() {
  65         return out;
  66     }
  67
  68     /**
  69      * Receives netconf message from InputStream and return it's text (without netconf frame characters).
  70      *
  71      * @return text of message received from netconf device
  72      * @throws IOException
  73      */
  74     public String receiveMessage() throws IOException {
  75         NetconfMessage message = new NetconfMessage();
  76         byte[] buf = new byte[1024];
  77         int c;
  78         while((c = pipedInOut.read(buf)) > 0) {
  79                 message.append(buf, 0, c);
  80                 if (message.isCompleted()) {
  81                     break;
  82                 }
  83         }
  84         String text = message.getText();
  85         if(LOG.isDebugEnabled()) {
  86             LOG.debug("Received message from netconf device:\n" + text);
  87         }
  88         return text;
  89     }
  90
  91     /**
  92      * Sends netconf message with provided text (adds netconf frame characters and sends the message).
  93      *
  94      * @param text text of message to be sent to netconf device
  95      * @throws IOException
  96      */
  97     public void sendMessage(final String text) throws IOException {
  98         if(LOG.isDebugEnabled()) {
  99             LOG.debug("Sending message to netconf device:\n" + text);
 100         }
 101         pipedOutIn.write(new NetconfMessage(text).getFrame());
 102     }
 103 }