Function getStorageVirtualFilesByPath

internal/op/storage.go:378–443

(prefix string, rootCallback func(driver.Driver, model.Obj) model.Obj, filterByName string)

}

func getStorageVirtualFilesByPath(prefix string, rootCallback func(driver.Driver, model.Obj) model.Obj, filterByName string) []model.Obj {
	files := make([]model.Obj, 0)
	storages := storagesMap.Values()
	sort.Slice(storages, func(i, j int) bool {
		if storages[i].GetStorage().Order == storages[j].GetStorage().Order {
			return storages[i].GetStorage().MountPath < storages[j].GetStorage().MountPath
		}
		return storages[i].GetStorage().Order < storages[j].GetStorage().Order
	})

	if !strings.HasSuffix(prefix, "/") {
		prefix += "/"
	}
	set := make(map[string]int)
	var wg sync.WaitGroup
	for _, v := range storages {
		// Exclude prefix itself and non prefix
		p, found := strings.CutPrefix(utils.GetActualMountPath(v.GetStorage().MountPath), prefix)
		if !found || p == "" {
			continue
		}
		name, _, found := strings.Cut(p, "/")
		if filterByName != "" && name != filterByName {
			continue
		}

		if idx, ok := set[name]; ok {
			if !found {
				files[idx].(*model.Object).Mask = model.Locked | model.Virtual
				if rootCallback != nil {
					wg.Add(1)
					go func() {
						defer wg.Done()
						files[idx] = rootCallback(v, files[idx])
					}()
				}
			}
			continue
		}
		set[name] = len(files)
		obj := &model.Object{
			Name:     name,
			Modified: v.GetStorage().Modified,
			IsFolder: true,
		}
		if !found {
			idx := len(files)
			obj.Mask = model.Locked | model.Virtual
			files = append(files, obj)
			if rootCallback != nil {
				wg.Add(1)
				go func() {
					defer wg.Done()
					files[idx] = rootCallback(v, files[idx])
				}()
			}
		} else {
			obj.Mask = model.ReadOnly | model.Virtual