List<OnapCommandSchemaInfo> schemas = OnapCommandDiscoveryUtils.discoverOrLoadSchemas(true);
for (OnapCommandSchemaInfo schema : schemas) {
- if (schema.isIgnore()) {
- continue;
- }
-
- if (schema.getProduct().equalsIgnoreCase(product)) {
+ if (schema.getProduct().equalsIgnoreCase(product) && !schema.isIgnore()) {
if (service.length() > 0 && !service.equalsIgnoreCase(schema.getService())) {
continue;
}
throw new OnapCommandNotFound(cmd, product, service);
}
- Map <String, Object> ioMap = new HashMap<String, Object>();
+ Map <String, Object> ioMap = new HashMap<>();
ioMap.put("name", info.getCmdName());
ioMap.put("author", info.getAuthor());
ioMap.put("description", info.getDescription());
this.defaultValue = UUID.randomUUID().toString();
break;
case JSON:
- this.defaultValue = new String("{}");
+ this.defaultValue = "{}";
break;
default:
- this.defaultValue = new String("");
+ this.defaultValue = "";
break;
}
}
*
* if type=TEXT, then it holds the result in text format such as help message
*/
- private Object output = new String("");
+ private Object output = "";
/*
* Type requested by user
}
}
- public List<Map<String, ?>> getTestSuite(String cmd, String product) throws OnapCommandException {
+ public List<Map<String, Object>> getTestSuite(String cmd, String product) throws OnapCommandException {
return OnapCommandDiscoveryUtils.createTestSuite(cmd, product);
}
* @throws OnapCommandInvalidSchema invalid schema
* @throws OnapCommandSchemaNotFound schema not found
*/
- public static Map<String, ?> validateSchemaVersion(String schemaName, String version) throws OnapCommandException {
- Map<String, ?> values = null;
+ public static Map<String, Object> validateSchemaVersion(String schemaName, String version) throws OnapCommandException {
+ Map<String, Object> values = null;
try {
InputStream inputStream = OnapCommandUtils.class.getClassLoader().getResourceAsStream(schemaName);
errors.addAll(parseSchema(cmd, defaultParameterMap, validateSchema));
}
- Map<String, List<Map<String, String>>> commandYamlMap =
- (Map<String, List<Map<String, String>>>)validateSchemaVersion(schemaName, cmd.getSchemaVersion());
+ Map<String, ?> commandYamlMap = validateSchemaVersion(schemaName, cmd.getSchemaVersion());
errors.addAll(parseSchema(cmd, commandYamlMap, validateSchema));
HashMap<String, String> validationMap = new HashMap<>();
validationMap.put(INFO_TYPE, COMMAND_TYPE_VALUES);
- for (String secKey : validationMap.keySet()) {
+ for (Map.Entry<String,String> entry : validationMap.entrySet()) {
+ String secKey=entry.getKey();
if (infoMap.containsKey(secKey)) {
- Object obj = infoMap.get(secKey);
- if (obj == null) {
+ String value = infoMap.get(secKey);
+ if (value == null) {
exceptionList.add("Attribute '" + secKey + "' under '" + INFO + "' is empty");
} else {
- String value = String.valueOf(obj);
if (!OnapCommandConfig.getCommaSeparatedList(validationMap.get(secKey)).contains(value)) {
exceptionList.add("Attribute '" + secKey + "' contains invalid value. Valide values are "
+ OnapCommandConfig.getCommaSeparatedList(validationMap.get(key))); //
Object ignore = infoMap.get(key1);
info.setIgnore(ignore.toString().equalsIgnoreCase(OnapCommandConstants.BOOLEAN_TRUE));
break;
+ default : // Do nothing
}
}
break;
case IS_SECURED:
- if (validate) {
- if (!OnapCommandUtils.validateBoolean(String.valueOf(parameter.get(key2)))) {
+ if (validate && !OnapCommandUtils.validateBoolean(String.valueOf(parameter.get(key2)))) {
exceptionList.add(OnapCommandUtils.invalidBooleanValueMessage(parameter.get(NAME),
IS_SECURED, String.valueOf(parameter.get(key2))));
}
- }
param.setSecured(BOOLEAN_TRUE.equalsIgnoreCase(String.valueOf(parameter.get(key2))));
break;
break;
case IS_DEFAULT_PARAM:
- if (validate) {
- if (!OnapCommandUtils.validateBoolean(String.valueOf(parameter.get(key2)))) {
+ if (validate && !OnapCommandUtils.validateBoolean(String.valueOf(parameter.get(key2)))) {
exceptionList.add(OnapCommandUtils.invalidBooleanValueMessage(parameter.get(NAME),
IS_DEFAULT_PARAM, String.valueOf(parameter.get(key2))));
}
- }
param.setDefaultParam(BOOLEAN_TRUE.equalsIgnoreCase(String.valueOf(parameter.get(key2))));
break;
+ default : // Do nothing
}
}
break;
case IS_SECURED:
- if (validate) {
- if (!OnapCommandUtils.validateBoolean(String.valueOf(map.get(key4)))) {
+ if (validate && !OnapCommandUtils.validateBoolean(String.valueOf(map.get(key4)))) {
exceptionList.add(OnapCommandUtils.invalidBooleanValueMessage(ATTRIBUTES,
IS_SECURED, String.valueOf(map.get(key4))));
}
- }
attr.setSecured(BOOLEAN_TRUE.equals(String.valueOf(map.get(key4))));
break;
case IS_DEFAULT_ATTR:
- if (validate) {
- if (!OnapCommandUtils.validateBoolean(String.valueOf(map.get(key4)))) {
+ if (validate && !OnapCommandUtils.validateBoolean(String.valueOf(map.get(key4)))) {
exceptionList.add(OnapCommandUtils.invalidBooleanValueMessage(ATTRIBUTES,
IS_DEFAULT_ATTR, String.valueOf(map.get(key4))));
}
- }
attr.setDefaultAttr(BOOLEAN_TRUE.equals(String.valueOf(map.get(key4))));
break;
+ default : // Do nothing
}
}
cmd.getResult().getRecords().add(attr);
}
break;
+ default : // Do nothing
}
}
}
break;
+ default : // Do nothing
}
}
* @throws OnapCommandInvalidSchema
* exception
*/
- public static Map<String, ?> loadSchema(InputStream stream, String schemaName) throws OnapCommandInvalidSchema {
+ public static Map<String, Object> loadSchema(InputStream stream, String schemaName) throws OnapCommandInvalidSchema {
return OnapCommandDiscoveryUtils.loadYaml(stream);
}
String nameN = (String)oN.getOrDefault(OnapCommandConstants.NAME, null);
//Name should be existing in the map, otherwise continue as don't know how to compare
- if (nameN == null) {
- continue;
- }
+ if (nameN != null) {
boolean existing = false;
for (Object e: originalList) {
String nameE = (String)oE.getOrDefault(OnapCommandConstants.NAME, null);
//Name should be existing in the map, otherwise continue as don't know how to compare
- if (nameE == null) {
- continue;
- }
-
if (nameN.equals(nameE)) {
for (Entry<String, Object> oNe : oN.entrySet()) {
oE.put(oNe.getKey(), oNe.getValue());
originalList.add(o);
}
}
+ }
}
}
private SimpleDateFormat dateFormatter = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS", Locale.US);
- private static String SEPARATOR = "__";
+ private static final String SEPARATOR = "__";
public static class Artifact {
private String name;
if (!aFile.exists()) {
throw new OnapCommandArtifactNotFound(name, category);
}
- if(!aFile.delete()){
- log.error("Failed to delete the artifact {}", aFile.getAbsolutePath());
+ try {
+ Files.delete(Paths.get(storePath));
+ } catch (IOException e) {
+ log.error("Failed to delete the artifact " + aFile.getAbsolutePath());
}
}
import java.io.File;
import java.io.FilenameFilter;
import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Arrays;
private SimpleDateFormat dateFormatter = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS", Locale.US);
- private static String SEPARATOR = "__";
+ private static final String SEPARATOR = "__";
private enum SearchMode {
FIND,
}
- private static SearchMode SEARCH_MODE = SearchMode.FILE;
+ private static SearchMode searchMode = SearchMode.FILE;
static {
String mode = OnapCommandConfig.getPropertyValue(OnapCommandConstants.OPEN_CLI_EXECUTION_SEARCH_MODE);
if (mode.equalsIgnoreCase(SearchMode.FIND.name()))
- SEARCH_MODE = SearchMode.FIND;
+ searchMode = SearchMode.FIND;
}
public static class ExecutionStoreContext {
FileUtils.touch(new File(context.getStorePath() + File.separator + COMPLETED));
else
FileUtils.touch(new File(context.getStorePath() + File.separator + FAILED));
-
- if(!new File(context.getStorePath() + File.separator + IN_PROGRESS).delete()){
- log.error("Failed to delete {}", context.getStorePath() + File.separator + IN_PROGRESS);
+ Path path= Paths.get(context.getStorePath() + File.separator + IN_PROGRESS);
+ try {
+ Files.delete(path);
+ } catch (IOException e) {
+ log.error("Failed to delete "+ context.getStorePath() + File.separator + IN_PROGRESS);
}
} catch (IOException e) {
log.error("Failed to store the execution end details {}", context.storePath);
try {
List <String> dirs = new ArrayList<>();
- if (System.getProperty("os.name").toLowerCase().startsWith("windows") || SEARCH_MODE.equals(SearchMode.FILE)) {
+ if (System.getProperty("os.name").toLowerCase().startsWith("windows") || searchMode.equals(SearchMode.FILE)) {
for (File f: new File(getBasePath()).listFiles()) {
if(search.containsKey(EXECUTIONID)) {
if (f.getName().startsWith(search.get(EXECUTIONID)))
if (f.getName().startsWith(search.get(REQUESTID)))
dirs.add(f.getAbsolutePath());
- continue;
}
else
}
private File getExecutionDir(String executionId) throws OnapCommandExecutionNotFound {
- File []f = new File(getBasePath()).listFiles(new FilenameFilter() {
-
- @Override
- public boolean accept(File dir, String name) {
- return name.startsWith(executionId);
- }
+ File []f = new File(getBasePath()).listFiles((dir, name) -> {
+ if (name.startsWith(executionId)) return true;
+ return false;
});
if (f.length == 0) {
import java.io.File;
import java.io.FilenameFilter;
import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Paths;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
}
public void remove(String productVersion, String paramName) {
- if (paramCache.containsKey(productVersion)) {
- if (paramCache.get(productVersion).containsKey(paramName)) {
+ if (paramCache.containsKey(productVersion) && paramCache.get(productVersion).containsKey(paramName)) {
paramCache.get(productVersion).remove(paramName);
}
- }
this.persist();
}
public void removeProfile(String profile) {
String dataDir = getDataStorePath();
File file = new File(dataDir + File.separator + profile + DATA_PATH_PROFILE_JSON);
- if (file.exists()) {
- if(!file.delete()){
- log.error("Failed to delete profile {}", file.getAbsolutePath());
+ try {
+ Files.delete(Paths.get(dataDir + File.separator + profile + DATA_PATH_PROFILE_JSON));
+ } catch (IOException e) {
+ log.error("Failed to delete profile {}"+file.getAbsolutePath());
}
- }
}
public List<String> getProfiles() {
List<String> profiles = new ArrayList<>();
String dataDir = getDataStorePath();
- for (File file: new File(dataDir).listFiles(new FilenameFilter() {
- @Override
- public boolean accept(File dir, String name) {
- return name.endsWith(DATA_PATH_PROFILE_JSON);
- }
- })) {
+ for (File file: new File(dataDir).listFiles((dir, name) -> name.endsWith(DATA_PATH_PROFILE_JSON))) {
String profile = file.getName().substring(0, file.getName().indexOf(DATA_PATH_PROFILE_JSON));
profiles.add(profile);
}
import java.io.FileInputStream;
public class OnapCommandDiscoveryUtils {
+ private OnapCommandDiscoveryUtils() {
+ throw new IllegalStateException("Utility class");
+ }
+
private static Gson gson = new GsonBuilder().serializeNulls().create();
/**
* @throws OnapCommandInvalidSchema
* exception
*/
- public static Map<String, ?> loadSchema(Resource resource) throws OnapCommandInvalidSchema {
- Map<String, ?> values = null;
+ public static Map<String, Object> loadSchema(Resource resource) throws OnapCommandInvalidSchema {
+ Map<String, Object> values = null;
try {
values = loadYaml(resource.getInputStream());
} catch (Exception e) {
Object obj = resourceMap.get(OPEN_CLI_SCHEMA_VERSION);
if (obj == null) {
- OnapCommandUtils.log.info("Invalid Schema yaml {}", schema.getSchemaURI());
- continue;
+ OnapCommandUtils.log.info("Invalid Schema yaml {}" + schema.getSchemaURI());
}
-
+ else{
schema.setVersion(obj.toString());
if (!schema.getVersion().equalsIgnoreCase(OnapCommandConstants.OPEN_CLI_SCHEMA_VERSION_VALUE_1_0)) {
- OnapCommandUtils.log.info("Unsupported Schema version found {}", schema.getSchemaURI());
- continue;
+ OnapCommandUtils.log.info("Unsupported Schema version found {} " + schema.getSchemaURI());
}
+ else{
//There are schema like default input parameters and does not have command name
- if (resourceMap.get(NAME) == null) {
- continue;
- }
-
+ if (resourceMap.get(NAME) != null) {
schema.setSchemaName(resource.getFilename());
schema.setCmdName((String) resourceMap.get(NAME));
extSchemas.add(schema);
}
+ }
+ }
+ }
}
}
} catch (IOException e) {
}
- public static List<Map<String, ?>> createTestSuite(String cmd, String version) throws OnapCommandException {
+ public static List<Map<String, Object>> createTestSuite(String cmd, String version) throws OnapCommandException {
+
+ ArrayList<Map<String, Object>> testSamples = new ArrayList();
- ArrayList<Map<String, ?>> testSamples = new ArrayList<>();
List<Resource> resources = new ArrayList<>();
OnapCommandSchemaInfo schemaInfo = getSchemaInfo(cmd, version);
Map<String, Map<String, String>> samples = (Map<String, Map<String, String>>) stringMap
.get(OnapCommandConstants.VERIFY_SAMPLES);
- for (String sampleId : samples.keySet()) {
-
- Map<String, String> sample = samples.get(sampleId);
+ for (Map.Entry<String,Map<String, String>> entry : samples.entrySet()) {
+ String sampleId=entry.getKey();
+ Map<String, String> sample = entry.getValue();
List<String> inputArgs = new ArrayList<>();
if (sample.get(OnapCommandConstants.VERIFY_INPUT) != null) {
* @throws OnapCommandInvalidSchema
* exception
*/
- public static Map<String, ?> loadYaml(Resource resource) throws OnapCommandInvalidSchema {
- Map<String, ?> values = null;
+ public static Map<String, Object> loadYaml(Resource resource) throws OnapCommandInvalidSchema {
+ Map<String, Object> values = null;
try {
values = loadYaml(resource.getInputStream());
} catch (Exception e) {
* @throws OnapCommandInvalidSchema
* exception
*/
- public static Map<String, ?> loadYaml(String filePath) throws OnapCommandInvalidSchema {
- Map<String, ?> values = null;
+ public static Map<String, Object> loadYaml(String filePath) throws OnapCommandInvalidSchema {
+ Map<String, Object> values = null;
try {
values = loadYaml(new FileInputStream(new File(filePath)));
} catch (Exception e) {
* @throws OnapCommandInvalidSchema
* exception
*/
- public static Map<String, ?> loadYaml(InputStream inputStream) throws OnapCommandInvalidSchema {
- Map<String, ?> values = null;
+ public static Map<String, Object> loadYaml(InputStream inputStream) throws OnapCommandInvalidSchema {
+ Map<String, Object> values = null;
try(InputStreamReader inputStreamReader = new InputStreamReader(inputStream);){
YamlReader reader = new YamlReader(inputStreamReader);
- values = (Map<String, ?>) reader.read();
+ values = (Map<String, Object>) reader.read();
} catch (IOException e) {
throw new OnapCommandInvalidSchema(inputStream.getClass().getName(),e.getMessage());
}
public class OnapCommandHelperUtils {
+ private OnapCommandHelperUtils() {
+ throw new IllegalStateException("Utility class");
+ }
+
/**
* Returns the build time from manifest.mf
*/
String value = "";
- switch (splEntry) {
- case OnapCommandConstants.SPL_ENTRY_UUID:
+ if (OnapCommandConstants.SPL_ENTRY_UUID.equals(splEntry)) {
value = UUID.randomUUID().toString();
- break;
-
- default:
-
+ }
+ else{
if (splEntry.startsWith(OnapCommandConstants.SPL_ENTRY_ENV)) {
//start to read after env:ENV_VAR_NAME
String envVarName = splEntry.substring(4);
readError = true;
}
- final OutputStream stdout = this.getStdout();
- final OutputStream stderr = this.getStderr();
+ final OutputStream stdoutLocal = this.getStdout();
+ final OutputStream stderrLocal = this.getStderr();
final InputStream stdoutP = p.getInputStream();
final InputStream stderrP = p.getErrorStream();
- Thread outThread = new Thread(new Runnable() {
- public void run() {
- try {
- IOUtils.copy(stdoutP, stdout);
- } catch (IOException e) { // NOSONAR
- }
+ Thread outThread = new Thread(() -> {
+ try {
+ IOUtils.copy(stdoutP, stdoutLocal);
+ } catch (IOException e) { //NOSONAR
+ // Do nothing
}
});
- Thread errThread = new Thread(new Runnable() {
- public void run() {
- try {
- IOUtils.copy(stderrP, stderr);
- } catch (IOException e) { // NOSONAR
- }
+ Thread errThread = new Thread(() -> {
+ try {
+ IOUtils.copy(stderrP, stderrLocal);
+ } catch (IOException e) { //NOSONAR
+ // Do nothing
}
});
import java.io.File;
import java.net.URL;
import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
import org.junit.Before;
import org.junit.Test;
cmd.printVersion();
registrar.listCommands();
}
+ @Test
+ public void getTestSuiteTest() throws OnapCommandException {
+ List<Map<String, Object>> cmds =registerar.getTestSuite("schema-validate","open-cli");
+ assertTrue(cmds.size() >= 1);
+ }
}
@OnapCommandSchema(schema = "sample-test-schema.yaml")
import static org.junit.Assert.assertTrue;
+import java.util.ArrayList;
+import java.util.HashMap;
import java.util.List;
+import java.util.Map;
import org.junit.Test;
import org.onap.cli.fw.cmd.OnapCommand;
assertTrue(errorList2.size() > 0);
}
+ @Test
+ public void parseSchemaTest() throws OnapCommandException {
+ OnapCommand cmd = new OnapCommand() {
+ @Override
+ protected void run() throws OnapCommandException {}
+ };
+ Map<String, Object> values=new HashMap<>();
+ List<Map<String, Object>> list=new ArrayList<>();
+ Map<String,Object> paraValues=new HashMap<>();
+ paraValues.put("is_secured","yes");
+ paraValues.put("is_default_param","yes");
+ list.add(paraValues);
+ values.put("parameters",list);
+ assertTrue(OnapCommandSchemaLoader.parseSchema(cmd,values,true).size()==2);
+
+ }
+ @Test
+ public void parseSchema2Test() throws OnapCommandException {
+ OnapCommand cmd = new OnapCommand() {
+ @Override
+ protected void run() throws OnapCommandException {}
+ };
+ Map<String, Object> values=new HashMap<>();
+ List<Map<String, Object>> list=new ArrayList<>();
+ Map<String,Object> paraValues=new HashMap<>();
+ Map<String, Object> attributesValues=new HashMap<>();
+ paraValues.put("is_secured","yes");
+ paraValues.put("is_default_attr","yes");
+ list.add(paraValues);
+ attributesValues.put("attributes",list);
+ values.put("results",attributesValues);
+ assertTrue(OnapCommandSchemaLoader.parseSchema(cmd,values,true).size()==2);
+
+ }
}
assertNotNull(onapCommandProfileStore.getParams("abc"));
}
-
+ @Test
+ public void removeTest() {
+ onapCommandProfileStore.add("abc", "abc", "abc");
+ onapCommandProfileStore.remove("abc","abc");
+ }
@AfterClass
public static void tearDown() throws Exception {
import org.onap.cli.fw.schema.OnapCommandSchemaInfo;
import org.onap.cli.fw.schema.OnapCommandSchemaLoader;
+import java.io.File;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
List<Class<OnapCommand>> cmds = OnapCommandDiscoveryUtils.discoverCommandPlugins();
assertTrue(cmds.size() >= 1);
}
+ @Test
+ public void createTestSuiteTest() throws OnapCommandException {
+ List<Map<String, Object>> cmds = OnapCommandDiscoveryUtils.createTestSuite("schema-validate","open-cli");
+ assertTrue(cmds.size() >= 1);
+ }
@Test
public void sortTest() {
assertTrue(mapExample.get("key2").equals("paramB"));
}
+ @Test
+ public void loadYamlTest() throws OnapCommandInvalidSchema {
+ File file=new File("src/test/resources/sample-test-info.yaml");
+ Map<String, Object> values= OnapCommandDiscoveryUtils.loadYaml(file.getAbsolutePath());
+ assertEquals(values.get("name"),"sample-test-info");
+ }
}
cmd.getParametersMap().get(OnapCommandConstants.RPC_MODE).setValue(OnapCommandConstants.RPC_MODE_RUN_RPC);
}
- if (!cmd.isRpc()) {
//Start the execution
- if (req.getRequestId() != null && !req.getRequestId().isEmpty()) {
- if (!(cmd.getInfo().getProduct().equalsIgnoreCase("open-cli") &&
+ if (!cmd.isRpc()&&req.getRequestId() != null && !req.getRequestId().isEmpty()&&!(cmd.getInfo().getProduct().equalsIgnoreCase("open-cli") &&
cmd.getName().equalsIgnoreCase("execution-list"))) {
String input = cmd.getArgsJson(true);
executionStoreContext = OnapCommandExecutionStore.getStore().storeExectutionStart(
profile,
input);
}
- }
- }
cmd.setExecutionContext(executionStoreContext);
cmd.execute();
.filter(e -> e.getName().equals(OnapCommandConstants.VERIFY_CONTEXT_PARAM))
.findFirst();
- List<Map<String, ?>> testSuite = OnapCommandRegistrar.getRegistrar().getTestSuite(
+ List<Map<String, Object>> testSuite = OnapCommandRegistrar.getRegistrar().getTestSuite(
cmd.getName(),
cmd.getInfo().getProduct());
OnapCliArgsParser.populateParams(cmd.getParameters(), this.args);
//start the execution
- if (this.requestId != null && this.product != null && !this.requestId.isEmpty()) {
- if (!(this.product.equalsIgnoreCase("open-cli") &&
+ if (this.requestId != null && this.product != null && !this.requestId.isEmpty()&& !(this.product.equalsIgnoreCase("open-cli") &&
this.cmdName.equalsIgnoreCase("execution-list"))) {
String input = cmd.getArgsJson(true);
executionStoreContext = OnapCommandExecutionStore.getStore().storeExectutionStart(
this.profile,
input);
}
- }
cmd.setExecutionContext(executionStoreContext);
OnapCommandResult result = cmd.execute();
*
*/
public class StringCompleter implements Completer {
- private final SortedSet<String> strings = new TreeSet<String>();
+ private final SortedSet<String> strings = new TreeSet<>();
/**
* Public Constructor takes collection of strings.
import org.onap.cli.fw.error.OnapCommandHelpFailed;
import org.onap.cli.fw.registrar.OnapCommandRegistrar;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
import java.util.Map;
+import java.util.Arrays;
import org.onap.cli.fw.error.OnapCommandInvalidSchema;
import org.onap.cli.fw.utils.OnapCommandDiscoveryUtils;
import static org.junit.Assert.assertFalse;
Map<String,?> map = OnapCommandDiscoveryUtils.loadYaml("src/test/resources/open-cli-schema/sample-test-schema.yaml");
assertFalse(map.isEmpty());
}
+ @Test
+ public void testverifyCommand() throws OnapCommandException {
+ cli = new OnapCli(new String[] {"schema-validate","--verify" });
+ new MockUp<OnapCommandRegistrar>(){
+ @Mock
+ public List<Map<String, Object>> getTestSuite(String cmd, String product) throws OnapCommandException {
+ List<Map<String, Object>> list=new ArrayList<>();
+ Map<String,Object>map=new HashMap<>();
+ map.put("output","output");
+ map.put("input", Arrays.asList(new String[]{"--verify"}));
+ map.put("sampleid","sample1");
+ map.put("samplefileid","schema-validate-sample.yaml");
+ map.put("moco","schema-validate-moco.json");
+ list.add(map);
+ return list;
+ }
+ };
+ cli.handleCommand();
+ }
}
//Process command
String []cmd = commandLine.toArray(new String []{});
String cwd = this.getWd();
- List <String> envs = new ArrayList<>();
+ List <String> envList = new ArrayList<>();
//add current process environments to sub process
for (Map.Entry<String, String> env: System.getenv().entrySet()) { //NOSONAR
- envs.add(env.getKey() + "=" + env.getValue());
+ envList.add(env.getKey() + "=" + env.getValue());
}
//add oclip specific environment variables
if (this.getExecutionContext() != null) {
- envs.add("OPEN_CLI_REQUEST_ID=" + this.getExecutionContext().getRequestId());
+ envList.add("OPEN_CLI_REQUEST_ID=" + this.getExecutionContext().getRequestId());
if (this.getExecutionContext().getProfile() != null) {
- envs.add("OPEN_CLI_PROFILE=" + this.getExecutionContext().getProfile());
+ envList.add("OPEN_CLI_PROFILE=" + this.getExecutionContext().getProfile());
}
if (OnapCommandRegistrar.getRegistrar().getHost() != null) {
- envs.add("OPEN_CLI_RPC_HOST=" + OnapCommandRegistrar.getRegistrar().getHost());
- envs.add("OPEN_CLI_RPC_PORT=" + OnapCommandRegistrar.getRegistrar().getPort());
+ envList.add("OPEN_CLI_RPC_HOST=" + OnapCommandRegistrar.getRegistrar().getHost());
+ envList.add("OPEN_CLI_RPC_PORT=" + OnapCommandRegistrar.getRegistrar().getPort());
}
}
for (String env: this.getEnvs().keySet()) {
- envs.add(env + "=" + this.getEnvs().get(env));
+ envList.add(env + "=" + this.getEnvs().get(env));
}
ProcessRunner pr = new ProcessRunner(
cmd,
- (!envs.isEmpty()) ? envs.toArray(new String []{}) : null,
+ (!envList.isEmpty()) ? envList.toArray(new String []{}) : null,
cwd);
FileOutputStream stdoutStream = null;
FileOutputStream stderrStream = null;
case OnapCommandCmdConstants.PASS_CODE:
cmd.setPassCodes((ArrayList) valMap.get(key1));
break;
+ default : // Do nothing
}
}
}
errors.addAll(OnapCommandSchemaLoader.parseSchema(cmd, defaultParameterMap, validateSchema));
}
- Map<String, List<Map<String, String>>> commandYamlMap =
- (Map<String, List<Map<String, String>>>) OnapCommandSchemaLoader.validateSchemaVersion(schemaName, cmd.getSchemaVersion());
+ Map<String, ?> commandYamlMap =
+ OnapCommandSchemaLoader.validateSchemaVersion(schemaName, cmd.getSchemaVersion());
errors.addAll(parseHttpSchema(cmd, commandYamlMap, validateSchema));
Map<String, Object> context = (Map<String, Object>) map.get(key2);
for (String key: context.keySet()) {
- switch (key) {
- case OnapCommandHttpConstants.CONTEXT_REMOVE_EMPTY_JSON_NODES:
+ if (OnapCommandHttpConstants.CONTEXT_REMOVE_EMPTY_JSON_NODES.equals(key)) {
Boolean flag = Boolean.valueOf(context.get(OnapCommandHttpConstants.CONTEXT_REMOVE_EMPTY_JSON_NODES).toString());
cmd.getInput().getContext().put(OnapCommandHttpConstants.CONTEXT_REMOVE_EMPTY_JSON_NODES, flag.toString());
- break;
}
}
-
break;
case OnapCommandHttpConstants.MULTIPART_ENTITY_NAME:
Object multipartEntityName = map.get(key2);
cmd.getInput().setMultipartEntityName(multipartEntityName.toString());
break;
+ default : // Do nothing
}
}catch (Exception ex) {
OnapCommandUtils.throwOrCollect(new OnapCommandInvalidSchema(cmd.getSchemaName(), ex), errorList, validate);
Object mode = serviceMap.get(key);
srv.setMode(mode.toString());
break;
+ default : // Do nothing
}
}
case OnapCommandHttpConstants.SAMPLE_RESPONSE:
// (mrkanag) implement sample response handling
break;
+ default : // Do nothing
}
}
}
for (Object successCode : requestSuccessCodes) {
Integer code = Integer.valueOf(String.valueOf(successCode));
- if (code < 200 || code >= 300) {
- if ( code != 404) {
+ if ((code < 200 || code >= 300) && code != 404) {
errorList.add(OnapCommandHttpConstants.HTTP_SUCCESS_CODE_INVALID);
- }
}
}
public class OnapCommandHttpUtils {
- static Logger LOG = LoggerFactory.getLogger(OnapCommandHttpUtils.class);
+ static Logger log = LoggerFactory.getLogger(OnapCommandHttpUtils.class);
private static Gson gson = new GsonBuilder().serializeNulls().create();
-
+ private OnapCommandHttpUtils() {
+ throw new IllegalStateException("Utility class");
+ }
/**
* Set argument to param value.
*
--- /dev/null
+/*
+ * Copyright 2020 Huawei Technologies Co., Ltd.
+ *
+ * Licensed 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.onap.cli.fw.http.schema;
+
+import org.junit.Test;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class OnapCommandSchemaHttpLoaderTest {
+ @Test
+ public void validateHttpSccessCodesTest(){
+ List<String> errorList= new ArrayList<>();
+ List<Object> requestSuccessCodes=new ArrayList<>();
+ requestSuccessCodes.add("101");
+ OnapCommandSchemaHttpLoader.validateHttpSccessCodes(errorList,requestSuccessCodes);
+ }
+}
method: POST
body: '{"serviceName":"${service-name}","version":"${service-version}","url":"${service-url}","protocol":"REST","visualRange":"1","lb_policy":"hash","nodes":[{"ip":"${node-ip}","port":"${node-port}","ttl":0}]}'
headers:
+ context:
+ remove_empty_node: true
queries:
createOrUpdate: ${create-or-update}
success_codes:
String[] oidStrArr = oids.toArray(new String[oids.size()]);
- switch (this.command) {
-
- case OnapCommandSnmpConstants.SNMP_CMD_GET:
+ if (OnapCommandSnmpConstants.SNMP_CMD_GET.equals(this.command)) {
ResponseEvent responseEvent = snmp.send(getPDU(PDU.GET, oidStrArr), getTarget(), null);
if ( responseEvent != null) {
if (responseEvent.getResponse().getErrorStatus() == PDU.noError) {
} else {
throw new OnapSnmpErrorResponse("Failed to send SNMP GET command");
}
- break;
-
- default:
- break;
}
snmp.close();
} catch (IOException ex) {
import org.onap.cli.fw.utils.OnapCommandUtils;
public class OnapCommandSchemaSnmpLoader {
-
+ private OnapCommandSchemaSnmpLoader() {
+ throw new IllegalStateException("Utility class");
+ }
private static List<String> validateSnmpSchemaSection(Map<String, Object> values) {
ArrayList<String> errorList = new ArrayList<>();
case OnapCommandSnmpConstants.SNMP_COMMAND:
cmd.setCommand((String) entry.getValue());
-
+ break;
default:
break;
}
public class MockJsonGenerator {
private static Gson gson = new GsonBuilder().serializeNulls().create();
-
+ private MockJsonGenerator() {
+ throw new IllegalStateException("Utility class");
+ }
public static void generateMocking(MockRequest mockRequest, MockResponse mockResponse, String jsonFilePath) throws IOException {
MockObject mockObject = new MockObject();
public class SampleYamlGenerator {
static int nTab;
-
+ private SampleYamlGenerator() {
+ throw new IllegalStateException("Utility class");
+ }
public static void generateSampleYaml(String cmdName, List<String> input, String output, String version,
String targetPath, boolean debug, String name) throws IOException {
Code Review / cli.git / commitdiff