diff --git a/models/peer/peer_cache.go b/models/peer/peer_cache.go index 0d5fdd9..2c96a68 100644 --- a/models/peer/peer_cache.go +++ b/models/peer/peer_cache.go @@ -85,7 +85,7 @@ func (p *PeerCache) LaunchPeerExecution(peerID string, dataID string, // If the peer is not reachable, add the execution to the failed executions list pexec := &PeerExecution{ Method: method.String(), - Url: p.urlFormat((mypeer.Url)+meth, dt), + Url: p.urlFormat((mypeer.Url), dt) + meth, Body: body, DataType: dt.EnumIndex(), DataID: dataID, @@ -98,7 +98,7 @@ func (p *PeerCache) LaunchPeerExecution(peerID string, dataID string, return nil, errors.New("peer not found") } // If the peer is reachable, launch the execution - url = p.urlFormat((mypeer.Url)+meth, dt) // Format the URL + url = p.urlFormat((mypeer.Url), dt) + meth // Format the URL tmp := mypeer.FailedExecution // Get the failed executions list mypeer.FailedExecution = []PeerExecution{} // Reset the failed executions list NewShallowAccessor().UpdateOne(mypeer, peerID) // Update the peer in the db