authz-cmd/src/main/java/com/att/cmd/AAFcli.java

   1 /*******************************************************************************\r
   2  * ============LICENSE_START====================================================\r
   3  * * org.onap.aaf\r
   4  * * ===========================================================================\r
   5  * * Copyright © 2017 AT&T Intellectual Property. All rights reserved.\r
   6  * * ===========================================================================\r
   7  * * Licensed under the Apache License, Version 2.0 (the "License");\r
   8  * * you may not use this file except in compliance with the License.\r
   9  * * You may obtain a copy of the License at\r
  10  * * \r
  11  *  *      http://www.apache.org/licenses/LICENSE-2.0\r
  12  * * \r
  13  *  * Unless required by applicable law or agreed to in writing, software\r
  14  * * distributed under the License is distributed on an "AS IS" BASIS,\r
  15  * * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  16  * * See the License for the specific language governing permissions and\r
  17  * * limitations under the License.\r
  18  * * ============LICENSE_END====================================================\r
  19  * *\r
  20  * * ECOMP is a trademark and service mark of AT&T Intellectual Property.\r
  21  * *\r
  22  ******************************************************************************/\r
  23 package com.att.cmd;\r
  24 \r
  25 import java.io.BufferedReader;\r
  26 import java.io.Console;\r
  27 import java.io.File;\r
  28 import java.io.FileReader;\r
  29 import java.io.IOException;\r
  30 import java.io.InputStream;\r
  31 import java.io.InputStreamReader;\r
  32 import java.io.OutputStreamWriter;\r
  33 import java.io.PrintWriter;\r
  34 import java.io.Reader;\r
  35 import java.io.Writer;\r
  36 import java.net.HttpURLConnection;\r
  37 import java.util.ArrayList;\r
  38 import java.util.List;\r
  39 import java.util.Properties;\r
  40 \r
  41 import org.apache.log4j.PropertyConfigurator;\r
  42 \r
  43 import com.att.aft.dme2.api.DME2Manager;\r
  44 import com.att.authz.env.AuthzEnv;\r
  45 import com.att.cadi.Access.Level;\r
  46 import com.att.cadi.CadiException;\r
  47 import com.att.cadi.Locator;\r
  48 import com.att.cadi.SecuritySetter;\r
  49 import com.att.cadi.client.PropertyLocator;\r
  50 import com.att.cadi.client.Retryable;\r
  51 import com.att.cadi.config.Config;\r
  52 import com.att.cadi.config.SecurityInfo;\r
  53 import com.att.cadi.config.SecurityInfoC;\r
  54 import com.att.cadi.dme2.DME2Locator;\r
  55 import com.att.cadi.filter.AccessGetter;\r
  56 import com.att.cadi.http.HBasicAuthSS;\r
  57 import com.att.cadi.http.HMangr;\r
  58 import com.att.cmd.mgmt.Mgmt;\r
  59 import com.att.cmd.ns.NS;\r
  60 import com.att.cmd.perm.Perm;\r
  61 import com.att.cmd.role.Role;\r
  62 import com.att.cmd.user.User;\r
  63 import com.att.inno.env.APIException;\r
  64 import com.att.inno.env.Env;\r
  65 import com.att.inno.env.impl.Log4JLogTarget;\r
  66 import com.att.inno.env.util.Split;\r
  67 \r
  68 import jline.console.ConsoleReader;\r
  69 \r
  70 public class AAFcli {\r
  71 \r
  72         public static final String AAF_DEFAULT_REALM = "aaf_default_realm";\r
  73         protected static PrintWriter pw;\r
  74         protected HMangr hman;\r
  75         // Storage for last reused client. We can do this\r
  76         // because we're technically "single" threaded calls.\r
  77         public Retryable<?> prevCall;\r
  78 \r
  79         protected SecuritySetter<HttpURLConnection> ss;\r
  80         protected AuthzEnv env;\r
  81         private boolean close;\r
  82         private List<Cmd> cmds;\r
  83 \r
  84         // Lex State\r
  85         private ArrayList<Integer> expect = new ArrayList<Integer>();\r
  86         private boolean verbose = true;\r
  87         private int delay;\r
  88         private SecurityInfo si;\r
  89         private boolean request = false;\r
  90         private String force = null;\r
  91         private boolean gui = false;\r
  92 \r
  93         private static int TIMEOUT = Integer.parseInt(Config.AAF_CONN_TIMEOUT_DEF);\r
  94         private static boolean isConsole = false;\r
  95         private static boolean isTest = false;\r
  96         private static boolean showDetails = false;\r
  97         private static boolean ignoreDelay = false;\r
  98         private static int globalDelay=0;\r
  99         \r
 100         public static int timeout() {\r
 101                 return TIMEOUT;\r
 102         }\r
 103 \r
 104         public AAFcli(AuthzEnv env, Writer wtr, HMangr hman, SecurityInfo si, SecuritySetter<HttpURLConnection> ss) throws APIException {\r
 105                 this.env = env;\r
 106                 this.ss = ss;\r
 107                 this.hman = hman;\r
 108                 this.si = si;\r
 109                 if (wtr instanceof PrintWriter) {\r
 110                         pw = (PrintWriter) wtr;\r
 111                         close = false;\r
 112                 } else {\r
 113                         pw = new PrintWriter(wtr);\r
 114                         close = true;\r
 115                 }\r
 116 \r
 117 \r
 118                 // client = new DRcli(new URI(aafurl), new\r
 119                 // BasicAuth(user,toPass(pass,true)))\r
 120                 // .apiVersion("2.0")\r
 121                 // .timeout(TIMEOUT);\r
 122 \r
 123                 /*\r
 124                  * Create Cmd Tree\r
 125                  */\r
 126                 cmds = new ArrayList<Cmd>();\r
 127 \r
 128                 Role role = new Role(this);\r
 129                 cmds.add(new Help(this, cmds));\r
 130                 cmds.add(new Version(this));\r
 131                 cmds.add(new Perm(role));\r
 132                 cmds.add(role);\r
 133                 cmds.add(new User(this));\r
 134                 cmds.add(new NS(this));\r
 135                 cmds.add(new Mgmt(this));\r
 136         }\r
 137 \r
 138         public void verbose(boolean v) {\r
 139                 verbose = v;\r
 140         }\r
 141 \r
 142         public void close() {\r
 143                 if (hman != null) {\r
 144                         hman.close();\r
 145                         hman = null;\r
 146                 }\r
 147                 if (close) {\r
 148                         pw.close();\r
 149                 }\r
 150         }\r
 151 \r
 152         public boolean eval(String line) throws Exception {\r
 153                 if (line.length() == 0) {\r
 154                         return true;\r
 155                 } else if (line.startsWith("#")) {\r
 156                         pw.println(line);\r
 157                         return true;\r
 158                 }\r
 159 \r
 160                 String[] largs = argEval(line);\r
 161                 int idx = 0;\r
 162 \r
 163                 // Variable replacement\r
 164                 StringBuilder sb = null;\r
 165                 while (idx < largs.length) {\r
 166                         int e = 0;\r
 167                         for (int v = largs[idx].indexOf("@["); v >= 0; v = largs[idx].indexOf("@[", v + 1)) {\r
 168                                 if (sb == null) {\r
 169                                         sb = new StringBuilder();\r
 170                                 }\r
 171                                 sb.append(largs[idx], e, v);\r
 172                                 if ((e = largs[idx].indexOf(']', v)) >= 0) {\r
 173                                         String p = env.getProperty(largs[idx].substring(v + 2, e++));\r
 174                                         if (p != null) {\r
 175                                                 sb.append(p);\r
 176                                         }\r
 177                                 }\r
 178                         }\r
 179                         if (sb != null && sb.length() > 0) {\r
 180                                 sb.append(largs[idx], e, largs[idx].length());\r
 181                                 largs[idx] = sb.toString();\r
 182                                 sb.setLength(0);\r
 183                         }\r
 184                         ++idx;\r
 185                 }\r
 186 \r
 187                 idx = 0;\r
 188                 boolean rv = true;\r
 189                 while (rv && idx < largs.length) {\r
 190                         // Allow Script to change Credential\r
 191                         if (!gui) {\r
 192                                 if("as".equalsIgnoreCase(largs[idx])) {\r
 193                                         if (largs.length > ++idx) {\r
 194                                                 // get Password from Props with ID as Key\r
 195                                                 String user = largs[idx++];\r
 196                                                 int colon = user.indexOf(':');\r
 197                                                 String pass;\r
 198                                                 if (colon > 0) {\r
 199                                                         pass = user.substring(colon + 1);\r
 200                                                         user = user.substring(0, colon);\r
 201                                                 } else {\r
 202                                                         pass = env.getProperty(user);\r
 203                                                 }\r
 204                                                 \r
 205                                                 if (pass != null) {\r
 206                                                         pass = env.decrypt(pass, false);\r
 207                                                         env.setProperty(user, pass);\r
 208                                                         ss = new HBasicAuthSS(user, pass,(SecurityInfoC<HttpURLConnection>) si);\r
 209                                                         pw.println("as " + user);\r
 210                                                 } else { // get Pass from System Properties, under name of\r
 211                                                         // Tag\r
 212                                                         pw.println("ERROR: No password set for " + user);\r
 213                                                         rv = false;\r
 214                                                 }\r
 215                                                 continue;\r
 216                                         }\r
 217                                 } else if ("expect".equalsIgnoreCase(largs[idx])) {\r
 218                                         expect.clear();\r
 219                                         if (largs.length > idx++) {\r
 220                                                 if (!"nothing".equals(largs[idx])) {\r
 221                                                         for (String str : largs[idx].split(",")) {\r
 222                                                                 try {\r
 223                                                                         if ("Exception".equalsIgnoreCase(str)) {\r
 224                                                                                 expect.add(-1);\r
 225                                                                         } else {\r
 226                                                                                 expect.add(Integer.parseInt(str));\r
 227                                                                         }\r
 228                                                                 } catch (NumberFormatException e) {\r
 229                                                                         throw new CadiException("\"expect\" should be followed by Number");\r
 230                                                                 }\r
 231                                                         }\r
 232                                                 ++idx;\r
 233                                                 }\r
 234                                         }\r
 235                                         continue;\r
 236                                         // Sleep, typically for reports, to allow DB to update\r
 237                                         // Milliseconds\r
 238                                         \r
 239                                 } else if ("sleep".equalsIgnoreCase(largs[idx])) {\r
 240                                         Integer t = Integer.parseInt(largs[++idx]);\r
 241                                         pw.println("sleep " + t);\r
 242                                         Thread.sleep(t);\r
 243                                         ++idx;\r
 244                                         continue;\r
 245                                 } else if ("delay".equalsIgnoreCase(largs[idx])) {\r
 246                                         delay = Integer.parseInt(largs[++idx]);\r
 247                                         pw.println("delay " + delay);\r
 248                                         ++idx;\r
 249                                         continue;\r
 250                                 } else if ("pause".equalsIgnoreCase(largs[idx])) {\r
 251                                         pw.println("Press <Return> to continue...");\r
 252                                         ++idx;\r
 253                                         new BufferedReader(new InputStreamReader(System.in)).readLine();\r
 254                                         continue;\r
 255                                 } else if ("exit".equalsIgnoreCase(largs[idx])) {\r
 256                                         pw.println("Exiting...");\r
 257                                         return false;\r
 258                                 }\r
 259 \r
 260                         } \r
 261                         \r
 262                         if("REQUEST".equalsIgnoreCase(largs[idx])) {\r
 263                                 request=true;\r
 264                                 ++idx;\r
 265                         } else if("FORCE".equalsIgnoreCase(largs[idx])) {\r
 266                                 force="true";\r
 267                                 ++idx;\r
 268                         } else if ("set".equalsIgnoreCase(largs[idx])) {\r
 269                                 while (largs.length > ++idx) {\r
 270                                         int equals = largs[idx].indexOf('=');\r
 271                                         if (equals < 0) {\r
 272                                                 break;\r
 273                                         }\r
 274                                         String tag = largs[idx].substring(0, equals);\r
 275                                         String value = largs[idx].substring(++equals);\r
 276                                         pw.println("set " + tag + ' ' + value);\r
 277                                         boolean isTrue = "TRUE".equalsIgnoreCase(value);\r
 278                                         if("FORCE".equalsIgnoreCase(tag)) {\r
 279                                                 force = value;\r
 280                                         } else if("REQUEST".equalsIgnoreCase(tag)) {\r
 281                                                 request = isTrue;\r
 282                                         } else if("DETAILS".equalsIgnoreCase(tag)) {\r
 283                                                 showDetails = isTrue;\r
 284                                         } else {\r
 285                                                 env.setProperty(tag, value);\r
 286                                         }\r
 287                                 }\r
 288                                 continue;\r
 289                                 // Allow Script to indicate if Failure is what is expected\r
 290                         }\r
 291 \r
 292                         int ret = 0;\r
 293                         for (Cmd c : cmds) {\r
 294                                 if (largs[idx].equalsIgnoreCase(c.getName())) {\r
 295                                         if (verbose) {\r
 296                                                 pw.println(line);\r
 297                                                 if (expect.size() > 0) {\r
 298                                                         pw.print("** Expect ");\r
 299                                                         boolean first = true;\r
 300                                                         for (Integer i : expect) {\r
 301                                                                 if (first) {\r
 302                                                                         first = false;\r
 303                                                                 } else {\r
 304                                                                         pw.print(',');\r
 305                                                                 }\r
 306                                                                 pw.print(i);\r
 307                                                         }\r
 308                                                         pw.println(" **");\r
 309                                                 }\r
 310                                         }\r
 311                                         try {\r
 312                                                 ret = c.exec(++idx, largs);\r
 313                                                 if (delay+globalDelay > 0) {\r
 314                                                         Thread.sleep(delay+globalDelay);\r
 315                                                 }\r
 316                                         } catch (Exception e) {\r
 317                                                 if (expect.contains(-1)) {\r
 318                                                         pw.println(e.getMessage());\r
 319                                                         ret = -1;\r
 320                                                 } else {\r
 321                                                         throw e;\r
 322                                                 }\r
 323                                         } finally {\r
 324                                                 clearSingleLineProperties();\r
 325                                         }\r
 326                                         rv = expect.isEmpty() ? true : expect.contains(ret);\r
 327                                         if (verbose) {\r
 328                                                 if (rv) {\r
 329                                                         pw.println();\r
 330                                                 } else {\r
 331                                                         pw.print("!!! Unexpected Return Code: ");\r
 332                                                         pw.print(ret);\r
 333                                                         pw.println(", VALIDATE OUTPUT!!!");\r
 334                                                 }\r
 335                                         }\r
 336                                         return rv;\r
 337                                 }\r
 338                         }\r
 339                         pw.write("Unknown Instruction \"");\r
 340                         pw.write(largs[idx]);\r
 341                         pw.write("\"\n");\r
 342                         idx = largs.length;// always end after one command\r
 343                 }\r
 344                 return rv;\r
 345         }\r
 346 \r
 347         private String[] argEval(String line) {\r
 348                 StringBuilder sb = new StringBuilder();\r
 349                 ArrayList<String> arr = new ArrayList<String>();\r
 350                 boolean start = true;\r
 351                 char quote = 0;\r
 352                 for (int i = 0; i < line.length(); ++i) {\r
 353                         char ch;\r
 354                         if (Character.isWhitespace(ch = line.charAt(i))) {\r
 355                                 if (start) {\r
 356                                         continue; // trim\r
 357                                 } else if (quote != 0) {\r
 358                                         sb.append(ch);\r
 359                                 } else {\r
 360                                         arr.add(sb.toString());\r
 361                                         sb.setLength(0);\r
 362                                         start = true;\r
 363                                 }\r
 364                         } else if (ch == '\'' || ch == '"') { // toggle\r
 365                                 if (quote == ch) {\r
 366                                         quote = 0;\r
 367                                 } else {\r
 368                                         quote = ch;\r
 369                                 }\r
 370                         } else {\r
 371                                 start = false;\r
 372                                 sb.append(ch);\r
 373                         }\r
 374                 }\r
 375                 if (sb.length() > 0) {\r
 376                         arr.add(sb.toString());\r
 377                 }\r
 378 \r
 379                 String[] rv = new String[arr.size()];\r
 380                 arr.toArray(rv);\r
 381                 return rv;\r
 382         }\r
 383 \r
 384         public static void keyboardHelp() {\r
 385                 System.out.println("'C-' means hold the ctrl key down while pressing the next key.");\r
 386                 System.out.println("'M-' means hold the alt key down while pressing the next key.");\r
 387                 System.out.println("For instance, C-b means hold ctrl key and press b, M-b means hold alt and press b\n");\r
 388 \r
 389                 System.out.println("Basic Keybindings:");\r
 390                 System.out.println("\tC-l - clear screen");        \r
 391                 System.out.println("\tC-a - beginning of line");\r
 392                 System.out.println("\tC-e - end of line");\r
 393                 System.out.println("\tC-b - backward character (left arrow also works)");\r
 394                 System.out.println("\tM-b - backward word");\r
 395                 System.out.println("\tC-f - forward character (right arrow also works)");\r
 396                 System.out.println("\tM-f - forward word");\r
 397                 System.out.println("\tC-d - delete character under cursor");\r
 398                 System.out.println("\tM-d - delete word forward");\r
 399                 System.out.println("\tM-backspace - delete word backward");\r
 400                 System.out.println("\tC-k - delete from cursor to end of line");\r
 401                 System.out.println("\tC-u - delete entire line, regardless of cursor position\n");\r
 402 \r
 403                 System.out.println("Command History:");\r
 404                 System.out.println("\tC-r - search backward in history (repeating C-r continues the search)");\r
 405                 System.out.println("\tC-p - move backwards through history (up arrow also works)");\r
 406                 System.out.println("\tC-n - move forwards through history (down arrow also works)\n");\r
 407 \r
 408         }\r
 409 \r
 410         /**\r
 411          * @param args\r
 412          */\r
 413         public static void main(String[] args) {\r
 414                 int rv = 0;\r
 415                 // Cover for bash's need to escape *... (\\*)\r
 416                 for (int i = 0; i < args.length; ++i) {\r
 417                         if ("\\*".equals(args[i])) {\r
 418                                 args[i] = "*";\r
 419                         }\r
 420                 }\r
 421                 \r
 422                 System.setProperty("java.util.logging.config.file", "etc/logging.props");\r
 423                 final AuthzEnv env = new AuthzEnv(System.getProperties());\r
 424                 \r
 425                 // Stop the (exceedingly annoying) DME2/other logs from printing console\r
 426                 InputStream is;\r
 427 \r
 428                 // Load Log4j too... sigh\r
 429                 is = ClassLoader.getSystemResourceAsStream("log4j.properties");\r
 430                 if(is==null) {\r
 431                         env.log(Level.WARN, "Cannot find 'log4j.properties' in Classpath.  Best option: add 'etc' directory to classpath");\r
 432                 } else {\r
 433                         try {\r
 434                                 Properties props = new Properties();\r
 435                                 props.load(is);\r
 436                                 PropertyConfigurator.configure(props);\r
 437                         } catch (Exception e) {\r
 438                                 e.printStackTrace();\r
 439                         } finally {\r
 440                                 try {\r
 441                                         is.close();\r
 442                                 } catch (IOException e) {\r
 443                                         env.debug().log(e); // only logging to avoid Sonar False positives.\r
 444                                 }\r
 445                         }\r
 446                 }\r
 447 \r
 448                 env.loadFromSystemPropsStartsWith("AFT", "DME2", "aaf", "keyfile");\r
 449                 try {\r
 450                         Log4JLogTarget.setLog4JEnv("aaf", env);\r
 451                         GetProp gp = new GetProp(env);\r
 452                         String user = gp.get(false,Config.AAF_MECHID,"fully qualified id");\r
 453                         String pass = gp.get(true, Config.AAF_MECHPASS, "password is hidden");\r
 454                         if(env.getProperty(Config.AAF_URL)==null) {\r
 455                                 String p = env.getProperty("DMEServiceName");\r
 456                                 if(p!=null) {\r
 457                                         boolean https = "true".equalsIgnoreCase(env.getProperty("AFT_DME2_SSL_ENABLE"));\r
 458                                         env.setProperty(Config.AAF_URL, "http"+(https?"s":"")+"://DME2RESOLVE/"+p);\r
 459                                 }\r
 460                         }\r
 461                         String aafUrl = gp.get(false, Config.AAF_URL, "https://DME2RESOLVE or Direct URL:port");\r
 462 \r
 463                         if(aafUrl!=null && aafUrl.contains("//DME2")) {\r
 464                                 //gp.set(Config.AFT_LATITUDE,"Lookup from a Map App or table");\r
 465                                 //gp.set(Config.AFT_LONGITUDE,"Lookup from a Map App or table");\r
 466                                 //gp.set(Config.AFT_ENVIRONMENT,"Check DME2 Installations");\r
 467                         }\r
 468 \r
 469                         if (gp.err() != null) {\r
 470                                 gp.err().append("to continue...");\r
 471                                 System.err.println(gp.err());\r
 472                                 System.exit(1);\r
 473                         }\r
 474                         \r
 475 \r
 476                         Reader rdr = null;\r
 477                         boolean exitOnFailure = true;\r
 478                         /*\r
 479                          * Check for "-" options anywhere in command line\r
 480                          */\r
 481                         StringBuilder sb = new StringBuilder();\r
 482                         for (int i = 0; i < args.length; ++i) {\r
 483                                 if ("-i".equalsIgnoreCase(args[i])) {\r
 484                                         rdr = new InputStreamReader(System.in);\r
 485                                         // } else if("-o".equalsIgnoreCase(args[i])) {\r
 486                                         // // shall we do something different? Output stream is\r
 487                                         // already done...\r
 488                                 } else if ("-f".equalsIgnoreCase(args[i])) {\r
 489                                         if (args.length > i + 1) {\r
 490                                                 rdr = new FileReader(args[++i]);\r
 491                                         }\r
 492                                 } else if ("-a".equalsIgnoreCase(args[i])) {\r
 493                                         exitOnFailure = false;\r
 494                                 } else if ("-c".equalsIgnoreCase(args[i])) {\r
 495                                         isConsole = true;\r
 496                                 } else if ("-s".equalsIgnoreCase(args[i]) && args.length > i + 1) {\r
 497                                         env.setProperty(Cmd.STARTDATE, args[++i]);\r
 498                                 } else if ("-e".equalsIgnoreCase(args[i]) && args.length > i + 1) {\r
 499                                         env.setProperty(Cmd.ENDDATE, args[++i]);\r
 500                                 } else if ("-t".equalsIgnoreCase(args[i])) {\r
 501                                         isTest = true;\r
 502                                 } else if ("-d".equalsIgnoreCase(args[i])) {\r
 503                                         showDetails = true;\r
 504                                 } else if ("-n".equalsIgnoreCase(args[i])) {\r
 505                                         ignoreDelay = true;\r
 506                                 } else {\r
 507                                         if (sb.length() > 0) {\r
 508                                                 sb.append(' ');\r
 509                                         }\r
 510                                         sb.append(args[i]);\r
 511                                 }\r
 512                         }\r
 513 \r
 514                         SecurityInfo si = new SecurityInfo(env);\r
 515                         env.loadToSystemPropsStartsWith("AAF", "DME2");\r
 516                         Locator loc;\r
 517                         if(aafUrl.contains("//DME2RESOLVE")) {\r
 518                                 DME2Manager dm = new DME2Manager("AAFcli DME2Manager", System.getProperties());\r
 519                                 loc = new DME2Locator(env, dm, aafUrl);\r
 520                         } else {\r
 521                                 loc = new PropertyLocator(aafUrl);\r
 522                         }\r
 523 \r
 524                         //Config.configPropFiles(new AccessGetter(env), env);\r
 525                         \r
 526                         TIMEOUT = Integer.parseInt(env.getProperty(Config.AAF_CONN_TIMEOUT, Config.AAF_CONN_TIMEOUT_DEF));\r
 527                         HMangr hman = new HMangr(env, loc).readTimeout(TIMEOUT).apiVersion("2.0");\r
 528                         \r
 529                         //TODO: Consider requiring a default in properties\r
 530                         env.setProperty(Config.AAF_DEFAULT_REALM, System.getProperty(Config.AAF_DEFAULT_REALM,Config.getDefaultRealm()));\r
 531 \r
 532                         AAFcli aafcli = new AAFcli(env, new OutputStreamWriter(System.out), hman, si, \r
 533                                 new HBasicAuthSS(user, env.decrypt(pass,false), (SecurityInfoC<HttpURLConnection>) si));\r
 534                         if(!ignoreDelay) {\r
 535                                 File delay = new File("aafcli.delay");\r
 536                                 if(delay.exists()) {\r
 537                                         BufferedReader br = new BufferedReader(new FileReader(delay));\r
 538                                         try {\r
 539                                                 globalDelay = Integer.parseInt(br.readLine());\r
 540                                         } catch(Exception e) {\r
 541                                                 env.debug().log(e);\r
 542                                         } finally {\r
 543                                                 br.close();\r
 544                                         }\r
 545                                 }\r
 546                         }\r
 547                         try {\r
 548                                 if (isConsole) {\r
 549                                         System.out.println("Type 'help' for short help or 'help -d' for detailed help with aafcli commands");\r
 550                                         System.out.println("Type '?' for help with command line editing");\r
 551                                         System.out.println("Type 'q', 'quit', or 'exit' to quit aafcli\n");\r
 552 \r
 553                                         ConsoleReader reader = new ConsoleReader();\r
 554                                         try {\r
 555                                                 reader.setPrompt("aafcli > ");\r
 556         \r
 557                                                 String line;\r
 558                                                 while ((line = reader.readLine()) != null) {\r
 559                                                         showDetails = (line.contains("-d"))?true:false;\r
 560         \r
 561                                                         if (line.equalsIgnoreCase("quit") || line.equalsIgnoreCase("q") || line.equalsIgnoreCase("exit")) {\r
 562                                                                 break;\r
 563                                                         } else if (line.equalsIgnoreCase("--help -d") || line.equalsIgnoreCase("help -d") \r
 564                                                                         || line.equalsIgnoreCase("help")) {\r
 565                                                                 line = "--help";\r
 566                                                         } else if (line.equalsIgnoreCase("cls")) {\r
 567                                                                 reader.clearScreen();\r
 568                                                                 continue;\r
 569                                                         } else if (line.equalsIgnoreCase("?")) {\r
 570                                                                 keyboardHelp();\r
 571                                                                 continue;\r
 572                                                         }\r
 573                                                         try {\r
 574                                                                 aafcli.eval(line);\r
 575                                                                 pw.flush();\r
 576                                                         } catch (Exception e) {\r
 577                                                                 pw.println(e.getMessage());\r
 578                                                                 pw.flush();\r
 579                                                         }\r
 580                                                 }\r
 581                                         } finally {\r
 582                                                 reader.close();\r
 583                                         }\r
 584                                 } else if (rdr != null) {\r
 585                                         BufferedReader br = new BufferedReader(rdr);\r
 586                                         String line;\r
 587                                         while ((line = br.readLine()) != null) {\r
 588                                                 if (!aafcli.eval(line) && exitOnFailure) {\r
 589                                                         rv = 1;\r
 590                                                         break;\r
 591                                                 }\r
 592                                         }\r
 593                                 } else { // just run the command line\r
 594                                         aafcli.verbose(false);\r
 595                                         if (sb.length() == 0) {\r
 596                                                 sb.append("--help");\r
 597                                         }\r
 598                                         rv = aafcli.eval(sb.toString()) ? 0 : 1;\r
 599                                 }\r
 600                         } finally {\r
 601                                 aafcli.close();\r
 602 \r
 603                                 // Don't close if No Reader, or it's a Reader of Standard In\r
 604                                 if (rdr != null && !(rdr instanceof InputStreamReader)) {\r
 605                                         rdr.close();\r
 606                                 }\r
 607                         }\r
 608                 } catch (MessageException e) {\r
 609                         System.out.println("MessageException caught");\r
 610 \r
 611                         System.err.println(e.getMessage());\r
 612                 } catch (Exception e) {\r
 613                         e.printStackTrace(System.err);\r
 614                 }\r
 615                 System.exit(rv);\r
 616 \r
 617         }\r
 618 \r
 619         private static class GetProp {\r
 620                 private Console cons = System.console();\r
 621                 private StringBuilder err = null;\r
 622                 private AuthzEnv env;\r
 623                 \r
 624                 public GetProp(AuthzEnv env) {\r
 625                         this.env = env;\r
 626                 }\r
 627 \r
 628                 public String get(final boolean pass, final String tag, final String other)  {\r
 629                         String data = env.getProperty(tag,null);\r
 630                         if (data == null) {\r
 631                                 if(cons!=null) {\r
 632                                         if(pass) {\r
 633                                                 char[] cp = System.console().readPassword("%s: ",tag);\r
 634                                                 if(cp!=null) {\r
 635                                                         data=String.valueOf(cp);\r
 636                                                 }\r
 637                                         } else {\r
 638                                                 cons.writer().format("%s: ", tag);\r
 639                                                 cons.flush();\r
 640                                                 data = cons.readLine();\r
 641                                         }\r
 642                                 }\r
 643                                 if(data==null) {\r
 644                                         if(err == null) {\r
 645                                                 err  = new StringBuilder("Add -D");\r
 646                                         } else {\r
 647                                                 err.append(", -D");\r
 648                                         }\r
 649                                         err.append(tag);\r
 650                                         if(other!=null) {\r
 651                                                 err.append("=<");\r
 652                                                 err.append(other);\r
 653                                                 err.append('>');\r
 654                                         }\r
 655                                 }\r
 656                         }\r
 657                         return data;\r
 658                 }\r
 659                 \r
 660                 public void set(final String tag, final String other)  {\r
 661                         String data = env.getProperty(tag,null);\r
 662                         if (data == null) {\r
 663                                 if(cons!=null) {\r
 664                                         cons.writer().format("%s: ", tag);\r
 665                                         cons.flush();\r
 666                                         data = cons.readLine();\r
 667                                 }\r
 668                                 if(data==null) {\r
 669                                         if(err == null) {\r
 670                                                 err  = new StringBuilder("Add -D");\r
 671                                         } else {\r
 672                                                 err.append(", -D");\r
 673                                         }\r
 674                                         err.append(tag);\r
 675                                         if(other!=null) {\r
 676                                                 err.append("=<");\r
 677                                                 err.append(other);\r
 678                                                 err.append('>');\r
 679                                         }\r
 680                                 }\r
 681                         }\r
 682                         if(data!=null) {\r
 683                                 System.setProperty(tag, data);\r
 684                         }\r
 685                 }\r
 686 \r
 687                 public StringBuilder err() {\r
 688                         return err;\r
 689                 }\r
 690         }\r
 691 \r
 692         public boolean isTest() {\r
 693                 return AAFcli.isTest;\r
 694         }\r
 695         \r
 696         public boolean isDetailed() {\r
 697                 return AAFcli.showDetails;\r
 698         }\r
 699 \r
 700         public String typeString(Class<?> cls, boolean json) {\r
 701                 return "application/" + cls.getSimpleName() + "+" + (json ? "json" : "xml") + ";version=" + hman.apiVersion();\r
 702         }\r
 703 \r
 704         public String forceString() {\r
 705                 return force;\r
 706         }\r
 707 \r
 708         public boolean addRequest() {\r
 709                 return request;\r
 710         }\r
 711 \r
 712         public void clearSingleLineProperties() {\r
 713                 force  = null;\r
 714                 request = false;\r
 715                 showDetails = false;\r
 716         }\r
 717 \r
 718         public void gui(boolean b) {\r
 719                 gui  = b;\r
 720         }\r
 721 \r
 722 }\r