Function NewSymlink

pkg/devspace/sync/symlink.go:39–72

NewSymlink creates a new symlink object

(upstream *upstream, symlinkPath, targetPath string, isDir bool, ignoreMatcher ignoreparser.IgnoreParser)

// NewSymlink creates a new symlink object
func NewSymlink(upstream *upstream, symlinkPath, targetPath string, isDir bool, ignoreMatcher ignoreparser.IgnoreParser) (*Symlink, error) {
	symlink := &Symlink{
		SymlinkPath: symlinkPath,
		TargetPath:  targetPath,
		IsDir:       isDir,
		events:      make(chan notify.EventInfo, 1000),
		upstream:    upstream,
	}

	symlink.watcher = notify.NewTree()
	_ = symlink.watcher.Watch(targetPath, symlink.events, func(path string) bool {
		if ignoreMatcher == nil || ignoreMatcher.RequireFullScan() {
			return false
		}

		stat, err := os.Stat(path)
		if err != nil {
			return false
		}

		return ignoreMatcher.Matches(path[len(symlink.SymlinkPath):], stat.IsDir())
	}, notify.All)

	go func() {
		for event := range symlink.events {
			symlink.upstream.events <- &symlinkEvent{
				path:  symlink.rewritePath(event.Path()),
				event: event.Event(),
			}
		}
	}()

	return symlink, nil
}

func (s *Symlink) rewritePath(path string) string {
	return s.SymlinkPath + path[len(s.TargetPath):]