Function deleteExtraFiles

drivers/strm/hook.go:174–216

(driver *Strm, localPath string, objs []model.Obj)

}

func deleteExtraFiles(driver *Strm, localPath string, objs []model.Obj) {
	if driver.SaveLocalMode != SaveLocalSyncMode {
		return
	}
	localFiles, localDirs, err := getLocalDirsAndFiles(localPath)
	if err != nil {
		log.Errorf("Failed to read local files from %s: %v", localPath, err)
		return
	}

	fileSet := make(map[string]struct{})
	dirSet := make(map[string]struct{})
	for _, obj := range objs {
		objPath := stdpath.Join(localPath, obj.GetName())
		if obj.IsDir() {
			dirSet[objPath] = struct{}{}
		} else {
			fileSet[objPath] = struct{}{}
		}
	}

	for _, localFile := range localFiles {
		if _, exists := fileSet[localFile]; !exists {
			err := os.Remove(localFile)
			if err != nil {
				log.Errorf("Failed to delete file: %s, error: %v\n", localFile, err)
			} else {
				log.Infof("Deleted file %s", localFile)
			}
		}
	}

	for _, localDir := range localDirs {
		if _, exists := dirSet[localDir]; !exists {
			err := os.RemoveAll(localDir)
			if err != nil {
				log.Errorf("Failed to delete directory: %s, error: %v\n", localDir, err)
			} else {
				log.Infof("Deleted directory %s", localDir)
			}
		}
	}
}

func getLocalDirsAndFiles(localPath string) ([]string, []string, error) {
	var files, dirs []string