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

oc-peer partnership flow improved

Browse Source
This commit is contained in:
mr
2026-03-06 10:15:47 +01:00
parent a91a9d91b6
commit 72d35d4b18
1 changed files with 14 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
infrastructure/nats.go
View File

@@ -55,10 +55,6 @@ func ListenNATS() {
if resp.FromApp == config.GetAppName() || resp.Datatype != tools.PEER { if resp.FromApp == config.GetAppName() || resp.Datatype != tools.PEER {
return return
} }
m := map[string]interface{}{
"verify": true,
"relation": peer.PENDING_PARTNER,
}
p := &peer.Peer{} p := &peer.Peer{}
if err := json.Unmarshal(resp.Payload, &p); err == nil { if err := json.Unmarshal(resp.Payload, &p); err == nil {
/*if err := verify(resp.Payload); err != nil { /*if err := verify(resp.Payload); err != nil {
@@ -68,22 +64,25 @@ func ListenNATS() {
access := oclib.NewRequestAdmin(oclib.LibDataEnum(resp.Datatype), nil) access := oclib.NewRequestAdmin(oclib.LibDataEnum(resp.Datatype), nil)
if data := access.LoadOne(p.GetID()); data.Data != nil { if data := access.LoadOne(p.GetID()); data.Data != nil {
if !data.ToPeer().Verify && data.ToPeer().Relation == peer.PENDING_PARTNER { if p.Relation == peer.PENDING_PARTNER {
access.UpdateOne(map[string]interface{}{ if data.ToPeer().Verify {
"verify": false,
"relation": peer.PARTNER,
}, p.GetID())
} else if data.ToPeer().Relation != peer.BLACKLIST && data.ToPeer().Relation != peer.SELF {
if p.Relation == peer.NONE {
access.UpdateOne(map[string]interface{}{ access.UpdateOne(map[string]interface{}{
"relation": peer.NONE, "verify": false,
"relation": peer.PARTNER,
}, p.GetID()) }, p.GetID())
} else { } else {
access.UpdateOne(m, p.GetID()) access.UpdateOne(map[string]interface{}{
"verify": true,
"relation": peer.PENDING_PARTNER,
}, p.GetID())
} }
} else if data.ToPeer().Relation != peer.BLACKLIST && data.ToPeer().Relation != peer.SELF {
access.UpdateOne(map[string]interface{}{
"relation": p.Relation,
}, p.GetID())
} }
} else if err := json.Unmarshal(resp.Payload, &m); err == nil { } else if p.Relation != peer.SELF {
access.StoreOne(m) access.StoreOne(p.Serialize(p))
} }
} }