diff --git a/workflow_builder/admiralty_setter.go b/workflow_builder/admiralty_setter.go index ca1a14e..aedbaed 100644 --- a/workflow_builder/admiralty_setter.go +++ b/workflow_builder/admiralty_setter.go @@ -15,32 +15,38 @@ type AdmiraltySetter struct { func (s *AdmiraltySetter) InitializeAdmiralty(localPeerID string, remotePeerID string) error { /* - data := oclib.NewRequest(oclib.LibDataEnum(oclib.PEER),"",localPeerID,nil,nil).LoadOne(remotePeerID) - if data.Code != 200 { - logger.Error().Msg("Error while trying to instantiate remote peer " + remotePeerID) - return fmt.Errorf(data.Err) - } - remotePeer := data.ToPeer() + data := oclib.NewRequest(oclib.LibDataEnum(oclib.PEER),"",localPeerID,nil,nil).LoadOne(remotePeerID) + if data.Code != 200 { + logger.Error().Msg("Error while trying to instantiate remote peer " + remotePeerID) + return fmt.Errorf(data.Err) + } + remotePeer := data.ToPeer() - data = oclib.NewRequest(oclib.LibDataEnum(oclib.PEER),"",localPeerID,nil,nil).LoadOne(localPeerID) - if data.Code != 200 { - logger.Error().Msg("Error while trying to instantiate local peer " + remotePeerID) - return fmt.Errorf(data.Err) - } - localPeer := data.ToPeer() + data = oclib.NewRequest(oclib.LibDataEnum(oclib.PEER),"",localPeerID,nil,nil).LoadOne(localPeerID) + if data.Code != 200 { + logger.Error().Msg("Error while trying to instantiate local peer " + remotePeerID) + return fmt.Errorf(data.Err) + } + localPeer := data.ToPeer() - caller := tools.NewHTTPCaller( - map[tools.DataType]map[tools.METHOD]string{ - tools.ADMIRALTY_SOURCE: { - tools.POST :"/:id", - }, - tools.ADMIRALTY_KUBECONFIG: { - tools.GET:"/:id", - }, - tools.ADMIRALTY_SECRET: { - tools.POST:"/:id", - }, - tools.ADMIRALTY_TARGET: { + caller := tools.NewHTTPCaller( + map[tools.DataType]map[tools.METHOD]string{ + tools.ADMIRALTY_SOURCE: { + tools.POST :"/:id", + }, + tools.ADMIRALTY_KUBECONFIG: { + tools.GET:"/:id", + }, + tools.ADMIRALTY_SECRET: { + tools.POST:"/:id", + }, + tools.ADMIRALTY_TARGET: { + tools.POST:"/:id", + }, + tools.ADMIRALTY_NODES: { + tools.GET:"/:id", + }, + tools.ADMIRALTY_TARGET: { tools.POST:"/:id", }, tools.ADMIRALTY_NODES: { @@ -48,12 +54,16 @@ func (s *AdmiraltySetter) InitializeAdmiralty(localPeerID string, remotePeerID s }, }, ) - fmt.Println("Creating source in", remotePeerID, " ns-" + s.Id) + logger.Info().Msg(" Creating the Admiralty Source on " + remotePeerID + " ns-" + s.Id + "\n\n") _ = s.callRemoteExecution(remotePeer, http.StatusCreated,caller, s.Id, tools.ADMIRALTY_SOURCE, tools.POST, nil) + logger.Info().Msg(" Retrieving kubeconfig with the secret on " + remotePeerID + " ns-" + s.Id + "\n\n") kubeconfig := s.getKubeconfig(remotePeer, caller) + logger.Info().Msg(" Creating a secret from the kubeconfig " + localPeerID + " ns-" + s.Id + "\n\n") _ = s.callRemoteExecution(localPeer, http.StatusCreated, caller,s.Id, tools.ADMIRALTY_SECRET, tools.POST,kubeconfig) + logger.Info().Msg(" Creating the Admiralty Target on " + localPeerID + " ns-" + s.Id + "\n\n") _ = s.callRemoteExecution(localPeer,http.StatusCreated,caller,s.Id,tools.ADMIRALTY_TARGET,tools.POST, nil) + logger.Info().Msg(" Checking for the creation of the admiralty node on " + localPeerID + " ns-" + s.Id + "\n\n") _ = s.callRemoteExecution(localPeer,http.StatusOK,caller,s.Id,tools.ADMIRALTY_NODES,tools.GET, nil) */ return nil