Method GetNodeTree

common/storage/sql/index/folder-size-cache.go:133–159

GetNodeTree List from the path

(ctx context.Context, path *tree.MPath, filter ...*tree.MetaFilter)

// GetNodeTree List from the path
func (dao *FolderSizeCacheSQL) GetNodeTree(ctx context.Context, path *tree.MPath, filter ...*tree.MetaFilter) chan interface{} {
	c := make(chan interface{})

	go func() {
		defer close(c)

		cc := dao.DAO.GetNodeTree(ctx, path, filter...)

		for obj := range cc {
			if node, ok := obj.(*tree.TreeNode); ok {
				if node != nil && !node.GetNode().IsLeaf() {
					err := dao.folderSize(ctx, node)
					if err != nil {
						log.Logger(ctx).Debug("Unable to use cache for folder size", zap.Error(err))
					}
				}
			}
			select {
			case c <- obj:
			case <-ctx.Done():
				return
			}
		}
	}()

	return c
}

func (dao *FolderSizeCacheSQL) GetOrCreateNodeByPath(ctx context.Context, nodePath string, info *tree.Node, rootInfo ...*tree.Node) (tree.ITreeNode, []tree.ITreeNode, error) {
	n, cc, e := dao.DAO.GetOrCreateNodeByPath(ctx, nodePath, info, rootInfo...)