cr: move DeleteAllFiles to be part of the backend interface

fakestorage/server.go

@@ -363,31 +363,16 @@ func (s *Server) reseedServer(r *http.Request) jsonResponse {
 }
 
 func (s *Server) deleteAllFiles(r *http.Request) jsonResponse {
-	storageRoot := s.options.StorageRoot
-	storageType := "filesystem"
-
-	if storageRoot != "" {
-		if err := os.RemoveAll(storageRoot); err != nil {
-			return jsonResponse{
-				status:       http.StatusInternalServerError,
-				errorMessage: err.Error(),
-			}
+	if err := s.backend.DeleteAllFiles(); err != nil {
+		return jsonResponse{
+			status:       http.StatusInternalServerError,
+			errorMessage: err.Error(),
 		}
-
-		if err := os.MkdirAll(filepath.Join(storageRoot), 0o700); err != nil {
-			return jsonResponse{
-				status:       http.StatusInternalServerError,
-				errorMessage: err.Error(),
-			}
-		}
-	} else {
-		storageType = "memory"
-		s.backend, _ = backend.NewStorageMemory(nil)
 	}
 
 	return jsonResponse{
 		status: http.StatusOK,
-		data:   map[string]string{"message": fmt.Sprintf("All files deleted successfully from %s", storageType)},
+		data:   map[string]string{"message": "All files deleted successfully"},
 	}
 }
 

internal/backend/fs.go

@@ -467,3 +467,12 @@ func (s *storageFS) ComposeObject(bucketName string, objectNames []string, desti
 
 	return result, nil
 }
+
+func (s *storageFS) DeleteAllFiles() error {
+	s.mtx.Lock()
+	defer s.mtx.Unlock()
+	if err := os.RemoveAll(s.rootDir); err != nil {
+		return err
+	}
+	return os.MkdirAll(s.rootDir, 0o700)
+}

internal/backend/memory.go

@@ -390,3 +390,10 @@ func (s *storageMemory) ComposeObject(bucketName string, objectNames []string, d
 
 	return result, nil
 }
+
+func (s *storageMemory) DeleteAllFiles() error {
+	s.mtx.Lock()
+	defer s.mtx.Unlock()
+	s.buckets = make(map[string]bucketInMemory)
+	return nil
+}

internal/backend/storage.go

@@ -31,6 +31,7 @@ type Storage interface {
 	PatchObject(bucketName, objectName string, attrsToUpdate ObjectAttrs) (StreamingObject, error)
 	UpdateObject(bucketName, objectName string, attrsToUpdate ObjectAttrs) (StreamingObject, error)
 	ComposeObject(bucketName string, objectNames []string, destinationName string, metadata map[string]string, contentType string) (StreamingObject, error)
+	DeleteAllFiles() error
 }
 
 type Error string