core/oc-discovery
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

oc-discovery + auto create peer

Browse Source
This commit is contained in:
mr
2026-02-05 15:47:29 +01:00
parent 425cbdfe7d
commit 2e31df89c2
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
daemons/node/common/common_stream.go
View File

@@ -68,7 +68,7 @@ func (ix *LongLivedStreamRecordedService[T]) gc() {
} }
ix.PubsubMu.Lock() ix.PubsubMu.Lock()
if ix.LongLivedPubSubs[TopicPubSubNodeActivity] != nil { if ix.LongLivedPubSubs[TopicPubSubNodeActivity] != nil {
ad, err := pp.AddrInfoFromString("/ip4/" + conf.GetConfig().Hostname + " /tcp/" + fmt.Sprintf("%v", conf.GetConfig().NodeEndpointPort) + "/p2p/" + ix.Host.ID().String()) ad, err := pp.AddrInfoFromString("/ip4/" + conf.GetConfig().Hostname + "/tcp/" + fmt.Sprintf("%v", conf.GetConfig().NodeEndpointPort) + "/p2p/" + ix.Host.ID().String())
if err == nil { if err == nil {
if b, err := json.Marshal(TopicNodeActivityPub{ if b, err := json.Marshal(TopicNodeActivityPub{
Disposer: *ad, Disposer: *ad,

2
daemons/node/indexer/handler.go
View File

@@ -183,7 +183,7 @@ func (ix *IndexerService) handleNodePublish(s network.Stream) {
} }
if ix.LongLivedPubSubs[common.TopicPubSubNodeActivity] != nil && !rec.NoPub { if ix.LongLivedPubSubs[common.TopicPubSubNodeActivity] != nil && !rec.NoPub {
ad, err := peer.AddrInfoFromString("/ip4/" + conf.GetConfig().Hostname + " /tcp/" + fmt.Sprintf("%v", conf.GetConfig().NodeEndpointPort) + "/p2p/" + ix.Host.ID().String()) ad, err := peer.AddrInfoFromString("/ip4/" + conf.GetConfig().Hostname + "/tcp/" + fmt.Sprintf("%v", conf.GetConfig().NodeEndpointPort) + "/p2p/" + ix.Host.ID().String())
if err == nil { if err == nil {
if b, err := json.Marshal(common.TopicNodeActivityPub{ if b, err := json.Marshal(common.TopicNodeActivityPub{
Disposer: *ad, Disposer: *ad,

2
daemons/node/node.go
View File

@@ -237,7 +237,7 @@ func (d *Node) claimInfo(
} }
rec.APIUrl = endPoint rec.APIUrl = endPoint
rec.StreamAddress = "/ip4/" + conf.GetConfig().Hostname + " /tcp/" + fmt.Sprintf("%v", conf.GetConfig().NodeEndpointPort) + "/p2p/" + rec.PeerID rec.StreamAddress = "/ip4/" + conf.GetConfig().Hostname + "/tcp/" + fmt.Sprintf("%v", conf.GetConfig().NodeEndpointPort) + "/p2p/" + rec.PeerID
rec.NATSAddress = oclib.GetConfig().NATSUrl rec.NATSAddress = oclib.GetConfig().NATSUrl
rec.WalletAddress = "my-wallet" rec.WalletAddress = "my-wallet"
rec.ExpiryDate = expiry rec.ExpiryDate = expiry