Method applyChange

helper/server/downstream.go:363–406

(newState map[string]*remote.Change, fullPath string)

}

func (d *Downstream) applyChange(newState map[string]*remote.Change, fullPath string) {
	fullPath = strings.TrimSuffix(fullPath, "/")

	relativePath := fullPath[len(d.options.RemotePath):]

	// in any case we mark this part of the tree as dirty and delete it
	if old, ok := d.watchedFiles[fullPath]; ok {
		if old.IsDir {
			deletePathFromState(newState, fullPath)
		} else {
			delete(newState, fullPath)
		}
	}

	// check if the path still exists
	stat, err := os.Stat(fullPath)
	if err != nil {
		return
	} else if d.ignoreMatcher != nil && !d.ignoreMatcher.RequireFullScan() && d.ignoreMatcher.Matches(relativePath, stat.IsDir()) {
		return
	}

	if stat.IsDir() {
		if d.ignoreMatcher == nil || !d.ignoreMatcher.RequireFullScan() || !d.ignoreMatcher.Matches(relativePath, true) {
			newState[fullPath] = &remote.Change{
				Path:  fullPath,
				IsDir: true,
			}
		}

		walkDir(d.options.RemotePath, fullPath, d.ignoreMatcher, newState, d.options.NoRecursiveWatch, time.Duration(d.options.Throttle)*time.Millisecond)
	} else {
		if d.ignoreMatcher == nil || !d.ignoreMatcher.RequireFullScan() || !d.ignoreMatcher.Matches(relativePath, false) {
			newState[fullPath] = &remote.Change{
				Path:          fullPath,
				Size:          stat.Size(),
				MtimeUnix:     stat.ModTime().Unix(),
				MtimeUnixNano: stat.ModTime().UnixNano(),
				Mode:          uint32(stat.Mode()),
				IsDir:         false,
			}
		}
	}
}

func deletePathFromState(state map[string]*remote.Change, path string) {
	for k := range state {