fix

Author: vreff

test/test_project/por_workflow/main.go

@@ -105,25 +105,30 @@ func doPOR(config *Config, runtime cre.Runtime, runTime time.Time) (string, erro
 
 	logger.Info("ReserveInfo", "reserveInfo", reserveInfo)
 
-	confHttpClient := &confidentialhttp.Client{}
-	confOutput, err := confidentialhttp.SendRequest(
-		config,
-		runtime,
-		confHttpClient,
-		fetchPORConfidential,
-		cre.ConsensusIdenticalAggregation[*confidentialhttp.HTTPResponse](),
+	porResp, err := cre.RunInNodeMode(*config, runtime,
+		func(config Config, nodeRuntime cre.NodeRuntime) (PORResponse, error) {
+			confHttpClient := confidentialhttp.Client{}
+			confOutput, err := confHttpClient.SendRequest(nodeRuntime, &confidentialhttp.ConfidentialHTTPRequest{
+				Request: &confidentialhttp.HTTPRequest{
+					Url:    config.URL,
+					Method: "GET",
+				},
+				EncryptOutput: true,
+			}).Await()
+			if err != nil {
+				logger.Error("error fetching conf por", "err", err)
+				return PORResponse{}, err
+			}
+			logger.Info("Conf POR response", "response", confOutput)
+
+			porResp := &PORResponse{}
+			if err = json.Unmarshal(confOutput.Body, porResp); err != nil {
+				return PORResponse{}, err
+			}
+
+			return *porResp, nil
+		}, cre.ConsensusIdenticalAggregation[PORResponse](),
 	).Await()
-	if err != nil {
-		logger.Error("error fetching conf por", "err", err)
-		return "", err
-	}
-	logger.Info("Conf POR response", "response", confOutput)
-
-	// Compare responses
-	porResp := &PORResponse{}
-	if err = json.Unmarshal(confOutput.Body, porResp); err != nil {
-		return "", err
-	}
 
 	if porResp.Ripcord {
 		return "", errors.New("ripcord is true")
@@ -272,16 +277,6 @@ func updateReserves(config *Config, runtime cre.Runtime, totalSupply *big.Int, t
 	return nil
 }
 
-func fetchPORConfidential(config *Config, logger *slog.Logger, sendRequester *confidentialhttp.SendRequester) (*confidentialhttp.HTTPResponse, error) {
-	return sendRequester.SendRequest(&confidentialhttp.ConfidentialHTTPRequest{
-		Request: &confidentialhttp.HTTPRequest{
-			Url:    config.URL,
-			Method: "GET",
-		},
-		// No Vault DON Secrets in this example
-	}).Await()
-}
-
 func fetchPOR(config *Config, logger *slog.Logger, sendRequester *http.SendRequester) (*ReserveInfo, error) {
 	httpActionOut, err := sendRequester.SendRequest(&http.Request{
 		Method: "GET",