"Delete all files from device implemented and tested"

Author: skp-github

app/src/main/java/com/googleresearch/capturesync/MainActivity.java

@@ -407,13 +407,22 @@ private void handleWebSocketMsg(@NotNull WsMessageContext wsMessageContext){
 
                 break;
 
-
             case "STATUS" :
                 String status = softwaresyncStatusTextView.getText().toString();
                 Log.i(TAG,"handling the message in STATUS:" + status );
                 wsMessageContext.send(status);
                 break;
 
+            case "DELETE_ALL" :
+                Log.i(TAG,"handling the message in DELETE_ALL" );
+                deleteAllFiles();
+                ((SoftwareSyncLeader) softwareSyncController.softwareSync)
+                        .broadcastRpc(
+                                SoftwareSyncController.METHOD_EMPTY_DEVICE,
+                                "0");
+
+                break;
+
         }
     }
 
@@ -1109,6 +1118,32 @@ private MediaRecorder setUpMediaRecorder(Surface surface, boolean specifyOutput,
 //        return isVideoRecording;
 //    }
 
+    public void deleteAllFiles() {
+        File sdcard = Environment.getExternalStorageDirectory();
+        String videoFilePath = sdcard.getAbsolutePath()+ "/RecSync/VID/";
+        String csvFilePath = sdcard.getAbsolutePath()+ "/RecSync/";
+        File path = new File(videoFilePath);
+        File fileList[] = path.listFiles();
+        Log.i(TAG,"Video File Path:"+videoFilePath );
+        Log.i(TAG,"No of files to delete: "+fileList.length );
+        String filename;
+        for(int i=0; i< fileList.length; i++){
+            filename = fileList[i].getName();
+            try{
+                Log.i(TAG,"inside  deleteall" );
+                File vFile = new File(videoFilePath + filename);
+                vFile.delete();
+                Log.i(TAG,"csv_file_path : " + csvFilePath + filename.split("\\.")[0] + ".csv" );
+                File csvFile = new File(csvFilePath + filename.split("\\.")[0] + ".csv");
+                csvFile.delete();
+            }catch (Exception e){
+                e.printStackTrace();
+            }
+
+        }
+    }
+
+
     public void sendFilesToServer(String payload){
         try {
 

app/src/main/java/com/googleresearch/capturesync/SoftwareSyncController.java

@@ -63,6 +63,7 @@ public class SoftwareSyncController implements Closeable {
     public static final int METHOD_START_RECORDING = 200_003;
     public static final int METHOD_STOP_RECORDING = 200_004;
     public static final int METHOD_UPLOAD_RECORDED_FILES = 200_005;
+    public static final int METHOD_EMPTY_DEVICE = 200_006;
 
     private long upcomingTriggerTimeNs;
 
@@ -219,6 +220,14 @@ private void setupSoftwareSync() {
                         );
                     });
 
+            clientRpcs.put(
+                    METHOD_EMPTY_DEVICE,
+                    payload -> {
+                        Log.v(TAG, "Deleting All Recordings and Related Files");
+                        context.runOnUiThread(
+                                () -> context.deleteAllFiles()
+                        );
+                    });
 
             clientRpcs.put(
                     SyncConstants.METHOD_MSG_OFFSET_UPDATED,

remote_control/remote_control.py

@@ -52,12 +52,29 @@ def stopBtn(self):
     def statusBtn(self):
         try:
             self.ws.send("STATUS")
+            message = self.ws.recv()
+            self.status_label.setPlainText(message)
         except Exception as e:
             self.show_popup()
-        with open('last_prefix.txt','w+') as file:
-            file.writelines(self.download_prefix_text.toPlainText())
-        message = self.ws.recv()
-        self.status_label.setPlainText(message)
+            with open('last_prefix.txt','w+') as file:
+                file.writelines(self.download_prefix_text.toPlainText())
+            sys.exit()
+
+    def delete_all_btn(self):
+        msgBox = QMessageBox()
+        msgBox.setText("Are you sure you want to delete all the recordings and related files ?")
+        msgBox.setInformativeText("This action cannot be reversed !!!")
+        msgBox.setStandardButtons(QMessageBox.Ok | QMessageBox.Cancel)
+        msgBox.setDefaultButton(QMessageBox.Cancel)
+        ret = msgBox.exec()
+        if ret == QMessageBox.Ok:
+            try:
+                self.ws.send("DELETE_ALL")
+            except Exception as e:
+                self.show_popup()
+                with open('last_prefix.txt','w+') as file:
+                    file.writelines(self.download_prefix_text.toPlainText())
+                sys.exit()
 
     def clearStatusBtn(self):
         self.status_label.setPlainText("")
@@ -77,14 +94,11 @@ def isPrefix(self, prefix_text):
         return True
 
     def setupUi(self, MainWindow):
-
-        #
         # Setup the WEB SOCKET
         self.ws = websocket.WebSocket()
-        #self.ws.connect("ws://172.16.62.107:7867/remotecon")
+
         self.ws.connect("ws://192.168.5.2:7867/remotecon", ping_interval=1)
 
-        #
         # Setup the GUI
         MainWindow.setObjectName("MainWindow")
         MainWindow.resize(800, 800)
@@ -130,6 +144,14 @@ def setupUi(self, MainWindow):
         self.download_btn.setFont(font)
         self.download_btn.setObjectName("pushButton_4")
         self.download_btn.clicked.connect(self.downloadBtn)
+
+        self.delete_btn = QtWidgets.QPushButton(self.centralwidget)
+        self.delete_btn.setGeometry(QtCore.QRect(280, 520, 161, 50))
+        self.delete_btn.setFont(font)
+        self.delete_btn.setObjectName("pushButton_6")
+        self.delete_btn.clicked.connect(self.delete_all_btn)
+
+
         self.status_label = QtWidgets.QPlainTextEdit(self.centralwidget)
         self.status_label.setGeometry(QtCore.QRect(173, 280, 381, 91))
         self.status_label.setObjectName("plainTextEdit")
@@ -159,6 +181,8 @@ def retranslateUi(self, MainWindow):
         self.status_btn.setText(_translate("MainWindow", "Status"))
         self.status_clear_btn.setText(_translate("MainWindow", "X"))
         self.status_clear_btn.setStyleSheet('QPushButton {;color: red;}')
+        self.delete_btn.setText(_translate("MainWindow", "Empty Device"))
+        self.delete_btn.setStyleSheet('QPushButton {;background-color: red;}')
         self.api_input.setPlaceholderText(_translate("MainWindow", "Please enter the api endpoint where you want the files to be uploaded."))
         self.download_prefix_text.setPlaceholderText(_translate("MainWindow", " Enter Session Prefix"))
         self.download_btn.setText(_translate("MainWindow", "Download"))