From f59913170810fec1714b36d3fb3347030c8d1987 Mon Sep 17 00:00:00 2001
From: mr <mr>
Date: Tue, 20 Aug 2024 13:31:11 +0200
Subject: [PATCH] id on peer

---
 models/peer/peer_cache.go                  | 1 +
 models/workflow/workflow_mongo_accessor.go | 4 ++++
 2 files changed, 5 insertions(+)

diff --git a/models/peer/peer_cache.go b/models/peer/peer_cache.go
index 69384f9..6543beb 100644
--- a/models/peer/peer_cache.go
+++ b/models/peer/peer_cache.go
@@ -51,6 +51,7 @@ func (p *PeerCache) LaunchPeerExecution(peerID string, dataID string, url string
 	if !p.checkPeerStatus(peerID) {
 		return nil, err
 	}
+	fmt.Println("LaunchPeerExecution", method, url, methods[method], body)
 	if method == tools.POST {
 		b, err = caller.CallPost(url, methods[method], body)
 	}
diff --git a/models/workflow/workflow_mongo_accessor.go b/models/workflow/workflow_mongo_accessor.go
index 5e31e8a..b5eb408 100644
--- a/models/workflow/workflow_mongo_accessor.go
+++ b/models/workflow/workflow_mongo_accessor.go
@@ -2,6 +2,7 @@ package oclib
 
 import (
 	"errors"
+	"fmt"
 	"strings"
 
 	"cloud.o-forge.io/core/oc-lib/dbs"
@@ -111,11 +112,13 @@ func (wfa *workflowMongoAccessor) book(id string, realData *Workflow, execs []*w
 				}
 				// CHECK BOOKING
 				peerID := dc.(*datacenter.DatacenterResource).PeerID
+				fmt.Println("PEER ID", peerID)
 				if peerID == "" {
 					continue
 				}
 				paccess := (&peer.Peer{})
 				p, code, _ := paccess.GetAccessor(nil).LoadOne(peerID)
+				fmt.Println("PEER", p, code)
 				if code != 200 {
 					continue
 				}
@@ -125,6 +128,7 @@ func (wfa *workflowMongoAccessor) book(id string, realData *Workflow, execs []*w
 						ResourceID: dc_id,
 						Executions: execs,
 					}).Serialize(), wfa.Caller)
+				fmt.Println("LaunchPeerExecution RES", b, err)
 				if err != nil && b == nil {
 					return err
 				}