diff --git a/infrastructure/nats.go b/infrastructure/nats.go index 2ff479a..52709ea 100644 --- a/infrastructure/nats.go +++ b/infrastructure/nats.go @@ -22,6 +22,13 @@ func ListenNATS() { access := oclib.NewRequestAdmin(oclib.LibDataEnum(oclib.PEER), nil) if data := access.Search(nil, search, false); len(data.Data) > 0 { pp := data.Data[0].(*peer.Peer) + pp.Name = p.Name + pp.PeerID = p.PeerID + pp.State = p.State + pp.Url = p.Url + pp.PublicKey = p.PublicKey + pp.WalletAddress = p.WalletAddress + pp.NATSUrl = p.NATSUrl access.UpdateOne(pp.Serialize(pp), pp.GetID()) } else { access.StoreOne(p.Serialize(p))