From 29c2ab0e4c72eb4501afdba8525be111557432bb Mon Sep 17 00:00:00 2001
From: mr <mr>
Date: Fri, 23 Aug 2024 09:11:41 +0200
Subject: [PATCH] send

---
 models/peer/peer_cache.go | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/models/peer/peer_cache.go b/models/peer/peer_cache.go
index c49f71a..4ee666a 100644
--- a/models/peer/peer_cache.go
+++ b/models/peer/peer_cache.go
@@ -55,17 +55,19 @@ func (p *PeerCache) checkPeerStatus(peerID string, caller *tools.HTTPCaller) boo
 		return false
 	}
 	methods := caller.URLS[utils.PEER.String()]
-
+	fmt.Println("PEER AFT 3", methods)
 	if methods == nil {
 		return false
 	}
 	meth := methods[tools.POST]
+	fmt.Println("PEER AFT 4", meth)
 	if meth == "" {
 		return false
 	}
 	url := p.urlFormat(res.(*Peer).Url+meth, utils.PEER)
-	state := api.CheckRemotePeer(url)
-	res.(*Peer).State = state
+	fmt.Println("PEER AFT 5", url)
+	state, services := api.CheckRemotePeer(url)
+	res.(*Peer).Services = services
 	access.UpdateOne(res, peerID)
 	fmt.Printf("Peer %v is %v\n", peerID, state)
 	return state != tools.DEAD
@@ -92,6 +94,7 @@ func (p *PeerCache) LaunchPeerExecution(peerID string, isMySelf bool, dataID str
 		meth = strings.ReplaceAll(meth, ":id", dataID)
 	}
 	url = p.urlFormat(url+meth, dt)
+	fmt.Println("LaunchPeerExecution AFT 3", url)
 	if !p.checkPeerStatus(peerID, caller) {
 		return nil, errors.New("peer is not reachable")
 	}
@@ -118,10 +121,10 @@ func (p *PeerCache) LaunchPeerExecution(peerID string, isMySelf bool, dataID str
 			DataID:   dataID,
 		}
 		singleton.Executions = append(singleton.Executions, pexec)
-		if currentRountine == 0 {
+		/*if currentRountine == 0 {
 			currentRountine++
 			go p.retryPeerExecution()
-		}
+		}*/
 		return pexec, err
 	}
 	fmt.Println("LaunchPeerExecution AFT 3", m, url)