Method handleNextMessage

overlay/receive.go:383–452

(src key.NodePublic, msg []byte, system string)

}

func (r *Receive) handleNextMessage(src key.NodePublic, msg []byte, system string) (resRaw []byte, nodeKey key.NodePublic, _ error) {
	cleartext, ok := r.SelfPriv.OpenFrom(r.PeerPriv.Public(), msg)
	if !ok {
		return nil, key.NodePublic{}, errors.New("message failed decryption")
	}

	var ovMsg overlayMessage
	err := json.Unmarshal(cleartext, &ovMsg)
	if err != nil {
		panic("unmarshal node: " + err.Error())
	}

	res := overlayMessage{}
	switch ovMsg.Typ {
	case messageTypePing:
		res.Typ = messageTypePong
	case messageTypePong:
		// do nothing
	case messageTypeHello:
		res.Typ = messageTypeHelloResponse
		username := "unknown"
		if u := ovMsg.HostInfo.Username; u != "" {
			username = u
		}
		hostname := "unknown"
		if h := ovMsg.HostInfo.Hostname; h != "" {
			hostname = h
		}
		if lastNode := r.lastNode.Load(); lastNode != nil {
			res.Node = *lastNode
		}

		if ovMsg.WebrtcDescription != nil {
			r.setupWebrtcConnection(src, &res, *ovMsg.WebrtcDescription)
		}

		r.HumanLogf("%s Received connection request over %s from %s", cliui.Timestamp(time.Now()), system, cliui.Keyword(fmt.Sprintf("%s@%s", username, hostname)))
	case messageTypeNodeUpdate:
		r.Logger.Debug("received updated node", slog.String("node_key", ovMsg.Node.Key.String()))
		r.in <- &ovMsg.Node
		res.Typ = messageTypeNodeUpdate
		if lastNode := r.lastNode.Load(); lastNode != nil {
			res.Node = *lastNode
		}

	case messageTypeWebRTCCandidate:
		pc, ok := r.webrtcConns.Load(src)
		if !ok {
			fmt.Println("got candidate for unknown connection")
			break
		}

		err := pc.AddICECandidate(*ovMsg.WebrtcCandidate)
		if err != nil {
			fmt.Println("failed to add ice candidate:", err)
		}
	}