1 files changed, 207 insertions, 0 deletions
diff --git a/client/client-full/src/main/java/org/onap/policy/apex/client/full/rest/ApexServicesRestMain.java b/client/client-full/src/main/java/org/onap/policy/apex/client/full/rest/ApexServicesRestMain.java
new file mode 100644
index 000000000..a9e5db9d0
--- /dev/null
+++ b/client/client-full/src/main/java/org/onap/policy/apex/client/full/rest/ApexServicesRestMain.java
@@ -0,0 +1,207 @@
+/*-
+ * ============LICENSE_START=======================================================
+ *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
+ * ================================================================================
+ * 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.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.apex.client.full.rest;
+
+import java.io.PrintStream;
+
+/**
+ * This class is the main class that is used to launch the Apex editor from the command line.
+ *
+ */
+public class ApexServicesRestMain {
+    /**
+     * The Enum EditorState holds the current state of the editor.
+     */
+    // Editor state
+    public enum EditorState {
+        /** The editor is stopped. */
+        STOPPED,
+        /** The editor is ready to run. */
+        READY,
+        /** The editor is getting ready to run. */
+        INITIALIZING,
+        /** The editor is running. */
+        RUNNING
+    };
+
+    private static final int EDITOR_RNNING_CHECK_TIMEOUT = 1000;
+
+    private EditorState state = EditorState.STOPPED;
+
+    // The Apex editor this class is running
+    private ApexServicesRest apexServices = null;
+
+    // The parameters for the editor
+    private ApexServicesRestParameters parameters = null;
+
+    // Output and error streams for messages
+    private final PrintStream outStream;
+
+    /**
+     * Main method, main entry point for command.
+     *
+     * @param args The command line arguments for the editor
+     */
+    public static void main(final String[] args) {
+        try {
+            final ApexServicesRestMain editorMain = new ApexServicesRestMain(args, System.out);
+            editorMain.init();
+        } catch (final Exception e) {
+            System.err.println(e.getMessage());
+        }
+    }
+
+    /**
+     * Constructor, kicks off the editor.
+     *
+     * @param args The command line arguments for the editor
+     * @param outStream The stream for output messages
+     */
+    public ApexServicesRestMain(final String[] args, final PrintStream outStream) {
+        // Save the streams for output and error
+        this.outStream = outStream;
+
+        // Editor parameter parsing
+        final ApexServicesRestParameterParser parser = new ApexServicesRestParameterParser();
+
+        try {
+            // Get and check the parameters
+            parameters = parser.parse(args);
+        } catch (final ApexServicesRestParameterException e) {
+            throw new ApexServicesRestParameterException(
+                    "Apex Editor REST endpoint (" + this.toString() + ") parameter error, " + e.getMessage() + '\n'
+                            + parser.getHelp(ApexServicesRestMain.class.getCanonicalName()));
+        }
+
+        if (parameters.isHelpSet()) {
+            throw new ApexServicesRestParameterException(parser.getHelp(ApexServicesRestMain.class.getCanonicalName()));
+        }
+
+        // Validate the parameters
+        final String validationMessage = parameters.validate();
+        if (validationMessage.length() > 0) {
+            throw new ApexServicesRestParameterException(
+                    "Apex Editor REST endpoint (" + this.toString() + ") parameters invalid, " + validationMessage
+                            + '\n' + parser.getHelp(ApexServicesRestMain.class.getCanonicalName()));
+        }
+
+        state = EditorState.READY;
+    }
+
+    /**
+     * Initialize the Apex editor.
+     */
+    public void init() {
+        outStream.println("Apex Editor REST endpoint (" + this.toString() + ") starting at "
+                + parameters.getBaseURI().toString() + " . . .");
+
+        try {
+            state = EditorState.INITIALIZING;
+
+            // Start the editor
+            apexServices = new ApexServicesRest(parameters);
+
+            // Add a shutdown hook to shut down the editor when the process is exiting
+            Runtime.getRuntime().addShutdownHook(new Thread(new ApexServicesRestShutdownHook()));
+
+            state = EditorState.RUNNING;
+
+            if (parameters.getTimeToLive() == ApexServicesRestParameters.INFINITY_TIME_TO_LIVE) {
+                outStream.println("Apex Editor REST endpoint (" + this.toString() + ") started at "
+                        + parameters.getBaseURI().toString());
+            } else {
+                outStream.println("Apex Editor REST endpoint (" + this.toString() + ") started");
+            }
+
+            // Find out how long is left to wait
+            long timeRemaining = parameters.getTimeToLive();
+            while (timeRemaining == ApexServicesRestParameters.INFINITY_TIME_TO_LIVE || timeRemaining > 0) {
+                // decrement the time to live in the non-infinity case
+                if (timeRemaining > 0) {
+                    timeRemaining--;
+                }
+
+                // Wait for a second
+                Thread.sleep(EDITOR_RNNING_CHECK_TIMEOUT);
+            }
+        } catch (final Exception e) {
+            outStream.println(
+                    "Apex Editor REST endpoint (" + this.toString() + ") failed at with error: " + e.getMessage());
+        } finally {
+            if (apexServices != null) {
+                apexServices.shutdown();
+                apexServices = null;
+            }
+            state = EditorState.STOPPED;
+        }
+    }
+
+    /**
+     * Get the editor state.
+     *
+     * @return the state
+     */
+    public EditorState getState() {
+        return state;
+    }
+
+    /*
+     * (non-Javadoc)
+     *
+     * @see java.lang.Object#toString()
+     */
+    @Override
+    public String toString() {
+        final StringBuilder ret = new StringBuilder();
+        ret.append(this.getClass().getSimpleName()).append(": Config=[").append(parameters).append("], State=")
+                .append(this.getState());
+        return ret.toString();
+    }
+
+    /**
+     * Explicitly shut down the editor.
+     */
+    public void shutdown() {
+        if (apexServices != null) {
+            outStream.println("Apex Editor REST endpoint (" + this.toString() + ") shutting down");
+            apexServices.shutdown();
+        }
+        state = EditorState.STOPPED;
+        outStream.println("Apex Editor REST endpoint (" + this.toString() + ") shut down");
+    }
+
+    /**
+     * This class is a shutdown hook for the Apex editor command.
+     */
+    private class ApexServicesRestShutdownHook implements Runnable {
+        /*
+         * (non-Javadoc)
+         *
+         * @see java.lang.Runnable#run()
+         */
+        @Override
+        public void run() {
+            if (apexServices != null) {
+                apexServices.shutdown();
+            }
+        }
+    }
+}