Remove existing data from execution client volumes

internal/adapters/apis/docker/docker_adapter.go

@@ -321,3 +321,27 @@ func (d *DockerAdapter) ensureImage(ctx context.Context, imageName string) error
 
 	return nil
 }
+
+// RemoveVolumeData removes all data from a Docker volume by deleting its contents
+func (d *DockerAdapter) RemoveVolumeData(ctx context.Context, volumeTargetPath string) error {
+	// remove all files in the volume target path
+	dirEntries, err := os.ReadDir(volumeTargetPath)
+	if err != nil {
+		return fmt.Errorf("failed to read volume directory: %w", err)
+	}
+
+	for _, entry := range dirEntries {
+		entryPath := fmt.Sprintf("%s/%s", volumeTargetPath, entry.Name())
+		if entry.IsDir() {
+			if err := os.RemoveAll(entryPath); err != nil {
+				return fmt.Errorf("failed to remove directory %s: %w", entryPath, err)
+			}
+		} else {
+			if err := os.Remove(entryPath); err != nil {
+				return fmt.Errorf("failed to remove file %s: %w", entryPath, err)
+			}
+		}
+	}
+
+	return nil
+}

internal/adapters/composite/snapshotmanager/snapshotmanager.go

@@ -57,3 +57,8 @@ func (s *SnapshotManagerAdapter) StopDownload(ctx context.Context, clientShortNa
 	containerName := fmt.Sprintf("%s%s", downloadContainerPrefix, clientShortName)
 	_ = s.docker.StopContainerWithTimeout(ctx, containerName, 5)
 }
+
+// ClearExecutionClientData removes existing data for the execution client
+func (s *SnapshotManagerAdapter) ClearExecutionClientData(ctx context.Context, client domain.ExecutionClientInfo) error {
+	return s.docker.RemoveVolumeData(ctx, client.VolumeName)
+}

internal/application/ports/snapshotChecker_port.go

@@ -16,4 +16,7 @@ type SnapshotManager interface {
 
 	// StopDownload stops the snapshot download container for a specific client
 	StopDownload(ctx context.Context, clientShortName string)
+
+	// ClearExecutionClientData removes existing data for the execution client
+	ClearExecutionClientData(ctx context.Context, client domain.ExecutionClientInfo) error
 }

internal/application/services/snapshot_checker.go

@@ -126,6 +126,12 @@ func (s *SnapshotCheckerService) checkAndUpdateSnapshot(ctx context.Context) err
 
 	logger.InfoWithPrefix(snapshotLogPrefix, "[%s] Snapshot download needed", client.ShortName)
 
+	// Remove ec volume data before downloading new snapshot
+	logger.InfoWithPrefix(snapshotLogPrefix, "[%s] Removing existing volume data before snapshot download...", client.ShortName)
+	if err := s.snapshotManager.ClearExecutionClientData(ctx, client); err != nil {
+		return fmt.Errorf("failed to clear execution client data: %w", err)
+	}
+
 	// Set download in progress for this client
 	logger.InfoWithPrefix(snapshotLogPrefix, "[%s] Setting download in progress marker...", client.ShortName)
 	if err := s.downloadProgress.SetDownloadInProgress(ctx); err != nil {