| /** |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| package org.apache.oozie.cli; |
| |
| import java.io.ByteArrayOutputStream; |
| import java.io.IOException; |
| import java.io.PipedInputStream; |
| import java.io.PipedOutputStream; |
| import java.io.PrintStream; |
| import java.nio.charset.StandardCharsets; |
| |
| import junit.framework.TestCase; |
| |
| import org.apache.commons.cli.Option; |
| import org.apache.commons.cli.Options; |
| import org.apache.commons.cli.ParseException; |
| import org.junit.Test; |
| |
| import com.google.common.io.ByteStreams; |
| |
| public class TestCLIParser extends TestCase { |
| |
| @Test |
| public void testEmptyParser() throws Exception { |
| try { |
| CLIParser parser = new CLIParser("oozie", new String[]{}); |
| CLIParser.Command c = parser.parse(new String[]{"a"}); |
| fail(); |
| } |
| catch (ParseException ex) { |
| //nop |
| } |
| } |
| |
| @Test |
| public void testCommandParser() throws Exception { |
| try { |
| CLIParser parser = new CLIParser("oozie", new String[]{}); |
| parser.addCommand("a", "<A>", "AAAAA", new Options(), false); |
| CLIParser.Command c = parser.parse(new String[]{"a", "b"}); |
| assertEquals("a", c.getName()); |
| assertEquals("b", c.getCommandLine().getArgs()[0]); |
| } |
| catch (ParseException ex) { |
| fail(); |
| } |
| } |
| |
| @Test |
| public void testCommandParserX() throws Exception { |
| Option opt = new Option("o", false, "O"); |
| Options opts = new Options(); |
| opts.addOption(opt); |
| CLIParser parser = new CLIParser("test", new String[]{}); |
| parser.addCommand("c", "-X ", "(everything after '-X' are pass-through parameters)", opts, true); |
| CLIParser.Command c = parser.parse("c -o -X -o c".split(" ")); |
| assertEquals("-X", c.getCommandLine().getArgList().get(0)); |
| assertEquals(3, c.getCommandLine().getArgList().size()); |
| } |
| |
| @Test |
| public void testCommandParserShowHelp() throws Exception { |
| String pattern = "oozie job <A>: AAAAA"; |
| CLIParser parser = new CLIParser("oozie", new String[]{}); |
| parser.addCommand("job", "<A>", "AAAAA", new Options(), false); |
| CLIParser.Command c = parser.parse(new String[]{"job", "b"}); |
| assertTrue(readCommandOutput(parser, c).contains(pattern)); |
| } |
| |
| @Test |
| public void testCommandParserShowHelpWithOptions() throws Exception { |
| String pattern = "oozie job <OPTIONS> : job operations"; |
| CLIParser parser = new CLIParser("oozie", new String[]{}); |
| parser.addCommand("job", "", "job operations", createCommandOptions(), false); |
| CLIParser.Command c = parser.parse(new String[]{ "job", "-url", "test-name", "-verbose" }); |
| assertTrue(readCommandOutput(parser, c).contains(pattern)); |
| } |
| |
| private Options createCommandOptions() { |
| Option oozie = new Option("url", true, "URL"); |
| Option name = new Option("verbose", false, "verbose"); |
| Options complexOptions = new Options(); |
| complexOptions.addOption(oozie); |
| complexOptions.addOption(name); |
| return complexOptions; |
| } |
| |
| private String readCommandOutput(CLIParser parser, CLIParser.Command c) throws IOException { |
| ByteArrayOutputStream outBytes = new ByteArrayOutputStream(); |
| PipedOutputStream pipeOut = new PipedOutputStream(); |
| PipedInputStream pipeIn = new PipedInputStream(pipeOut, 1024 * 10); |
| System.setOut(new PrintStream(pipeOut, false, StandardCharsets.UTF_8.name())); |
| |
| parser.showHelp(c.getCommandLine()); |
| pipeOut.close(); |
| ByteStreams.copy(pipeIn, outBytes); |
| pipeIn.close(); |
| return new String(outBytes.toByteArray(), StandardCharsets.UTF_8); |
| } |
| } |