X-Git-Url: https://gerrit.akraino.org/r/gitweb?a=blobdiff_plain;f=example-apps%2FROBO%2Fbackup_BE%2Fsrc%2Fmain%2Fjava%2Forg%2Fedgegallery%2Fexample_app%2Futil%2FShellCommand.java;h=716e5283122742a039e4f430e95ae7dd87532114;hb=e6d40ddb2640f434a9d7d7ed99566e5e8fa60cc1;hp=cc53aa5e6fe0e9b4af74004b19d337e777496bc7;hpb=90720a02fb3c8cc388c82eee0971173c3087ca38;p=ealt-edge.git

diff --git a/example-apps/ROBO/backup_BE/src/main/java/org/edgegallery/example_app/util/ShellCommand.java b/example-apps/ROBO/backup_BE/src/main/java/org/edgegallery/example_app/util/ShellCommand.java
index cc53aa5..716e528 100644
--- a/example-apps/ROBO/backup_BE/src/main/java/org/edgegallery/example_app/util/ShellCommand.java
+++ b/example-apps/ROBO/backup_BE/src/main/java/org/edgegallery/example_app/util/ShellCommand.java
@@ -1,20 +1,54 @@
 package org.edgegallery.example_app.util;
 
 import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.LinkedList;
 import java.util.List;
+import java.util.StringTokenizer;
+
+import org.apache.commons.lang.StringUtils;
+import org.edgegallery.example_app.model.EALTEdgeBackup;
+import org.edgegallery.example_app.model.EALTEdgeRestore;
 import org.springframework.stereotype.Service;
 
+
 @Service
 public class ShellCommand {
 
-    public String executeCommand(String command) {
+	 public String executeCommand(String command) {
 
-        StringBuffer output = new StringBuffer();
+	    StringBuffer output = new StringBuffer();
 
-        Process p;
-        try {
+	    Process p;
+	    try {
+
+	        p = Runtime.getRuntime().exec(command);
+	        p.waitFor();
+			BufferedReader reader = new BufferedReader(new InputStreamReader(p.getInputStream()));
+
+	        String line = "";
+	        while ((line = reader.readLine())!= null) {
+	            output.append(line + "\n");
+	        }
+		}
+		catch (Exception e) {
+	        e.printStackTrace();
+	    }
+	    return output.toString();
+
+	}
+
+    public List<EALTEdgeBackup> executeBackupCommand(String command) {
+
+        EALTEdgeBackup backup = new EALTEdgeBackup();
+		List<EALTEdgeBackup> backupsList = new ArrayList<EALTEdgeBackup>();
+
+		try {
+			Process p;
             p = Runtime.getRuntime().exec(command);
             p.waitFor();
             BufferedReader reader =
@@ -22,31 +56,117 @@ public class ShellCommand {
 
             String line = "";
             while ((line = reader.readLine())!= null) {
-                output.append(line + "\n");
+            	if(line.startsWith("NAME")) {
+            		continue;
+            	}
+            	else {
+            		backup = parseBackupResult(line);
+                	backupsList.add(backup);
+            	}
             }
 
         } catch (Exception e) {
             e.printStackTrace();
         }
+        return backupsList;
+    }
+    
+    public static EALTEdgeBackup parseBackupResult(String newstr){
 
-        return output.toString();
+    	EALTEdgeBackup backup = new EALTEdgeBackup();
+    	List<String> al = new ArrayList<String>();
+		
+		StringTokenizer st = new StringTokenizer(newstr, " ");
+		StringBuffer sb = new StringBuffer();
+		
+		while(st.hasMoreElements()) {
+			sb.append(st.nextElement()).append(" ");
+		}
+		
+		String newstrwithProperSpacing = sb.toString();
+		String str[] = newstrwithProperSpacing.split(" ");
+		
+		str[4] = str[4] + str[5] + str[6] + str[7];
+		
+		al = Arrays.asList(str);
+		
+		for(int i = 0; i < al.size(); i++) {
+			if( i == 0 ) {
+				backup.setName(al.get(i));
+			}
+			if( i == 1) {
+				backup.setStatus(al.get(i));
+			}
+			if( i == 2) {
+				backup.setErrors(al.get(i));
+			}
+			if( i == 3){
+				backup.setWarnings(al.get(i));
+			}
+			if( i == 4) {
+				backup.setCreated(al.get(i));
+			}
 
+		}
+        return backup;
     }
 
-    //parse velero cmd and get details
-    public String parseResult(String msg){
-        List<String> itemsList = new ArrayList<String>();
+    public List<EALTEdgeRestore> executeRestoreCommand(String command) {
 
-        /*
-        if (msg == null || msg.equals(""))
-            return itemsList;
+        EALTEdgeRestore restore = new EALTEdgeRestore();
+        List<EALTEdgeRestore> restoresList = new ArrayList<EALTEdgeRestore>();
+        
+        try {
+        	Process p;
+            p = Runtime.getRuntime().exec(command);
+            p.waitFor();
+            BufferedReader reader =
+                    new BufferedReader(new InputStreamReader(p.getInputStream()));
 
-        matcher = pattern.matcher(msg);
-        while (matcher.find()) {
-            ipList.add(matcher.group(0));
+            String line = "";
+            while ((line = reader.readLine())!= null) {
+            	if(line.startsWith("NAME")) {
+            		continue;
+            	}
+            	else {
+            		restore = parseRestoreResult(line);
+                	restoresList.add(restore);
+            	}
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
         }
-        return ipList;
-*/
-        return "success";
+        return restoresList;
+    }
+
+    public static EALTEdgeRestore parseRestoreResult(String newstr){
+
+    	EALTEdgeRestore restore = new EALTEdgeRestore();
+
+    	StringTokenizer st = new StringTokenizer(newstr, " ");
+		StringBuffer sb = new StringBuffer();
+
+		while(st.hasMoreElements()) {
+			sb.append(st.nextElement()).append(" ");
+		}
+
+		String newstrwithProperSpacing = sb.toString();
+		String str[] = newstrwithProperSpacing.split(" ");
+		
+		List<String> ll = new LinkedList<String>(Arrays.asList(str));
+		
+		for(int i = 0; i < ll.size(); i++) {
+			if( i == 0 ) {
+				restore.setName(ll.get(i));
+			}
+			if( i == 1) {
+				restore.setBackup(ll.get(i));
+			}
+			if( i == 2) {
+				restore.setStatus(ll.get(i));
+			}
+		}
+
+        return restore;
     }
-}
\ No newline at end of file
+}