|
@@ -90,11 +90,12 @@ func migrate(w http.ResponseWriter, r *http.Request) {
|
|
continue
|
|
continue
|
|
}
|
|
}
|
|
host.Nodes = append(host.Nodes, node.ID.String())
|
|
host.Nodes = append(host.Nodes, node.ID.String())
|
|
- if err := logic.UpsertHost(&host); err != nil {
|
|
|
|
- slog.Error("save host", "error", err)
|
|
|
|
- }
|
|
|
|
|
|
+
|
|
nodes = append(nodes, node)
|
|
nodes = append(nodes, node)
|
|
}
|
|
}
|
|
|
|
+ if err := logic.UpsertHost(&host); err != nil {
|
|
|
|
+ slog.Error("save host", "error", err)
|
|
|
|
+ }
|
|
go mq.PublishPeerUpdate()
|
|
go mq.PublishPeerUpdate()
|
|
response := models.HostPull{
|
|
response := models.HostPull{
|
|
Host: host,
|
|
Host: host,
|