Method getFileInformationFromEvent

pkg/devspace/sync/upstream.go:433–466

(events []notify.EventInfo)

}

func (u *upstream) getFileInformationFromEvent(events []notify.EventInfo) ([]*FileInformation, error) {
	u.sync.fileIndex.fileMapMutex.Lock()
	defer u.sync.fileIndex.fileMapMutex.Unlock()

	changes := make([]*FileInformation, 0, len(events))
	for _, event := range events {
		fileInfo, ok := event.(*FileInformation)

		// if the change is sent from the initial sync don't evaluate it
		if ok {
			changes = append(changes, fileInfo)
		} else {
			u.sync.log.Debugf("Upstream - Event from filesystem for %s", event.Path())

			// check if path is correct
			fullPath := event.Path()
			if !strings.HasPrefix(filepath.ToSlash(fullPath), filepath.ToSlash(u.sync.LocalPath)+"/") {
				u.sync.log.Infof("Upstream - unexpected upload path %s", fullPath)
				continue
			}

			// Determine what kind of change we got (Create or Remove)
			relativePath := getRelativeFromFullPath(fullPath, u.sync.LocalPath)
			newChanges, err := u.evaluateChange(relativePath, fullPath)
			if err != nil {
				return nil, errors.Wrap(err, "evaluate change")
			}

			changes = append(changes, newChanges...)
		}
	}

	return changes, nil
}

func (u *upstream) evaluateChange(relativePath, fullPath string) ([]*FileInformation, error) {
	stat, err := os.Stat(fullPath)