add vacuum operation

weed/admin/handlers/admin_handlers.go

@@ -112,6 +112,12 @@ func (h *AdminHandlers) SetupRoutes(r *gin.Engine, authRequired bool, username,
 				filesApi.GET("/view", h.fileBrowserHandlers.ViewFile)
 				filesApi.GET("/properties", h.fileBrowserHandlers.GetFileProperties)
 			}
+
+			// Volume management API routes
+			volumeApi := api.Group("/volumes")
+			{
+				volumeApi.POST("/:id/:server/vacuum", h.clusterHandlers.VacuumVolume)
+			}
 		}
 	} else {
 		// No authentication required - all routes are public
@@ -177,6 +183,12 @@ func (h *AdminHandlers) SetupRoutes(r *gin.Engine, authRequired bool, username,
 				filesApi.GET("/view", h.fileBrowserHandlers.ViewFile)
 				filesApi.GET("/properties", h.fileBrowserHandlers.GetFileProperties)
 			}
+
+			// Volume management API routes
+			volumeApi := api.Group("/volumes")
+			{
+				volumeApi.POST("/:id/:server/vacuum", h.clusterHandlers.VacuumVolume)
+			}
 		}
 	}
 }

weed/admin/handlers/cluster_handlers.go

@@ -240,3 +240,35 @@ func (h *ClusterHandlers) GetVolumeServers(c *gin.Context) {
 	}
 	c.JSON(http.StatusOK, gin.H{"volume_servers": topology.VolumeServers})
 }
+
+// VacuumVolume handles volume vacuum requests via API
+func (h *ClusterHandlers) VacuumVolume(c *gin.Context) {
+	volumeIDStr := c.Param("id")
+	server := c.Param("server")
+
+	if volumeIDStr == "" {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "Volume ID is required"})
+		return
+	}
+
+	volumeID, err := strconv.Atoi(volumeIDStr)
+	if err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "Invalid volume ID"})
+		return
+	}
+
+	// Perform vacuum operation
+	err = h.adminServer.VacuumVolume(volumeID, server)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{
+			"error": "Failed to vacuum volume: " + err.Error(),
+		})
+		return
+	}
+
+	c.JSON(http.StatusOK, gin.H{
+		"message":   "Volume vacuum started successfully",
+		"volume_id": volumeID,
+		"server":    server,
+	})
+}