Method handleIndex

lib/model/model.go:1163–1193

(conn protocol.Connection, folder string, fs []protocol.FileInfo, update bool, prevSequence, lastSequence int64)

}

func (m *model) handleIndex(conn protocol.Connection, folder string, fs []protocol.FileInfo, update bool, prevSequence, lastSequence int64) error {
	op := "Index"
	if update {
		op += " update"
	}

	deviceID := conn.DeviceID()
	l.Debugf("%v (in): %s / %q: %d files", op, deviceID, folder, len(fs))

	if cfg, ok := m.cfg.Folder(folder); !ok || !cfg.SharedWith(deviceID) {
		slog.Warn(`Operation for unexpected folder ID; ensure that the folder exists and that this device is selected under "Share With" in the folder configuration.`, slog.String("operation", op), cfg.LogAttr(), deviceID.LogAttr())
		return fmt.Errorf("%s: %w", folder, ErrFolderMissing)
	} else if cfg.Paused {
		l.Debugf("%v for paused folder (ID %q) sent from device %q.", op, folder, deviceID)
		return fmt.Errorf("%s: %w", folder, ErrFolderPaused)
	}

	m.mut.RLock()
	indexHandler, ok := m.getIndexHandlerRLocked(conn)
	m.mut.RUnlock()
	if !ok {
		// This should be impossible, as an index handler is registered when
		// we send a cluster config, and that is what triggers index
		// sending.
		m.evLogger.Log(events.Failure, "index sender does not exist for connection on which indexes were received")
		l.Debugf("%v for folder (ID %q) sent from device %q: missing index handler", op, folder, deviceID)
		return fmt.Errorf("%s: %w", folder, ErrFolderNotRunning)
	}

	return indexHandler.ReceiveIndex(folder, fs, update, op, prevSequence, lastSequence)
}

type clusterConfigDeviceInfo struct {
	local, remote protocol.Device