| | |
|---|
| | | package org.openmuc.openiec61850.internal.cli; |
|---|
| | | |
|---|
| | | import static java.lang.System.exit; |
|---|
| | | import static java.lang.System.out; |
|---|
| | | |
|---|
| | | import java.io.BufferedReader; |
|---|
| | | import java.io.IOException; |
|---|
| | | import java.io.InputStreamReader; |
|---|
| | | import java.util.LinkedHashMap; |
|---|
| | | import java.util.Map; |
|---|
| | | |
|---|
| | | public class ActionProcessor { |
|---|
| | | |
|---|
| | | private static final String SEPARATOR_LINE = "------------------------------------------------------"; |
|---|
| | | |
|---|
| | | private final BufferedReader reader; |
|---|
| | | private final ActionListener actionListener; |
|---|
| | | private volatile boolean closed = false; |
|---|
| | | |
|---|
| | | private final Map<String, Action> actionMap = new LinkedHashMap<>(); |
|---|
| | | |
|---|
| | | private final Action helpAction = new Action("h", "print help message"); |
|---|
| | | private final Action quitAction = new Action("q", "quit the application"); |
|---|
| | | |
|---|
| | | public ActionProcessor(ActionListener actionListener) { |
|---|
| | | reader = new BufferedReader(new InputStreamReader(System.in)); |
|---|
| | | this.actionListener = actionListener; |
|---|
| | | } |
|---|
| | | |
|---|
| | | public void addAction(Action action) { |
|---|
| | | actionMap.put(action.getKey(), action); |
|---|
| | | } |
|---|
| | | |
|---|
| | | public BufferedReader getReader() { |
|---|
| | | return reader; |
|---|
| | | } |
|---|
| | | |
|---|
| | | public void start() { |
|---|
| | | |
|---|
| | | actionMap.put(helpAction.getKey(), helpAction); |
|---|
| | | actionMap.put(quitAction.getKey(), quitAction); |
|---|
| | | |
|---|
| | | printHelp(); |
|---|
| | | |
|---|
| | | try { |
|---|
| | | |
|---|
| | | String actionKey; |
|---|
| | | while (true) { |
|---|
| | | |
|---|
| | | if (closed) { |
|---|
| | | exit(1); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | System.out.println("\n** Enter action key: "); |
|---|
| | | |
|---|
| | | try { |
|---|
| | | actionKey = reader.readLine(); |
|---|
| | | } catch (IOException e) { |
|---|
| | | System.err.printf("%s. Application is being shut down.\n", e.getMessage()); |
|---|
| | | exit(2); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (closed) { |
|---|
| | | exit(1); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (actionMap.get(actionKey) == null) { |
|---|
| | | System.err.println("Illegal action key.\n"); |
|---|
| | | printHelp(); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (actionKey.equals(helpAction.getKey())) { |
|---|
| | | printHelp(); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (actionKey.equals(quitAction.getKey())) { |
|---|
| | | actionListener.quit(); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | try { |
|---|
| | | actionListener.actionCalled(actionKey); |
|---|
| | | } catch (ActionException e) { |
|---|
| | | System.err.println(e.getMessage() + "\n"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | } catch (Exception e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | actionListener.quit(); |
|---|
| | | } finally { |
|---|
| | | close(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | private void printHelp() { |
|---|
| | | final String message = " %s - %s\n"; |
|---|
| | | out.flush(); |
|---|
| | | out.println(); |
|---|
| | | out.println(SEPARATOR_LINE); |
|---|
| | | |
|---|
| | | for (Action action : actionMap.values()) { |
|---|
| | | out.printf(message, action.getKey(), action.getDescription()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | out.println(SEPARATOR_LINE); |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | public void close() { |
|---|
| | | closed = true; |
|---|
| | | try { |
|---|
| | | reader.close(); |
|---|
| | | } catch (IOException e) { |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | package org.openmuc.openiec61850.internal.cli;
|
|---|
| | |
|
|---|
| | | import static java.lang.System.exit;
|
|---|
| | | import static java.lang.System.out;
|
|---|
| | |
|
|---|
| | | import java.io.BufferedReader;
|
|---|
| | | import java.io.IOException;
|
|---|
| | | import java.io.InputStreamReader;
|
|---|
| | | import java.util.LinkedHashMap;
|
|---|
| | | import java.util.Map;
|
|---|
| | |
|
|---|
| | | public class ActionProcessor {
|
|---|
| | |
|
|---|
| | | private static final String SEPARATOR_LINE = "------------------------------------------------------";
|
|---|
| | |
|
|---|
| | | private final BufferedReader reader;
|
|---|
| | | private final ActionListener actionListener;
|
|---|
| | | private volatile boolean closed = false;
|
|---|
| | |
|
|---|
| | | private final Map<String, Action> actionMap = new LinkedHashMap<>();
|
|---|
| | |
|
|---|
| | | private final Action helpAction = new Action("h", "print help message");
|
|---|
| | | private final Action quitAction = new Action("q", "quit the application");
|
|---|
| | |
|
|---|
| | | public ActionProcessor(ActionListener actionListener) {
|
|---|
| | | reader = new BufferedReader(new InputStreamReader(System.in));
|
|---|
| | | this.actionListener = actionListener;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public void addAction(Action action) {
|
|---|
| | | actionMap.put(action.getKey(), action);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public BufferedReader getReader() {
|
|---|
| | | return reader;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public void start() {
|
|---|
| | |
|
|---|
| | | actionMap.put(helpAction.getKey(), helpAction);
|
|---|
| | | actionMap.put(quitAction.getKey(), quitAction);
|
|---|
| | |
|
|---|
| | | printHelp();
|
|---|
| | |
|
|---|
| | | try {
|
|---|
| | |
|
|---|
| | | String actionKey;
|
|---|
| | | while (true) {
|
|---|
| | |
|
|---|
| | | if (closed) {
|
|---|
| | | exit(1);
|
|---|
| | | return;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | System.out.println("\n** Enter action key: ");
|
|---|
| | |
|
|---|
| | | try {
|
|---|
| | | actionKey = reader.readLine();
|
|---|
| | | } catch (IOException e) {
|
|---|
| | | System.err.printf("%s. Application is being shut down.\n", e.getMessage());
|
|---|
| | | exit(2);
|
|---|
| | | return;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | if (closed) {
|
|---|
| | | exit(1);
|
|---|
| | | return;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | if (actionMap.get(actionKey) == null) {
|
|---|
| | | System.err.println("Illegal action key.\n");
|
|---|
| | | printHelp();
|
|---|
| | | continue;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | if (actionKey.equals(helpAction.getKey())) {
|
|---|
| | | printHelp();
|
|---|
| | | continue;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | if (actionKey.equals(quitAction.getKey())) {
|
|---|
| | | actionListener.quit();
|
|---|
| | | return;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | try {
|
|---|
| | | actionListener.actionCalled(actionKey);
|
|---|
| | | } catch (ActionException e) {
|
|---|
| | | System.err.println(e.getMessage() + "\n");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | actionListener.quit();
|
|---|
| | | } finally {
|
|---|
| | | close();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | private void printHelp() {
|
|---|
| | | final String message = " %s - %s\n";
|
|---|
| | | out.flush();
|
|---|
| | | out.println();
|
|---|
| | | out.println(SEPARATOR_LINE);
|
|---|
| | |
|
|---|
| | | for (Action action : actionMap.values()) {
|
|---|
| | | out.printf(message, action.getKey(), action.getDescription());
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | out.println(SEPARATOR_LINE);
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public void close() {
|
|---|
| | | closed = true;
|
|---|
| | | try {
|
|---|
| | | reader.close();
|
|---|
| | | } catch (IOException e) {
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
