BUG-5790: BGP Test tool

[bgpcep.git] / bgp / testtool / src / main / java / org / opendaylight / protocol / bgp / testtool / Main.java

diff --git a/bgp/testtool/src/main/java/org/opendaylight/protocol/bgp/testtool/Main.java b/bgp/testtool/src/main/java/org/opendaylight/protocol/bgp/testtool/Main.java
index 9f9e73cecc8adfb75ca66264b155d3db65d0467d..6e9bb653484bbbbe8c2db3a73ba969e5367033c9 100644 (file)
--- a/bgp/testtool/src/main/java/org/opendaylight/protocol/bgp/testtool/Main.java
+++ b/bgp/testtool/src/main/java/org/opendaylight/protocol/bgp/testtool/Main.java
@@ -7,90 +7,34 @@
  */
 package org.opendaylight.protocol.bgp.testtool;
 
-import io.netty.util.concurrent.GlobalEventExecutor;
-
+import java.io.BufferedReader;
 import java.io.IOException;
-import java.net.InetAddress;
-import java.net.InetSocketAddress;
-
-import org.opendaylight.protocol.bgp.parser.BGPSessionListener;
-import org.opendaylight.protocol.bgp.parser.impl.BGPMessageFactoryImpl;
-import org.opendaylight.protocol.bgp.rib.impl.BGPDispatcherImpl;
-import org.opendaylight.protocol.bgp.rib.impl.BGPSessionProposalImpl;
-import org.opendaylight.protocol.bgp.rib.impl.spi.BGPSessionPreferences;
-import org.opendaylight.protocol.framework.NeverReconnectStrategy;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.AsNumber;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv4Address;
+import java.io.InputStreamReader;
+import org.opendaylight.protocol.util.LoggerUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
  * Starter class for testing.
  */
-public class Main {
-
-       private final static Logger logger = LoggerFactory.getLogger(Main.class);
-
-       public static String usage = "DESCRIPTION:\n" + "\tCreates a server with given parameters. As long as it runs, it accepts connections "
-                       + "from PCCs.\n" + "USAGE:\n" + "\t-a, --address\n" + "\t\tthe ip address to which is this server bound.\n"
-                       + "\t\tFormat: x.x.x.x:y where y is port number.\n\n"
-                       + "\t\tThis IP address will appear in BGP Open message as BGP Identifier of the server.\n" +
-
-                       "\t-as\n" + "\t\t value of AS in the initial open message\n\n" +
-
-                       "\t-h, --holdtimer\n" + "\t\tin seconds, value of the desired holdtimer\n"
-                       + "\t\tAccording to RFC4271, recommended value for deadtimer is 90 seconds.\n"
-                       + "\t\tIf not set, this will be the default value.\n\n" +
-
-                       "\t--help\n" + "\t\tdisplay this help and exits\n\n" +
-
-                       "With no parameters, this help is printed.";
-
-       BGPDispatcherImpl dispatcher;
-
-       public Main() throws IOException {
-               this.dispatcher = new BGPDispatcherImpl(BGPMessageFactoryImpl.getInstance());
-       }
-
-       public static void main(final String[] args) throws NumberFormatException, IOException {
-               if (args.length == 0 || args.length == 1 && args[0].equalsIgnoreCase("--help")) {
-                       System.out.println(Main.usage);
-                       return;
-               }
-
-               InetSocketAddress address = null;
-               short holdTimerValue = 90;
-               AsNumber as = null;
-
-               int i = 0;
-               while (i < args.length) {
-                       if (args[i].equalsIgnoreCase("-a") || args[i].equalsIgnoreCase("--address")) {
-                               final String[] ip = args[i + 1].split(":");
-                               address = new InetSocketAddress(InetAddress.getByName(ip[0]), Integer.valueOf(ip[1]));
-                               i++;
-                       } else if (args[i].equalsIgnoreCase("-h") || args[i].equalsIgnoreCase("--holdtimer")) {
-                               holdTimerValue = Short.valueOf(args[i + 1]);
-                               i++;
-                       } else if (args[i].equalsIgnoreCase("-as")) {
-                               as = new AsNumber(Long.valueOf(args[i + 1]));
-                               i++;
-                       } else {
-                               System.out.println("WARNING: Unrecognized argument: " + args[i]);
-                       }
-                       i++;
-               }
-
-               final Main m = new Main();
-
-               final BGPSessionListener sessionListener = new TestingListener();
-
-               final BGPSessionProposalImpl prop = new BGPSessionProposalImpl(holdTimerValue, as.getValue().intValue(), new Ipv4Address("25.25.25.2"));
-
-               final BGPSessionPreferences proposal = prop.getProposal();
-
-               logger.debug("{} {} {}", address, sessionListener, proposal);
-
-               final InetSocketAddress addr = address;
-               m.dispatcher.createClient(addr, proposal, sessionListener, new NeverReconnectStrategy(GlobalEventExecutor.INSTANCE, 5000));
-       }
+public final class Main {
+    private static final Logger LOG = LoggerFactory.getLogger(Main.class);
+
+    private Main() {
+        throw new UnsupportedOperationException();
+    }
+
+    public static void main(final String[] args) throws IOException {
+        final Arguments arguments = Arguments.parseArguments(args);
+        LoggerUtil.initiateLogger(arguments);
+
+        final BGPTestTool bgpTestTool = new BGPTestTool();
+        final InputStreamReader isr = new InputStreamReader(System.in);
+        final BufferedReader br = new BufferedReader(isr);
+        bgpTestTool.start(arguments);
+        for (;;) {
+            LOG.info("Insert local address:");
+            bgpTestTool.printCount(br.readLine());
+        }
+    }
 }