Quellcode durchsuchen

add peer signal action to fallback api

abhishek9686 vor 1 Monat
Ursprung
Commit
d218f2fb58
2 geänderte Dateien mit 4 neuen und 2 gelöschten Zeilen
  1. 2 0
      controllers/hosts.go
  2. 2 2
      mq/handlers.go

+ 2 - 0
controllers/hosts.go

@@ -403,6 +403,8 @@ func hostUpdateFallback(w http.ResponseWriter, r *http.Request) {
 			e.Update(db.WithContext(r.Context()))
 		}
 		sendPeerUpdate = true
+	case models.SignalHost:
+		mq.SignalPeer(hostUpdate.Signal)
 	}
 	go func() {
 		if sendDeletedNodeUpdate {

+ 2 - 2
mq/handlers.go

@@ -171,7 +171,7 @@ func UpdateHost(client mqtt.Client, msg mqtt.Message) {
 		}
 		sendPeerUpdate = true
 	case models.SignalHost:
-		signalPeer(hostUpdate.Signal)
+		SignalPeer(hostUpdate.Signal)
 
 	}
 
@@ -183,7 +183,7 @@ func UpdateHost(client mqtt.Client, msg mqtt.Message) {
 	}
 }
 
-func signalPeer(signal models.Signal) {
+func SignalPeer(signal models.Signal) {
 
 	if signal.ToHostPubKey == "" {
 		msg := "insufficient data to signal peer"