Another option for our rest service. Need to choose between the two.

symmetric-server/src/main/java/org/jumpmind/symmetric/web/rest/RestService2.java

@@ -0,0 +1,224 @@
+package org.jumpmind.symmetric.web.rest;
+
+import java.lang.annotation.Annotation;
+import java.util.Set;
+
+import javax.servlet.ServletContext;
+import javax.servlet.http.HttpServletRequest;
+
+import org.jumpmind.symmetric.ISymmetricEngine;
+import org.jumpmind.symmetric.web.SymmetricEngineHolder;
+import org.jumpmind.symmetric.web.WebConstants;
+import org.jumpmind.symmetric.web.rest.model.ChannelStatus;
+import org.jumpmind.symmetric.web.rest.model.Engine;
+import org.jumpmind.symmetric.web.rest.model.Identity;
+import org.jumpmind.symmetric.web.rest.model.NodeStatus;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.ResponseStatus;
+import org.springframework.web.multipart.MultipartFile;
+
+@Controller
+public class RestService2 {
+
+    @Autowired
+    ServletContext context;
+
+    /**
+     * Returns the list of engine names that are configured on the node.   
+     * @return Set<{@link Engine> of engine names configured on the node
+     */
+    @RequestMapping(value = "/engine", method = RequestMethod.GET)
+    @ResponseBody
+    public final Set<Engine> engine() {
+    	//TODO:implement
+        //return getSymmetricEngineHolder().getEngines().keySet();
+    	return null;
+    }
+
+    /**
+     * Returns the identity for the single engine on the node.
+     * If more than one engine exists on the node, service will 
+     * return an HTTP Status Code 405 (Method Not Allowed)
+     * @return Identity the identity of the engine
+     */
+    @RequestMapping(value = "/identity", method = RequestMethod.GET)
+    @ResponseBody
+    public final Identity identity(@RequestParam("engine") String engineName) {
+    	//TODO:implement
+        //ISymmetricEngine engine = getSymmetricEngine(engineName);
+        //return engine.getNodeService().findIdentityNodeId();
+    	return null;
+    }
+
+    /**
+     * Loads a profile for the specified engine on the node. 
+     * @param engineName 
+     */
+    @RequestMapping(value = "profile", method = RequestMethod.POST)
+    @ResponseBody
+    //TODO: figure out how we will pass the file info...
+    public final void loadProfile(@RequestParam("engine") String engineName, @RequestParam MultipartFile file) {
+        System.out.println("File '" + file.getOriginalFilename() + "' uploaded successfully");
+    }
+
+    /**
+     * Drops SymmetricDS triggers for the specified engine and table on the node.
+     * @param engineName
+     * @param tableName
+     */
+    @RequestMapping(value = "/tables/{table}/trigger", method = RequestMethod.DELETE)
+    @ResponseBody
+    public final void dropTrigger(@RequestParam("engine") String engineName,
+                    @PathVariable("table") String tableName) {
+            //TODO: Implementation
+    }
+
+    /**
+     * Drops all SymmetricDS triggers for the specified engine on the node.
+     * @param engineName
+     */
+    @RequestMapping(value = "/trigger", method = RequestMethod.DELETE)
+    @ResponseBody
+    public final void dropTrigger(@PathVariable("engine") String engineName) {
+            //TODO: Implementation
+    }
+
+    /**
+     * Creates SymmetricDS triggers for the specified engine and table on the node.
+     * @param engineName
+     * @param tableName
+     */
+    @RequestMapping(value = "/tables/{table}/trigger", method = RequestMethod.POST)
+    @ResponseBody
+    public final void syncTrigger(@RequestParam("engine") String engineName,
+                    @PathVariable("table") String tableName) {
+            //TODO: Implementation
+    }
+
+    /**
+     * Creates SymmetricDS triggers for all configured tables on the specified engine on the node.
+     * @param engineName
+     */
+    @RequestMapping(value = "/trigger", method = RequestMethod.POST)
+    @ResponseBody
+    public final void syncTrigger(@RequestParam("engine") String engineName) {
+            //TODO: Implementation
+    }    
+
+    /**
+     * Reinitializes the specified engine on the node.  This includes:
+     * <ul>
+     * <li>Uninstalling all SymmetricDS objects from the database</li>
+     * <li>Reregistering the node</li>
+     * <li>Initial load (if configured)</li>
+     * <li>Reverse initial load (if configured)</li>
+     * </ul>
+     * @param engineName
+     */
+    @RequestMapping(value = "/reinitialize/engines/{engine}", method = RequestMethod.POST)
+    @ResponseBody
+    public final void initialize(@PathVariable("engine") String engineName) {
+            //TODO: Implementation
+    }
+
+    /**
+     * Returns an overall status for the specified engine of the node.
+     * @param engineName
+     * @return {@link NodeStatus}
+     */
+    @RequestMapping(value = "/engines/{engine}/node/status", method = RequestMethod.GET)
+    @ResponseBody
+    public final NodeStatus nodeStatus(@PathVariable("engine") String engineName) {
+            //TODO: Implementation
+            return new NodeStatus();
+    }
+
+    /**
+     * Returns status of each channel for the specified engine of the node.
+     * @param engineName
+     * @return Set<{@link ChannelStatus}>
+     */    
+    @RequestMapping(value = "/engines/{engine}/channel/status", method = RequestMethod.GET)
+    @ResponseBody
+    public final Set<ChannelStatus> channelStatus(@PathVariable("engine") String engineName) {
+            throw new RuntimeException("Test");
+    }
+
+    /**
+     * Uninstalls all SymmetricDS objects from the database for the specified engine of the node.
+     * @param engineName
+     */
+    @RequestMapping(value = "/engines/{engine}", method = RequestMethod.DELETE)
+    @ResponseBody
+    public final void unintstall(@PathVariable("engine") String engineName) {
+            //TODO: Implementation
+    }
+
+    /**
+     * Starts SymmetricDS for the node.
+     */
+    @RequestMapping(value = "/start", method = RequestMethod.POST)
+    @ResponseBody
+    public final void start() {
+            //TODO: Implementation
+    }
+
+    /**
+     * Stops SymmetricDS for the node.
+     */
+    @RequestMapping(value = "/stop", method = RequestMethod.POST)
+    @ResponseBody
+    public final void stop() {
+            //TODO: Implementation
+    }
+
+    /**
+     * Refreshes the cache for the node.
+     */
+    @RequestMapping(value = "/cache", method = RequestMethod.PUT)
+    @ResponseBody
+    public final void refreshCache() {
+            //TODO: Implementation
+    }
+
+    //TODO: reloadtable
+    //TODO: reloadnode
+
+    @ExceptionHandler(Exception.class)
+    @ResponseBody
+    public RestError handleError(Exception ex, HttpServletRequest req) {
+        int httpErrorCode = 500;
+        Annotation annotation = ex.getClass().getAnnotation(ResponseStatus.class);
+        if (annotation != null) {
+           httpErrorCode = ((ResponseStatus)annotation).value().value();
+        }
+        return new RestError(ex, httpErrorCode);
+    }
+
+    protected SymmetricEngineHolder getSymmetricEngineHolder() {
+        SymmetricEngineHolder holder = (SymmetricEngineHolder) context
+                .getAttribute(WebConstants.ATTR_ENGINE_HOLDER);
+        if (holder == null) {
+            throw new NotFoundException();
+        }
+        return holder;
+    }
+
+    protected ISymmetricEngine getSymmetricEngine(String engineName) {
+        SymmetricEngineHolder holder = getSymmetricEngineHolder();
+        ISymmetricEngine engine = holder.getEngines().get(engineName);
+        if (engine == null) {
+            throw new NotFoundException();
+        } else {
+            return engine;
+        }
+    }
+
+}