Method AddConnection

lib/model/model.go:2290–2349

AddConnection adds a new peer connection to the model. An initial index will be sent to the connected peer, thereafter index updates whenever the local folder changes.

(conn protocol.Connection, hello protocol.Hello)

// be sent to the connected peer, thereafter index updates whenever the local
// folder changes.
func (m *model) AddConnection(conn protocol.Connection, hello protocol.Hello) {
	deviceID := conn.DeviceID()
	deviceCfg, ok := m.cfg.Device(deviceID)
	if !ok {
		slog.Info("Trying to add connection to unknown device")
		return
	}

	connID := conn.ConnectionID()
	closed := make(chan struct{})

	m.mut.Lock()

	m.connections[connID] = conn
	m.closed[connID] = closed
	m.helloMessages[deviceID] = hello
	m.deviceConnIDs[deviceID] = append(m.deviceConnIDs[deviceID], connID)
	if m.deviceDownloads[deviceID] == nil {
		m.deviceDownloads[deviceID] = newDeviceDownloadState()
	}

	event := map[string]string{
		"id":            deviceID.String(),
		"deviceName":    hello.DeviceName,
		"clientName":    hello.ClientName,
		"clientVersion": hello.ClientVersion,
		"type":          conn.Type(),
	}

	addr := conn.RemoteAddr()
	if addr != nil {
		event["addr"] = addr.String()
	}

	m.evLogger.Log(events.DeviceConnected, event)

	if len(m.deviceConnIDs[deviceID]) == 1 {
		slog.Info("New device connection", deviceID.LogAttr(), slogutil.Address(conn.RemoteAddr()), slog.Group("remote", slog.String("name", hello.DeviceName), slog.String("client", hello.ClientName), slog.String("version", hello.ClientVersion)))
	} else {
		slog.Info("Additional device connection", deviceID.LogAttr(), slogutil.Address(conn.RemoteAddr()), slog.Int("count", len(m.deviceConnIDs[deviceID])-1))
	}

	m.mut.Unlock()

	if (deviceCfg.Name == "" || m.cfg.Options().OverwriteRemoteDevNames) && hello.DeviceName != "" {
		m.cfg.Modify(func(cfg *config.Configuration) {
			for i := range cfg.Devices {
				if cfg.Devices[i].DeviceID == deviceID {
					if cfg.Devices[i].Name == "" || cfg.Options.OverwriteRemoteDevNames {
						cfg.Devices[i].Name = hello.DeviceName
					}
					return
				}
			}
		})
	}

	m.deviceWasSeen(deviceID)