Method watch

helper/server/downstream.go:328–361

(stopChan chan struct{})

}

func (d *Downstream) watch(stopChan chan struct{}) {
	for {
		select {
		case <-stopChan:
			return
		case event, ok := <-d.events:
			if !ok {
				return
			}

			d.changesMutex.Lock()
			// re-sync if overflow
			if len(d.events) >= 999 {
				d.lastRescan = nil
			} else {
				// check if parent folder might be already in changes then skip
				// this saves us a lot of folder crawling later on
				parts := strings.Split(filepath.ToSlash(event.Path()), "/")
				found := false
				for i := len(parts) - 1; i > 0; i-- {
					path := strings.Join(parts[:i], "/")
					if d.changes[path] {
						found = true
						break
					}
				}
				if !found {
					d.changes[event.Path()] = true
				}
			}
			d.changesMutex.Unlock()
		}
	}
}

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